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()
652 boost::container::devector<PendingRequest> requestQueue; member in crow::ConnectionPool661 if (requestQueue.empty()) in setConnProps()668 PendingRequest& nextReq = requestQueue.front(); in setConnProps()676 requestQueue.pop_front(); in setConnProps()692 if (!requestQueue.empty()) in sendNext()696 requestQueue.size(), destIP, connId); in sendNext()779 else if (requestQueue.size() < maxRequestQueueSize) in sendData()783 requestQueue.emplace_back(std::move(thisReq), std::move(cb)); in sendData()