33     if (m_Socket)  in ~ZmqReqRep()
35         zmq_close(m_Socket);  in ~ZmqReqRep()
56     m_Socket = zmq_socket(m_Context, ZMQ_REQ);  in OpenRequester()
62         ret = zmq_connect(m_Socket, address.c_str());  in OpenRequester()
63         zmq_setsockopt(m_Socket, ZMQ_SNDTIMEO, &m_Timeout, sizeof(m_Timeout));  in OpenRequester()
64         zmq_setsockopt(m_Socket, ZMQ_RCVTIMEO, &m_Timeout, sizeof(m_Timeout));  in OpenRequester()
65         zmq_setsockopt(m_Socket, ZMQ_LINGER, &m_Timeout, sizeof(m_Timeout));  in OpenRequester()
72             zmq_close(m_Socket);  in OpenRequester()
84     m_Socket = zmq_socket(m_Context, ZMQ_REP);  in OpenReplier()
85     if (not m_Socket)  in OpenReplier()  local
90     int error = zmq_bind(m_Socket, address.c_str());  in OpenReplier()
96     zmq_setsockopt(m_Socket, ZMQ_RCVTIMEO, &m_Timeout, sizeof(m_Timeout));  in OpenReplier()
97     zmq_setsockopt(m_Socket, ZMQ_LINGER, &m_Timeout, sizeof(m_Timeout));  in OpenReplier()
102     int bytes = zmq_recv(m_Socket, m_ReceiverBuffer.data(),  in ReceiveRequest()
115     zmq_send(m_Socket, reply->data(), reply->size(), 0);  in SendReply()
120     zmq_send(m_Socket, reply, size, 0);  in SendReply()
195         ret = zmq_send(m_Socket, request, size, 0);  in Request()
201             zmq_close(m_Socket);  in Request()
210         ret = zmq_recv(m_Socket, m_ReceiverBuffer.data(),  in Request()
217             zmq_close(m_Socket);  in Request()