| /ohos5.0/foundation/multimedia/av_session/services/session/server/ |
| H A D | session_stack.cpp | 37 if (it == sessions_.end()) { in UpdateSessionSort()
41 sessions_.erase(it); in UpdateSessionSort()
51 for (auto it = sessions_.begin(); it != sessions_.end();) { in RemoveSession()
56 it = sessions_.erase(it); in RemoveSession()
69 for (auto it = sessions_.begin(); it != sessions_.end();) { in RemoveSession()
73 it = sessions_.erase(it); in RemoveSession()
86 if (it == sessions_.end()) { in RemoveSession()
91 sessions_.erase(it); in RemoveSession()
100 if (it == sessions_.end()) { in GetSession()
110 for (auto it = sessions_.begin(); it != sessions_.end(); it++) { in GetSessionsByPid()
[all …]
|
| H A D | session_stack.h | 51 std::map<std::pair<pid_t, std::string>, sptr<AVSessionItem>> sessions_;
|
| /ohos5.0/base/update/updateservice/frameworks/js/napi/update/src/ |
| H A D | session_manager.cpp | 53 sessions_.erase(sessionId); in RemoveSession()
60 if (sessions_.empty()) { in GetFirstSessionId()
73 if (iter == sessions_.end()) { in GetNextSessionId()
77 if (iter == sessions_.end()) { in GetNextSessionId()
96 if (iter == sessions_.end()) { in ProcessUnsubscribe()
103 iter = sessions_.erase(iter); in ProcessUnsubscribe()
127 for (auto iter = sessions_.begin(); iter != sessions_.end();) { in Unsubscribe()
142 iter = sessions_.erase(iter); in Unsubscribe()
164 if (iter == sessions_.end()) { in FindSessionByHandle()
188 for (auto &iter : sessions_) { in FindSessionByHandle()
[all …]
|
| /ohos5.0/base/msdp/device_status/intention/ipc/socket/src/ |
| H A D | socket_session_manager.cpp | 124 auto iter = std::find_if(sessions_.cbegin(), sessions_.cend(), in FindSessionByPid()
161 if (auto iter = sessions_.find(fd); iter != sessions_.end()) { in ReleaseSession()
163 sessions_.erase(iter); in ReleaseSession()
177 auto iter = std::find_if(sessions_.cbegin(), sessions_.cend(), in DeleteCollaborationServiceByName()
181 if (iter != sessions_.end()) { in DeleteCollaborationServiceByName()
187 sessions_.erase(iter); in DeleteCollaborationServiceByName()
196 auto iter = std::find_if(sessions_.cbegin(), sessions_.cend(), in ReleaseSessionByPid()
200 if (iter != sessions_.end()) { in ReleaseSessionByPid()
206 sessions_.erase(iter); in ReleaseSessionByPid()
224 auto iter = sessions_.find(fd); in FindSession()
[all …]
|
| /ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/ |
| H A D | dsched_transport_softbus_adapter.cpp | 119 if (!sessions_.empty()) { in ConnectDevice()
120 for (auto iter = sessions_.begin(); iter != sessions_.end(); iter++) { in ConnectDevice()
253 for (auto iter = sessions_.begin(); iter != sessions_.end(); iter++) { in DisconnectDevice()
259 if (sessionId != 0 && sessions_[sessionId] != nullptr && sessions_[sessionId]->OnDisconnect()) { in DisconnectDevice()
263 sessions_.erase(sessionId); in DisconnectDevice()
285 for (auto iter = sessions_.begin(); iter != sessions_.end(); iter++) { in GetSessionIdByDeviceId()
307 … if (sessions_.empty() || sessions_.count(sessionId) == 0 || sessions_[sessionId] == nullptr) { in OnShutdown()
341 for (auto iter = sessions_.begin(); iter != sessions_.end(); iter++) { in ReleaseChannel()
347 sessions_.clear(); in ReleaseChannel()
366 if (!sessions_.count(sessionId) || sessions_[sessionId] == nullptr) { in SendData()
[all …]
|
| /ohos5.0/foundation/multimodalinput/input/intention/ipc/socket/src/ |
| H A D | socket_session_manager.cpp | 120 auto iter = std::find_if(sessions_.cbegin(), sessions_.cend(), in FindSessionByPid()
124 return (iter != sessions_.cend() ? iter->second : nullptr); in FindSessionByPid()
156 if (auto iter = sessions_.find(fd); iter != sessions_.end()) { in ReleaseSession()
158 sessions_.erase(iter); in ReleaseSession()
171 auto iter = std::find_if(sessions_.cbegin(), sessions_.cend(), in ReleaseSessionByPid()
175 if (iter != sessions_.end()) { in ReleaseSessionByPid()
181 sessions_.erase(iter); in ReleaseSessionByPid()
198 auto iter = sessions_.find(fd); in FindSession()
199 return (iter != sessions_.cend() ? iter->second : nullptr); in FindSession()
207 for (auto &[_, session] : sessions_) { in DumpSession()
[all …]
|
| /ohos5.0/base/msdp/device_status/intention/adapters/dsoftbus_adapter/src/ |
| H A D | dsoftbus_adapter_impl.cpp | 157 if (auto iter = sessions_.find(networkId); iter != sessions_.end()) { in CloseSession()
159 sessions_.erase(iter); in CloseSession()
226 if (sessions_.empty()) { in BroadcastPacket()
282 if (auto iter = sessions_.find(networkId); iter != sessions_.cend()) { in OnBind()
289 sessions_.erase(iter); in OnBind()
307 auto iter = std::find_if(sessions_.cbegin(), sessions_.cend(), in OnShutdown()
316 sessions_.erase(iter); in OnShutdown()
333 auto iter = std::find_if(sessions_.begin(), sessions_.end(), in OnBytes()
430 if (sessions_.find(networkId) != sessions_.end()) { in OpenSessionLocked()
485 std::for_each(sessions_.begin(), sessions_.end(), [](const auto &item) { in CloseAllSessionsLocked()
[all …]
|
| /ohos5.0/foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/src/ |
| H A D | dsoftbus_adapter_impl.cpp | 162 if (auto iter = sessions_.find(networkId); iter != sessions_.end()) { in CloseSession()
164 sessions_.erase(iter); in CloseSession()
231 if (sessions_.empty()) { in BroadcastPacket()
280 if (auto iter = sessions_.find(networkId); iter != sessions_.cend()) { in OnBind()
287 sessions_.erase(iter); in OnBind()
305 auto iter = std::find_if(sessions_.cbegin(), sessions_.cend(), in OnShutdown()
314 sessions_.erase(iter); in OnShutdown()
331 auto iter = std::find_if(sessions_.begin(), sessions_.end(), in OnBytes()
428 if (sessions_.find(networkId) != sessions_.end()) { in OpenSessionLocked()
483 std::for_each(sessions_.begin(), sessions_.end(), [](const auto &item) { in CloseAllSessionsLocked()
[all …]
|
| /ohos5.0/base/update/updateservice/frameworks/js/napi/update/include/ |
| H A D | update_client.h | 74 auto iter = sessions_.find(sessId); in GetUpdateSession()
75 if (iter != sessions_.end()) { in GetUpdateSession()
|
| H A D | session_manager.h | 55 std::map<uint32_t, std::shared_ptr<BaseSession>> sessions_; variable
|
| /ohos5.0/foundation/filemanagement/dfs_service/services/cloudfiledaemon/include/fuse_manager/ |
| H A D | fuse_manager.h | 39 map<int32_t, struct fuse_session *> sessions_;
|
| /ohos5.0/foundation/multimodalinput/input/intention/ipc/socket/include/ |
| H A D | socket_session_manager.h | 76 std::map<int32_t, std::shared_ptr<SocketSession>> sessions_; variable
|
| /ohos5.0/base/msdp/device_status/intention/ipc/socket/include/ |
| H A D | socket_session_manager.h | 78 std::map<int32_t, std::shared_ptr<SocketSession>> sessions_; variable
|
| /ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/transport/ |
| H A D | dsched_transport_softbus_adapter.h | 75 std::map<int32_t, std::shared_ptr<DSchedSoftbusSession>> sessions_;
|
| /ohos5.0/foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/include/ |
| H A D | dsoftbus_adapter_impl.h | 111 std::map<std::string, Session> sessions_; variable
|
| /ohos5.0/base/msdp/device_status/intention/adapters/dsoftbus_adapter/include/ |
| H A D | dsoftbus_adapter_impl.h | 112 std::map<std::string, Session> sessions_; variable
|
| /ohos5.0/base/msdp/device_status/test/unittest/intention/ipc/src/ |
| H A D | socket_session_test.cpp | 594 g_socketSessionManager->sessions_.emplace(i, nullptr);
598 g_socketSessionManager->sessions_.clear();
|
| /ohos5.0/base/msdp/device_status/test/unittest/intention/cooperate/src/ |
| H A D | cooperate_plugin_test.cpp | 345 g_socketSessionMgr.sessions_.clear();
|