Lines Matching defs:conn
89 REPMGR_CONNECTION *conn;
124 conn = site->ref.conn;
126 if ((ret = __repmgr_send_one(env, conn, REPMGR_REP_MESSAGE,
128 (t_ret = __repmgr_bust_connection(env, conn)) != 0)
237 if (site->ref.conn->state == CONN_READY)
262 REPMGR_CONNECTION *conn;
290 TAILQ_FOREACH(conn, &db_rep->connections, entries) {
291 if (conn->state != CONN_READY)
293 DB_ASSERT(env, IS_VALID_EID(conn->eid) &&
294 conn->version > 0 &&
295 conn->version <= DB_REPMGR_VERSION);
310 if (type > version_max_msg_type[conn->version])
320 conn, &msg, FALSE)) == 0) {
321 site = SITE_FROM_EID(conn->eid);
326 if ((ret = __repmgr_bust_connection(env, conn)) != 0)
355 __repmgr_send_one(env, conn, msg_type, control, rec, blockable)
357 REPMGR_CONNECTION *conn;
365 return (__repmgr_send_internal(env, conn, &msg, blockable));
389 __repmgr_send_internal(env, conn, msg, blockable)
391 REPMGR_CONNECTION *conn;
406 conn->state != CONN_CONNECTING && conn->state != CONN_DEFUNCT);
407 if (!STAILQ_EMPTY(&conn->outbound_queue)) {
416 conn->eid, buffer)));
417 if (conn->out_queue_length >= OUT_QUEUE_LIMIT &&
418 blockable && conn->state != CONN_CONGESTED) {
426 conn->blockers++;
428 conn, drain_to * OUT_QUEUE_LIMIT);
429 conn->blockers--;
432 db_rep->finished, conn->out_queue_length));
437 if (STAILQ_EMPTY(&conn->outbound_queue))
440 if (conn->out_queue_length < OUT_QUEUE_LIMIT)
441 return (enqueue_msg(env, conn, msg, 0));
460 while ((ret = __repmgr_writev(conn->fd, &iovecs.vectors[iovecs.offset],
474 __repmgr_format_eid_loc(env->rep_handle, conn->eid, buffer)));
480 if ((ret = enqueue_msg(env, conn, msg, total_written)) != 0)
493 if (WSAEventSelect(conn->fd, conn->event_object,
622 __repmgr_bust_connection(env, conn)
624 REPMGR_CONNECTION *conn;
632 eid = conn->eid;
633 connecting = (conn->state == CONN_CONNECTING);
635 DISABLE_CONNECTION(conn);
638 * When we first accepted the incoming connection, we set conn->eid to
680 __repmgr_cleanup_connection(env, conn)
682 REPMGR_CONNECTION *conn;
689 if ((ret = __repmgr_close_connection(env, conn)) != 0)
697 if (conn->blockers > 0) {
698 ret = __repmgr_signal(&conn->drained);
702 TAILQ_REMOVE(&db_rep->connections, conn, entries);
704 ret = __repmgr_destroy_connection(env, conn);
711 __repmgr_close_connection(env, conn)
713 REPMGR_CONNECTION *conn;
718 conn->state == CONN_DEFUNCT || env->rep_handle->finished);
721 if (conn->fd != INVALID_SOCKET) {
722 ret = closesocket(conn->fd);
723 conn->fd = INVALID_SOCKET;
729 if (!WSACloseEvent(conn->event_object) && ret == 0)
737 __repmgr_destroy_connection(env, conn)
739 REPMGR_CONNECTION *conn;
749 if (conn->reading_phase == DATA_PHASE) {
750 if (conn->msg_type == REPMGR_REP_MESSAGE)
751 __os_free(env, conn->input.rep_message);
753 dbt = &conn->input.repmgr_msg.cntrl;
756 dbt = &conn->input.repmgr_msg.rec;
761 while (!STAILQ_EMPTY(&conn->outbound_queue)) {
762 out = STAILQ_FIRST(&conn->outbound_queue);
763 STAILQ_REMOVE_HEAD(&conn->outbound_queue, entries);
770 ret = __repmgr_free_cond(&conn->drained);
771 __os_free(env, conn);
776 enqueue_msg(env, conn, msg, offset)
778 REPMGR_CONNECTION *conn;
794 STAILQ_INSERT_TAIL(&conn->outbound_queue, q_element, entries);
795 conn->out_queue_length++;
1151 REPMGR_CONNECTION *conn;
1163 conn = TAILQ_FIRST(&db_rep->connections);
1164 if ((t_ret = __repmgr_close_connection(env, conn)) != 0 &&
1167 TAILQ_REMOVE(&db_rep->connections, conn, entries);
1168 if ((t_ret = __repmgr_destroy_connection(env, conn)) != 0 &&
1202 REPMGR_CONNECTION *conn;
1219 conn = TAILQ_FIRST(&db_rep->connections);
1220 (void)__repmgr_destroy_connection(env, conn);