: cct(cct), connected(0), error(0), infiniband(ib),
dispatcher(s), worker(w), lock("RDMAConnectedSocketImpl::lock"),
is_server(false), con_handler(new C_handle_connection(this)),
- active(false), detached(false)
+ active(false)
{
qp = infiniband->create_queue_pair(
cct, s->get_tx_cq(), s->get_rx_cq(), IBV_QPT_RC);
Mutex lock;
std::vector<ibv_wc> wc;
bool is_server;
- RDMAServerSocketImpl* ssi;
EventCallbackRef con_handler;
int tcp_fd = -1;
bool active;// qp is active ?
- bool detached;
void notify();
ssize_t read_buffers(char* buf, size_t len);