Lines Matching refs:conn
520 conn_request_state(connection, NS(conn, C_BROKEN_PIPE), CS_HARD); in drbd_recv()
650 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in drbd_try_connect()
731 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in prepare_listen_socket()
773 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in drbd_wait_for_connect()
917 if (conn_request_state(connection, NS(conn, C_WF_CONNECTION), CS_VERBOSE) < SS_SUCCESS) in conn_connect()
1096 rv = conn_request_state(connection, NS(conn, C_WF_REPORT_PARAMS), CS_VERBOSE); in conn_connect()
1942 pcmd = (device->state.conn >= C_SYNC_SOURCE && in e_end_block()
1943 device->state.conn <= C_PAUSED_SYNC_T && in e_end_block()
2249 _conn_request_state(connection, NS(conn, C_TIMEOUT), CS_HARD); in handle_write_conflicts()
2399 if (device->state.conn == C_SYNC_TARGET) in receive_Data()
2496 if (device->state.conn == C_VERIFY_S || device->state.conn == C_VERIFY_T) in drbd_rs_c_min_rate_throttle()
3437 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_protocol()
3599 if (device->state.conn == C_WF_REPORT_PARAMS) { in receive_SyncParam()
3613 if (device->state.conn == C_WF_REPORT_PARAMS) { in receive_SyncParam()
3709 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_SyncParam()
3761 if (device->state.conn == C_WF_REPORT_PARAMS) in receive_sizes()
3769 device->state.conn < C_CONNECTED) { in receive_sizes()
3771 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_sizes()
3844 if (device->state.conn > C_WF_REPORT_PARAMS) { in receive_sizes()
3852 (dd == DS_GREW && device->state.conn == C_CONNECTED)) { in receive_sizes()
3892 if (device->state.conn < C_CONNECTED && in receive_uuids()
3898 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_uuids()
3904 device->state.conn == C_CONNECTED && in receive_uuids()
3934 if (device->state.conn >= C_CONNECTED && device->state.disk < D_INCONSISTENT) in receive_uuids()
3964 ms.conn = c_tab[ps.conn]; in convert_state()
4062 if (os.conn <= C_TEAR_DOWN) in receive_state()
4073 os.conn > C_CONNECTED && os.disk == D_UP_TO_DATE) { in receive_state()
4080 if (peer_state.conn > C_CONNECTED && in receive_state()
4081 peer_state.conn < C_SYNC_SOURCE) in receive_state()
4087 else if (os.conn >= C_SYNC_SOURCE && in receive_state()
4088 peer_state.conn == C_CONNECTED) { in receive_state()
4096 if (os.conn == C_VERIFY_T && os.disk == D_UP_TO_DATE && in receive_state()
4097 peer_state.conn == C_CONNECTED && real_peer_disk == D_UP_TO_DATE) { in receive_state()
4109 os.conn == C_CONNECTED && peer_state.conn > C_SYNC_SOURCE) in receive_state()
4112 if (ns.conn == C_WF_REPORT_PARAMS) in receive_state()
4113 ns.conn = C_CONNECTED; in receive_state()
4115 if (peer_state.conn == C_AHEAD) in receive_state()
4116 ns.conn = C_BEHIND; in receive_state()
4123 cr = (os.conn < C_CONNECTED); in receive_state()
4126 cr |= (os.conn == C_CONNECTED && in receive_state()
4134 cr |= (os.conn == C_CONNECTED && in receive_state()
4135 (peer_state.conn >= C_STARTING_SYNC_S && in receive_state()
4136 peer_state.conn <= C_WF_BITMAP_T)); in receive_state()
4139 ns.conn = drbd_sync_handshake(peer_device, peer_state.role, real_peer_disk); in receive_state()
4142 if (ns.conn == C_MASK) { in receive_state()
4143 ns.conn = C_CONNECTED; in receive_state()
4153 D_ASSERT(device, os.conn == C_WF_REPORT_PARAMS); in receive_state()
4154 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_state()
4167 if ((ns.conn == C_CONNECTED || ns.conn == C_WF_BITMAP_S) && ns.disk == D_NEGOTIATING) in receive_state()
4169 cs_flags = CS_VERBOSE + (os.conn < C_CONNECTED && ns.conn >= C_CONNECTED ? 0 : CS_HARD); in receive_state()
4170 …if (ns.pdsk == D_CONSISTENT && drbd_suspended(device) && ns.conn == C_CONNECTED && os.conn < C_CON… in receive_state()
4179 conn_request_state(peer_device->connection, NS2(conn, C_PROTOCOL_ERROR, susp, 0), CS_HARD); in receive_state()
4187 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_state()
4191 if (os.conn > C_WF_REPORT_PARAMS) { in receive_state()
4192 if (ns.conn > C_CONNECTED && peer_state.conn <= C_CONNECTED && in receive_state()
4221 device->state.conn == C_WF_SYNC_UUID || in receive_sync_uuid()
4222 device->state.conn == C_BEHIND || in receive_sync_uuid()
4223 device->state.conn < C_CONNECTED || in receive_sync_uuid()
4385 conn_request_state(peer_device->connection, NS(conn, C_PROTOCOL_ERROR), CS_HARD); in decode_bitmap_c()
4497 if (device->state.conn == C_WF_BITMAP_T) { in receive_bitmap()
4504 rv = _drbd_request_state(device, NS(conn, C_WF_SYNC_UUID), CS_VERBOSE); in receive_bitmap()
4506 } else if (device->state.conn != C_WF_BITMAP_S) { in receive_bitmap()
4510 drbd_conn_str(device->state.conn)); in receive_bitmap()
4516 if (!err && device->state.conn == C_WF_BITMAP_S) in receive_bitmap()
4549 switch (device->state.conn) { in receive_out_of_sync()
4556 drbd_conn_str(device->state.conn)); in receive_out_of_sync()
4645 conn_request_state(connection, NS(conn, C_PROTOCOL_ERROR), CS_HARD); in drbdd()
4662 conn_request_state(connection, NS(conn, C_NETWORK_FAILURE), CS_HARD); in conn_disconnect()
4693 _conn_request_state(connection, NS(conn, C_UNCONNECTED), CS_VERBOSE); in conn_disconnect()
4698 conn_request_state(connection, NS(conn, C_STANDALONE), CS_VERBOSE | CS_HARD); in conn_disconnect()
5084 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in drbd_receiver()
5365 if (device->state.conn == C_AHEAD && in got_BarrierAck()
5650 conn_request_state(connection, NS(conn, C_NETWORK_FAILURE), CS_HARD); in drbd_asender()
5655 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in drbd_asender()