Lines Matching refs:db_rep
34 DB_REP *db_rep;
37 db_rep = env->rep_handle;
38 if (db_rep->finished) {
45 db_rep->operation_needed = initial_operation;
46 if (db_rep->elect_thread == NULL)
48 else if (db_rep->elect_thread->finished) {
51 if ((ret = __repmgr_thread_join(db_rep->elect_thread)) != 0)
53 __os_free(env, db_rep->elect_thread);
54 db_rep->elect_thread = NULL;
59 if ((ret = __repmgr_signal(&db_rep->check_election)) != 0)
73 DB_REP *db_rep;
77 db_rep = env->rep_handle;
86 db_rep->elect_thread = elector;
117 DB_REP *db_rep;
130 db_rep = env->rep_handle;
135 * db_rep->operation_needed is the mechanism by which the outside world
150 LOCK_MUTEX(db_rep->mutex);
151 if (db_rep->finished) {
152 db_rep->elect_thread->finished = TRUE;
153 UNLOCK_MUTEX(db_rep->mutex);
156 to_do = db_rep->operation_needed;
157 db_rep->operation_needed = 0;
158 UNLOCK_MUTEX(db_rep->mutex);
191 nsites = __repmgr_get_nsites(db_rep);
199 !FLD_ISSET(db_rep->region->config,
229 if (db_rep->takeover_pending) {
230 db_rep->takeover_pending = FALSE;
274 LOCK_MUTEX(db_rep->mutex);
277 duration = db_rep->election_retry_wait / US_PER_MS;
278 ret = SignalObjectAndWait(db_rep->mutex,
279 db_rep->check_election, duration, FALSE);
280 LOCK_MUTEX(db_rep->mutex);
286 db_rep->election_retry_wait);
288 &db_rep->check_election, &db_rep->mutex, &deadline))
308 if ((to_do = db_rep->operation_needed) != 0) {
309 db_rep->operation_needed = 0;
325 (!need_success && IS_VALID_EID(db_rep->master_eid)) ||
326 db_rep->finished)))
327 db_rep->elect_thread->finished = TRUE;
341 if (db_rep->init_policy == DB_REP_CLIENT &&
342 !db_rep->found_master)
347 UNLOCK_MUTEX(db_rep->mutex);
360 DB_REP *db_rep;
362 db_rep = env->rep_handle;
366 db_rep->operation_needed, db_rep->finished, db_rep->master_eid));
368 return (db_rep->operation_needed || db_rep->finished);
380 DB_REP *db_rep;
384 db_rep = env->rep_handle;
385 db_rep->master_eid = SELF_EID;
386 db_rep->found_master = TRUE;