Searched refs:msgQueue_ (Results 1 – 10 of 10) sorted by relevance
41 msgQueue_.push(inMsg); in PutMsg()118 while (!msgQueue_.empty()) { in UpdateMsgMap()119 msgTmpQueue.push(msgQueue_.front()); in UpdateMsgMap()120 msgQueue_.pop(); in UpdateMsgMap()189 while (!msgQueue_.empty()) { in GetLastMsgFromQueue()190 Message *msg = msgQueue_.front(); in GetLastMsgFromQueue()191 msgQueue_.pop(); in GetLastMsgFromQueue()192 if (msgQueue_.empty()) { // means last msg in GetLastMsgFromQueue()219 while (!msgQueue_.empty()) { in ClearMsgQueue()220 Message *msg = msgQueue_.front(); in ClearMsgQueue()[all …]
59 std::queue<Message *> msgQueue_; variable
239 replyCond_.Wait(lock, [this, time] { return msgQueue_.find(time) == msgQueue_.end(); }); in SubmitJobOnce()256 … if (msgQueue_.empty() && ((runningState_.load() != RunningState::STARTED) || jobQueue_.empty())) { in UpdateTop()260 if (msgQueue_.empty()) { in UpdateTop()264 topProcessUs_ = msgQueue_.begin()->first; in UpdateTop()267 int64_t msgProcessTime = msgQueue_.begin()->first; in UpdateTop()314 nextJob = std::move(msgQueue_.begin()->second); in HandleJob()315 msgQueue_.erase(msgQueue_.begin()); in HandleJob()344 … while (msgQueue_.find(processTime) != msgQueue_.end()) { // To prevent dropping job unexpectedly in InsertJob()348 msgQueue_[processTime] = std::move(job); in InsertJob()
85 msgQueue_.enqueue(msg); in PostMessage()94 if (msgQueue_.isEmpty()) { in GetMessage()98 const AbilityInnerMsg *msg = msgQueue_.dequeue(); in GetMessage()
60 QQueue<const AbilityInnerMsg *> msgQueue_; variable
131 while (!msgQueue_.empty()) { in Close()132 Message *inMsg = msgQueue_.front(); in Close()133 msgQueue_.pop_front(); in Close()407 if (msgQueue_.empty()) { in DealMsgUtilQueueEmpty()410 inMsg = msgQueue_.front(); in DealMsgUtilQueueEmpty()411 msgQueue_.pop_front(); in DealMsgUtilQueueEmpty()555 auto iter = std::find_if(msgQueue_.begin(), msgQueue_.end(), in PutMsgIntoQueue()559 if (iter != msgQueue_.end()) { // LCOV_EXCL_BR_LINE in PutMsgIntoQueue()566 msgQueue_.push_back(inMsg); in PutMsgIntoQueue()568 …ngine] The quantity of executing threads is beyond maximum. msgQueueSize = %zu", msgQueue_.size()); in PutMsgIntoQueue()
228 std::deque<Message *> msgQueue_; variable
123 msgQueue_.enqueue(message); in PostMessage()132 if (msgQueue_.isEmpty()) { in GetMessage()136 const AMSMessage *msg = msgQueue_.dequeue(); in GetMessage()
90 QQueue<const AMSMessage *> msgQueue_; variable
111 std::map<int64_t, std::function<void()>> msgQueue_; // msg will be sorted by timeUs variable