| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator.cpp | 180 void Communicator::OnConnectChange(const std::string &target, bool isConnect) in OnConnectChange() argument
187 if (isConnect) { in OnConnectChange()
193 isConnect); in OnConnectChange()
195 onConnectHandle_(target, isConnect); in OnConnectChange()
|
| H A D | communicator_aggregator.cpp | 518 void CommunicatorAggregator::OnTargetChange(const std::string &target, bool isConnect) in OnTargetChange() argument
528 onConnectHandle_(target, isConnect); in OnTargetChange()
536 if (isConnect) { in OnTargetChange()
548 if (entry.second.second && (!isConnect || (relatedLabels.count(entry.first) != 0))) { in OnTargetChange()
549 entry.second.first->OnConnectChange(target, isConnect); in OnTargetChange()
733 [this](const std::string &target, bool isConnect) { OnTargetChange(target, isConnect); }, in RegCallbackToAdapter() argument
|
| H A D | communicator.h | 62 void OnConnectChange(const std::string &target, bool isConnect);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_communicator.cpp | 111 void VirtualCommunicator::CallbackOnConnect(const std::string &target, bool isConnect) const in CallbackOnConnect()
116 onlineDevicesMap_[target] = isConnect; in CallbackOnConnect()
121 onConnect_(target, isConnect); in CallbackOnConnect()
|
| H A D | virtual_communicator.h | 66 void CallbackOnConnect(const std::string &target, bool isConnect) const;
|
| H A D | virtual_communicator_aggregator.cpp | 94 void VirtualCommunicatorAggregator::RunOnConnectCallback(const std::string &target, bool isConnect) in RunOnConnectCallback() argument
97 onConnect_(target, isConnect); in RunOnConnectCallback()
|
| H A D | virtual_communicator_aggregator.h | 44 void RunOnConnectCallback(const std::string &target, bool isConnect);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_test.cpp | 41 if (isConnect) { in HandleConnectChange()
183 commAA->RegOnConnectCallback([&onlineForAA](const std::string &target, bool isConnect) { in __anonf82a9c550202() argument
184 HandleConnectChange(onlineForAA, target, isConnect);}, nullptr); in __anonf82a9c550202()
201 commBB->RegOnConnectCallback([&onlineForBB](const std::string &target, bool isConnect) { in __anonf82a9c550302() argument
202 HandleConnectChange(onlineForBB, target, isConnect);}, nullptr); in __anonf82a9c550302()
222 HandleConnectChange(onlineForBA, target, isConnect);}, nullptr); in __anonf82a9c550402()
264 HandleConnectChange(online, target, isConnect); \
484 [&onlineForA](const std::string &target, bool isConnect) { in __anonf82a9c550502() argument
485 HandleConnectChange(onlineForA, target, isConnect); in __anonf82a9c550502()
490 [&onlineForB](const std::string &target, bool isConnect) { in __anonf82a9c550602() argument
[all …]
|
| H A D | distributeddb_communicator_deep_test.cpp | 600 OnConnectCallback callback = [&count](const std::string &target, bool isConnect) { in __anonb9037cf20b02() argument
601 if (isConnect) { in __anonb9037cf20b02()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | device_manager.cpp | 93 void DeviceManager::OnDeviceConnectCallback(const std::string &targetDev, bool isConnect) in OnDeviceConnectCallback() argument
98 if (isConnect) { in OnDeviceConnectCallback()
|
| H A D | device_manager.h | 48 void OnDeviceConnectCallback(const std::string &targetDev, bool isConnect);
|
| H A D | sync_engine.cpp | 214 [this, deviceManager = deviceManager_](const std::string &targetDev, bool isConnect) { in StartCommunicator() argument
215 deviceManager->OnDeviceConnectCallback(targetDev, isConnect); in StartCommunicator()
911 [this, deviceManager = deviceManager_](const std::string &targetDev, bool isConnect) { in AllocCommunicator() argument
912 deviceManager->OnDeviceConnectCallback(targetDev, isConnect); in AllocCommunicator()
|
| /ohos5.0/foundation/multimodalinput/input/service/message_handle/src/ |
| H A D | server_msg_handler.cpp | 909 bool isConnect = injectNotice_->ConnectNoticeSrv(); in InitInjectNoticeSource() local
910 if (!isConnect) { in InitInjectNoticeSource()
911 MMI_HILOGD("Injectnotice ConnectNoticeSrv isConnect:%{public}d", isConnect); in InitInjectNoticeSource()
936 bool isConnect = pConnect->IsConnected(); in AddInjectNotice() local
937 MMI_HILOGD("SendNotice %{public}d", isConnect); in AddInjectNotice()
938 if (isConnect) { in AddInjectNotice()
969 bool isConnect = pConnect->IsConnected(); in CloseInjectNotice() local
970 MMI_HILOGD("CloseNotice %{public}d", isConnect); in CloseInjectNotice()
971 if (isConnect) { in CloseInjectNotice()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | communicator_type_define.h | 29 using OnConnectCallback = std::function<void(const std::string &target, bool isConnect)>;
|
| H A D | iadapter.h | 30 using TargetChangeCallback = std::function<void(const std::string &target, bool isConnect)>;
|
| H A D | communicator_aggregator.h | 107 void OnTargetChange(const std::string &target, bool isConnect);
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/ |
| H A D | obex_headers.cpp | 97 …ParseFields(const uint8_t *buf, const uint8_t &code, uint16_t &pos, bool isRequest, bool isConnect) in ParseFields() argument
114 } else if (isConnect) { in ParseFields()
156 bool ObexHeader::Parse(const uint8_t *buf, const uint16_t size, bool isRequest, bool isConnect) in Parse() argument
159 isRequest, isConnect, size); in Parse()
174 ParseFields(buf, code, pos, isRequest, isConnect); in Parse()
317 …_ptr<ObexHeader> ObexHeader::ParseResponse(const uint8_t *buf, const uint16_t size, bool isConnect) in ParseResponse() argument
320 if (header->Parse(buf, size, false, isConnect)) { in ParseResponse()
|
| H A D | obex_headers.h | 408 …std::unique_ptr<ObexHeader> ParseResponse(const uint8_t *buf, const uint16_t size, bool isConnect);
409 bool Parse(const uint8_t *buf, const uint16_t size, bool isRequest, bool isConnect);
542 …arseFields(const uint8_t *buf, const uint8_t &code, uint16_t &pos, bool isRequest, bool isConnect);
|
| /ohos5.0/base/telephony/call_manager/services/call_voice_assistant/src/ |
| H A D | call_voice_assistant_manager.cpp | 160 void CallVoiceAssistantManager::PublishCommonEvent(bool isConnect, std::string publisher) in PublishCommonEvent() argument
166 if (isConnect) { in PublishCommonEvent()
167 isConnect = isConnectService; in PublishCommonEvent()
169 std::string startService = isConnect ? SWITCH_TURN_ON : SWITCH_TURN_OFF; in PublishCommonEvent()
|
| /ohos5.0/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/heartbeat/src/ |
| H A D | lnn_heartbeat_medium_mgr.c | 72 bool isConnect; member
713 … anonyUdid, device->addr[0].type, connectCondition->isConnect, connectCondition->connectReason); in SoftBusNetNodeResult()
736 if (LnnNotifyDiscoveryDevice(device->addr, &info, connectCondition->isConnect) != SOFTBUS_OK) { in SoftBusNetNodeResult()
740 if (connectCondition->isConnect) { in SoftBusNetNodeResult()
897 … connectCondition.isConnect = IsNeedConnectOnLine(device, hbResp, &connectCondition.connectReason); in CheckJoinLnnConnectResult()
898 if (connectCondition.isConnect && !device->isOnline) { in CheckJoinLnnConnectResult()
|
| /ohos5.0/foundation/communication/dsoftbus/core/authentication/include/ |
| H A D | auth_manager.h | 65 bool isConnect, bool isOldKey);
|
| /ohos5.0/base/telephony/call_manager/services/call_voice_assistant/include/ |
| H A D | call_voice_assistant_manager.h | 58 void PublishCommonEvent(bool isConnect, std::string publisher);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | auto_launch.cpp | 63 …[this](const std::string &device, bool isConnect) { OnlineCallBack(device, isConnect); }, nullptr); in SetCommunicatorAggregator() argument
530 void AutoLaunch::OnlineCallBack(const std::string &device, bool isConnect) in OnlineCallBack() argument
532 LOGI("[AutoLaunch] OnlineCallBack device:%s{private}, isConnect:%d", device.c_str(), isConnect); in OnlineCallBack()
533 if (!isConnect) { in OnlineCallBack()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | auto_launch.h | 148 void OnlineCallBack(const std::string &device, bool isConnect);
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/bus_center/test/heartbeat/ |
| H A D | hb_medium_mgr_test.cpp | 852 connectCondition.isConnect = false;
858 connectCondition.isConnect = true;
|