ResponsePtr SocketClient::askCynaraServer(RequestPtr request) {
//pass request to protocol
- RequestContextPtr context = std::make_shared<RequestContext>(-1, ResponseTakerPtr(),
- m_writeQueue);
+ RequestContextPtr context = std::make_shared<RequestContext>(ResponseTakerPtr(), m_writeQueue);
request->execute(request, m_protocol, context);
//send request to cynara
class RequestContext {
private:
- int m_desc;
ResponseTakerWeakPtr m_responseTaker;
BinaryQueue &m_responseQueue;
public:
- RequestContext(int desc, ResponseTakerPtr responseTaker, BinaryQueue &responseQueue)
- : m_desc(desc), m_responseTaker(responseTaker), m_responseQueue(responseQueue) {
+ RequestContext(ResponseTakerPtr responseTaker, BinaryQueue &responseQueue)
+ : m_responseTaker(responseTaker), m_responseQueue(responseQueue) {
}
void returnResponse(RequestContextPtr self, ResponsePtr response) const {
LOGD("request extracted");
//build context
- auto context = std::make_shared<RequestContext>(fd, desc.responseTaker(),
+ auto context = std::make_shared<RequestContext>(desc.responseTaker(),
desc.writeQueue());
//pass request to request taker
req->execute(req, requestTaker(), context);