Home
last modified time | relevance | path

Searched refs:isConnect (Results 1 - 24 of 24) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Ddevice_manager.cpp93 void DeviceManager::OnDeviceConnectCallback(const std::string &targetDev, bool isConnect) in OnDeviceConnectCallback() argument
98 if (isConnect) { in OnDeviceConnectCallback()
H A Ddevice_manager.h48 void OnDeviceConnectCallback(const std::string &targetDev, bool isConnect);
H A Dsync_engine.cpp214 [this, deviceManager = deviceManager_](const std::string &targetDev, bool isConnect) { in StartCommunicator()
215 deviceManager->OnDeviceConnectCallback(targetDev, isConnect); in StartCommunicator()
921 [this, deviceManager = deviceManager_](const std::string &targetDev, bool isConnect) { in AllocCommunicator()
922 deviceManager->OnDeviceConnectCallback(targetDev, isConnect); in AllocCommunicator()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator.cpp111 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 Dvirtual_communicator.h66 void CallbackOnConnect(const std::string &target, bool isConnect) const;
H A Dvirtual_communicator_aggregator.cpp94 void VirtualCommunicatorAggregator::RunOnConnectCallback(const std::string &target, bool isConnect) in RunOnConnectCallback() argument
97 onConnect_(target, isConnect); in RunOnConnectCallback()
H A Dvirtual_communicator_aggregator.h44 void RunOnConnectCallback(const std::string &target, bool isConnect);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dcommunicator.cpp180 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 Dcommunicator.h62 void OnConnectChange(const std::string &target, bool isConnect);
H A Dcommunicator_aggregator.cpp518 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()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dcommunicator_type_define.h29 using OnConnectCallback = std::function<void(const std::string &target, bool isConnect)>;
H A Diadapter.h30 using TargetChangeCallback = std::function<void(const std::string &target, bool isConnect)>;
H A Dcommunicator_aggregator.h107 void OnTargetChange(const std::string &target, bool isConnect);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_test.cpp39 static void HandleConnectChange(OnOfflineDevice &onlines, const std::string &target, bool isConnect) in HandleConnectChange() argument
41 if (isConnect) { in HandleConnectChange()
183 commAA->RegOnConnectCallback([&onlineForAA](const std::string &target, bool isConnect) { in HWTEST_F()
184 HandleConnectChange(onlineForAA, target, isConnect);}, nullptr); in HWTEST_F()
201 commBB->RegOnConnectCallback([&onlineForBB](const std::string &target, bool isConnect) { in HWTEST_F()
202 HandleConnectChange(onlineForBB, target, isConnect);}, nullptr); in HWTEST_F()
221 commBA->RegOnConnectCallback([&onlineForBA](const std::string &target, bool isConnect) { in HWTEST_F()
222 HandleConnectChange(onlineForBA, target, isConnect);}, nullptr); in HWTEST_F()
263 communicator->RegOnConnectCallback([&online](const std::string &target, bool isConnect) { \
264 HandleConnectChange(online, target, isConnect); \
[all...]
H A Ddistributeddb_communicator_deep_test.cpp600 OnConnectCallback callback = [&count](const std::string &target, bool isConnect) { in HWTEST_F()
601 if (isConnect) { in HWTEST_F()
/foundation/multimodalinput/input/service/message_handle/src/
H A Dserver_msg_handler.cpp989 bool isConnect = injectNotice_->ConnectNoticeSrv(); in InitInjectNoticeSource() local
990 if (!isConnect) { in InitInjectNoticeSource()
991 MMI_HILOGD("Injectnotice ConnectNoticeSrv isConnect:%{public}d", isConnect); in InitInjectNoticeSource()
1016 bool isConnect = pConnect->IsConnected(); in AddInjectNotice()
1017 MMI_HILOGD("SendNotice %{public}d", isConnect); in AddInjectNotice()
1018 if (isConnect) { in AddInjectNotice()
1049 bool isConnect = pConnect->IsConnected(); in CloseInjectNotice()
1050 MMI_HILOGD("CloseNotice %{public}d", isConnect); in CloseInjectNotice()
1051 if (isConnect) { in CloseInjectNotice()
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/
H A Dobex_headers.cpp97 void ObexHeader::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
158 OBEX_LOG_DEBUG("ObexHeader Parse: isRequest[%{public}d],isConnect:[%{public}d], buf size=[%{public}d]", in Parse()
159 isRequest, isConnect, size); in Parse()
174 ParseFields(buf, code, pos, isRequest, isConnect); in Parse()
317 std::unique_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 Dobex_headers.h408 static 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 void ParseFields(const uint8_t *buf, const uint8_t &code, uint16_t &pos, bool isRequest, bool isConnect);
/foundation/communication/dsoftbus/core/authentication/include/
H A Dauth_manager.h65 bool isConnect, bool isOldKey);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Dauto_launch.h148 void OnlineCallBack(const std::string &device, bool isConnect);
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/heartbeat/src/
H A Dlnn_heartbeat_medium_mgr.c74 bool isConnect; member
708 "heartbeat(HB) find device, udidHash=%{public}s, ConnectionAddrType=%{public}02X, isConnect=%{public}d, " in SoftBusNetNodeResult()
710 device->addr[0].type, connectCondition->isConnect, connectCondition->connectReason); in SoftBusNetNodeResult()
733 if (LnnNotifyDiscoveryDevice(device->addr, &info, connectCondition->isConnect) != SOFTBUS_OK) { in SoftBusNetNodeResult()
740 if (connectCondition->isConnect) { in SoftBusNetNodeResult()
911 connectCondition.isConnect = IsNeedConnectOnLine(device, hbResp, &connectCondition.connectReason); in CheckJoinLnnConnectResult()
912 if (connectCondition.isConnect && !device->isOnline) { in CheckJoinLnnConnectResult()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dauto_launch.cpp63 [this](const std::string &device, bool isConnect) { OnlineCallBack(device, isConnect); }, nullptr); in SetCommunicatorAggregator()
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()
/foundation/communication/dsoftbus/core/authentication/src/
H A Dauth_manager.c733 bool isConnect, bool isOldKey) in AuthManagerSetSessionKey()
743 authSeq = isConnect ? authSeq : GenSeq(info->isServer); in AuthManagerSetSessionKey()
749 if (!isConnect && info->connInfo.type != AUTH_LINK_TYPE_BLE) { in AuthManagerSetSessionKey()
773 if (!isConnect) { in AuthManagerSetSessionKey()
732 AuthManagerSetSessionKey(int64_t authSeq, AuthSessionInfo *info, const SessionKey *sessionKey, bool isConnect, bool isOldKey) AuthManagerSetSessionKey() argument
/foundation/communication/dsoftbus/tests/core/bus_center/test/heartbeat/
H A Dhb_medium_mgr_test.cpp852 connectCondition.isConnect = false; in HWTEST_F()
859 connectCondition.isConnect = true; in HWTEST_F()

Completed in 26 milliseconds