/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
H A D | communicator.cpp | 98 int Communicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig … in SendMessage() 103 int Communicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig … in SendMessage() 219 void Communicator::TriggerVersionNegotiation(const std::string &dstTarget) in TriggerVersionNegotiation() 239 void Communicator::TriggerUnknownMessageFeedback(const std::string &dstTarget, Message* &oriMsg) in TriggerUnknownMessageFeedback()
|
H A D | send_task_scheduler.cpp | 250 std::string dstTarget = taskOrderByPrio_[prio].front(); in ScheduleDelayTask() local 268 std::string dstTarget; in ScheduleNoDelayTask() local
|
H A D | communicator_aggregator.cpp | 295 int CommunicatorAggregator::ScheduleSendTask(const std::string &dstTarget, SerialBuffer *inBuff, in ScheduleSendTask() 791 void CommunicatorAggregator::TriggerVersionNegotiation(const std::string &dstTarget) in TriggerVersionNegotiation() 811 void CommunicatorAggregator::TryToFeedbackWhenCommunicatorNotFound(const std::string &dstTarget, in TryToFeedbackWhenCommunicatorNotFound() 829 void CommunicatorAggregator::TriggerCommunicatorNotFoundFeedback(const std::string &dstTarget, in TriggerCommunicatorNotFoundFeedback()
|
H A D | network_adapter.cpp | 218 int NetworkAdapter::SendBytes(const std::string &dstTarget, const uint8_t *bytes, uint32_t length, … in SendBytes()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
H A D | adapter_stub.cpp | 78 int AdapterStub::SendBytes(const std::string &dstTarget, const uint8_t *bytes, uint32_t length, uin… in SendBytes() 251 void AdapterStub::SimulateSendRetry(const std::string &dstTarget) in SimulateSendRetry() 257 void AdapterStub::SimulateSendRetryClear(const std::string &dstTarget, int softBusErrCode) in SimulateSendRetryClear() 272 void AdapterStub::SimulateTriggerSendableCallback(const std::string &dstTarget, int softBusErrCode) in SimulateTriggerSendableCallback() 350 bool AdapterStub::QuerySendRetry(const std::string &dstTarget) in QuerySendRetry()
|
H A D | distributeddb_communicator_deep_test.cpp | 200 …reateBufferThenAddIntoScheduler(SendTaskScheduler &scheduler, const std::string &dstTarget, Priori… in CreateBufferThenAddIntoScheduler()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | virtual_time_sync_communicator.cpp | 85 int VirtualTimeSyncCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, in SendMessage() 91 int VirtualTimeSyncCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, in SendMessage()
|
H A D | virtual_communicator.cpp | 48 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const Send… in SendMessage() 53 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const Send… in SendMessage()
|
H A D | virtual_communicator_aggregator.cpp | 168 …CommunicatorAggregator::DispatchMessage(const std::string &srcTarget, const std::string &dstTarget, in DispatchMessage() 188 …nicatorAggregator::DispatchMessageInner(const std::string &srcTarget, const std::string &dstTarget, in DispatchMessageInner() 323 …id VirtualCommunicatorAggregator::DelayTimeHandle(uint32_t messageId, const std::string &dstTarget) in DelayTimeHandle()
|
H A D | distributeddb_single_ver_p2p_sync_check_test.cpp | 1745 … g_communicatorAggregator->RegBeforeDispatch([](const std::string &dstTarget, const Message *msg) { in __anon6e997c5f2902()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
H A D | icommunicator.h | 39 inline void SetSendConfigParam(const DBProperties &dbProperty, const std::string &dstTarget, bool n… in SetSendConfigParam()
|
H A D | send_task_scheduler.h | 38 std::string dstTarget; member
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
H A D | communicator_proxy.cpp | 198 int CommunicatorProxy::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendCo… in SendMessage() 203 int CommunicatorProxy::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendCo… in SendMessage()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
H A D | time_helper.cpp | 142 void TimeHelper::SetSendConfig(const std::string &dstTarget, bool nonBlock, uint32_t timeout, SendC… in SetSendConfig()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
H A D | iprocess_communicator.h | 36 std::string dstTarget; member
|
/ohos5.0/foundation/window/window_manager/wmserver/src/ |
H A D | remote_animation.cpp | 289 …sptr<RSWindowAnimationTarget>& dstTarget, sptr<RSWindowAnimationFinishedCallback>& finishedCallbac… in NotifyAnimationStartApp() 313 …tion::GetExpectRect(const sptr<WindowNode>& dstNode, const sptr<RSWindowAnimationTarget>& dstTarge… in GetExpectRect() 356 auto dstTarget = CreateWindowAnimationTarget(dstInfo, dstNode); in NotifyAnimationTransition() local 503 sptr<RSWindowAnimationTarget> dstTarget = CreateWindowAnimationTarget(dstInfo, dstNode); in NotifyAnimationBackTransition() local
|
/ohos5.0/foundation/window/window_manager/wmserver/test/unittest/ |
H A D | remote_animation_test.cpp | 1119 sptr<RSWindowAnimationTarget> dstTarget; variable
|