Lines Matching refs:nsock
290 static void nbd_mark_nsock_dead(struct nbd_device *nbd, struct nbd_sock *nsock, in nbd_mark_nsock_dead() argument
293 if (!nsock->dead && notify && !nbd_disconnected(nbd->config)) { in nbd_mark_nsock_dead()
302 if (!nsock->dead) { in nbd_mark_nsock_dead()
303 kernel_sock_shutdown(nsock->sock, SHUT_RDWR); in nbd_mark_nsock_dead()
314 nsock->dead = true; in nbd_mark_nsock_dead()
315 nsock->pending = NULL; in nbd_mark_nsock_dead()
316 nsock->sent = 0; in nbd_mark_nsock_dead()
372 struct nbd_sock *nsock = config->socks[i]; in sock_shutdown() local
373 mutex_lock(&nsock->tx_lock); in sock_shutdown()
374 nbd_mark_nsock_dead(nbd, nsock, 0); in sock_shutdown()
375 mutex_unlock(&nsock->tx_lock); in sock_shutdown()
432 struct nbd_sock *nsock = in nbd_xmit_timeout() local
434 mutex_lock(&nsock->tx_lock); in nbd_xmit_timeout()
441 if (cmd->cookie == nsock->cookie) in nbd_xmit_timeout()
442 nbd_mark_nsock_dead(nbd, nsock, 1); in nbd_xmit_timeout()
443 mutex_unlock(&nsock->tx_lock); in nbd_xmit_timeout()
457 struct nbd_sock *nsock = config->socks[cmd->index]; in nbd_xmit_timeout() local
464 mutex_lock(&nsock->tx_lock); in nbd_xmit_timeout()
465 if (cmd->cookie != nsock->cookie) { in nbd_xmit_timeout()
467 mutex_unlock(&nsock->tx_lock); in nbd_xmit_timeout()
472 mutex_unlock(&nsock->tx_lock); in nbd_xmit_timeout()
555 struct nbd_sock *nsock = config->socks[index]; in nbd_send_cmd() local
565 int sent = nsock->sent, skip = 0; in nbd_send_cmd()
601 cmd->cookie = nsock->cookie; in nbd_send_cmd()
627 nsock->pending = req; in nbd_send_cmd()
628 nsock->sent = sent; in nbd_send_cmd()
669 nsock->pending = req; in nbd_send_cmd()
670 nsock->sent = sent; in nbd_send_cmd()
692 nsock->pending = NULL; in nbd_send_cmd()
693 nsock->sent = 0; in nbd_send_cmd()
830 struct nbd_sock *nsock; in recv_work() local
872 nsock = config->socks[args->index]; in recv_work()
873 mutex_lock(&nsock->tx_lock); in recv_work()
874 nbd_mark_nsock_dead(nbd, nsock, 1); in recv_work()
875 mutex_unlock(&nsock->tx_lock); in recv_work()
915 struct nbd_sock *nsock = config->socks[index]; in find_fallback() local
916 int fallback = nsock->fallback_index; in find_fallback()
931 if (nsock->fallback_index < 0 || in find_fallback()
932 nsock->fallback_index >= config->num_connections || in find_fallback()
933 config->socks[nsock->fallback_index]->dead) { in find_fallback()
943 nsock->fallback_index = new_index; in find_fallback()
950 new_index = nsock->fallback_index; in find_fallback()
975 struct nbd_sock *nsock; in nbd_handle_cmd() local
993 nsock = config->socks[index]; in nbd_handle_cmd()
994 mutex_lock(&nsock->tx_lock); in nbd_handle_cmd()
995 if (nsock->dead) { in nbd_handle_cmd()
998 mutex_unlock(&nsock->tx_lock); in nbd_handle_cmd()
1023 if (unlikely(nsock->pending && nsock->pending != req)) { in nbd_handle_cmd()
1042 nbd_mark_nsock_dead(nbd, nsock, 1); in nbd_handle_cmd()
1047 mutex_unlock(&nsock->tx_lock); in nbd_handle_cmd()
1111 struct nbd_sock *nsock; in nbd_add_socket() local
1137 nsock = kzalloc(sizeof(*nsock), GFP_KERNEL); in nbd_add_socket()
1138 if (!nsock) { in nbd_add_socket()
1146 kfree(nsock); in nbd_add_socket()
1153 nsock->fallback_index = -1; in nbd_add_socket()
1154 nsock->dead = false; in nbd_add_socket()
1155 mutex_init(&nsock->tx_lock); in nbd_add_socket()
1156 nsock->sock = sock; in nbd_add_socket()
1157 nsock->pending = NULL; in nbd_add_socket()
1158 nsock->sent = 0; in nbd_add_socket()
1159 nsock->cookie = 0; in nbd_add_socket()
1160 socks[config->num_connections++] = nsock; in nbd_add_socket()
1191 struct nbd_sock *nsock = config->socks[i]; in nbd_reconnect_socket() local
1193 if (!nsock->dead) in nbd_reconnect_socket()
1196 mutex_lock(&nsock->tx_lock); in nbd_reconnect_socket()
1197 if (!nsock->dead) { in nbd_reconnect_socket()
1198 mutex_unlock(&nsock->tx_lock); in nbd_reconnect_socket()
1206 old = nsock->sock; in nbd_reconnect_socket()
1207 nsock->fallback_index = -1; in nbd_reconnect_socket()
1208 nsock->sock = sock; in nbd_reconnect_socket()
1209 nsock->dead = false; in nbd_reconnect_socket()
1213 nsock->cookie++; in nbd_reconnect_socket()
1214 mutex_unlock(&nsock->tx_lock); in nbd_reconnect_socket()
1269 struct nbd_sock *nsock = config->socks[i]; in send_disconnects() local
1272 mutex_lock(&nsock->tx_lock); in send_disconnects()
1277 mutex_unlock(&nsock->tx_lock); in send_disconnects()