Searched refs:requestQueue (Results 1 – 2 of 2) sorted by relevance
100 std::deque<std::shared_ptr<RegisteredRequest>> requestQueue; //!< Queue member200 endpointMessageQueues[eid]->requestQueue.empty()) in pollEndpointQueue()206 auto requestMsg = endpointMessageQueues[eid]->requestQueue.front(); in pollEndpointQueue()207 endpointMessageQueues[eid]->requestQueue.pop_front(); in pollEndpointQueue()279 endpointMessageQueues[eid]->requestQueue.push_back(inputRequest); in registerRequest()346 auto requestMsg = endpointMessageQueues[eid]->requestQueue; in unregisterRequest()354 it = endpointMessageQueues[eid]->requestQueue.erase(it); in unregisterRequest()
660 boost::container::devector<PendingRequest> requestQueue; member in crow::ConnectionPool669 if (requestQueue.empty()) in setConnProps()676 PendingRequest& nextReq = requestQueue.front(); in setConnProps()684 requestQueue.pop_front(); in setConnProps()700 if (!requestQueue.empty()) in sendNext()704 requestQueue.size(), destIP, connId); in sendNext()787 else if (requestQueue.size() < maxRequestQueueSize) in sendData()791 requestQueue.emplace_back(std::move(thisReq), std::move(cb)); in sendData()