Home
last modified time | relevance | path

Searched refs:peerConnectDecision_ (Results 1 - 4 of 4) sorted by relevance

/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/allconnectmgr/
H A Ddsched_all_connect_manager.cpp235 return peerConnectDecision_.find(peerNetworkId) != peerConnectDecision_.end(); in WaitAllConnectApplyCb()
238 if (peerConnectDecision_.find(peerNetworkId) == peerConnectDecision_.end()) { in WaitAllConnectApplyCb()
242 int32_t ret = peerConnectDecision_.at(peerNetworkId).load() ? ERR_OK : DMS_CONNECT_APPLY_REJECT_FAILED; in WaitAllConnectApplyCb()
244 GetAnonymStr(peerNetworkId).c_str(), peerConnectDecision_.at(peerNetworkId).load()); in WaitAllConnectApplyCb()
245 peerConnectDecision_.erase(peerNetworkId); in WaitAllConnectApplyCb()
254 peerConnectDecision_[peerNetworkId] = isSupport; in NotifyAllConnectDecision()
/foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/
H A Ddsched_continue_manager.cpp110 peerConnectDecision_[peerDeviceId] = isSupport; in NotifyAllConnectDecision()
318 if (peerConnectDecision_.find(peerDeviceId) != peerConnectDecision_.end()) { in HandleContinueMissionWithBundleName()
319 peerConnectDecision_.erase(peerDeviceId); in HandleContinueMissionWithBundleName()
338 return peerConnectDecision_.find(peerDeviceId) != peerConnectDecision_.end() && in WaitAllConnectDecision()
339 peerConnectDecision_.at(peerDeviceId).load(); in WaitAllConnectDecision()
342 if (peerConnectDecision_.find(peerDeviceId) == peerConnectDecision_.end()) { in WaitAllConnectDecision()
347 if (!peerConnectDecision_ in WaitAllConnectDecision()
[all...]
/foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/allconnectmgr/
H A Ddsched_all_connect_manager.h73 std::map<std::string, std::atomic<bool>> peerConnectDecision_; member in OHOS::DistributedSchedule::DSchedAllConnectManager
/foundation/ability/dmsfwk/services/dtbschedmgr/include/continue/
H A Ddsched_continue_manager.h109 std::map<std::string, std::atomic<bool>> peerConnectDecision_; member in OHOS::DistributedSchedule::DSchedContinueManager

Completed in 3 milliseconds