Searched refs:RegOnDispatch (Results 1 – 8 of 8) sorted by relevance
166 g_communicatorAggregator->RegOnDispatch(nullptr); in TearDown()309 g_communicatorAggregator->RegOnDispatch(nullptr);796 g_communicatorAggregator->RegOnDispatch([&invalid]( in RegOnDispatchWithInvalidMsg()912 g_communicatorAggregator->RegOnDispatch(nullptr); in PrepareWaterMarkError()1862 g_communicatorAggregator->RegOnDispatch(nullptr);1913 g_communicatorAggregator->RegOnDispatch(nullptr);1950 g_communicatorAggregator->RegOnDispatch(nullptr);2021 g_communicatorAggregator->RegOnDispatch(nullptr);2066 g_communicatorAggregator->RegOnDispatch(nullptr);2104 g_communicatorAggregator->RegOnDispatch(nullptr);[all …]
270 g_communicatorAggregator->RegOnDispatch(nullptr); in DoRemoteQuery()313 g_communicatorAggregator->RegOnDispatch(nullptr); in CheckSyncResult()367 g_communicatorAggregator->RegOnDispatch([&](const std::string&, Message *inMsg) { in TestSyncWithUserChange()415 …g_communicatorAggregator->RegOnDispatch([&messageCount, checkVirtual](const std::string &dev, Mess… in RegOnDispatchWithoutDataPacket()1078 g_communicatorAggregator->RegOnDispatch(nullptr);1120 g_communicatorAggregator->RegOnDispatch(nullptr);1162 g_communicatorAggregator->RegOnDispatch(nullptr);1204 g_communicatorAggregator->RegOnDispatch(nullptr);1248 g_communicatorAggregator->RegOnDispatch(nullptr);
373 g_communicatorAggregator->RegOnDispatch([&responseCount, &requestCount, &key, &value](404 g_communicatorAggregator->RegOnDispatch(nullptr);431 …g_communicatorAggregator->RegOnDispatch([](const std::string &target, DistributedDB::Message *msg)… in __anonb4f3bed90502()449 …g_communicatorAggregator->RegOnDispatch([](const std::string &target, DistributedDB::Message *msg)… in __anonb4f3bed90702()479 g_communicatorAggregator->RegOnDispatch(nullptr);566 …g_communicatorAggregator->RegOnDispatch([&sleep](const std::string &target, DistributedDB::Message… in __anonb4f3bed90d02()604 g_communicatorAggregator->RegOnDispatch(nullptr);619 …g_communicatorAggregator->RegOnDispatch([](const std::string &target, DistributedDB::Message *msg)… in __anonb4f3bed91102()656 g_communicatorAggregator->RegOnDispatch(nullptr);2302 …g_communicatorAggregator->RegOnDispatch([](const std::string &target, DistributedDB::Message *msg)… in __anonb4f3bed91d02()[all …]
70 …void RegOnDispatch(const std::function<void(const std::string &target, Message *inMsg)> &onDispatc…
908 g_communicatorAggregator->RegOnDispatch(nullptr); in TearDown()1466 g_communicatorAggregator->RegOnDispatch([&alter](const std::string &target, Message *inMsg) { in __anond45d0a2b1002()1488 g_communicatorAggregator->RegOnDispatch(nullptr);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 …g_communicatorAggregator->RegOnDispatch([&offlineThread, &offline](const std::string &device, Mess… 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()
265 g_communicatorAggregator->RegOnDispatch([&](const std::string&, Message *inMsg) { in TestSyncWithUserChange()281 g_communicatorAggregator->RegOnDispatch(nullptr); in TestSyncWithUserChange()
268 void VirtualCommunicatorAggregator::RegOnDispatch( in RegOnDispatch() function in DistributedDB::VirtualCommunicatorAggregator
180 g_communicatorAggregator->RegOnDispatch(nullptr); in TearDown()