| /foundation/ability/ability_runtime/services/abilitymgr/src/data_ability/ |
| H A D | data_ability_record.cpp | 221 auto &clientInfo = clients_.emplace_back(); in AddClient()
249 if (clients_.empty()) { in RemoveClient()
254 for (auto it(clients_.begin()); it != clients_.end(); ++it) { in RemoveClient()
256 clients_.erase(it); in RemoveClient()
281 if (clients_.empty()) { in RemoveClients()
294 auto it = clients_.begin(); in RemoveClients()
295 while (it != clients_.end()) { in RemoveClients()
304 it = clients_.erase(it); in RemoveClients()
320 auto it = clients_ in RemoveClients()
[all...] |
| /foundation/ai/ai_engine/services/server/communication_adapter/source/ |
| H A D | sa_async_handler.cpp | 44 for (auto &iter : clients_) { in ~SaAsyncHandler()
47 clients_.clear(); in ~SaAsyncHandler()
53 auto iter = clients_.find(clientId); in StopClientListenerHandler()
54 CHK_RET_NONE(iter == clients_.end()); in StopClientListenerHandler()
62 ClientListenerHandlerMap::iterator iter = clients_.find(clientId); in RemoveClientListenerHandler()
63 CHK_RET_NONE(iter == clients_.end()); in RemoveClientListenerHandler()
66 clients_.erase(iter); in RemoveClientListenerHandler()
72 ClientListenerHandlerMap::iterator iter = clients_.find(clientId); in FindClientListenerHandler()
73 CHK_RET(iter == clients_.end(), nullptr); in FindClientListenerHandler()
85 clients_[clientI in AddClientListenerHandler()
[all...] |
| /foundation/arkui/napi/sample/native_module_netserver/ |
| H A D | net_server.cpp | 31 clients_ = nullptr; in NetServer()
98 if (that->clients_ == nullptr) { in OnConnection()
99 that->clients_ = new NetClient(); in OnConnection()
102 tmp->next = that->clients_; in OnConnection()
103 that->clients_ = tmp; in OnConnection()
106 uv_tcp_init(that->loop_, (uv_tcp_t*)&that->clients_->tcp); in OnConnection()
107 that->clients_->tcp.data = server->data; in OnConnection()
108 uv_accept(server, (uv_stream_t*)&that->clients_->tcp); in OnConnection()
109 uv_read_start((uv_stream_t*)&that->clients_->tcp, EchoAlloc, AfterRead); in OnConnection()
123 for (NetClient* i = that->clients_; in OnServerClose()
[all...] |
| H A D | netserver.cpp | 30 clients_ = nullptr; in NetServer()
97 if (that->clients_ == nullptr) { in OnConnection()
98 that->clients_ = new NetClient(); in OnConnection()
101 tmp->next = that->clients_; in OnConnection()
102 that->clients_ = tmp; in OnConnection()
105 uv_tcp_init(that->loop_, (uv_tcp_t*)&that->clients_->tcp); in OnConnection()
106 that->clients_->tcp.data = server->data; in OnConnection()
107 uv_accept(server, (uv_stream_t*)&that->clients_->tcp); in OnConnection()
108 uv_read_start((uv_stream_t*)&that->clients_->tcp, EchoAlloc, AfterRead); in OnConnection()
122 for (NetClient* i = that->clients_; in OnServerClose()
[all...] |
| H A D | net_server.h | 73 NetClient* clients_; member in NetServer
|
| H A D | netserver.h | 114 NetClient* clients_; member in NetServer
|
| /foundation/ai/ai_engine/services/server/communication_adapter/include/ |
| H A D | sa_async_handler.h | 130 ClientListenerHandlerMap clients_;
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/gatt/ |
| H A D | gatt_client_service.cpp | 94 std::map<int, ClientApplication> clients_ = {}; member
1064 if (clients_.size() >= MAXIMUM_NUMBER_APPLICATION) { in RegisterApplication()
1070 if (clients_.emplace(appid, ClientApplication(callback, device, *profile_, isShared)).second) { in RegisterApplication()
1080 if (clients_.emplace(appid, ClientApplication(callback, device, *profile_, isShared)).second) { in RegisterApplication()
1103 clients_.erase(client.value()); in DeregisterApplication()
1117 for (auto &it : clients_) { in OnConnect()
1138 for (auto &it : clients_) { in OnDisconnect()
1159 for (auto &it : clients_) { in OnConnectionChanged()
1177 for (auto it : clients_) { in OnConnectionParameterChanged()
1192 auto it = clients_ in GetValidApplication()
[all...] |
| /foundation/ability/ability_runtime/services/abilitymgr/include/data_ability/ |
| H A D | data_ability_record.h | 72 std::list<ClientInfo> clients_ {};
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_data_service.h | 183 ConcurrentMap<uint32_t, std::map<int32_t, KvStoreClientDeathObserverImpl>> clients_; member in OHOS::DistributedKv::KvStoreDataService
|
| H A D | kvstore_data_service.cpp | 81 : SystemAbility(runOnCreate), clients_() in KvStoreDataService()
93 : SystemAbility(systemAbilityId, runOnCreate), clients_() in KvStoreDataService()
107 clients_.Clear(); in ~KvStoreDataService()
205 clients_.Compute( in RegisterClientDeathObserver()
222 clients_.ComputeIfPresent(token, [&impl, pid](auto &, auto &value) { in AppExit()
|
| /foundation/distributeddatamgr/pasteboard/services/core/include/ |
| H A D | pasteboard_service.h | 341 ConcurrentMap<pid_t, sptr<PasteboardDeathRecipient>> clients_; member in OHOS::MiscServices::final
|
| /foundation/distributeddatamgr/pasteboard/services/core/src/ |
| H A D | pasteboard_service.cpp | 106 clients_.Clear(); in ~PasteboardService()
2372 clients_.Erase(pid); in AppExit()
2394 clients_.InsertOrAssign(pid, std::move(deathRecipient)); in RegisterClientDeathObserver()
|
| /foundation/ability/ability_runtime/test/unittest/data_ability_manager_test/ |
| H A D | data_ability_manager_test.cpp | 496 dataAbilityRecord->clients_.push_back(ci); in HWTEST_F()
|