diff options
Diffstat (limited to 'src/kernel/mq.c')
| -rw-r--r-- | src/kernel/mq.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/kernel/mq.c b/src/kernel/mq.c index 60673b0..5fa34d5 100644 --- a/src/kernel/mq.c +++ b/src/kernel/mq.c @@ -132,7 +132,7 @@ static int dnbd3_handle_cmd(struct dnbd3_cmd *cmd, int index) // blk_rq_pos(req), blk_rq_bytes(req), index); - if (!(sock->server && sock->sock && !sock->panic)) { + if (!dnbd3_is_sock_alive(*sock)) { // warn_dev(dev, "attempted send on invalid socket %d", index); // msleep(SOCKET_TIMEOUT_CLIENT_DATA * 1000); @@ -142,7 +142,7 @@ static int dnbd3_handle_cmd(struct dnbd3_cmd *cmd, int index) ret = 0; goto out; } else { - error_dev(dev, "ending request, device not connected"); + error_dev(dev, "ending request device not connected"); dnbd3_end_cmd(cmd, BLK_STS_IOERR); ret = -EIO; goto out; @@ -165,7 +165,7 @@ static int dnbd3_handle_cmd(struct dnbd3_cmd *cmd, int index) ret = dnbd3_send_request(sock, blk_mq_rq_from_pdu(cmd), cmd); if (ret == -EAGAIN) { - dev_err_ratelimited(disk_to_dev(dev->disk), "request send failed, requeueing\n"); + error_dev(dev, "request send failed, requeueing"); dnbd3_requeue_cmd(cmd); ret = 0; } |