diff --git a/lib/nvme/nvme_tcp.c b/lib/nvme/nvme_tcp.c index 17c9ca88b..95b293c19 100644 --- a/lib/nvme/nvme_tcp.c +++ b/lib/nvme/nvme_tcp.c @@ -1661,9 +1661,11 @@ nvme_tcp_qpair_process_completions(struct spdk_nvme_qpair *qpair, uint32_t max_c uint32_t reaped; int rc; - rc = spdk_sock_flush(tqpair->sock); - if (rc < 0) { - return rc; + if (qpair->poll_group == NULL) { + rc = spdk_sock_flush(tqpair->sock); + if (rc < 0) { + return rc; + } } if (max_completions == 0) {