Lines Matching refs:db_rep
99 DB_REP *db_rep;
103 db_rep = env->rep_handle;
104 for (i=0; i<db_rep->waiters->next_avail; i++) {
105 slot = &db_rep->waiters->array[i];
125 DB_REP *db_rep;
128 db_rep = env->rep_handle;
133 timeout = db_rep->ack_timeout > 0 ?
134 DB_TIMEOUT_TO_WINDOWS_TIMEOUT(db_rep->ack_timeout) : INFINITE;
136 if ((ret = SignalObjectAndWait(db_rep->mutex, me->event, timeout,
144 LOCK_MUTEX(db_rep->mutex);
162 DB_REP *db_rep;
165 db_rep = env->rep_handle;
166 table = db_rep->waiters;
206 DB_REP *db_rep;
208 db_rep = env->rep_handle;
211 slot->next_free = db_rep->waiters->first_free;
212 db_rep->waiters->first_free = slot;
222 DB_REP *db_rep;
228 db_rep = env->rep_handle;
249 ret = SignalObjectAndWait(db_rep->mutex,
251 LOCK_MUTEX(db_rep->mutex);
260 if (db_rep->finished)
295 * close_sync function. db_rep->waiters should be non-NULL iff all of these
299 __repmgr_init_sync(env, db_rep)
301 DB_REP *db_rep;
307 db_rep->signaler = db_rep->queue_nonempty = db_rep->check_election =
308 db_rep->mutex = NULL;
311 if ((db_rep->signaler = CreateEvent(NULL, /* security attr */
317 if ((db_rep->queue_nonempty = CreateEvent(NULL, TRUE, FALSE, NULL))
321 if ((db_rep->check_election = CreateEvent(NULL, FALSE, FALSE, NULL))
325 if ((db_rep->mutex = CreateMutex(NULL, FALSE, NULL)) == NULL)
341 db_rep->waiters = table;
347 if (db_rep->check_election != NULL)
348 CloseHandle(db_rep->check_election);
349 if (db_rep->queue_nonempty != NULL)
350 CloseHandle(db_rep->queue_nonempty);
351 if (db_rep->signaler != NULL)
352 CloseHandle(db_rep->signaler);
353 if (db_rep->mutex != NULL)
354 CloseHandle(db_rep->mutex);
357 db_rep->waiters = NULL;
365 DB_REP *db_rep;
368 db_rep = env->rep_handle;
369 if (!(REPMGR_SYNC_INITED(db_rep)))
373 for (i = 0; i < db_rep->waiters->next_avail; i++) {
374 if (!CloseHandle(db_rep->waiters->array[i].event) && ret == 0)
377 __os_free(env, db_rep->waiters->array);
378 __os_free(env, db_rep->waiters);
380 if (!CloseHandle(db_rep->check_election) && ret == 0)
383 if (!CloseHandle(db_rep->queue_nonempty) && ret == 0)
386 if (!CloseHandle(db_rep->signaler) && ret == 0)
389 if (!CloseHandle(db_rep->mutex) && ret == 0)
392 db_rep->waiters = NULL;
398 * and allocation. A valid db_rep->listen_fd acts as the "all-or-nothing"
404 __repmgr_net_init(env, db_rep)
406 DB_REP *db_rep;
411 if (!db_rep->wsa_inited && (ret = __repmgr_wsa_init(env)) != 0)
422 err: db_rep->listen_fd = INVALID_SOCKET;
436 DB_REP *db_rep;
440 db_rep = env->rep_handle;
446 db_rep->wsa_inited = TRUE;
524 DB_REP *db_rep;
535 db_rep = env->rep_handle;
542 if (WSAEventSelect(db_rep->listen_fd, listen_event, FD_ACCEPT) ==
549 LOCK_MUTEX(db_rep->mutex);
555 events[0] = db_rep->signaler;
568 for (conn = TAILQ_FIRST(&db_rep->connections);
603 UNLOCK_MUTEX(db_rep->mutex);
606 if (db_rep->finished) {
610 LOCK_MUTEX(db_rep->mutex);
625 db_rep->listen_fd, listen_event,
655 UNLOCK_MUTEX(db_rep->mutex);
733 DB_REP *db_rep;
767 db_rep = env->rep_handle;
772 STAT(db_rep->region->mstat.st_connect_fail++);