Lines Matching refs:db_rep
87 DB_REP *db_rep;
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->region->mstat.st_perm_failed++);
229 DB_REP *db_rep;
232 db_rep = env->rep_handle;
260 DB_REP *db_rep;
271 db_rep = env->rep_handle;
280 __os_gettime(env, &db_rep->last_bcast, 1);
290 TAILQ_FOREACH(conn, &db_rep->connections, entries) {
395 DB_REP *db_rep;
403 db_rep = env->rep_handle;
422 if ((drain_to = db_rep->ack_timeout) == 0)
432 db_rep->finished, conn->out_queue_length));
433 if (db_rep->finished)
517 DB_REP *db_rep;
522 db_rep = env->rep_handle;
524 if (db_rep->perm_policy == DB_REPMGR_ACKS_NONE)
529 for (eid = 0; eid < db_rep->site_cnt; eid++) {
551 switch (db_rep->perm_policy) {
566 if (__repmgr_get_nsites(db_rep) == 2 &&
567 !FLD_ISSET(db_rep->region->config, REP_C_2SITE_STRICT)) {
589 is_perm = (npeers >= (__repmgr_get_nsites(db_rep)-1)/2);
593 is_perm = (nsites >= __repmgr_get_nsites(db_rep) - 1);
596 if (db_rep->site_cnt < __repmgr_get_nsites(db_rep) - 1) {
626 DB_REP *db_rep;
629 db_rep = env->rep_handle;
654 if (!connecting && eid == db_rep->master_eid) {
684 DB_REP *db_rep;
687 db_rep = env->rep_handle;
702 TAILQ_REMOVE(&db_rep->connections, conn, entries);
881 DB_REP *db_rep;
885 db_rep = env->rep_handle;
886 for (i = 0; i < db_rep->site_cnt; i++) {
887 site = &db_rep->sites[i];
1002 DB_REP *db_rep;
1008 db_rep = env->rep_handle;
1034 if (db_rep->selector != NULL &&
1047 * Initializes net-related memory in the db_rep handle.
1052 __repmgr_net_create(db_rep)
1053 DB_REP *db_rep;
1055 db_rep->listen_fd = INVALID_SOCKET;
1056 db_rep->master_eid = DB_EID_INVALID;
1058 TAILQ_INIT(&db_rep->connections);
1059 TAILQ_INIT(&db_rep->retries);
1077 DB_REP *db_rep;
1082 db_rep = env->rep_handle;
1086 ai = ADDR_LIST_FIRST(&db_rep->my_addr);
1095 for (; ai != NULL; ai = ADDR_LIST_NEXT(&db_rep->my_addr)) {
1132 db_rep->listen_fd = s;
1150 DB_REP *db_rep;
1157 db_rep = env->rep_handle;
1158 if (db_rep->listen_fd == INVALID_SOCKET)
1162 while (!TAILQ_EMPTY(&db_rep->connections)) {
1163 conn = TAILQ_FIRST(&db_rep->connections);
1167 TAILQ_REMOVE(&db_rep->connections, conn, entries);
1173 if (closesocket(db_rep->listen_fd) == SOCKET_ERROR && ret == 0)
1180 db_rep->wsa_inited = FALSE;
1183 if (db_rep->chg_sig_handler) {
1190 db_rep->listen_fd = INVALID_SOCKET;
1198 __repmgr_net_destroy(env, db_rep)
1200 DB_REP *db_rep;
1207 __repmgr_cleanup_netaddr(env, &db_rep->my_addr);
1209 if (db_rep->sites == NULL)
1212 while (!TAILQ_EMPTY(&db_rep->retries)) {
1213 retry = TAILQ_FIRST(&db_rep->retries);
1214 TAILQ_REMOVE(&db_rep->retries, retry, entries);
1218 while (!TAILQ_EMPTY(&db_rep->connections)) {
1219 conn = TAILQ_FIRST(&db_rep->connections);
1223 for (i = 0; i < db_rep->site_cnt; i++) {
1224 site = &db_rep->sites[i];
1227 __os_free(env, db_rep->sites);
1228 db_rep->sites = NULL;