]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
Merge pull request #13940 from Adirl/out
authorHaomai Wang <haomaiwang@gmail.com>
Tue, 11 Apr 2017 01:13:03 +0000 (09:13 +0800)
committerGitHub <noreply@github.com>
Tue, 11 Apr 2017 01:13:03 +0000 (09:13 +0800)
msg/async/rdma: Update fix broken compilation

Reviewed-by: Haomai Wang <haomai@xsky.com>
1  2 
src/msg/async/rdma/RDMAServerSocketImpl.cc

index 1c5f170b4d0fea6fe141bd393011bbdfceb7cc8f,8f5fd81d3dc751eab08adf86f2a031979c1c3dd3..a9665d96edf016260e24a9a462a2cf210b466eef
@@@ -110,12 -96,16 +110,16 @@@ int RDMAServerConnTCP::accept(Connected
      ::close(sd);
      return -errno;
    }
+   assert(NULL != out); //out should not be NULL in accept connection
+   out->set_sockaddr((sockaddr*)&ss);
    net.set_priority(sd, opt.priority, out->get_family());
  
 -  RDMAConnectedSocketImplserver;
 +  RDMAConnectedSocketImpl *server;
    //Worker* w = dispatcher->get_stack()->get_worker();
 -  server = new RDMAConnectedSocketImpl(cct, infiniband, dispatcher, dynamic_cast<RDMAWorker*>(w));
 -  server->set_accept_fd(sd);
 +  RDMAConnTCPInfo conn_info = { sd };
 +  server = new RDMAConnectedSocketImpl(cct, infiniband, dispatcher, dynamic_cast<RDMAWorker*>(w), &conn_info);
    ldout(cct, 20) << __func__ << " accepted a new QP, tcp_fd: " << sd << dendl;
    std::unique_ptr<RDMAConnectedSocketImpl> csi(server);
    *sock = ConnectedSocket(std::move(csi));