Home
last modified time | relevance | path

Searched refs:sessions_ (Results 1 - 9 of 9) sorted by relevance

/base/msdp/device_status/intention/ipc/socket/src/
H A Dsocket_session_manager.cpp59 std::for_each(sessions_.cbegin(), sessions_.cend(), [this](const auto &item) { in Disable()
63 sessions_.clear(); in Disable()
141 auto iter = std::find_if(sessions_.cbegin(), sessions_.cend(), in FindSessionByPid()
145 return (iter != sessions_.cend() ? iter->second : nullptr); in FindSessionByPid()
208 if (auto iter = sessions_.find(fd); iter != sessions_.end()) { in ReleaseSession()
210 sessions_.erase(iter); in ReleaseSession()
224 auto iter = std::find_if(sessions_ in DeleteCollaborationServiceByName()
[all...]
/base/update/updateservice/frameworks/js/napi/update/src/
H A Dsession_manager.cpp47 sessions_.insert(make_pair(session->GetSessionId(), session)); in AddSession()
53 sessions_.erase(sessionId); in RemoveSession()
60 if (sessions_.empty()) { in GetFirstSessionId()
63 sessionId = sessions_.begin()->second->GetSessionId(); in GetFirstSessionId()
72 auto iter = sessions_.find(sessionId); in GetNextSessionId()
73 if (iter == sessions_.end()) { in GetNextSessionId()
77 if (iter == sessions_.end()) { in GetNextSessionId()
95 auto iter = sessions_.find(currSessId); in ProcessUnsubscribe()
96 if (iter == sessions_.end()) { in ProcessUnsubscribe()
103 iter = sessions_ in ProcessUnsubscribe()
[all...]
/base/msdp/device_status/intention/adapters/dsoftbus_adapter/src/
H A Ddsoftbus_adapter_impl.cpp168 if (auto iter = sessions_.find(networkId); iter != sessions_.end()) { in CloseSession()
170 sessions_.erase(iter); in CloseSession()
186 auto iter = sessions_.find(networkId); in FindConnection()
187 return (iter != sessions_.end() ? iter->second.socket_ : -1); in FindConnection()
237 if (sessions_.empty()) { in BroadcastPacket()
250 for (const auto &elem : sessions_) { in BroadcastPacket()
268 auto iter = sessions_.find(networkId); in HasSessionExisted()
269 return (iter != sessions_.end() && iter->second.socket_ != INVALID_SOCKET); in HasSessionExisted()
293 if (auto iter = sessions_ in OnBind()
[all...]
/base/update/updateservice/frameworks/js/napi/update/include/
H A Dupdate_client.h74 auto iter = sessions_.find(sessId); in GetUpdateSession()
75 if (iter != sessions_.end()) { in GetUpdateSession()
H A Dsession_manager.h55 std::map<uint32_t, std::shared_ptr<BaseSession>> sessions_; member in OHOS::UpdateEngine::SessionManager
/base/msdp/device_status/intention/ipc/socket/include/
H A Dsocket_session_manager.h80 std::map<int32_t, std::shared_ptr<SocketSession>> sessions_; member in OHOS::Msdp::DeviceStatus::final
/base/msdp/device_status/intention/adapters/dsoftbus_adapter/include/
H A Ddsoftbus_adapter_impl.h120 std::map<std::string, Session> sessions_; member in OHOS::Msdp::DeviceStatus::final
/base/msdp/device_status/test/unittest/intention/ipc/src/
H A Dsocket_session_test.cpp594 g_socketSessionManager->sessions_.emplace(i, nullptr); in HWTEST_F()
598 g_socketSessionManager->sessions_.clear(); in HWTEST_F()
/base/msdp/device_status/test/unittest/intention/cooperate/src/
H A Dcooperate_plugin_test.cpp353 g_socketSessionMgr.sessions_.clear(); in HWTEST_F()

Completed in 9 milliseconds