Searched refs:db_rep (Results 1 - 25 of 25) sorted by relevance

/netgear-R7000-V1.0.7.12_1.2.5/ap/gpl/timemachine/db-4.7.25.NC/repmgr/
H A Drepmgr_method.c26 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 Drepmgr_elect.c34 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 Drepmgr_queue.c24 __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 Drepmgr_posix.c112 * 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 Drepmgr_msg.c64 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 Drepmgr_windows.c99 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 Drepmgr_util.c36 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 Drepmgr_net.c87 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 Drepmgr_stat.c58 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 Drepmgr_sel.c70 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 Drep_region.c29 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 Drep_method.c34 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 Drep_lease.c32 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 Drep_verify.c38 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 Drep_util.c67 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 Drep_record.c147 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 Drep_log.c32 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 Drep_stat.c64 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 Drep_elect.c53 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 Drep_backup.c526 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 Drepmgr.h249 * 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 Ddb_err.c891 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 Dlog_put.c90 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 Ddb_method.c132 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 Ddbreg.c452 DB_REP *db_rep; local
465 db_rep = env->rep_handle;
467 (!REP_ON(env) || ((REP *)db_rep->region)->gen == dbp->fid_gen);

Completed in 137 milliseconds