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()
673 boost::container::devector<PendingRequest> requestQueue; member in crow::ConnectionPool682 if (requestQueue.empty()) in setConnProps()689 PendingRequest& nextReq = requestQueue.front(); in setConnProps()697 requestQueue.pop_front(); in setConnProps()713 if (!requestQueue.empty()) in sendNext()717 requestQueue.size(), destIP, connId); in sendNext()800 else if (requestQueue.size() < maxRequestQueueSize) in sendData()804 requestQueue.emplace_back(std::move(thisReq), std::move(cb)); in sendData()