Lines Matching refs:db_rep
70 DB_REP *db_rep;
80 db_rep = env->rep_handle;
82 if ((s = accept(db_rep->listen_fd, (struct sockaddr *)&siaddr,
172 DB_REP *db_rep;
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;
228 db_rep = env->rep_handle;
230 if (db_rep->master_eid == SELF_EID && db_rep->heartbeat_frequency > 0) {
231 t = db_rep->last_bcast;
232 TIMESPEC_ADD_DB_TIMEOUT(&t, db_rep->heartbeat_frequency);
235 db_rep->heartbeat_monitor_timeout > 0 &&
242 site = SITE_FROM_EID(db_rep->master_eid);
244 TIMESPEC_ADD_DB_TIMEOUT(&t, db_rep->heartbeat_monitor_timeout);
272 DB_REP *db_rep;
276 db_rep = env->rep_handle;
278 if (db_rep->master_eid == SELF_EID ||
279 !IS_VALID_EID(db_rep->master_eid))
281 master = SITE_FROM_EID(db_rep->master_eid);
339 DB_REP *db_rep;
345 db_rep = env->rep_handle;
348 while (!TAILQ_EMPTY(&db_rep->retries)) {
349 retry = TAILQ_FIRST(&db_rep->retries);
353 TAILQ_REMOVE(&db_rep->retries, retry, entries);
374 DB_REP *db_rep;
378 db_rep = env->rep_handle;
379 for (eid=0; eid<db_rep->site_cnt; eid++)
397 DB_REP *db_rep;
401 db_rep = env->rep_handle;
448 DB_REP *db_rep;
459 db_rep = env->rep_handle;
476 STAT(db_rep->region->mstat.st_connect_fail++);
595 DB_REP *db_rep;
602 db_rep = env->rep_handle;
603 my_addr = &db_rep->my_addr;
652 DB_REP *db_rep;
658 db_rep = env->rep_handle;
659 rep = db_rep->region;
660 my_addr = &db_rep->my_addr;
693 DB_REP *db_rep;
699 db_rep = env->rep_handle;
987 DB_REP *db_rep;
996 db_rep = env->rep_handle;
997 my_addr = &db_rep->my_addr;
1052 DB_REP *db_rep;
1063 db_rep = env->rep_handle;
1064 rep = db_rep->region;
1065 my_addr = &db_rep->my_addr;
1234 DB_REP *db_rep;
1240 db_rep = env->rep_handle;
1254 TAILQ_REMOVE(&db_rep->retries, retry, entries);
1313 if (db_rep->master_eid == DB_EID_INVALID && !db_rep->done_one) {
1314 db_rep->done_one = TRUE;
1329 DB_REP *db_rep;
1335 db_rep = env->rep_handle;
1361 if (ackp->generation < db_rep->generation) {
1364 (u_long)ackp->generation, (u_long)db_rep->generation,
1373 if (ackp->generation == db_rep->generation &&