Home
last modified time | relevance | path

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

123

/dports/databases/db18/db-18.1.40/src/repmgr/
H A Drepmgr_queue.c24 DB_REP *db_rep; local
33 db_rep = env->rep_handle;
34 rep = db_rep->region;
44 !IS_SUBORDINATE(db_rep))
94 DB_REP *db_rep; local
104 db_rep = env->rep_handle;
105 rep = db_rep->region;
194 DB_REP *db_rep; local
206 if (db_rep->nthreads > db_rep->non_rep_th + RESERVED_MSG_TH(env))
226 DB_REP *db_rep; local
[all …]
H A Drepmgr_method.c61 DB_REP *db_rep; local
150 DB_REP *db_rep; local
206 db_rep->restored_list, db_rep->restored_list_length,
563 DB_REP *db_rep; local
574 db_rep->selector != NULL && IS_SUBORDINATE(db_rep)) {
642 DB_REP *db_rep; local
658 db_rep->messengers[db_rep->nthreads++] = messenger;
675 DB_REP *db_rep; local
802 DB_REP *db_rep; local
855 DB_REP *db_rep; local
[all …]
H A Drepmgr_elect.c32 DB_REP *db_rep; local
39 db_rep = env->rep_handle;
128 DB_REP *db_rep; local
149 rep = db_rep->region;
457 &db_rep->check_election, db_rep->mutex, &deadline))
517 DB_REP *db_rep; local
522 rep = db_rep->region;
554 DB_REP *db_rep; local
564 rep = db_rep->region;
719 DB_REP *db_rep; local
[all …]
H A Drepmgr_msg.c82 DB_REP *db_rep; local
213 DB_REP *db_rep; local
310 DB_REP *db_rep; local
345 DB_REP *db_rep; local
500 DB_REP *db_rep; local
591 DB_REP *db_rep; local
765 DB_REP *db_rep; local
853 DB_REP *db_rep; local
941 DB_REP *db_rep; local
1060 DB_REP *db_rep; local
[all …]
H A Drepmgr_windows.c137 DB_REP *db_rep; local
171 DB_REP *db_rep; local
267 DB_REP *db_rep; local
282 DB_REP *db_rep; local
306 DB_REP *db_rep; local
379 DB_REP *db_rep; in __repmgr_env_create_pf()
403 DB_REP *db_rep; local
448 db_rep->msg_avail =
460 DB_REP *db_rep; local
573 DB_REP *db_rep; local
[all …]
H A Drepmgr_util.c46 DB_REP *db_rep; local
121 DB_REP *db_rep; local
259 DB_REP *db_rep; local
267 if (db_rep->site_cnt >= db_rep->site_max) {
306 site = &db_rep->sites[db_rep->site_cnt++];
499 DB_REP *db_rep; local
542 DB_REP *db_rep; local
564 DB_REP *db_rep; local
714 db_rep->member_version_gen = db_rep->region->gen;
985 db_rep->sites[j] = db_rep->sites[i];
[all …]
H A Drepmgr_sel.c85 DB_REP *db_rep; local
110 DB_REP *db_rep; local
210 DB_REP *db_rep; local
290 DB_REP *db_rep; local
362 DB_REP *db_rep; local
413 DB_REP *db_rep; local
508 DB_REP *db_rep; local
568 DB_REP *db_rep; local
602 DB_REP *db_rep; local
682 DB_REP *db_rep; local
[all …]
H A Drepmgr_posix.c220 DB_REP *db_rep; local
257 DB_REP *db_rep; local
328 DB_REP *db_rep; local
396 DB_REP *db_rep; in __repmgr_env_create_pf()
398 db_rep->read_pipe = db_rep->write_pipe = NO_SUCH_FILE_DESC;
430 DB_REP *db_rep; local
495 db_rep->read_pipe = db_rep->write_pipe = NO_SUCH_FILE_DESC;
507 DB_REP *db_rep; local
534 db_rep->read_pipe = db_rep->write_pipe = NO_SUCH_FILE_DESC;
611 DB_REP *db_rep; local
[all …]
H A Drepmgr_net.c214 DB_REP *db_rep; local
293 DB_REP *db_rep; local
362 DB_REP *db_rep; local
748 DB_REP *db_rep; local
769 DB_REP *db_rep; local
812 DB_REP *db_rep; local
913 DB_REP *db_rep; local
1088 DB_REP *db_rep; local
1261 DB_REP *db_rep; local
1352 DB_REP *db_rep; local
[all …]
H A Drepmgr_stat.c56 DB_REP *db_rep; local
63 db_rep = env->rep_handle;
64 stats = &db_rep->region->mstat;
80 LOCK_MUTEX(db_rep->mutex);
91 UNLOCK_MUTEX(db_rep->mutex);
334 DB_REP *db_rep; local
343 db_rep = env->rep_handle;
350 rep = db_rep->region;
351 LOCK_MUTEX(db_rep->mutex);
372 site = &db_rep->sites[i];
[all …]
/dports/databases/db5/db-5.3.28/src/repmgr/
H A Drepmgr_elect.c32 DB_REP *db_rep; local
39 db_rep = env->rep_handle;
115 DB_REP *db_rep; local
133 rep = db_rep->region;
325 &db_rep->check_election, db_rep->mutex, &deadline))
384 DB_REP *db_rep; local
389 rep = db_rep->region;
421 DB_REP *db_rep; local
514 DB_REP *db_rep; local
565 DB_REP *db_rep; local
[all …]
H A Drepmgr_queue.c24 DB_REP *db_rep; local
29 db_rep = env->rep_handle;
62 DB_REP *db_rep; local
70 db_rep = env->rep_handle;
90 LOCK_MUTEX(db_rep->mutex);
98 db_rep->mutex)) != 0)
127 DB_REP *db_rep; local
130 db_rep = env->rep_handle;
139 if (db_rep->nthreads > db_rep->non_rep_th + RESERVED_MSG_TH(env))
159 DB_REP *db_rep; local
[all …]
H A Drepmgr_posix.c146 DB_REP *db_rep; local
183 DB_REP *db_rep; local
254 DB_REP *db_rep; local
322 DB_REP *db_rep; in __repmgr_env_create_pf()
324 db_rep->read_pipe = db_rep->write_pipe = NO_SUCH_FILE_DESC;
356 DB_REP *db_rep; local
421 db_rep->read_pipe = db_rep->write_pipe = NO_SUCH_FILE_DESC;
433 DB_REP *db_rep; local
460 db_rep->read_pipe = db_rep->write_pipe = NO_SUCH_FILE_DESC;
537 DB_REP *db_rep; local
[all …]
H A Drepmgr_util.c42 DB_REP *db_rep; local
98 DB_REP *db_rep; local
235 DB_REP *db_rep; local
243 if (db_rep->site_cnt >= db_rep->site_max) {
282 site = &db_rep->sites[db_rep->site_cnt++];
472 DB_REP *db_rep; local
515 DB_REP *db_rep; local
537 DB_REP *db_rep; local
678 db_rep->member_version_gen = db_rep->region->gen;
940 db_rep->sites[j] = db_rep->sites[i];
[all …]
H A Drepmgr_method.c63 DB_REP *db_rep; local
131 db_rep->restored_list, db_rep->restored_list_length);
407 DB_REP *db_rep; local
418 db_rep->selector != NULL && IS_SUBORDINATE(db_rep)) {
439 DB_REP *db_rep; local
455 db_rep->messengers[db_rep->nthreads++] = messenger;
472 DB_REP *db_rep; local
592 DB_REP *db_rep; local
640 DB_REP *db_rep; local
677 DB_REP *db_rep; local
[all …]
H A Drepmgr_windows.c137 DB_REP *db_rep; local
171 DB_REP *db_rep; local
267 DB_REP *db_rep; local
282 DB_REP *db_rep; local
306 DB_REP *db_rep; local
379 DB_REP *db_rep; in __repmgr_env_create_pf()
403 DB_REP *db_rep; local
448 db_rep->msg_avail =
460 DB_REP *db_rep; local
573 DB_REP *db_rep; local
[all …]
H A Drepmgr_msg.c74 DB_REP *db_rep; local
182 DB_REP *db_rep; local
279 DB_REP *db_rep; local
314 DB_REP *db_rep; local
430 DB_REP *db_rep; local
472 DB_REP *db_rep; local
675 DB_REP *db_rep; local
758 DB_REP *db_rep; local
888 DB_REP *db_rep; local
1017 DB_REP *db_rep; local
[all …]
H A Drepmgr_net.c200 DB_REP *db_rep; local
265 DB_REP *db_rep; local
637 DB_REP *db_rep; local
658 DB_REP *db_rep; local
701 DB_REP *db_rep; local
797 DB_REP *db_rep; local
969 DB_REP *db_rep; local
1121 DB_REP *db_rep; local
1206 DB_REP *db_rep; local
1342 DB_REP *db_rep; local
[all …]
H A Drepmgr_sel.c73 DB_REP *db_rep; local
91 DB_REP *db_rep; local
182 DB_REP *db_rep; local
232 DB_REP *db_rep; local
294 DB_REP *db_rep; local
324 DB_REP *db_rep; local
398 DB_REP *db_rep; local
439 DB_REP *db_rep; local
470 DB_REP *db_rep; local
533 DB_REP *db_rep; local
[all …]
H A Drepmgr_stat.c56 DB_REP *db_rep; local
61 db_rep = env->rep_handle;
62 stats = &db_rep->region->mstat;
249 DB_REP *db_rep; local
261 db_rep = env->rep_handle;
268 rep = db_rep->region;
269 LOCK_MUTEX(db_rep->mutex);
292 site = &db_rep->sites[i];
315 site = &db_rep->sites[eid];
342 if (db_rep->selector == NULL)
[all …]
/dports/databases/db18/db-18.1.40/src/rep/
H A Drep_region.c31 DB_REP *db_rep; local
39 db_rep = env->rep_handle;
222 db_rep->region = rep;
260 DB_REP *db_rep; local
286 DB_REP *db_rep; local
294 rep = db_rep->region;
408 DB_REP *db_rep; local
424 if (db_rep == NULL || db_rep->region == NULL)
484 DB_REP *db_rep; local
492 if (db_rep == NULL || db_rep->region == NULL)
[all …]
H A Drep_method.c40 DB_REP *db_rep; local
116 DB_REP *db_rep; local
172 DB_REP *db_rep; local
567 DB_REP *db_rep; local
649 DB_REP *db_rep; local
1288 DB_REP *db_rep; local
1373 DB_REP *db_rep; local
1466 DB_REP *db_rep; local
1742 DB_REP *db_rep; local
1989 DB_REP *db_rep; local
[all …]
/dports/databases/db5/db-5.3.28/src/rep/
H A Drep_region.c28 DB_REP *db_rep; local
36 db_rep = env->rep_handle;
92 rep->eid = db_rep->eid;
166 db_rep->region = rep;
204 DB_REP *db_rep; local
230 DB_REP *db_rep; local
238 rep = db_rep->region;
349 DB_REP *db_rep; local
365 if (db_rep == NULL || db_rep->region == NULL)
423 DB_REP *db_rep; local
[all …]
H A Drep_method.c40 DB_REP *db_rep; local
116 DB_REP *db_rep; local
167 DB_REP *db_rep; local
371 DB_REP *db_rep; local
447 DB_REP *db_rep; local
983 DB_REP *db_rep; local
1066 DB_REP *db_rep; local
1159 DB_REP *db_rep; local
1342 DB_REP *db_rep; local
1589 DB_REP *db_rep; local
[all …]
/dports/databases/db18/db-18.1.40/src/dbinc/
H A Drepmgr.h162 #define PARTICIPANT_TO_VIEW(db_rep, site) \ argument
164 #define VIEW_TO_PARTICIPANT(db_rep, site) \ argument
614 (((u_int)(e)) < db_rep->site_cnt))
617 ((u_int)i) < db_rep->site_cnt; \
626 #define IS_LISTENER_CAND(db_rep) \ argument
628 IS_SUBORDINATE(db_rep) && (db_rep)->repmgr_status == running)
647 if (IS_LISTENER_CAND(db_rep)) { \
920 #define IS_SUBORDINATE(db_rep) (db_rep->listen_fd == INVALID_SOCKET) argument
983 #define REPMGR_INITED(db_rep) (db_rep->signaler != NULL) argument
999 #define REPMGR_INITED(db_rep) (db_rep->read_pipe >= 0) argument
[all …]

123