Merge pull request #28921 from rzarzynski/wip-msgr-drop-0c

msg/async: drop zero_copy_read() & co from ConnectedSocket.

Reviewed-by: Haomai Wang <haomai@xsky.com>
Reviewed-by: Kefu Chai <kchai@redhat.com>

diff --cc src/msg/async/PosixStack.cc
Simple merge

diff --cc src/msg/async/Stack.h
Simple merge

diff --cc src/msg/async/dpdk/DPDKStack.h
Simple merge

diff --cc src/msg/async/rdma/RDMAConnectedSocketImpl.cc
index c64da95b731d72a3b3140b356e5bd585e279bf9e,a95151331a4f862e4b656ba61a8d1b77b81bf599..4eb4d02b053f9c7056a8be2711c33c87f7dc7afa
--- 1/src/msg/async/rdma/RDMAConnectedSocketImpl.cc
--- 2/src/msg/async/rdma/RDMAConnectedSocketImpl.cc
+++ b/src/msg/async/rdma/RDMAConnectedSocketImpl.cc
@@@ -269,59 -356,13 +269,12 @@@ ssize_t RDMAConnectedSocketImpl::read_b
      }
    }
  
 -  if (c != buffers.end() && (*c)->over())
 -    ++c;
 -  buffers.erase(buffers.begin(), c);
 -  ldout(cct, 25) << __func__ << " got " << read  << " bytes, buffers size: " << buffers.size() << dendl;
 -  return read;
 +  buffers.erase(buffers.begin(), pchunk);
 +  ldout(cct, 25) << __func__ << " got " << read_size  << " bytes, buffers size: " << buffers.size() << dendl;
 +  worker->perf_logger->inc(l_msgr_rdma_rx_bytes, read_size);
 +  return read_size;
  }
  
- ssize_t RDMAConnectedSocketImpl::zero_copy_read(bufferptr &data)
- {
-   if (error)
-     return -error;
-   static const int MAX_COMPLETIONS = 16;
-   ibv_wc wc[MAX_COMPLETIONS];
-   ssize_t size = 0;
- 
-   ibv_wc*  response;
-   Chunk* chunk;
-   bool loaded = false;
-   auto iter = buffers.begin();
-   if (iter != buffers.end()) {
-     chunk = *iter;
-     // FIXME need to handle release
-     // auto del = std::bind(&Chunk::post_srq, std::move(chunk), infiniband);
-     buffers.erase(iter);
-     loaded = true;
-     size = chunk->bound;
-   }
- 
-   std::vector<ibv_wc> cqe;
-   get_wc(cqe);
-   if (cqe.empty())
-     return size == 0 ? -EAGAIN : size;
- 
-   ldout(cct, 20) << __func__ << " pool completion queue got " << cqe.size() << " responses."<< dendl;
- 
-   for (size_t i = 0; i < cqe.size(); ++i) {
-     response = &wc[i];
-     chunk = reinterpret_cast<Chunk*>(response->wr_id);
-     chunk->prepare_read(response->byte_len);
-     if (!loaded && i == 0) {
-       // FIXME need to handle release
-       // auto del = std::bind(&Chunk::post_srq, std::move(chunk), infiniband);
-       size = chunk->bound;
-       continue;
-     }
-     buffers.push_back(chunk);
-     iter++;
-   }
- 
-   if (size == 0)
-     return -EAGAIN;
-   return size;
- }
- 
  ssize_t RDMAConnectedSocketImpl::send(bufferlist &bl, bool more)
  {
    if (error) {

diff --cc src/msg/async/rdma/RDMAStack.h
Simple merge

diff --cc src/test/msgr/test_async_networkstack.cc
Simple merge