Searched refs:responseTargetQueue_ (Results 1 – 3 of 3) sorted by relevance
167 if (!responseTargetQueue_.empty()) { in PopResponseTarget()168 ISyncTarget *tmpTarget = responseTargetQueue_.front(); in PopResponseTarget()169 responseTargetQueue_.pop_front(); in PopResponseTarget()181 return responseTargetQueue_.size(); in GetRspTargetQueueSize()255 responseTargetQueue_.size()); in ClearAllSyncTask()264 while (!responseTargetQueue_.empty()) { in ClearAllSyncTask()265 ISyncTarget *tmpTarget = responseTargetQueue_.front(); in ClearAllSyncTask()266 responseTargetQueue_.pop_front(); in ClearAllSyncTask()377 auto iter = std::find_if(responseTargetQueue_.begin(), responseTargetQueue_.end(), in FindResponseSyncTarget()381 if (iter == responseTargetQueue_.end()) { in FindResponseSyncTarget()[all …]
89 responseTargetQueue_.push_back(target); in AddSyncTarget()200 for (auto &responseTarget : responseTargetQueue_) { in ClearSyncTarget()206 responseTargetQueue_.clear(); in ClearSyncTarget()212 return requestTargetQueue_.empty() && responseTargetQueue_.empty(); in IsTargetQueueEmpty()241 while (!requestTargetQueue_.empty() || !responseTargetQueue_.empty()) { in MoveToNextTarget()247 tmpTarget = responseTargetQueue_.front(); in MoveToNextTarget()248 responseTargetQueue_.pop_front(); in MoveToNextTarget()746 totalSyncTaskCount = requestTargetQueue_.size() + responseTargetQueue_.size(); in Dump()752 reponseTaskCount = responseTargetQueue_.size(); in Dump()851 return static_cast<int32_t>(responseTargetQueue_.size()); in GetResponseTaskCount()
254 std::list<ISyncTarget *> responseTargetQueue_; variable