Lines Matching refs:conn
519 conn_request_state(connection, NS(conn, C_BROKEN_PIPE), CS_HARD); in drbd_recv()
649 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in drbd_try_connect()
730 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in prepare_listen_socket()
772 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in drbd_wait_for_connect()
916 if (conn_request_state(connection, NS(conn, C_WF_CONNECTION), CS_VERBOSE) < SS_SUCCESS) in conn_connect()
1095 rv = conn_request_state(connection, NS(conn, C_WF_REPORT_PARAMS), CS_VERBOSE); in conn_connect()
1941 pcmd = (device->state.conn >= C_SYNC_SOURCE && in e_end_block()
1942 device->state.conn <= C_PAUSED_SYNC_T && in e_end_block()
2248 _conn_request_state(connection, NS(conn, C_TIMEOUT), CS_HARD); in handle_write_conflicts()
2398 if (device->state.conn == C_SYNC_TARGET) in receive_Data()
2495 if (device->state.conn == C_VERIFY_S || device->state.conn == C_VERIFY_T) in drbd_rs_c_min_rate_throttle()
3436 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_protocol()
3598 if (device->state.conn == C_WF_REPORT_PARAMS) { in receive_SyncParam()
3612 if (device->state.conn == C_WF_REPORT_PARAMS) { in receive_SyncParam()
3708 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_SyncParam()
3760 if (device->state.conn == C_WF_REPORT_PARAMS) in receive_sizes()
3768 device->state.conn < C_CONNECTED) { in receive_sizes()
3770 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_sizes()
3843 if (device->state.conn > C_WF_REPORT_PARAMS) { in receive_sizes()
3851 (dd == DS_GREW && device->state.conn == C_CONNECTED)) { in receive_sizes()
3891 if (device->state.conn < C_CONNECTED && in receive_uuids()
3897 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_uuids()
3903 device->state.conn == C_CONNECTED && in receive_uuids()
3933 if (device->state.conn >= C_CONNECTED && device->state.disk < D_INCONSISTENT) in receive_uuids()
3963 ms.conn = c_tab[ps.conn]; in convert_state()
4061 if (os.conn <= C_TEAR_DOWN) in receive_state()
4072 os.conn > C_CONNECTED && os.disk == D_UP_TO_DATE) { in receive_state()
4079 if (peer_state.conn > C_CONNECTED && in receive_state()
4080 peer_state.conn < C_SYNC_SOURCE) in receive_state()
4086 else if (os.conn >= C_SYNC_SOURCE && in receive_state()
4087 peer_state.conn == C_CONNECTED) { in receive_state()
4095 if (os.conn == C_VERIFY_T && os.disk == D_UP_TO_DATE && in receive_state()
4096 peer_state.conn == C_CONNECTED && real_peer_disk == D_UP_TO_DATE) { in receive_state()
4108 os.conn == C_CONNECTED && peer_state.conn > C_SYNC_SOURCE) in receive_state()
4111 if (ns.conn == C_WF_REPORT_PARAMS) in receive_state()
4112 ns.conn = C_CONNECTED; in receive_state()
4114 if (peer_state.conn == C_AHEAD) in receive_state()
4115 ns.conn = C_BEHIND; in receive_state()
4122 cr = (os.conn < C_CONNECTED); in receive_state()
4125 cr |= (os.conn == C_CONNECTED && in receive_state()
4133 cr |= (os.conn == C_CONNECTED && in receive_state()
4134 (peer_state.conn >= C_STARTING_SYNC_S && in receive_state()
4135 peer_state.conn <= C_WF_BITMAP_T)); in receive_state()
4138 ns.conn = drbd_sync_handshake(peer_device, peer_state.role, real_peer_disk); in receive_state()
4141 if (ns.conn == C_MASK) { in receive_state()
4142 ns.conn = C_CONNECTED; in receive_state()
4152 D_ASSERT(device, os.conn == C_WF_REPORT_PARAMS); in receive_state()
4153 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_state()
4166 if ((ns.conn == C_CONNECTED || ns.conn == C_WF_BITMAP_S) && ns.disk == D_NEGOTIATING) in receive_state()
4168 cs_flags = CS_VERBOSE + (os.conn < C_CONNECTED && ns.conn >= C_CONNECTED ? 0 : CS_HARD); in receive_state()
4169 …if (ns.pdsk == D_CONSISTENT && drbd_suspended(device) && ns.conn == C_CONNECTED && os.conn < C_CON… in receive_state()
4178 conn_request_state(peer_device->connection, NS2(conn, C_PROTOCOL_ERROR, susp, 0), CS_HARD); in receive_state()
4186 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_state()
4190 if (os.conn > C_WF_REPORT_PARAMS) { in receive_state()
4191 if (ns.conn > C_CONNECTED && peer_state.conn <= C_CONNECTED && in receive_state()
4220 device->state.conn == C_WF_SYNC_UUID || in receive_sync_uuid()
4221 device->state.conn == C_BEHIND || in receive_sync_uuid()
4222 device->state.conn < C_CONNECTED || in receive_sync_uuid()
4384 conn_request_state(peer_device->connection, NS(conn, C_PROTOCOL_ERROR), CS_HARD); in decode_bitmap_c()
4496 if (device->state.conn == C_WF_BITMAP_T) { in receive_bitmap()
4503 rv = _drbd_request_state(device, NS(conn, C_WF_SYNC_UUID), CS_VERBOSE); in receive_bitmap()
4505 } else if (device->state.conn != C_WF_BITMAP_S) { in receive_bitmap()
4509 drbd_conn_str(device->state.conn)); in receive_bitmap()
4515 if (!err && device->state.conn == C_WF_BITMAP_S) in receive_bitmap()
4548 switch (device->state.conn) { in receive_out_of_sync()
4555 drbd_conn_str(device->state.conn)); in receive_out_of_sync()
4644 conn_request_state(connection, NS(conn, C_PROTOCOL_ERROR), CS_HARD); in drbdd()
4661 conn_request_state(connection, NS(conn, C_NETWORK_FAILURE), CS_HARD); in conn_disconnect()
4692 _conn_request_state(connection, NS(conn, C_UNCONNECTED), CS_VERBOSE); in conn_disconnect()
4697 conn_request_state(connection, NS(conn, C_STANDALONE), CS_VERBOSE | CS_HARD); in conn_disconnect()
5083 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in drbd_receiver()
5364 if (device->state.conn == C_AHEAD && in got_BarrierAck()
5649 conn_request_state(connection, NS(conn, C_NETWORK_FAILURE), CS_HARD); in drbd_asender()
5654 conn_request_state(connection, NS(conn, C_DISCONNECTING), CS_HARD); in drbd_asender()