Lines Matching refs:db_rep
34 DB_REP *db_rep;
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->clock_skew = 1;
55 db_rep->clock_base = 1;
58 if ((ret = __repmgr_env_create(env, db_rep)) != 0) {
59 __os_free(env, db_rep);
64 env->rep_handle = db_rep;
103 DB_REP *db_rep;
118 db_rep = env->rep_handle;
120 env, db_rep->region, "DB_ENV->rep_get_config", DB_INIT_REP);
125 rep = db_rep->region;
131 if (FLD_ISSET(db_rep->config, mapped))
152 DB_REP *db_rep;
162 db_rep = env->rep_handle;
171 env, db_rep->region, "DB_ENV->rep_set_config", DB_INIT_REP);
182 rep = db_rep->region;
217 db_rep->bulk = R_ADDR(&dblp->reginfo, lp->bulk_buf);
227 if (db_rep->bulk == NULL)
231 bulk.addr = db_rep->bulk;
244 FLD_SET(db_rep->config, mapped);
246 FLD_CLR(db_rep->config, mapped);
320 DB_REP *db_rep;
337 db_rep = env->rep_handle;
338 rep = db_rep->region;
354 if (db_rep->send == NULL) {
746 DB_REP *db_rep;
754 db_rep = env->rep_handle;
755 rep = db_rep->region;
760 rdbpp = &db_rep->rep_db;
916 DB_REP *db_rep;
925 db_rep = env->rep_handle;
926 rep = db_rep->region;
1160 DB_REP *db_rep;
1166 db_rep = env->rep_handle;
1169 env, db_rep->region, "DB_ENV->rep_get_limit", DB_INIT_REP);
1172 rep = db_rep->region;
1183 *gbytesp = db_rep->gbytes;
1185 *bytesp = db_rep->bytes;
1203 DB_REP *db_rep;
1209 db_rep = env->rep_handle;
1212 env, db_rep->region, "DB_ENV->rep_set_limit", DB_INIT_REP);
1220 rep = db_rep->region;
1228 db_rep->gbytes = gbytes;
1229 db_rep->bytes = bytes;
1243 DB_REP *db_rep;
1248 db_rep = env->rep_handle;
1251 env, db_rep->region, "DB_ENV->rep_set_nsites", DB_INIT_REP);
1254 rep = db_rep->region;
1262 db_rep->config_nsites = n;
1274 DB_REP *db_rep;
1279 db_rep = env->rep_handle;
1284 rep = db_rep->region;
1287 *n = db_rep->config_nsites;
1300 DB_REP *db_rep;
1305 db_rep = env->rep_handle;
1308 rep = db_rep->region;
1311 db_rep->my_priority = priority;
1323 DB_REP *db_rep;
1328 db_rep = env->rep_handle;
1331 rep = db_rep->region;
1334 *priority = db_rep->my_priority;
1347 DB_REP *db_rep;
1353 db_rep = env->rep_handle;
1354 rep = db_rep->region;
1362 db_rep->chkpt_delay = timeout;
1368 db_rep->elect_timeout = timeout;
1374 db_rep->full_elect_timeout = timeout;
1386 db_rep->lease_timeout = timeout;
1390 db_rep->ack_timeout = timeout;
1393 db_rep->connection_retry_wait = timeout;
1396 db_rep->election_retry_wait = timeout;
1399 db_rep->heartbeat_monitor_timeout = timeout;
1402 db_rep->heartbeat_frequency = timeout;
1424 DB_REP *db_rep;
1429 db_rep = env->rep_handle;
1430 rep = db_rep->region;
1435 rep->chkpt_delay : db_rep->chkpt_delay;
1439 rep->elect_timeout : db_rep->elect_timeout;
1443 rep->full_elect_timeout : db_rep->full_elect_timeout;
1447 rep->lease_timeout : db_rep->lease_timeout;
1451 *timeout = db_rep->ack_timeout;
1454 *timeout = db_rep->election_retry_wait;
1457 *timeout = db_rep->connection_retry_wait;
1482 DB_REP *db_rep;
1488 db_rep = env->rep_handle;
1491 env, db_rep->region, "DB_ENV->rep_get_request", DB_INIT_REP);
1494 rep = db_rep->region;
1509 &db_rep->request_gap, 0);
1511 DB_TIMESPEC_TO_TIMEOUT((*maxp), &db_rep->max_gap, 0);
1530 DB_REP *db_rep;
1537 db_rep = env->rep_handle;
1540 env, db_rep->region, "DB_ENV->rep_set_request", DB_INIT_REP);
1548 rep = db_rep->region;
1566 DB_TIMEOUT_TO_TIMESPEC(min, &db_rep->request_gap);
1567 DB_TIMEOUT_TO_TIMESPEC(max, &db_rep->max_gap);
1588 DB_REP *db_rep;
1607 db_rep = env->rep_handle;
1608 db_rep->send = f_send;
1611 rep = db_rep->region;
1618 db_rep->eid = eid;
1630 DB_REP *db_rep;
1635 db_rep = env->rep_handle;
1638 rep = db_rep->region;
1642 *fast_clockp = db_rep->clock_skew;
1643 *slow_clockp = db_rep->clock_base;
1657 DB_REP *db_rep;
1664 db_rep = env->rep_handle;
1668 env, db_rep->region, "DB_ENV->rep_set_clockskew", DB_INIT_REP);
1698 rep = db_rep->region;
1711 db_rep->clock_skew = fast_clock;
1712 db_rep->clock_base = slow_clock;
1773 DB_REP *db_rep;
1790 db_rep = env->rep_handle;
1791 rep = db_rep->region;