::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());
- RDMAConnectedSocketImpl* server;
+ 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));