Home
last modified time | relevance | path

Searched refs:senderNetworkId (Results 1 - 14 of 14) sorted by relevance

/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
H A Ddms_continue_recv_manager.cpp92 void DMSContinueRecvMgr::NotifyDataRecv(std::string& senderNetworkId, in NotifyDataRecv() argument
95 HILOGI("NotifyDataRecv start, senderNetworkId: %{public}s, dataLen: %{public}u.", in NotifyDataRecv()
96 GetAnonymStr(senderNetworkId).c_str(), dataLen); in NotifyDataRecv()
126 PostOnBroadcastBusiness(senderNetworkId, bundleNameId, continueTypeId, state); in NotifyDataRecv()
209 int32_t DMSContinueRecvMgr::VerifyBroadcastSource(const std::string& senderNetworkId, const std::string& srcBundleName, in VerifyBroadcastSource() argument
214 iconInfo_.senderNetworkId = senderNetworkId; in VerifyBroadcastSource()
219 if (senderNetworkId != iconInfo_.senderNetworkId) { in VerifyBroadcastSource()
220 HILOGW("Sender not match, task abort. senderNetworkId in VerifyBroadcastSource()
238 PostOnBroadcastBusiness(const std::string& senderNetworkId, uint16_t bundleNameId, uint8_t continueTypeId, const int32_t state, const int32_t delay, const int32_t retry) PostOnBroadcastBusiness() argument
252 RetryPostBroadcast(const std::string& senderNetworkId, uint16_t bundleNameId, uint8_t continueTypeId, const int32_t state, const int32_t retry) RetryPostBroadcast() argument
311 DealOnBroadcastBusiness(const std::string& senderNetworkId, uint16_t bundleNameId, uint8_t continueTypeId, const int32_t state, const int32_t retry) DealOnBroadcastBusiness() argument
544 std::string senderNetworkId; NotifyDeviceOffline() local
591 std::string senderNetworkId; NotifyPackageRemoved() local
[all...]
H A Ddistributed_mission_broadcast_listener.cpp27 void DistributedMissionBroadcastListener::OnDataRecv(std::string& senderNetworkId, uint8_t* payload, uint32_t dataLen) in OnDataRecv() argument
30 DMSContinueRecvMgr::GetInstance().NotifyDataRecv(senderNetworkId, payload, dataLen); in OnDataRecv()
/foundation/ability/dmsfwk/services/dtbschedmgr/include/mission/
H A Ddms_continue_recv_manager.h39 std::string senderNetworkId; member
47 return (this->senderNetworkId == "" && this->bundleName == "" && this->continueType == ""); in isEmpty()
52 : senderNetworkId(source_device_id), in currentIconInfo()
82 void NotifyDataRecv(std::string& senderNetworkId, uint8_t* payload, uint32_t dataLen);
95 int32_t RetryPostBroadcast(const std::string& senderNetworkId, uint16_t bundleNameId, uint8_t continueTypeId,
99 int32_t VerifyBroadcastSource(const std::string& senderNetworkId, const std::string& srcBundleName,
101 void PostOnBroadcastBusiness(const std::string& senderNetworkId, uint16_t bundleNameId, uint8_t continueTypeId,
105 int32_t DealOnBroadcastBusiness(const std::string& senderNetworkId, uint16_t bundleNameId, uint8_t continueTypeId,
H A Ddistributed_mission_broadcast_listener.h32 void OnDataRecv(std::string& senderNetworkId, uint8_t* payload, uint32_t dataLen) override;
/foundation/filemanagement/dfs_service/services/cloudsyncservice/include/transport/softbus/
H A Di_softbus_listener.h28 virtual void OnDataReceived(const std::string &senderNetworkId,
32 virtual void OnFileReceived(const std::string &senderNetworkId, const char *filePath, int result) = 0;
H A Dsession_manager.h50 void OnDataReceived(const std::string &senderNetworkId,
54 void OnFileReceived(const std::string &senderNetworkId, const char *filePath, int result) override;
80 virtual void OnMessageHandle(const std::string &senderNetworkId,
84 virtual void OnFileRecvHandle(const std::string &senderNetworkId, const char *filePath, int result) = 0;
/foundation/filemanagement/dfs_service/test/fuzztest/filetransfermanager_fuzzer/
H A Dfiletransfermanager_fuzzer.cpp56 std::string senderNetworkId = fuzzData.GetStringFromData(NETWORK_ID_SIZE_MAX); in HandleDownloadFileRequestFuzzTest() local
64 fileTransferMgrPtr->HandleDownloadFileRequest(msgHandle, senderNetworkId, receiverSessionId); in HandleDownloadFileRequestFuzzTest()
89 std::string senderNetworkId = fuzzData.GetStringFromData(NETWORK_ID_SIZE_MAX); in OnMessageHandleFuzzTest() local
107 fileTransferMgrPtr->OnMessageHandle(senderNetworkId, receiverSessionId, dataSubPtr.get(), msgHandle.GetDataSize()); in OnMessageHandleFuzzTest()
114 std::string senderNetworkId = fuzzData.GetStringFromData(NETWORK_ID_SIZE_MAX); in OnFileRecvHandleFuzzTest() local
118 fileTransferMgrPtr->OnFileRecvHandle(senderNetworkId, filePath.c_str(), result); in OnFileRecvHandleFuzzTest()
/foundation/filemanagement/dfs_service/services/cloudsyncservice/include/transport/
H A Dfile_transfer_manager.h40 void OnMessageHandle(const std::string &senderNetworkId,
44 void OnFileRecvHandle(const std::string &senderNetworkId, const char *filePath, int result) override;
47 const std::string &senderNetworkId,
/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/
H A Dfile_transfer_manager.cpp70 const std::string &senderNetworkId, in HandleDownloadFileRequest()
79 auto result = sessionManager_->SendFile(senderNetworkId, {physicalPath}, {relativePath}); in HandleDownloadFileRequest()
92 .dstNetworkId = senderNetworkId, in HandleDownloadFileRequest()
130 void FileTransferManager::OnMessageHandle(const std::string &senderNetworkId, in OnMessageHandle() argument
143 HandleDownloadFileRequest(msgHandler, senderNetworkId, receiverSessionId); in OnMessageHandle()
153 void FileTransferManager::OnFileRecvHandle(const std::string &senderNetworkId, const char *filePath, int result) in OnFileRecvHandle() argument
166 auto ret = sessionManager_->SendData(senderNetworkId, data.get(), dataLen); in OnFileRecvHandle()
69 HandleDownloadFileRequest(MessageHandler &msgHandler, const std::string &senderNetworkId, int receiverSessionId) HandleDownloadFileRequest() argument
/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/softbus/
H A Dsession_manager.cpp155 void SessionManager::OnDataReceived(const std::string &senderNetworkId, in OnDataReceived() argument
161 dataHandler_->OnMessageHandle(senderNetworkId, receiverSessionId, data, dataLen); in OnDataReceived()
165 void SessionManager::OnFileReceived(const std::string &senderNetworkId, const char *filePath, int result) in OnFileReceived() argument
168 dataHandler_->OnFileRecvHandle(senderNetworkId, filePath, result); in OnFileReceived()
/foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/
H A Dsoftbus_adapter_listener.h30 virtual void OnDataRecv(std::string& senderNetworkId, uint8_t* payload, uint32_t dataLen) = 0;
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/softbus_adapter/
H A Dsoftbus_adapter_test.h35 void OnDataRecv(std::string& senderNetworkId, uint8_t* payload, uint32_t dataLen) {}; in OnDataRecv() argument
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/mission/
H A Ddms_continue_manager_test.cpp437 * @tc.steps: step1. test DealOnBroadcastBusiness when senderNetworkId is invalid; in HWTEST_F()
439 std::string senderNetworkId = "invalid senderNetworkId"; in HWTEST_F() local
444 DMSContinueRecvMgr::GetInstance().PostOnBroadcastBusiness(senderNetworkId, bundleNameId, continueTypeId, state); in HWTEST_F()
446 int32_t ret = DMSContinueRecvMgr::GetInstance().DealOnBroadcastBusiness(senderNetworkId, bundleNameId, in HWTEST_F()
450 ret = DMSContinueRecvMgr::GetInstance().DealOnBroadcastBusiness(senderNetworkId, bundleNameId, continueTypeId, in HWTEST_F()
665 DMSContinueRecvMgr::GetInstance().iconInfo_.senderNetworkId = NETWORKID_01; in HWTEST_F()
682 DMSContinueRecvMgr::GetInstance().iconInfo_.senderNetworkId = NETWORKID_01; in HWTEST_F()
684 EXPECT_EQ(DMSContinueRecvMgr::GetInstance().iconInfo_.senderNetworkId, NETWORKID_01); in HWTEST_F()
697 DMSContinueRecvMgr::GetInstance().iconInfo_.senderNetworkId in HWTEST_F()
761 std::string senderNetworkId = NETWORKID_01; HWTEST_F() local
[all...]
/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/
H A Dsoftbus_adapter.cpp161 std::string networkId(eventNotify->senderNetworkId); in EventListenerReceived()

Completed in 7 milliseconds