Home
last modified time | relevance | path

Searched defs:inMsg (Results 26 – 33 of 33) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_task_context.cpp433 int SyncTaskContext::ReceiveMessageCallback(Message *inMsg) in ReceiveMessageCallback()
713 bool SyncTaskContext::IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) in IsNeedTriggerQueryAutoSync()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_relational_ver_p2p_sync_test.cpp1466 g_communicatorAggregator->RegOnDispatch([&alter](const std::string &target, Message *inMsg) { in __anond45d0a2b1002()
2127 g_communicatorAggregator->RegOnDispatch([](const std::string &device, Message *inMsg) { in __anond45d0a2b1902()
2164 g_communicatorAggregator->RegOnDispatch([](const std::string &device, Message *inMsg) { in __anond45d0a2b1b02()
2190 …orAggregator->RegOnDispatch([&offlineThread, &offline](const std::string &device, Message *inMsg) { in __anond45d0a2b1c02()
2253 g_communicatorAggregator->RegOnDispatch([](const std::string &device, Message *inMsg) { in __anond45d0a2b1f02()
2299 g_communicatorAggregator->RegOnDispatch([](const std::string &device, Message *inMsg) { in __anond45d0a2b2102()
H A Ddistributeddb_single_ver_multi_user_test.cpp265 g_communicatorAggregator->RegOnDispatch([&](const std::string&, Message *inMsg) { in TestSyncWithUserChange()
H A Ddistributeddb_relational_multi_user_test.cpp367 g_communicatorAggregator->RegOnDispatch([&](const std::string&, Message *inMsg) { in TestSyncWithUserChange()
H A Ddistributeddb_mock_sync_module_test.cpp1565 [&count](const std::string &device, DistributedDB::Message *inMsg) { in __anon34a84a721802()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_test.cpp583 commBA->RegOnMessageCallback([&recvMsgForBA](const std::string &srcTarget, Message *inMsg) { in __anonf82a9c550902()
767 commBA->RegOnMessageCallback([&msgCallbackForBA](const std::string &srcTarget, Message *inMsg) { in __anonf82a9c550c02()
/ohos5.0/foundation/communication/ipc/ipc/native/c/ipc/src/liteos_a/include/
H A Dlite_ipc.h73 IpcMsg *inMsg; /**< data reply by target */ member
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync_utils.cpp343 bool SingleVerDataSyncUtils::IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) in IsNeedTriggerQueryAutoSync()

12