Lines Matching refs:_pelQueue
64 if (!_pelQueue.empty() && _dataIface.isHostUp()) in HostNotifier()
87 _pelQueue.push_back(pel.id()); in addPELToQueue()
180 _pelQueue.push_back(pel.id()); in newLogCallback()
194 auto firstPEL = _pelQueue.size() == 1; in newLogCallback()
208 auto queueIt = std::find(_pelQueue.begin(), _pelQueue.end(), id); in deleteLogCallback()
209 if (queueIt != _pelQueue.end()) in deleteLogCallback()
212 _pelQueue.erase(queueIt); in deleteLogCallback()
264 "ID", lg2::hex, _pelQueue.front()); in doNewLogNotify()
277 while (!doNotify && !_pelQueue.empty()) in doNewLogNotify()
279 id = _pelQueue.front(); in doNewLogNotify()
280 _pelQueue.pop_front(); in doNewLogNotify()
311 _pelQueue.push_front(id); in doNewLogNotify()
330 if (hostUp && !_pelQueue.empty()) in hostStateChange()
345 _pelQueue.push_back(id); in hostStateChange()
379 if (!_hostFull && !_pelQueue.empty()) in commandResponse()
389 _pelQueue.push_front(id); in commandResponse()
399 _pelQueue.front()); in retryTimerExpired()
417 _pelQueue.push_front(_inProgressPEL); in stopCommand()
454 if (!_pelQueue.empty()) in ackPEL()
475 if (std::find(_pelQueue.begin(), _pelQueue.end(), id) == in setHostFull()
476 _pelQueue.end()) in setHostFull()
478 _pelQueue.push_front(id); in setHostFull()