Home
last modified time | relevance | path

Searched refs:srcTarget (Results 1 - 21 of 21) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dcommunicator_aggregator.cpp274 commMap_.at(commLabel).first->OnBufferReceive(entry.srcTarget, entry.buffer); in ActivateCommunicator()
479 void CommunicatorAggregator::OnBytesReceive(const std::string &srcTarget, const uint8_t *bytes, uint32_t length, in OnBytesReceive() argument
484 int errCode = ProtocolProto::CheckAndParsePacket(srcTarget, bytes, length, packetResult); in OnBytesReceive()
488 TriggerVersionNegotiation(srcTarget); in OnBytesReceive()
494 SetRemoteCommunicatorVersion(srcTarget, packetResult.GetDbVersion()); in OnBytesReceive()
496 dbStatusAdapter_->SetRemoteOptimizeCommunication(srcTarget, !packetResult.IsSendLabelExchange()); in OnBytesReceive()
504 OnFragmentReceive(srcTarget, bytes, length, packetResult, userId); in OnBytesReceive()
506 errCode = OnCommLayerFrameReceive(srcTarget, packetResult); in OnBytesReceive()
511 errCode = OnAppLayerFrameReceive(srcTarget, bytes, length, packetResult, userId); in OnBytesReceive()
564 void CommunicatorAggregator::OnFragmentReceive(const std::string &srcTarget, cons argument
605 OnCommLayerFrameReceive(const std::string &srcTarget, const ParseResult &inResult) OnCommLayerFrameReceive() argument
627 OnAppLayerFrameReceive(const std::string &srcTarget, const uint8_t *bytes, uint32_t length, const ParseResult &inResult, const std::string &userId) OnAppLayerFrameReceive() argument
664 OnAppLayerFrameReceive(const std::string &srcTarget, SerialBuffer *&inFrameBuffer, const ParseResult &inResult, const std::string &userId) OnAppLayerFrameReceive() argument
706 TryDeliverAppLayerFrameToCommunicatorNoMutex(const std::string &srcTarget, SerialBuffer *&inFrameBuffer, const LabelType &toLabel) TryDeliverAppLayerFrameToCommunicatorNoMutex() argument
888 NotifyConnectChange(const std::string &srcTarget, const std::map<LabelType, bool> &changedLabels) NotifyConnectChange() argument
[all...]
H A Dcommunicator.cpp147 void Communicator::OnBufferReceive(const std::string &srcTarget, const SerialBuffer *inBuf) in OnBufferReceive() argument
150 if (srcTarget.size() != 0 && inBuf != nullptr && onMessageHandle_) { in OnBufferReceive()
162 TriggerVersionNegotiation(srcTarget); in OnBufferReceive()
164 TriggerUnknownMessageFeedback(srcTarget, message); in OnBufferReceive()
168 LOGI("[Comm][Receive] label=%.3s, srcTarget=%s{private}.", VEC_TO_STR(commLabel_), srcTarget.c_str()); in OnBufferReceive()
169 onMessageHandle_(srcTarget, message); in OnBufferReceive()
172 srcTarget.size()); in OnBufferReceive()
H A Dprotocol_proto.h94 static int CheckAndParsePacket(const std::string &srcTarget, const uint8_t *bytes, uint32_t length,
115 static int ParseCommPhyHeader(const std::string &srcTarget, const uint8_t *bytes, uint32_t length,
118 static int ParseCommPhyHeaderCheckField(const std::string &srcTarget, const CommPhyHeader &phyHeader,
H A Dcommunicator.h59 void OnBufferReceive(const std::string &srcTarget, const SerialBuffer *inBuf);
H A Dframe_retainer.cpp104 std::map<uint64_t, RetainWork> &perLabelPerTarget = retainWorkPool_[inFrame.commLabel][inFrame.srcTarget]; in RetainFrame()
108 LogRetainInfo("[Retainer][Retain] DISCARD", inFrame.commLabel, inFrame.srcTarget, iter->first, iter->second); in RetainFrame()
H A Dprotocol_proto.cpp492 int ProtocolProto::CheckAndParsePacket(const std::string &srcTarget, const uint8_t *bytes, uint32_t length, in CheckAndParsePacket() argument
498 int errCode = ParseCommPhyHeader(srcTarget, bytes, length, outResult); in CheckAndParsePacket()
743 int ProtocolProto::ParseCommPhyHeaderCheckField(const std::string &srcTarget, const CommPhyHeader &phyHeader, in ParseCommPhyHeaderCheckField() argument
772 int ProtocolProto::ParseCommPhyHeader(const std::string &srcTarget, const uint8_t *bytes, uint32_t length, in ParseCommPhyHeader() argument
788 errCode = ParseCommPhyHeaderCheckField(srcTarget, phyHeader, bytes, length); in ParseCommPhyHeader()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dcommunicator_aggregator.h105 void OnBytesReceive(const std::string &srcTarget, const uint8_t *bytes, uint32_t length,
110 void OnFragmentReceive(const std::string &srcTarget, const uint8_t *bytes, uint32_t length,
113 int OnCommLayerFrameReceive(const std::string &srcTarget, const ParseResult &inResult);
114 int OnAppLayerFrameReceive(const std::string &srcTarget, const uint8_t *bytes,
116 int OnAppLayerFrameReceive(const std::string &srcTarget, SerialBuffer *&inFrameBuffer,
120 int TryDeliverAppLayerFrameToCommunicatorNoMutex(const std::string &srcTarget, SerialBuffer *&inFrameBuffer,
140 void NotifyConnectChange(const std::string &srcTarget, const std::map<LabelType, bool> &changedLabels);
H A Dframe_retainer.h31 std::string srcTarget; member
H A Diadapter.h28 using BytesReceiveCallback = std::function<void(const std::string &srcTarget, const uint8_t *bytes, uint32_t length,
H A Dicommunicator.h29 using OnMessageCallback = std::function<void(const std::string &srcTarget, Message *inMsg)>;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_anti_dos_sync_test.cpp170 const std::string srcTarget = "001"; in HWTEST_F() local
188 message->SetTarget(srcTarget); in HWTEST_F()
193 g_communicator->CallbackOnMessage(srcTarget, message); in HWTEST_F()
221 const std::string srcTarget = "001"; in HWTEST_F() local
240 message->SetTarget(srcTarget); in HWTEST_F()
245 g_communicator->CallbackOnMessage(srcTarget, message); in HWTEST_F()
285 const std::string srcTarget = "001"; in HWTEST_F() local
305 const std::string target = srcTarget + std::to_string(index); in HWTEST_F()
H A Dvirtual_communicator_aggregator.cpp168 void VirtualCommunicatorAggregator::DispatchMessage(const std::string &srcTarget, const std::string &dstTarget, in DispatchMessage() argument
185 DispatchMessageInner(srcTarget, dstTarget, inMsg, onEnd); in DispatchMessage()
188 void VirtualCommunicatorAggregator::DispatchMessageInner(const std::string &srcTarget, const std::string &dstTarget, in DispatchMessageInner() argument
204 msg->SetTarget(srcTarget); in DispatchMessageInner()
210 std::thread thread([communicator, srcTarget, dstTarget, msg, isNeedDelay, sendDelayTime, onDispatch]() { in DispatchMessageInner()
217 communicator->CallbackOnMessage(srcTarget, msg); in DispatchMessageInner()
H A Dvirtual_communicator.cpp95 void VirtualCommunicator::CallbackOnMessage(const std::string &srcTarget, Message *inMsg) in CallbackOnMessage() argument
98 if (isEnable_ && onMessage_ && (srcTarget != deviceId_) && ((inMsg->GetMessageId() != dropMsgId_) || in CallbackOnMessage()
100 onMessage_(srcTarget, inMsg); in CallbackOnMessage()
102 LOGD("drop msg from dev=%s, localDev=%s", srcTarget.c_str(), deviceId_.c_str()); in CallbackOnMessage()
H A Dvirtual_communicator_aggregator.h54 void DispatchMessage(const std::string &srcTarget, const std::string &dstTarget, const Message *inMsg,
102 void DispatchMessageInner(const std::string &srcTarget, const std::string &dstTarget, const Message *inMsg,
H A Dvirtual_communicator.h64 void CallbackOnMessage(const std::string &srcTarget, Message *inMsg);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_send_receive_test.cpp137 g_commAA->RegOnMessageCallback([&srcTargetForAA, &recvMsgForAA](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
138 srcTargetForAA = srcTarget; in HWTEST_F()
141 g_commBA->RegOnMessageCallback([&srcTargetForBA, &recvMsgForBA](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
142 srcTargetForBA = srcTarget; in HWTEST_F()
145 g_commBB->RegOnMessageCallback([&srcTargetForBB, &recvMsgForBB](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
146 srcTargetForBB = srcTarget; in HWTEST_F()
459 g_commAA->RegOnMessageCallback([&recvCount](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
520 g_commAA->RegOnMessageCallback([&recvCount](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
625 [&srcTargetFor##src##label, &recvMsgFor##src##label](const std::string &srcTarget, Message *inMsg) { \
626 srcTargetFor##src##label = srcTarget; \
[all...]
H A Ddistributeddb_communicator_deep_test.cpp146 g_commBB->RegOnMessageCallback([&msgForBB](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
150 g_commCA->RegOnMessageCallback([&msgForCA](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
332 g_commBB->RegOnMessageCallback([&recvMsgForBB](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
387 g_commCC->RegOnMessageCallback([&recvMsgForCC](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
453 OnMessageCallback callback = [&count](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
519 g_commBB->RegOnMessageCallback([&recvMsgForBB](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
H A Dadapter_stub.cpp204 void AdapterStub::DeliverBytes(const std::string &srcTarget, const uint8_t *bytes, uint32_t length) in DeliverBytes() argument
211 onReceiveHandle_(srcTarget, bytes + headLength, length - headLength, userId); in DeliverBytes()
H A Dadapter_stub.h89 void DeliverBytes(const std::string &srcTarget, const uint8_t *bytes, uint32_t length);
H A Ddistributeddb_communicator_test.cpp583 commBA->RegOnMessageCallback([&recvMsgForBA](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
625 [&srcTargetFor##src##label, &recvMsgFor##src##label](const std::string &srcTarget, Message *inMsg) { \
626 srcTargetFor##src##label = srcTarget; \
767 commBA->RegOnMessageCallback([&msgCallbackForBA](const std::string &srcTarget, Message *inMsg) { in HWTEST_F()
768 msgCallbackForBA.push_back({srcTarget, inMsg}); in HWTEST_F()
/foundation/window/window_manager/wmserver/src/
H A Dremote_animation.cpp377 auto srcTarget = CreateWindowAnimationTarget(srcInfo, srcNode); in NotifyAnimationTransition() local
393 windowAnimationController_->OnAppTransition(srcTarget, dstTarget, finishedCallback); in NotifyAnimationTransition()
401 sptr<RSWindowAnimationTarget> srcTarget = CreateWindowAnimationTarget(srcInfo, srcNode); in NotifyAnimationMinimize() local
402 if (srcTarget == nullptr) { in NotifyAnimationMinimize()
421 windowAnimationController_->OnMinimizeWindow(srcTarget, finishedCallback); in NotifyAnimationMinimize()
428 sptr<RSWindowAnimationTarget> srcTarget = CreateWindowAnimationTarget(srcInfo, srcNode); in NotifyAnimationClose() local
429 if (srcTarget == nullptr) { in NotifyAnimationClose()
445 windowAnimationController_->OnCloseWindow(srcTarget, finishedCallback); in NotifyAnimationClose()
502 sptr<RSWindowAnimationTarget> srcTarget = CreateWindowAnimationTarget(srcInfo, srcNode); in NotifyAnimationBackTransition() local
504 if (srcTarget in NotifyAnimationBackTransition()
548 sptr<RSWindowAnimationTarget> srcTarget = CreateWindowAnimationTarget(srcInfo, srcNode); GetAnimationTargetsForHome() local
982 sptr<RSWindowAnimationTarget> srcTarget = CreateWindowAnimationTarget(nullptr, node); NotifyAnimationUpdateWallpaper() local
[all...]

Completed in 19 milliseconds