|
@@ -914,6 +914,7 @@ static int nbd_reconnect_socket(struct nbd_device *nbd, unsigned long arg)
|
|
|
continue;
|
|
|
}
|
|
|
sk_set_memalloc(sock->sk);
|
|
|
+ sock->sk->sk_sndtimeo = nbd->tag_set.timeout;
|
|
|
atomic_inc(&config->recv_threads);
|
|
|
refcount_inc(&nbd->config_refs);
|
|
|
old = nsock->sock;
|
|
@@ -1083,6 +1084,7 @@ static int nbd_start_device(struct nbd_device *nbd)
|
|
|
return -ENOMEM;
|
|
|
}
|
|
|
sk_set_memalloc(config->socks[i]->sock->sk);
|
|
|
+ config->socks[i]->sock->sk->sk_sndtimeo = nbd->tag_set.timeout;
|
|
|
atomic_inc(&config->recv_threads);
|
|
|
refcount_inc(&nbd->config_refs);
|
|
|
INIT_WORK(&args->work, recv_work);
|