Lines Matching defs:conn
217 __repmgr_await_drain(env, conn, timeout)
219 REPMGR_CONNECTION *conn;
233 while (conn->out_queue_length >= OUT_QUEUE_LIMIT) {
234 if (!ResetEvent(conn->drained))
240 conn->state = CONN_CONGESTED;
250 conn->drained, duration, FALSE);
255 conn->state = CONN_CONGESTED;
262 if (conn->state == CONN_DEFUNCT)
527 REPMGR_CONNECTION *conn, *next;
568 for (conn = TAILQ_FIRST(&db_rep->connections);
569 conn != NULL;
570 conn = next) {
571 next = TAILQ_NEXT(conn, entries);
573 if (conn->state == CONN_DEFUNCT) {
575 conn)) != 0)
586 if (conn->state == CONN_CONNECTING ||
587 !STAILQ_EMPTY(&conn->outbound_queue) ||
588 (!flow_control || !IS_VALID_EID(conn->eid))) {
589 events[nevents] = conn->event_object;
590 connections[nevents++] = conn;
663 handle_completion(env, conn)
665 REPMGR_CONNECTION *conn;
670 if ((ret = WSAEnumNetworkEvents(conn->fd, conn->event_object, &events))
678 if (conn->state == CONN_CONNECTING) {
679 if ((ret = finish_connecting(env, conn, &events)) != 0)
702 __repmgr_write_some(env, conn)) != 0)
716 __repmgr_read_from_site(env, conn)) != 0)
723 ret = __repmgr_bust_connection(env, conn);
728 finish_connecting(env, conn, events)
730 REPMGR_CONNECTION *conn;
742 conn->state = CONN_CONNECTED;
757 if (WSAEventSelect(conn->fd, conn->event_object, FD_READ | FD_CLOSE) ==
764 return (__repmgr_propose_version(env, conn));
768 eid = conn->eid;
780 DISABLE_CONNECTION(conn);