File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -2699,16 +2699,17 @@ static int nvme_tcp_poll(struct blk_mq_hw_ctx *hctx, struct io_comp_batch *iob)
2699
2699
{
2700
2700
struct nvme_tcp_queue * queue = hctx -> driver_data ;
2701
2701
struct sock * sk = queue -> sock -> sk ;
2702
+ int ret ;
2702
2703
2703
2704
if (!test_bit (NVME_TCP_Q_LIVE , & queue -> flags ))
2704
2705
return 0 ;
2705
2706
2706
2707
set_bit (NVME_TCP_Q_POLLING , & queue -> flags );
2707
2708
if (sk_can_busy_loop (sk ) && skb_queue_empty_lockless (& sk -> sk_receive_queue ))
2708
2709
sk_busy_loop (sk , true);
2709
- nvme_tcp_try_recv (queue );
2710
+ ret = nvme_tcp_try_recv (queue );
2710
2711
clear_bit (NVME_TCP_Q_POLLING , & queue -> flags );
2711
- return queue -> nr_cqe ;
2712
+ return ret < 0 ? ret : queue -> nr_cqe ;
2712
2713
}
2713
2714
2714
2715
static int nvme_tcp_get_address (struct nvme_ctrl * ctrl , char * buf , int size )
You can’t perform that action at this time.
0 commit comments