Searched refs:requestTargetQueue_ (Results 1 – 3 of 3) sorted by relevance
87 requestTargetQueue_.push_back(target); in AddSyncTarget()171 auto iter = std::find_if(requestTargetQueue_.begin(), requestTargetQueue_.end(), in RemoveSyncOperation()178 if (iter != requestTargetQueue_.end()) { in RemoveSyncOperation()183 requestTargetQueue_.erase(iter); in RemoveSyncOperation()192 for (auto &requestTarget : requestTargetQueue_) { in ClearSyncTarget()198 requestTargetQueue_.clear(); in ClearSyncTarget()212 return requestTargetQueue_.empty() && responseTargetQueue_.empty(); in IsTargetQueueEmpty()243 if (!requestTargetQueue_.empty()) { in MoveToNextTarget()244 tmpTarget = requestTargetQueue_.front(); in MoveToNextTarget()245 requestTargetQueue_.pop_front(); in MoveToNextTarget()[all …]
253 std::list<ISyncTarget *> requestTargetQueue_; variable
103 auto iter = std::find_if(requestTargetQueue_.begin(), requestTargetQueue_.end(), in AddSyncOperation()115 if (iter != requestTargetQueue_.end()) { in AddSyncOperation()254 …("[SingleVerSyncTaskContext] request taskcount=%zu, responsecount=%zu", requestTargetQueue_.size(), in ClearAllSyncTask()256 while (!requestTargetQueue_.empty()) { in ClearAllSyncTask()257 ISyncTarget *tmpTarget = requestTargetQueue_.front(); in ClearAllSyncTask()258 requestTargetQueue_.pop_front(); in ClearAllSyncTask()