/dports/databases/db18/db-18.1.40/src/repmgr/ |
H A D | repmgr_queue.c | 24 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 D | repmgr_method.c | 61 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 D | repmgr_elect.c | 32 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 D | repmgr_msg.c | 82 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 D | repmgr_windows.c | 137 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 D | repmgr_util.c | 46 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 D | repmgr_sel.c | 85 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 D | repmgr_posix.c | 220 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 D | repmgr_net.c | 214 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 D | repmgr_stat.c | 56 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 D | repmgr_elect.c | 32 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 D | repmgr_queue.c | 24 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 D | repmgr_posix.c | 146 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 D | repmgr_util.c | 42 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 D | repmgr_method.c | 63 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 D | repmgr_windows.c | 137 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 D | repmgr_msg.c | 74 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 D | repmgr_net.c | 200 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 D | repmgr_sel.c | 73 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 D | repmgr_stat.c | 56 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 D | rep_region.c | 31 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 D | rep_method.c | 40 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 D | rep_region.c | 28 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 D | rep_method.c | 40 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 D | repmgr.h | 162 #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 …]
|