Home
last modified time | relevance | path

Searched refs:dstTarget (Results 1 - 25 of 31) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Dadapter_stub.cpp78 int AdapterStub::SendBytes(const std::string &dstTarget, const uint8_t *bytes, uint32_t length, uint32_t totalLength) in SendBytes() argument
80 LOGI("[UT][Stub][Send] Send length=%" PRIu32 " to dstTarget=%s begin.", length, dstTarget.c_str()); in SendBytes()
89 LOGI("[UT][Stub][Send] failed for %s errCode %d.", dstTarget.c_str(), errCode); in SendBytes()
95 if (QuerySendRetry(dstTarget)) { in SendBytes()
96 LOGI("[UT][Stub][Send] Retry for %s true.", dstTarget.c_str()); in SendBytes()
101 LOGI("[UT][Stub][Send] Total loss for %s true.", dstTarget.c_str()); in SendBytes()
106 LOGI("[UT][Stub][Send] Partial loss for %s true.", dstTarget.c_str()); in SendBytes()
111 if (targetMapAdapter_.count(dstTarget) == 0) { in SendBytes()
112 LOGI("[UT][Stub][Send] dstTarget in SendBytes()
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...]
H A Dadapter_stub.h44 int SendBytes(const std::string &dstTarget, const uint8_t *bytes, uint32_t length, uint32_t totalLength) override;
69 void SimulateSendRetry(const std::string &dstTarget);
70 void SimulateSendRetryClear(const std::string &dstTarget);
92 bool QuerySendRetry(const std::string &dstTarget);
H A Ddistributeddb_communicator_common.h82 localDbProperty_.dstTarget = info.dstTarget; in ExtendHeaderHandleTest()
H A Ddistributeddb_communicator_deep_test.cpp200 static int CreateBufferThenAddIntoScheduler(SendTaskScheduler &scheduler, const std::string &dstTarget, Priority inPrio) in CreateBufferThenAddIntoScheduler() argument
212 SendTask task{eachBuff, dstTarget, nullptr, 0u}; in CreateBufferThenAddIntoScheduler()
286 EXPECT_EQ(outTask.dstTarget, DEVICE_NAME_C); in HWTEST_F()
292 EXPECT_EQ(outTask.dstTarget, DEVICE_NAME_A); in HWTEST_F()
298 EXPECT_EQ(outTask.dstTarget, DEVICE_NAME_B); in HWTEST_F()
304 EXPECT_EQ(outTask.dstTarget, DEVICE_NAME_C); in HWTEST_F()
310 EXPECT_EQ(outTask.dstTarget, DEVICE_NAME_A); in HWTEST_F()
316 EXPECT_EQ(outTask.dstTarget, DEVICE_NAME_B); in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dsend_task_scheduler.cpp61 LOGW("[Scheduler][Finalize] dstTarget=%s{private}, delayFlag=%d, taskPrio=%d", task.dstTarget.c_str(), in Finalize()
77 totalBytesByTarget_[inTask.dstTarget] += taskSizeByByte; in AddSendTaskIntoSchedule()
78 if (policyMap_.count(inTask.dstTarget) == 0) { in AddSendTaskIntoSchedule()
79 policyMap_[inTask.dstTarget] = TargetPolicy::NO_DELAY; in AddSendTaskIntoSchedule()
81 if (policyMap_[inTask.dstTarget] == TargetPolicy::DELAY) { in AddSendTaskIntoSchedule()
87 taskOrderByPrio_[inPrio].push_back(inTask.dstTarget); in AddSendTaskIntoSchedule()
88 taskGroupByPrio_[inPrio][inTask.dstTarget].push_back(inTask); in AddSendTaskIntoSchedule()
97 LOGI("[Scheduler][OutTask] dstTarget=%s{private}, delayFlag=%d, taskPrio=%d", outTask.dstTarget in ScheduleOutSendTask()
250 std::string dstTarget = taskOrderByPrio_[prio].front(); ScheduleDelayTask() local
268 std::string dstTarget; ScheduleNoDelayTask() local
[all...]
H A Dcommunicator.cpp98 int Communicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) in SendMessage() argument
100 return SendMessage(dstTarget, inMsg, config, nullptr); in SendMessage()
103 int Communicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config, in SendMessage() argument
106 if (dstTarget.empty() || inMsg == nullptr) { in SendMessage()
134 errCode = commAggrHandle_->ScheduleSendTask(dstTarget, buffer, FrameType::APPLICATION_MESSAGE, taskConfig, onEnd); in SendMessage()
219 void Communicator::TriggerVersionNegotiation(const std::string &dstTarget) in TriggerVersionNegotiation() argument
221 LOGI("[Comm][TrigVer] Do version negotiate with target=%s{private}.", dstTarget.c_str()); in TriggerVersionNegotiation()
230 errCode = commAggrHandle_->ScheduleSendTask(dstTarget, buffer, FrameType::EMPTY, config); in TriggerVersionNegotiation()
239 void Communicator::TriggerUnknownMessageFeedback(const std::string &dstTarget, Message* &oriMsg) in TriggerUnknownMessageFeedback() argument
249 LOGI("[Comm][TrigFeedback] Do unknown message feedback with target=%s{private}.", dstTarget in TriggerUnknownMessageFeedback()
[all...]
H A Dcommunicator.h54 int SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) override;
55 int SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config,
71 void TriggerVersionNegotiation(const std::string &dstTarget);
72 void TriggerUnknownMessageFeedback(const std::string &dstTarget, Message* &oriMsg);
H A Dcommunicator_aggregator.cpp295 int CommunicatorAggregator::ScheduleSendTask(const std::string &dstTarget, SerialBuffer *inBuff, in ScheduleSendTask() argument
324 SendTask task{inBuff, dstTarget, onEnd, info.frameId, true}; in ScheduleSendTask()
335 LOGI("[CommAggr][Create] Exit ok, dev=%.3s, frameId=%u", dstTarget.c_str(), info.frameId); in ScheduleSendTask()
381 uint64_t currentSendSequenceId = IncreaseSendSequenceId(inTask.dstTarget); in SendPacketsAndDisposeTask()
384 LOGI("[CommAggr][SendPackets] DoSendBytes, dstTarget=%s{private}, extendHeadLength=%" PRIu32 in SendPacketsAndDisposeTask()
385 ", packetLength=%" PRIu32 ".", inTask.dstTarget.c_str(), entry.second.first, entry.second.second); in SendPacketsAndDisposeTask()
387 errCode = adapterHandle_->SendBytes(inTask.dstTarget, entry.first, entry.second.second, totalLength); in SendPacketsAndDisposeTask()
401 retryCount_[inTask.dstTarget] = 0; in SendPacketsAndDisposeTask()
405 RetrySendTaskIfNeed(inTask.dstTarget, currentSendSequenceId); in SendPacketsAndDisposeTask()
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...]
H A Dnetwork_adapter.cpp218 int NetworkAdapter::SendBytes(const std::string &dstTarget, const uint8_t *bytes, uint32_t length, uint32_t totalLength) in SendBytes() argument
223 LOGI("[NAdapt][SendBytes] Enter, to=%s{private}, length=%u, totalLength=%u", dstTarget.c_str(), length, in SendBytes()
226 dstDevInfo.identifier = dstTarget; in SendBytes()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator_aggregator.cpp168 void VirtualCommunicatorAggregator::DispatchMessage(const std::string &srcTarget, const std::string &dstTarget, in DispatchMessage() argument
183 beforeDispatch_(dstTarget, inMsg); in DispatchMessage()
185 DispatchMessageInner(srcTarget, dstTarget, inMsg, onEnd); in DispatchMessage()
188 void VirtualCommunicatorAggregator::DispatchMessageInner(const std::string &srcTarget, const std::string &dstTarget, in DispatchMessageInner() argument
192 auto iter = communicators_.find(dstTarget); in DispatchMessageInner()
194 LOGI("[VirtualCommunicatorAggregator] DispatchMessage, find dstTarget %s", dstTarget.c_str()); in DispatchMessageInner()
197 LOGE("[VirtualCommunicatorAggregator] DispatchMessage, find dstTarget %s disabled", dstTarget.c_str()); in DispatchMessageInner()
208 (delayDevices_.count(dstTarget) > in DispatchMessageInner()
320 DelayTimeHandle(uint32_t messageId, const std::string &dstTarget) DelayTimeHandle() argument
[all...]
H A Dvirtual_time_sync_communicator.cpp85 int VirtualTimeSyncCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, in SendMessage() argument
88 return SendMessage(dstTarget, inMsg, config, nullptr); in SendMessage()
91 int VirtualTimeSyncCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, in SendMessage() argument
98 LOGD("VirtualTimeSyncCommunicator::sendMessage dev = %s, syncid = %d", dstTarget.c_str(), inMsg->GetSequenceId()); in SendMessage()
100 if (dstTarget == deviceID_) { in SendMessage()
H A Dvirtual_communicator.cpp48 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) in SendMessage() argument
50 return SendMessage(dstTarget, inMsg, config, nullptr); in SendMessage()
53 int VirtualCommunicator::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config, in SendMessage() argument
64 if (dstTarget == deviceId_) { in SendMessage()
72 communicatorAggregator_->DispatchMessage(deviceId_, dstTarget, inMsg, onEnd); in SendMessage()
80 communicatorAggregator_->DispatchMessage(deviceId_, dstTarget, message, onEnd); in SendMessage()
H A Dvirtual_time_sync_communicator.h60 int SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) override;
61 int SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config,
H A Dvirtual_communicator_aggregator.h54 void DispatchMessage(const std::string &srcTarget, const std::string &dstTarget, const Message *inMsg,
101 void DelayTimeHandle(uint32_t messageId, const std::string &dstTarget);
102 void DispatchMessageInner(const std::string &srcTarget, const std::string &dstTarget, const Message *inMsg,
H A Dvirtual_communicator.h58 int SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) override;
59 int SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dicommunicator.h39 inline void SetSendConfigParam(const DBProperties &dbProperty, const std::string &dstTarget, bool nonBlock, in SetSendConfigParam() argument
49 sendConf.paramInfo.dstTarget = dstTarget; in SetSendConfigParam()
82 virtual int SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) = 0;
83 virtual int SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config,
H A Dcommunicator_aggregator.h87 int ScheduleSendTask(const std::string &dstTarget, SerialBuffer *inBuff, FrameType inType,
130 void TriggerVersionNegotiation(const std::string &dstTarget);
131 void TryToFeedbackWhenCommunicatorNotFound(const std::string &dstTarget, const LabelType &dstLabel,
133 void TriggerCommunicatorNotFoundFeedback(const std::string &dstTarget, const LabelType &dstLabel, Message* &oriMsg);
H A Diadapter.h57 virtual int SendBytes(const std::string &dstTarget, const uint8_t *bytes, uint32_t length,
H A Dsend_task_scheduler.h38 std::string dstTarget; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dcommunicator_proxy.cpp198 int CommunicatorProxy::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) in SendMessage() argument
200 return SendMessage(dstTarget, inMsg, config, nullptr); in SendMessage()
203 int CommunicatorProxy::SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config, in SendMessage() argument
209 if (devCommMap_.count(dstTarget) != 0) { in SendMessage()
210 targetCommunicator = devCommMap_[dstTarget].second; in SendMessage()
216 int errCode = targetCommunicator->SendMessage(dstTarget, inMsg, config, onEnd); in SendMessage()
222 return mainComm_->SendMessage(dstTarget, inMsg, config, onEnd); in SendMessage()
H A Dcommunicator_proxy.h45 int SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config) override;
46 int SendMessage(const std::string &dstTarget, const Message *inMsg, const SendConfig &config,
/foundation/window/window_manager/wmserver/src/
H A Dremote_animation.cpp289 sptr<RSWindowAnimationTarget>& dstTarget, sptr<RSWindowAnimationFinishedCallback>& finishedCallback) in NotifyAnimationStartApp()
298 windowAnimationController_->OnStartApp(StartingAppType::FROM_LAUNCHER, dstTarget, finishedCallback); in NotifyAnimationStartApp()
304 windowAnimationController_->OnStartApp(StartingAppType::FROM_RECENT, dstTarget, finishedCallback); in NotifyAnimationStartApp()
309 windowAnimationController_->OnStartApp(StartingAppType::FROM_OTHER, dstTarget, finishedCallback); in NotifyAnimationStartApp()
313 void RemoteAnimation::GetExpectRect(const sptr<WindowNode>& dstNode, const sptr<RSWindowAnimationTarget>& dstTarget) in GetExpectRect() argument
334 dstTarget->windowBounds_.rect_ = boundsRect; in GetExpectRect()
356 auto dstTarget = CreateWindowAnimationTarget(dstInfo, dstNode); in NotifyAnimationTransition() local
357 if (dstTarget == nullptr) { in NotifyAnimationTransition()
370 GetExpectRect(dstNode, dstTarget); in NotifyAnimationTransition()
393 windowAnimationController_->OnAppTransition(srcTarget, dstTarget, finishedCallbac in NotifyAnimationTransition()
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...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dtime_helper.cpp142 void TimeHelper::SetSendConfig(const std::string &dstTarget, bool nonBlock, uint32_t timeout, SendConfig &sendConf) in SetSendConfig() argument
144 SetSendConfigParam(storage_->GetDbProperties(), dstTarget, false, SEND_TIME_OUT, sendConf); in SetSendConfig()
H A Dtime_helper.h62 void SetSendConfig(const std::string &dstTarget, bool nonBlock, uint32_t timeout, SendConfig &sendConf);
/foundation/window/window_manager/wmserver/include/
H A Dremote_animation.h91 sptr<RSWindowAnimationTarget>& dstTarget, sptr<RSWindowAnimationFinishedCallback>& finishedCallback);
97 static void GetExpectRect(const sptr<WindowNode>& dstNode, const sptr<RSWindowAnimationTarget>& dstTarget);

Completed in 12 milliseconds

12