| /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 nonBlock, in SetSendConfigParam() argument
|
| H A D | send_task_scheduler.h | 38 std::string dstTarget; member
|
| /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 &config) in SendMessage() argument
103 int Communicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config, in SendMessage() argument
219 void Communicator::TriggerVersionNegotiation(const std::string &dstTarget) in TriggerVersionNegotiation() argument
239 void Communicator::TriggerUnknownMessageFeedback(const std::string &dstTarget, Message* &oriMsg) in TriggerUnknownMessageFeedback() argument
[all...] |
| H A D | send_task_scheduler.cpp | 250 std::string dstTarget = taskOrderByPrio_[prio].front(); ScheduleDelayTask() local
268 std::string dstTarget; ScheduleNoDelayTask() local
[all...] |
| H A D | network_adapter.cpp | 218 int NetworkAdapter::SendBytes(const std::string &dstTarget, const uint8_t *bytes, uint32_t length, uint32_t totalLength) in SendBytes() argument
|
| H A D | communicator_aggregator.cpp | 295 int CommunicatorAggregator::ScheduleSendTask(const std::string &dstTarget, SerialBuffer *inBuff, in ScheduleSendTask() argument
788 void CommunicatorAggregator::TriggerVersionNegotiation(const std::string &dstTarget) in TriggerVersionNegotiation() argument
808 TryToFeedbackWhenCommunicatorNotFound(const std::string &dstTarget, const LabelType &dstLabel, const SerialBuffer *inOriFrame) TryToFeedbackWhenCommunicatorNotFound() argument
826 TriggerCommunicatorNotFoundFeedback(const std::string &dstTarget, const LabelType &dstLabel, Message* &oriMsg) TriggerCommunicatorNotFoundFeedback() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | iprocess_communicator.h | 36 std::string dstTarget; member
|
| /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() argument
91 int VirtualTimeSyncCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, in SendMessage() argument
|
| H A D | virtual_communicator.cpp | 48 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) in SendMessage() argument
53 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config, in SendMessage() argument
|
| H A D | virtual_communicator_aggregator.cpp | 168 void VirtualCommunicatorAggregator::DispatchMessage(const std::string &srcTarget, const std::string &dstTarget, in DispatchMessage() argument
188 void VirtualCommunicatorAggregator::DispatchMessageInner(const std::string &srcTarget, const std::string &dstTarget, in DispatchMessageInner() argument
320 DelayTimeHandle(uint32_t messageId, const std::string &dstTarget) DelayTimeHandle() argument
[all...] |
| /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, SendConfig &sendConf) in SetSendConfig() argument
|
| /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 SendConfig &config) in SendMessage() argument
203 int CommunicatorProxy::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config, in SendMessage() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_deep_test.cpp | 200 static int CreateBufferThenAddIntoScheduler(SendTaskScheduler &scheduler, const std::string &dstTarget, Priority inPrio) in CreateBufferThenAddIntoScheduler() argument
|
| H A D | adapter_stub.cpp | 78 int AdapterStub::SendBytes(const std::string &dstTarget, const uint8_t *bytes, uint32_t length, uint32_t totalLength) in SendBytes() argument
251 SimulateSendRetry(const std::string &dstTarget) SimulateSendRetry() argument
257 SimulateSendRetryClear(const std::string &dstTarget) SimulateSendRetryClear() argument
342 QuerySendRetry(const std::string &dstTarget) QuerySendRetry() argument
[all...] |
| /foundation/window/window_manager/wmserver/test/unittest/ |
| H A D | remote_animation_test.cpp | 1119 sptr<RSWindowAnimationTarget> dstTarget; in HWTEST_F() local
|
| /foundation/window/window_manager/wmserver/src/ |
| H A D | remote_animation.cpp | 313 void RemoteAnimation::GetExpectRect(const sptr<WindowNode>& dstNode, const sptr<RSWindowAnimationTarget>& dstTarget) in GetExpectRect() argument
356 auto dstTarget = CreateWindowAnimationTarget(dstInfo, dstNode); in NotifyAnimationTransition() local
287 NotifyAnimationStartApp(sptr<WindowTransitionInfo> srcInfo, const sptr<WindowNode>& srcNode, const sptr<WindowNode>& dstNode, sptr<RSWindowAnimationTarget>& dstTarget, sptr<RSWindowAnimationFinishedCallback>& finishedCallback) NotifyAnimationStartApp() argument
503 sptr<RSWindowAnimationTarget> dstTarget = CreateWindowAnimationTarget(dstInfo, dstNode); NotifyAnimationBackTransition() local
[all...] |