Lines Matching refs:db_rep
26 DB_REP *db_rep;
32 db_rep = env->rep_handle;
41 if (db_rep->my_addr.port == 0) {
47 if (db_rep->selector != NULL || db_rep->finished) {
71 sizeof(REPMGR_RUNNABLE *), &db_rep->messengers)) != 0)
73 db_rep->nthreads = nthreads;
75 if ((ret = __repmgr_net_init(env, db_rep)) != 0 ||
76 (ret = __repmgr_init_sync(env, db_rep)) != 0 ||
85 if ((db_rep->init_policy = flags) == DB_REP_MASTER)
93 LOCK_MUTEX(db_rep->mutex);
95 UNLOCK_MUTEX(db_rep->mutex);
111 db_rep->selector = selector;
124 db_rep->messengers[i] = messenger;
137 DB_REP *db_rep;
141 db_rep = env->rep_handle;
142 if (db_rep->selector != NULL) {
208 __repmgr_env_create(env, db_rep)
210 DB_REP *db_rep;
215 db_rep->ack_timeout = DB_REPMGR_DEFAULT_ACK_TIMEOUT;
216 db_rep->connection_retry_wait = DB_REPMGR_DEFAULT_CONNECTION_RETRY;
217 db_rep->election_retry_wait = DB_REPMGR_DEFAULT_ELECTION_RETRY;
218 db_rep->config_nsites = 0;
219 db_rep->peer = DB_EID_INVALID;
220 db_rep->perm_policy = DB_REPMGR_ACKS_QUORUM;
223 db_rep->waiters = NULL;
225 db_rep->read_pipe = db_rep->write_pipe = -1;
227 if ((ret = __repmgr_net_create(db_rep)) == 0)
228 ret = __repmgr_queue_create(env, db_rep);
237 __repmgr_env_destroy(env, db_rep)
239 DB_REP *db_rep;
242 __repmgr_net_destroy(env, db_rep);
243 if (db_rep->messengers != NULL) {
244 __os_free(env, db_rep->messengers);
245 db_rep->messengers = NULL;
256 DB_REP *db_rep;
260 db_rep = env->rep_handle;
266 LOCK_MUTEX(db_rep->mutex);
267 db_rep->finished = TRUE;
268 if (db_rep->elect_thread != NULL &&
269 (ret = __repmgr_signal(&db_rep->check_election)) != 0)
272 if ((ret = __repmgr_signal(&db_rep->queue_nonempty)) != 0)
275 TAILQ_FOREACH(conn, &db_rep->connections, entries) {
280 UNLOCK_MUTEX(db_rep->mutex);
285 UNLOCK_MUTEX(db_rep->mutex);
293 DB_REP *db_rep;
297 db_rep = env->rep_handle;
299 if (db_rep->elect_thread != NULL) {
300 ret = __repmgr_thread_join(db_rep->elect_thread);
301 __os_free(env, db_rep->elect_thread);
302 db_rep->elect_thread = NULL;
305 for (i=0; i<db_rep->nthreads && db_rep->messengers[i] != NULL; i++) {
306 messenger = db_rep->messengers[i];
310 db_rep->messengers[i] = NULL; /* necessary? */
312 __os_free(env, db_rep->messengers);
313 db_rep->messengers = NULL;
315 if (db_rep->selector != NULL) {
316 if ((t_ret = __repmgr_thread_join(db_rep->selector)) != 0 &&
319 __os_free(env, db_rep->selector);
320 db_rep->selector = NULL;
338 DB_REP *db_rep;
348 db_rep = env->rep_handle;
349 if (db_rep->my_addr.port != 0) {
370 if (REPMGR_SYNC_INITED(db_rep)) {
371 LOCK_MUTEX(db_rep->mutex);
376 memcpy(&db_rep->my_addr, &addr, sizeof(addr));
379 UNLOCK_MUTEX(db_rep->mutex);
400 DB_REP *db_rep;
417 db_rep = env->rep_handle;
419 if (REPMGR_SYNC_INITED(db_rep)) {
420 LOCK_MUTEX(db_rep->mutex);
436 db_rep->peer = eid;
441 UNLOCK_MUTEX(db_rep->mutex);