Lines Matching defs:conn
217 __repmgr_await_drain(env, conn, timeout)
219 REPMGR_CONNECTION *conn;
231 while (conn->out_queue_length >= OUT_QUEUE_LIMIT) {
232 ret = pthread_cond_timedwait(&conn->drained,
242 if (conn->state == CONN_DEFUNCT) {
248 conn->state = CONN_CONGESTED;
536 REPMGR_CONNECTION *conn, *next;
577 for (conn = TAILQ_FIRST(&db_rep->connections);
578 conn != NULL;
579 conn = next) {
580 next = TAILQ_NEXT(conn, entries);
582 if (conn->state == CONN_DEFUNCT) {
584 conn)) != 0)
589 if (conn->state == CONN_CONNECTING) {
590 FD_SET((u_int)conn->fd, &reads);
591 FD_SET((u_int)conn->fd, &writes);
592 if (conn->fd > maxfd)
593 maxfd = conn->fd;
597 if (!STAILQ_EMPTY(&conn->outbound_queue)) {
598 FD_SET((u_int)conn->fd, &writes);
599 if (conn->fd > maxfd)
600 maxfd = conn->fd;
606 if (!flow_control || !IS_VALID_EID(conn->eid)) {
607 FD_SET((u_int)conn->fd, &reads);
608 if (conn->fd > maxfd)
609 maxfd = conn->fd;
651 TAILQ_FOREACH(conn, &db_rep->connections, entries) {
652 if (conn->state == CONN_DEFUNCT)
656 conn, &reads, &writes, flow_control)) != 0)
687 __repmgr_conn_work(env, conn, reads, writes, flow_control)
689 REPMGR_CONNECTION *conn;
697 fd = (u_int)conn->fd;
699 if (conn->state == CONN_CONNECTING) {
701 ret = finish_connecting(env, conn);
707 ret = __repmgr_write_some(env, conn);
710 ret = __repmgr_read_from_site(env, conn);
714 ret = __repmgr_bust_connection(env, conn);
719 finish_connecting(env, conn)
721 REPMGR_CONNECTION *conn;
732 conn->fd, SOL_SOCKET, SO_ERROR, (sockopt_t)&error, &len) < 0)
739 conn->state = CONN_CONNECTED;
740 return (__repmgr_propose_version(env, conn));
745 DB_ASSERT(env, IS_VALID_EID(conn->eid));
746 eid = (u_int)conn->eid;
762 DISABLE_CONNECTION(conn);