Home
last modified time | relevance | path

Searched defs:targetDev (Results 1 – 7 of 7) sorted by relevance

/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()
166 g_deviceManager->RegDeviceOffLineCallBack([&offlineCalled](const std::string &targetDev) { in __anon77278ea40302()
H A Ddistributeddb_single_ver_p2p_complex_sync_test.cpp496 std::string targetDev = "DEVICE_X"; variable
529 std::string targetDev = "DEVICE_X"; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_engine.cpp214 [this, deviceManager = deviceManager_](const std::string &targetDev, bool isConnect) { in StartCommunicator()
299 …[this](const std::string &targetDev, Message *inMsg) { MessageReciveCallback(targetDev, inMsg); },… in InitComunicator()
436 ISyncTaskContext *SyncEngine::GetContextForMsg(const std::string &targetDev, int &errCode) in GetContextForMsg()
492 void SyncEngine::MessageReciveCallback(const std::string &targetDev, Message *inMsg) in MessageReciveCallback()
504 int SyncEngine::MessageReciveCallbackInner(const std::string &targetDev, Message *inMsg) in MessageReciveCallbackInner()
552 void SyncEngine::PutMsgIntoQueue(const std::string &targetDev, Message *inMsg, int msgSize) in PutMsgIntoQueue()
903 …[this](const std::string &targetDev, Message *inMsg) { MessageReciveCallback(targetDev, inMsg); },… in AllocCommunicator()
911 [this, deviceManager = deviceManager_](const std::string &targetDev, bool isConnect) { in AllocCommunicator()
1198 int SyncEngine::HandleRemoteExecutorMsg(const std::string &targetDev, Message *inMsg) in HandleRemoteExecutorMsg()
H A Dremote_executor.cpp97 int RemoteExecutor::ReceiveMessage(const std::string &targetDev, Message *inMsg) in ReceiveMessage()
167 int RemoteExecutor::ReceiveRemoteExecutorRequest(const std::string &targetDev, Message *inMsg) in ReceiveRemoteExecutorRequest()
274 int RemoteExecutor::ReceiveRemoteExecutorAck(const std::string &targetDev, Message *inMsg) in ReceiveRemoteExecutorAck()
777 void RemoteExecutor::ReceiveMessageInner(const std::string &targetDev, Message *inMsg) in ReceiveMessageInner()
809 void RemoteExecutor::ReceiveDataWithValidSession(const std::string &targetDev, uint32_t sessionId, … in ReceiveDataWithValidSession()
H A Ddevice_manager.cpp93 void DeviceManager::OnDeviceConnectCallback(const std::string &targetDev, bool isConnect) in OnDeviceConnectCallback()
/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
207 std::vector<std::string> targetDev = {"devicid1", "devicid2"}; variable
/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