/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/repmgr/ |
H A D | repmgr_method.c | 26 DB_REP *db_rep; local 32 db_rep = env->rep_handle; 41 if (db_rep->my_addr.port == 0) { 47 if (db_rep->selector != NULL || db_rep->finished) { 71 sizeof(REPMGR_RUNNABLE *), &db_rep->messengers)) != 0) 73 db_rep->nthreads = nthreads; 75 if ((ret = __repmgr_net_init(env, db_rep)) != 0 || 76 (ret = __repmgr_init_sync(env, db_rep)) != 0 || 85 if ((db_rep 137 DB_REP *db_rep; local 256 DB_REP *db_rep; local 293 DB_REP *db_rep; local 338 DB_REP *db_rep; local 400 DB_REP *db_rep; local [all...] |
H A D | repmgr_elect.c | 34 DB_REP *db_rep; local 37 db_rep = env->rep_handle; 38 if (db_rep->finished) { 45 db_rep->operation_needed = initial_operation; 46 if (db_rep->elect_thread == NULL) 48 else if (db_rep->elect_thread->finished) { 51 if ((ret = __repmgr_thread_join(db_rep->elect_thread)) != 0) 53 __os_free(env, db_rep->elect_thread); 54 db_rep->elect_thread = NULL; 59 if ((ret = __repmgr_signal(&db_rep 73 DB_REP *db_rep; local 117 DB_REP *db_rep; local 360 DB_REP *db_rep; local 380 DB_REP *db_rep; local [all...] |
H A D | repmgr_queue.c | 24 __repmgr_queue_create(env, db_rep) 26 DB_REP *db_rep; 35 db_rep->input_queue = q; 79 DB_REP *db_rep; local 85 db_rep = env->rep_handle; 86 q = db_rep->input_queue; 88 LOCK_MUTEX(db_rep->mutex); 89 while (STAILQ_EMPTY(&q->header) && !db_rep->finished) { 91 if (!ResetEvent(db_rep->queue_nonempty)) { 95 if (SignalObjectAndWait(db_rep 132 DB_REP *db_rep; local [all...] |
H A D | repmgr_posix.c | 112 * Caller must hold the db_rep->mutex, if this thread synchronization is to work 136 DB_REP *db_rep; local 140 db_rep = env->rep_handle; 142 if ((timed = (db_rep->ack_timeout > 0))) 144 db_rep->ack_timeout); 150 ret = pthread_cond_timedwait(&db_rep->ack_condition, 151 &db_rep->mutex, &deadline); 153 ret = pthread_cond_wait(&db_rep->ack_condition, 154 &db_rep->mutex); 155 if (db_rep 222 DB_REP *db_rep; local 354 DB_REP *db_rep; local 475 DB_REP *db_rep; local 535 DB_REP *db_rep; local 723 DB_REP *db_rep; local [all...] |
H A D | repmgr_msg.c | 64 DB_REP *db_rep; local 69 db_rep = env->rep_handle; 75 generation = db_rep->generation; 80 if (db_rep->takeover_pending) { 81 db_rep->takeover_pending = FALSE; 90 LOCK_MUTEX(db_rep->mutex); 92 UNLOCK_MUTEX(db_rep->mutex); 100 LOCK_MUTEX(db_rep->mutex); 102 UNLOCK_MUTEX(db_rep->mutex); 111 rep = db_rep 146 DB_REP *db_rep; local 195 DB_REP *db_rep; local 256 DB_REP *db_rep; local 344 DB_REP *db_rep; local [all...] |
H A D | repmgr_windows.c | 99 DB_REP *db_rep; local 103 db_rep = env->rep_handle; 104 for (i=0; i<db_rep->waiters->next_avail; i++) { 105 slot = &db_rep->waiters->array[i]; 125 DB_REP *db_rep; local 128 db_rep = env->rep_handle; 133 timeout = db_rep->ack_timeout > 0 ? 134 DB_TIMEOUT_TO_WINDOWS_TIMEOUT(db_rep->ack_timeout) : INFINITE; 136 if ((ret = SignalObjectAndWait(db_rep->mutex, me->event, timeout, 144 LOCK_MUTEX(db_rep 162 DB_REP *db_rep; local 206 DB_REP *db_rep; local 222 DB_REP *db_rep; local 365 DB_REP *db_rep; local 436 DB_REP *db_rep; local 524 DB_REP *db_rep; local 733 DB_REP *db_rep; local [all...] |
H A D | repmgr_util.c | 36 DB_REP *db_rep; local 42 db_rep = env->rep_handle; 48 TAILQ_INSERT_HEAD(&db_rep->retries, retry, entries); 50 TIMESPEC_ADD_DB_TIMEOUT(&t, db_rep->connection_retry_wait); 51 TAILQ_INSERT_TAIL(&db_rep->retries, retry, entries); 98 DB_REP *db_rep; local 102 db_rep = env->rep_handle; 118 TAILQ_INSERT_TAIL(&db_rep->connections, c, entries); 138 DB_REP *db_rep; local 144 db_rep 303 DB_REP *db_rep; local [all...] |
H A D | repmgr_net.c | 87 DB_REP *db_rep; local 95 db_rep = env->rep_handle; 97 LOCK_MUTEX(db_rep->mutex); 111 IS_VALID_EID(db_rep->peer) && 112 (site = __repmgr_available_site(env, db_rep->peer)) != 147 nclients = __repmgr_get_nsites(db_rep) - 1; 149 switch (db_rep->perm_policy) { 190 FLD_ISSET(db_rep->region->config, 216 out: UNLOCK_MUTEX(db_rep->mutex); 218 STAT(db_rep 229 DB_REP *db_rep; local 260 DB_REP *db_rep; local 395 DB_REP *db_rep; local 517 DB_REP *db_rep; local 626 DB_REP *db_rep; local 684 DB_REP *db_rep; local 881 DB_REP *db_rep; local 1002 DB_REP *db_rep; local 1077 DB_REP *db_rep; local 1150 DB_REP *db_rep; local [all...] |
H A D | repmgr_stat.c | 58 DB_REP *db_rep; local 62 db_rep = env->rep_handle; 70 memcpy(stats, &db_rep->region->mstat, sizeof(*stats)); 72 memset(&db_rep->region->mstat, 0, sizeof(DB_REPMGR_STAT)); 231 DB_REP *db_rep; local 241 db_rep = env->rep_handle; 242 if (REPMGR_SYNC_INITED(db_rep)) { 243 LOCK_MUTEX(db_rep->mutex); 254 if ((count = db_rep->site_cnt) == 0) 260 site = &db_rep [all...] |
H A D | repmgr_sel.c | 70 DB_REP *db_rep; local 80 db_rep = env->rep_handle; 82 if ((s = accept(db_rep->listen_fd, (struct sockaddr *)&siaddr, 172 DB_REP *db_rep; local 177 db_rep = env->rep_handle; 186 if (!TAILQ_EMPTY(&db_rep->retries)) { 187 retry = TAILQ_FIRST(&db_rep->retries); 222 DB_REP *db_rep; local 228 db_rep = env->rep_handle; 230 if (db_rep 272 DB_REP *db_rep; local 339 DB_REP *db_rep; local 374 DB_REP *db_rep; local 397 DB_REP *db_rep; local 448 DB_REP *db_rep; local 595 DB_REP *db_rep; local 652 DB_REP *db_rep; local 693 DB_REP *db_rep; local 987 DB_REP *db_rep; local 1052 DB_REP *db_rep; local 1234 DB_REP *db_rep; local 1329 DB_REP *db_rep; local [all...] |
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/rep/ |
H A D | rep_region.c | 29 DB_REP *db_rep; local 35 db_rep = env->rep_handle; 78 rep->eid = db_rep->eid; 86 rep->gbytes = db_rep->gbytes; 87 rep->bytes = db_rep->bytes; 88 rep->request_gap = db_rep->request_gap; 89 rep->max_gap = db_rep->max_gap; 90 rep->config_nsites = db_rep->config_nsites; 91 rep->config = db_rep->config; 92 rep->elect_timeout = db_rep 127 DB_REP *db_rep; local 207 DB_REP *db_rep; local 273 DB_REP *db_rep; local [all...] |
H A D | rep_method.c | 34 DB_REP *db_rep; local 40 if ((ret = __os_calloc(env, 1, sizeof(DB_REP), &db_rep)) != 0) 43 db_rep->eid = DB_EID_INVALID; 44 db_rep->bytes = REP_DEFAULT_THROTTLE; 45 DB_TIMEOUT_TO_TIMESPEC(DB_REP_REQUEST_GAP, &db_rep->request_gap); 46 DB_TIMEOUT_TO_TIMESPEC(DB_REP_MAX_GAP, &db_rep->max_gap); 47 db_rep->elect_timeout = 2 * US_PER_SEC; /* 2 seconds */ 48 db_rep->chkpt_delay = 30 * US_PER_SEC; /* 30 seconds */ 49 db_rep->my_priority = DB_REP_DEFAULT_PRIORITY; 54 db_rep 103 DB_REP *db_rep; local 152 DB_REP *db_rep; local 320 DB_REP *db_rep; local 746 DB_REP *db_rep; local 916 DB_REP *db_rep; local 1160 DB_REP *db_rep; local 1203 DB_REP *db_rep; local 1243 DB_REP *db_rep; local 1274 DB_REP *db_rep; local 1300 DB_REP *db_rep; local 1323 DB_REP *db_rep; local 1347 DB_REP *db_rep; local 1424 DB_REP *db_rep; local 1482 DB_REP *db_rep; local 1530 DB_REP *db_rep; local 1588 DB_REP *db_rep; local 1630 DB_REP *db_rep; local 1657 DB_REP *db_rep; local 1773 DB_REP *db_rep; local [all...] |
H A D | rep_lease.c | 32 DB_REP *db_rep; local 41 db_rep = env->rep_handle; 42 rep = db_rep->region; 94 DB_REP *db_rep; local 98 db_rep = env->rep_handle; 99 rep = db_rep->region; 166 DB_REP *db_rep; local 173 db_rep = env->rep_handle; 174 rep = db_rep->region; 269 DB_REP *db_rep; local 376 DB_REP *db_rep; local 422 DB_REP *db_rep; local 464 DB_REP *db_rep; local [all...] |
H A D | rep_verify.c | 38 DB_REP *db_rep; local 45 db_rep = env->rep_handle; 46 rep = db_rep->region; 137 DB_REP *db_rep; local 144 db_rep = env->rep_handle; 145 rep = db_rep->region; 274 DB_REP *db_rep; local 280 db_rep = env->rep_handle; 281 rep = db_rep->region; 327 DB_REP *db_rep; local 454 DB_REP *db_rep; local [all...] |
H A D | rep_util.c | 67 DB_REP *db_rep; local 75 db_rep = env->rep_handle; 76 rep = db_rep->region; 215 DB_REP *db_rep; local 225 db_rep = env->rep_handle; 226 rep = db_rep->region; 297 DB_REP *db_rep; local 300 db_rep = env->rep_handle; 302 MUTEX_LOCK(env, db_rep->region->mtx_clientdb); 304 MUTEX_UNLOCK(env, db_rep 329 DB_REP *db_rep; local [all...] |
H A D | rep_record.c | 147 DB_REP *db_rep; local 193 db_rep = env->rep_handle; 194 rep = db_rep->region; 964 DB_REP *db_rep; local 974 db_rep = env->rep_handle; 975 rep = db_rep->region; 990 if (db_rep->rep_db == NULL && 995 dbp = db_rep->rep_db; 1368 DB_REP *db_rep; local 1380 db_rep 1615 DB_REP *db_rep; local 1748 DB_REP *db_rep; local 1780 DB_REP *db_rep; local 1850 DB_REP *db_rep; local 2052 DB_REP *db_rep; local 2195 DB_REP *db_rep; local 2220 DB_REP *db_rep; local [all...] |
H A D | rep_log.c | 32 DB_REP *db_rep; local 44 db_rep = env->rep_handle; 45 rep = db_rep->region; 226 DB_REP *db_rep; local 232 db_rep = env->rep_handle; 233 rep = db_rep->region; 333 DB_REP *db_rep; local 337 db_rep = env->rep_handle; 338 rep = db_rep->region; 374 DB_REP *db_rep; local [all...] |
H A D | rep_stat.c | 64 DB_REP *db_rep; local 71 db_rep = env->rep_handle; 72 rep = db_rep->region; 433 DB_REP *db_rep; local 441 db_rep = env->rep_handle; 442 rep = db_rep->region; 450 if (db_rep->rep_db == NULL) 451 STAT_ISSET("Bookkeeping database", db_rep->rep_db); 453 (void)__db_stat_print(db_rep->rep_db, ip, flags); 455 __db_prflags(env, NULL, db_rep [all...] |
H A D | rep_elect.c | 53 DB_REP *db_rep; local 79 db_rep = env->rep_handle; 80 rep = db_rep->region; 506 DB_REP *db_rep; local 520 db_rep = env->rep_handle; 521 rep = db_rep->region; 717 DB_REP *db_rep; local 726 db_rep = env->rep_handle; 727 rep = db_rep->region; 834 * Handle incoming vote message on a client. Called with the db_rep 978 DB_REP *db_rep; local 1102 DB_REP *db_rep; local [all...] |
H A D | rep_backup.c | 526 DB_REP *db_rep; local 531 db_rep = env->rep_handle; 532 rep = db_rep->region; 586 DB_REP *db_rep; local 598 db_rep = env->rep_handle; 599 rep = db_rep->region; 831 DB_REP *db_rep; local 842 db_rep = env->rep_handle; 843 rep = db_rep->region; 891 if (db_rep 1326 DB_REP *db_rep; local 1478 DB_REP *db_rep; local [all...] |
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/dbinc/ |
H A D | repmgr.h | 249 * db_rep->mutex, because that mutex is always held anyway whenever the 374 #define SITE_FROM_EID(eid) (&db_rep->sites[eid]) 375 #define EID_FROM_SITE(s) ((int)((s) - (&db_rep->sites[0]))) 409 #define REPMGR_SYNC_INITED(db_rep) (db_rep->waiters != NULL) 424 #define REPMGR_SYNC_INITED(db_rep) (db_rep->read_pipe >= 0)
|
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/common/ |
H A D | db_err.c | 891 DB_REP *db_rep; local 896 db_rep = env->rep_handle; 904 if (db_rep == NULL || F_ISSET(dbc, DBC_RECOVER)) 916 rep = db_rep->region;
|
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/log/ |
H A D | log_put.c | 90 DB_REP *db_rep; local 100 db_rep = env->rep_handle; 101 if (db_rep != NULL) 102 rep = db_rep->region; 117 if (IS_REP_MASTER(env) && db_rep->send == NULL) { 229 if (db_rep->bulk == NULL) 230 db_rep->bulk = R_ADDR(&dblp->reginfo, 233 bulk.addr = db_rep->bulk;
|
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/db/ |
H A D | db_method.c | 132 DB_REP *db_rep; local 171 db_rep = env->rep_handle; 172 dbp->fid_gen = REP_ON(env) ? ((REP *)db_rep->region)->gen : 0;
|
/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/dbreg/ |
H A D | dbreg.c | 452 DB_REP *db_rep; local 465 db_rep = env->rep_handle; 467 (!REP_ON(env) || ((REP *)db_rep->region)->gen == dbp->fid_gen);
|