Searched defs:srcTarget (Results 1 – 11 of 11) sorted by relevance
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/test/unittest/common/communicator/ |
| D | distributeddb_communicator_send_receive_test.cpp | 137 …g_commAA->RegOnMessageCallback([&srcTargetForAA, &recvMsgForAA](const std::string &srcTarget, Mess… in __anonf5cf6e830202()
141 …g_commBA->RegOnMessageCallback([&srcTargetForBA, &recvMsgForBA](const std::string &srcTarget, Mess… in __anonf5cf6e830302()
145 …g_commBB->RegOnMessageCallback([&srcTargetForBB, &recvMsgForBB](const std::string &srcTarget, Mess… in __anonf5cf6e830402()
459 g_commAA->RegOnMessageCallback([&recvCount](const std::string &srcTarget, Message *inMsg) { in __anonf5cf6e830d02()
520 g_commAA->RegOnMessageCallback([&recvCount](const std::string &srcTarget, Message *inMsg) { in __anonf5cf6e830e02()
717 …g_commAA->RegOnMessageCallback([&srcTargetForAA, &recvMsgForAA](const std::string &srcTarget, Mess… in __anonf5cf6e831002()
721 …g_commBA->RegOnMessageCallback([&srcTargetForBA, &recvMsgForBA](const std::string &srcTarget, Mess… in __anonf5cf6e831102()
|
| D | distributeddb_communicator_deep_test.cpp | 143 g_commBB->RegOnMessageCallback([&msgForBB](const std::string &srcTarget, Message *inMsg) { in __anon0e8d7f950302()
315 g_commBB->RegOnMessageCallback([&recvMsgForBB](const std::string &srcTarget, Message *inMsg) { in __anon0e8d7f950402()
370 g_commCC->RegOnMessageCallback([&recvMsgForCC](const std::string &srcTarget, Message *inMsg) { in __anon0e8d7f950502()
436 OnMessageCallback callback = [&count](const std::string &srcTarget, Message *inMsg) { in __anon0e8d7f950602()
|
| D | distributeddb_communicator_test.cpp | 484 commBA->RegOnMessageCallback([&recvMsgForBA](const std::string &srcTarget, Message *inMsg) { in __anon970cad180902()
668 commBA->RegOnMessageCallback([&msgCallbackForBA](const std::string &srcTarget, Message *inMsg) { in __anon970cad180c02()
|
| D | adapter_stub.cpp | 188 void AdapterStub::DeliverBytes(const std::string &srcTarget, const uint8_t *bytes, uint32_t length) in DeliverBytes()
|
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/test/unittest/common/syncer/ |
| D | distributeddb_anti_dos_sync_test.cpp | 167 const std::string srcTarget = "001"; variable
218 const std::string srcTarget = "001"; variable
282 const std::string srcTarget = "001"; variable
|
| D | virtual_communicator.cpp | 77 void VirtualCommunicator::CallbackOnMessage(const std::string &srcTarget, Message *inMsg) const in CallbackOnMessage() argument
|
| D | virtual_communicator_aggregator.cpp | 155 void VirtualCommunicatorAggregator::DispatchMessage(const std::string &srcTarget, const std::string… in DispatchMessage()
|
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/communicator/src/ |
| D | communicator_aggregator.cpp | 480 void CommunicatorAggregator::OnBytesReceive(const std::string &srcTarget, const uint8_t *bytes, uin… in OnBytesReceive()
567 void CommunicatorAggregator::OnFragmentReceive(const std::string &srcTarget, const uint8_t *bytes, … in OnFragmentReceive()
608 int CommunicatorAggregator::OnCommLayerFrameReceive(const std::string &srcTarget, const ParseResult… in OnCommLayerFrameReceive()
646 int CommunicatorAggregator::OnAppLayerFrameReceive(const std::string &srcTarget, const uint8_t *byt… in OnAppLayerFrameReceive()
683 int CommunicatorAggregator::OnAppLayerFrameReceive(const std::string &srcTarget, SerialBuffer *&inF… in OnAppLayerFrameReceive()
725 … CommunicatorAggregator::TryDeliverAppLayerFrameToCommunicatorNoMutex(const std::string &srcTarget, in TryDeliverAppLayerFrameToCommunicatorNoMutex()
|
| D | communicator.cpp | 147 void Communicator::OnBufferReceive(const std::string &srcTarget, const SerialBuffer *inBuf) in OnBufferReceive()
|
| D | protocol_proto.cpp | 461 int ProtocolProto::CheckAndParsePacket(const std::string &srcTarget, const uint8_t *bytes, uint32_t… in CheckAndParsePacket()
716 int ProtocolProto::ParseCommPhyHeaderCheckField(const std::string &srcTarget, const CommPhyHeader &… in ParseCommPhyHeaderCheckField()
750 int ProtocolProto::ParseCommPhyHeader(const std::string &srcTarget, const uint8_t *bytes, uint32_t … in ParseCommPhyHeader()
|
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/communicator/include/ |
| D | frame_retainer.h | 31 std::string srcTarget; member
|