Lines Matching refs:endpointMessageQueues
179 endpointMessageQueues[eid]->activeRequest = false; in instanceIdExpiryCallBack()
199 if (endpointMessageQueues[eid]->activeRequest || in pollEndpointQueue()
200 endpointMessageQueues[eid]->requestQueue.empty()) in pollEndpointQueue()
205 endpointMessageQueues[eid]->activeRequest = true; in pollEndpointQueue()
206 auto requestMsg = endpointMessageQueues[eid]->requestQueue.front(); in pollEndpointQueue()
207 endpointMessageQueues[eid]->requestQueue.pop_front(); in pollEndpointQueue()
224 endpointMessageQueues[eid]->activeRequest = false; in pollEndpointQueue()
239 endpointMessageQueues[eid]->activeRequest = false; in pollEndpointQueue()
277 if (endpointMessageQueues.contains(eid)) in registerRequest()
279 endpointMessageQueues[eid]->requestQueue.push_back(inputRequest); in registerRequest()
285 endpointMessageQueues[eid] = in registerRequest()
324 endpointMessageQueues[eid]->activeRequest = false; in unregisterRequest()
332 if (!endpointMessageQueues.contains(eid)) in unregisterRequest()
339 auto requestMsg = endpointMessageQueues[eid]->requestQueue; in unregisterRequest()
347 it = endpointMessageQueues[eid]->requestQueue.erase(it); in unregisterRequest()
390 endpointMessageQueues[eid]->activeRequest = false; in handleResponse()
434 endpointMessageQueues; member in pldm::requester::Handler