Lines Matching refs:db_rep
24 __repmgr_queue_create(env, db_rep)
26 DB_REP *db_rep;
35 db_rep->input_queue = q;
79 DB_REP *db_rep;
85 db_rep = env->rep_handle;
86 q = db_rep->input_queue;
88 LOCK_MUTEX(db_rep->mutex);
89 while (STAILQ_EMPTY(&q->header) && !db_rep->finished) {
91 if (!ResetEvent(db_rep->queue_nonempty)) {
95 if (SignalObjectAndWait(db_rep->mutex, db_rep->queue_nonempty,
100 LOCK_MUTEX(db_rep->mutex);
102 if ((ret = pthread_cond_wait(&db_rep->queue_nonempty,
103 &db_rep->mutex)) != 0)
107 if (db_rep->finished)
117 UNLOCK_MUTEX(db_rep->mutex);
132 DB_REP *db_rep;
135 db_rep = env->rep_handle;
136 q = db_rep->input_queue;
141 return (__repmgr_signal(&db_rep->queue_nonempty));