Home
last modified time | relevance | path

Searched refs:targetDev (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/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
95 if (targetDev.empty()) { in OnDeviceConnectCallback()
101 devices_.insert(targetDev); in OnDeviceConnectCallback()
104 onlineCallback_(targetDev); in OnDeviceConnectCallback()
110 devices_.erase(targetDev); in OnDeviceConnectCallback()
113 offlineCallback_(targetDev); in OnDeviceConnectCallback()
H A Dsync_engine.cpp299 …[this](const std::string &targetDev, Message *inMsg) { MessageReciveCallback(targetDev, inMsg); },… in InitComunicator() argument
441 context = FindSyncTaskContext(targetDev); in GetContextForMsg()
452 context = GetSyncTaskContext(targetDev, errCode); in GetContextForMsg()
495 int errCode = MessageReciveCallbackInner(targetDev, inMsg); in MessageReciveCallback()
506 if (targetDev.empty() || inMsg == nullptr) { in MessageReciveCallbackInner()
515 return HandleRemoteExecutorMsg(targetDev, inMsg); in MessageReciveCallbackInner()
536 PutMsgIntoQueue(targetDev, inMsg, msgSize); in MessageReciveCallbackInner()
556 [&targetDev](const Message *msg) { in PutMsgIntoQueue()
565 inMsg->SetTarget(targetDev); in PutMsgIntoQueue()
903 …[this](const std::string &targetDev, Message *inMsg) { MessageReciveCallback(targetDev, inMsg); },… in AllocCommunicator() argument
[all …]
H A Dremote_executor.h65 int ReceiveMessage(const std::string &targetDev, Message *inMsg);
90 void ReceiveMessageInner(const std::string &targetDev, Message *inMsg);
92 int ReceiveRemoteExecutorRequest(const std::string &targetDev, Message *inMsg);
94 int ReceiveRemoteExecutorAck(const std::string &targetDev, Message *inMsg);
131 …void ReceiveDataWithValidSession(const std::string &targetDev, uint32_t sessionId, uint32_t sequen…
H A Dsync_engine.h173 void MessageReciveCallback(const std::string &targetDev, Message *inMsg);
176 int MessageReciveCallbackInner(const std::string &targetDev, Message *inMsg);
182 void PutMsgIntoQueue(const std::string &targetDev, Message *inMsg, int msgSize);
193 ISyncTaskContext *GetContextForMsg(const std::string &targetDev, int &errCode);
219 int HandleRemoteExecutorMsg(const std::string &targetDev, Message *inMsg);
H A Dremote_executor.cpp97 int RemoteExecutor::ReceiveMessage(const std::string &targetDev, Message *inMsg) in ReceiveMessage() argument
109 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, targetDev, inMsg]() { in ReceiveMessage()
110 ReceiveMessageInner(targetDev, inMsg); in ReceiveMessage()
167 int RemoteExecutor::ReceiveRemoteExecutorRequest(const std::string &targetDev, Message *inMsg) in ReceiveRemoteExecutorRequest() argument
172 searchMessageQueue_.push(std::make_pair(targetDev, inMsg)); in ReceiveRemoteExecutorRequest()
274 int RemoteExecutor::ReceiveRemoteExecutorAck(const std::string &targetDev, Message *inMsg) in ReceiveRemoteExecutorAck() argument
300 ReceiveDataWithValidSession(targetDev, sessionId, sequenceId, packet); in ReceiveRemoteExecutorAck()
777 void RemoteExecutor::ReceiveMessageInner(const std::string &targetDev, Message *inMsg) in ReceiveMessageInner() argument
788 errCode = ReceiveRemoteExecutorRequest(targetDev, inMsg); in ReceiveMessageInner()
791 errCode = ReceiveRemoteExecutorAck(targetDev, inMsg); in ReceiveMessageInner()
[all …]
H A Ddevice_manager.h48 void OnDeviceConnectCallback(const std::string &targetDev, bool isConnect);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_syncer_device_manager_test.cpp135 g_deviceManager->RegDeviceOnLineCallBack([&onlineCalled](const std::string &targetDev) { in __anon77278ea40202() argument
136 LOGD("DeviceManageTest online called, dev %s", targetDev.c_str()); in __anon77278ea40202()
137 if (targetDev == g_deviceB->GetDeviceId()) { in __anon77278ea40202()
166 g_deviceManager->RegDeviceOffLineCallBack([&offlineCalled](const std::string &targetDev) { in __anon77278ea40302() argument
167 LOGD("DeviceManageTest offline called, dev %s", targetDev.c_str()); in __anon77278ea40302()
168 if (targetDev == g_deviceB->GetDeviceId()) { in __anon77278ea40302()
H A Ddistributeddb_single_ver_p2p_complex_sync_test.cpp496 std::string targetDev = "DEVICE_X"; variable
498 auto databaseStatusNotifyCallback = [targetDev, &isCheckOk] (const std::string &userId,
500 if (userId == USER_ID && appId == APP_ID && storeId == STORE_ID && deviceId == targetDev && in __anonb4f3bed90b02()
509 g_communicatorAggregator->OnlineDevice(targetDev);
529 std::string targetDev = "DEVICE_X"; variable
531 auto databaseStatusNotifyCallback = [targetDev, &isCheckOk] (const std::string &userId,
533 if (userId == USER_ID && appId == APP_ID && storeId == STORE_ID && deviceId == targetDev && in __anonb4f3bed90c02()
542 g_communicatorAggregator->OfflineDevice(targetDev);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/
H A Dend_point_test.cpp185 std::vector<std::string> targetDev = {"devicid1", "devicid2"}; variable
190 auto testStatus = kvStore_->SetIdentifier(accountId, appId, storeId, targetDev);
207 std::vector<std::string> targetDev = {"devicid1", "devicid2"}; variable
212 auto testStatus = kvStore_->SetIdentifier(accountId, appId, storeId, targetDev);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/kvdelegatemanager_fuzzer/
H A Dkvdelegatemanager_fuzzer.cpp114 std::string targetDev = GetRandomString(data, size, len, start); in CombineTest() local
116 auto databaseStatusNotifyCallback = [userId, appId, storeId, targetDev, &isCheckOk] ( in CombineTest()
120 deviceId == targetDev && onlineStatus == true) { in CombineTest()