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 @@ -2756,16 +2756,17 @@ static int nvme_tcp_poll(struct blk_mq_hw_ctx *hctx, struct io_comp_batch *iob)
2756
2756
{
2757
2757
struct nvme_tcp_queue * queue = hctx -> driver_data ;
2758
2758
struct sock * sk = queue -> sock -> sk ;
2759
+ int ret ;
2759
2760
2760
2761
if (!test_bit (NVME_TCP_Q_LIVE , & queue -> flags ))
2761
2762
return 0 ;
2762
2763
2763
2764
set_bit (NVME_TCP_Q_POLLING , & queue -> flags );
2764
2765
if (sk_can_busy_loop (sk ) && skb_queue_empty_lockless (& sk -> sk_receive_queue ))
2765
2766
sk_busy_loop (sk , true);
2766
- nvme_tcp_try_recv (queue );
2767
+ ret = nvme_tcp_try_recv (queue );
2767
2768
clear_bit (NVME_TCP_Q_POLLING , & queue -> flags );
2768
- return queue -> nr_cqe ;
2769
+ return ret < 0 ? ret : queue -> nr_cqe ;
2769
2770
}
2770
2771
2771
2772
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