Lines Matching defs:conn
38 #define ONLY_HANDSHAKE(env, conn) do { \
39 if (conn->msg_type != REPMGR_HANDSHAKE) { \
41 (int)conn->msg_type, conn->state); \
71 REPMGR_CONNECTION *conn;
143 __repmgr_new_connection(env, &conn, s, CONN_NEGOTIATE)) != 0) {
150 F_SET(conn, CONN_INCOMING);
151 conn->eid = -1;
153 conn->event_object = event_obj;
224 REPMGR_CONNECTION *conn;
234 } else if ((conn = __repmgr_master_connection(env)) != NULL &&
236 conn->version >= HEARTBEAT_MIN_VERSION) {
273 REPMGR_CONNECTION *conn;
284 conn = master->ref.conn;
285 if (IS_READY_STATE(conn->state))
286 return (conn);
294 REPMGR_CONNECTION *conn;
296 conn = __repmgr_master_connection(env);
297 DB_ASSERT(env, conn != NULL);
300 return (__repmgr_bust_connection(env, conn));
510 site->ref.conn = con;
591 __repmgr_propose_version(env, conn)
593 REPMGR_CONNECTION *conn;
639 ret = send_v1_handshake(env, conn, buf, rec_length);
646 send_v1_handshake(env, conn, buf, len)
648 REPMGR_CONNECTION *conn;
679 conn, REPMGR_HANDSHAKE, &cntrl, &rec, FALSE));
689 __repmgr_read_from_site(env, conn)
691 REPMGR_CONNECTION *conn;
705 if ((ret = __repmgr_readv(conn->fd,
706 &conn->iovecs.vectors[conn->iovecs.offset],
707 conn->iovecs.count - conn->iovecs.offset, &nr)) != 0) {
717 conn->eid, buffer);
727 if (IS_VALID_EID(conn->eid)) {
728 site = SITE_FROM_EID(conn->eid);
732 if (__repmgr_update_consumed(&conn->iovecs, nr))
734 conn));
737 conn->eid, buffer);
751 dispatch_phase_completion(env, conn)
753 REPMGR_CONNECTION *conn;
762 switch (conn->reading_phase) {
771 __repmgr_iovec_init(&conn->iovecs);
772 control_size = ntohl(conn->control_size_buf);
773 rec_size = ntohl(conn->rec_size_buf);
775 if (conn->msg_type == REPMGR_REP_MESSAGE) {
800 conn->input.rep_message = membase;
802 conn->input.rep_message->originating_eid = conn->eid;
803 DB_INIT_DBT(conn->input.rep_message->control,
805 __repmgr_add_dbt(&conn->iovecs,
806 &conn->input.rep_message->control);
809 DB_INIT_DBT(conn->input.rep_message->rec,
813 __repmgr_add_dbt(&conn->iovecs,
814 &conn->input.rep_message->rec);
816 DB_INIT_DBT(conn->input.rep_message->rec,
819 conn->input.repmgr_msg.cntrl.size = control_size;
820 conn->input.repmgr_msg.rec.size = rec_size;
823 dbt = &conn->input.repmgr_msg.cntrl;
827 __repmgr_add_dbt(&conn->iovecs, dbt);
831 dbt = &conn->input.repmgr_msg.rec;
836 conn->input.repmgr_msg.
840 __repmgr_add_dbt(&conn->iovecs, dbt);
844 conn->reading_phase = DATA_PHASE;
856 return (dispatch_msgin(env, conn));
869 dispatch_msgin(env, conn)
871 REPMGR_CONNECTION *conn;
879 switch (conn->state) {
886 ONLY_HANDSHAKE(env, conn);
887 if ((ret = read_version_response(env, conn)) != 0)
898 ONLY_HANDSHAKE(env, conn);
899 if ((ret = send_version_response(env, conn)) != 0)
908 ONLY_HANDSHAKE(env, conn);
909 dbt = &conn->input.repmgr_msg.rec;
912 if ((ret = accept_handshake(env, conn, hostname)) != 0)
914 conn->state = CONN_READY;
925 switch (conn->msg_type) {
927 if ((ret = record_ack(env, conn)) != 0)
942 conn->input.rep_message)) != 0)
954 (int)conn->msg_type);
967 dbt = &conn->input.repmgr_msg.cntrl;
970 dbt = &conn->input.repmgr_msg.rec;
974 __repmgr_reset_for_reading(conn);
983 send_version_response(env, conn)
985 REPMGR_CONNECTION *conn;
999 if ((ret = find_version_info(env, conn, &vi)) != 0)
1003 hostname = conn->input.repmgr_msg.rec.data;
1004 if ((ret = accept_v1_handshake(env, conn, hostname)) != 0)
1007 conn, my_addr->host, strlen(my_addr->host) + 1)) != 0)
1009 conn->state = CONN_READY;
1034 conn->version = conf.version;
1037 if ((ret = send_handshake(env, conn, buf, sizeof(buf))) != 0)
1040 conn->state = CONN_PARAMETERS;
1046 send_handshake(env, conn, opt, optlen)
1048 REPMGR_CONNECTION *conn;
1096 conn, REPMGR_HANDSHAKE, &cntrl, &rec, FALSE);
1102 read_version_response(env, conn)
1104 REPMGR_CONNECTION *conn;
1111 if ((ret = find_version_info(env, conn, &vi)) != 0)
1113 hostname = conn->input.repmgr_msg.rec.data;
1115 if ((ret = accept_v1_handshake(env, conn, hostname)) != 0)
1123 conn->version = conf.version;
1135 if ((ret = accept_handshake(env, conn, hostname)) != 0)
1137 if ((ret = send_handshake(env, conn, NULL, 0)) != 0)
1140 conn->state = CONN_READY;
1151 find_version_info(env, conn, vi)
1153 REPMGR_CONNECTION *conn;
1160 dbt = &conn->input.repmgr_msg.rec;
1189 accept_handshake(env, conn, hostname)
1191 REPMGR_CONNECTION *conn;
1198 conn->input.repmgr_msg.cntrl.data,
1199 conn->input.repmgr_msg.cntrl.size, NULL) != 0)
1202 return (process_parameters(env, conn, hostname, hs.port, hs.priority));
1206 accept_v1_handshake(env, conn, hostname)
1208 REPMGR_CONNECTION *conn;
1214 handshake = conn->input.repmgr_msg.cntrl.data;
1215 if (conn->input.repmgr_msg.cntrl.size != sizeof(*handshake) ||
1221 conn->version = 1;
1223 return (process_parameters(env, conn, hostname, handshake->port, prio));
1227 process_parameters(env, conn, host, port, priority)
1229 REPMGR_CONNECTION *conn;
1242 if (F_ISSET(conn, CONN_INCOMING)) {
1270 DISABLE_CONNECTION(site->ref.conn);
1272 conn->eid = eid;
1274 site->ref.conn = conn;
1287 conn->eid = EID_FROM_SITE(site);
1288 site->ref.conn = conn;
1296 DB_ASSERT(env, IS_VALID_EID(conn->eid));
1297 site = SITE_FROM_EID(conn->eid);
1325 record_ack(env, conn)
1327 REPMGR_CONNECTION *conn;
1337 DB_ASSERT(env, conn->version > 0 &&
1338 IS_READY_STATE(conn->state) && IS_VALID_EID(conn->eid));
1339 site = SITE_FROM_EID(conn->eid);
1345 if (conn->version == 1) {
1346 ackp = conn->input.repmgr_msg.cntrl.data;
1347 if (conn->input.repmgr_msg.cntrl.size != sizeof(ack) ||
1348 conn->input.repmgr_msg.rec.size != 0) {
1355 conn->input.repmgr_msg.cntrl.data,
1356 conn->input.repmgr_msg.cntrl.size, NULL)) != 0)
1386 __repmgr_write_some(env, conn)
1388 REPMGR_CONNECTION *conn;
1394 while (!STAILQ_EMPTY(&conn->outbound_queue)) {
1395 output = STAILQ_FIRST(&conn->outbound_queue);
1397 if ((bytes = send(conn->fd, &msg->data[output->offset],
1410 STAILQ_REMOVE_HEAD(&conn->outbound_queue, entries);
1412 conn->out_queue_length--;
1424 conn->state = CONN_READY;
1425 if (conn->blockers > 0 &&
1426 (ret = __repmgr_signal(&conn->drained)) != 0)
1437 if (WSAEventSelect(conn->fd, conn->event_object, FD_READ|FD_CLOSE)