Lines Matching refs:nsock
70 struct nbd_sock *nsock;
290 static void nbd_mark_nsock_dead(struct nbd_device *nbd, struct nbd_sock *nsock,
293 if (!nsock->dead && notify && !nbd_disconnected(nbd->config)) {
302 if (!nsock->dead) {
303 kernel_sock_shutdown(nsock->sock, SHUT_RDWR);
314 nsock->dead = true;
315 nsock->pending = NULL;
316 nsock->sent = 0;
375 struct nbd_sock *nsock = config->socks[i];
376 mutex_lock(&nsock->tx_lock);
377 nbd_mark_nsock_dead(nbd, nsock, 0);
378 mutex_unlock(&nsock->tx_lock);
451 struct nbd_sock *nsock =
453 mutex_lock(&nsock->tx_lock);
455 * we don't want to mark the nsock dead if we've
460 if (cmd->cookie == nsock->cookie)
461 nbd_mark_nsock_dead(nbd, nsock, 1);
462 mutex_unlock(&nsock->tx_lock);
476 struct nbd_sock *nsock = config->socks[cmd->index];
483 mutex_lock(&nsock->tx_lock);
484 if (cmd->cookie != nsock->cookie) {
486 mutex_unlock(&nsock->tx_lock);
491 mutex_unlock(&nsock->tx_lock);
577 struct nbd_sock *nsock = config->socks[index];
587 int sent = nsock->sent, skip = 0;
623 cmd->cookie = nsock->cookie;
649 nsock->pending = req;
650 nsock->sent = sent;
691 nsock->pending = req;
692 nsock->sent = sent;
714 nsock->pending = NULL;
715 nsock->sent = 0;
852 struct nbd_sock *nsock = args->nsock;
859 if (nbd_read_reply(nbd, nsock->sock, &reply))
894 mutex_lock(&nsock->tx_lock);
895 nbd_mark_nsock_dead(nbd, nsock, 1);
896 mutex_unlock(&nsock->tx_lock);
936 struct nbd_sock *nsock = config->socks[index];
937 int fallback = nsock->fallback_index;
952 if (nsock->fallback_index < 0 ||
953 nsock->fallback_index >= config->num_connections ||
954 config->socks[nsock->fallback_index]->dead) {
964 nsock->fallback_index = new_index;
971 new_index = nsock->fallback_index;
996 struct nbd_sock *nsock;
1014 nsock = config->socks[index];
1015 mutex_lock(&nsock->tx_lock);
1016 if (nsock->dead) {
1019 mutex_unlock(&nsock->tx_lock);
1044 if (unlikely(nsock->pending && nsock->pending != req)) {
1063 nbd_mark_nsock_dead(nbd, nsock, 1);
1068 mutex_unlock(&nsock->tx_lock);
1132 struct nbd_sock *nsock;
1161 nsock = kzalloc(sizeof(*nsock), GFP_KERNEL);
1162 if (!nsock) {
1170 kfree(nsock);
1177 nsock->fallback_index = -1;
1178 nsock->dead = false;
1179 mutex_init(&nsock->tx_lock);
1180 nsock->sock = sock;
1181 nsock->pending = NULL;
1182 nsock->sent = 0;
1183 nsock->cookie = 0;
1184 socks[config->num_connections++] = nsock;
1215 struct nbd_sock *nsock = config->socks[i];
1217 if (!nsock->dead)
1220 mutex_lock(&nsock->tx_lock);
1221 if (!nsock->dead) {
1222 mutex_unlock(&nsock->tx_lock);
1230 old = nsock->sock;
1231 nsock->fallback_index = -1;
1232 nsock->sock = sock;
1233 nsock->dead = false;
1237 args->nsock = nsock;
1238 nsock->cookie++;
1239 mutex_unlock(&nsock->tx_lock);
1294 struct nbd_sock *nsock = config->socks[i];
1297 mutex_lock(&nsock->tx_lock);
1302 mutex_unlock(&nsock->tx_lock);
1420 args->nsock = config->socks[i];