Home
last modified time | relevance | path

Searched refs:assetObj (Results 1 - 25 of 47) sorted by relevance

12

/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/ipc/
H A Ddaemon_execute.cpp79 auto assetObj = pushData->assetObj_; in ExecutePushAsset() local
80 if (assetObj == nullptr) { in ExecutePushAsset()
81 LOGE("assetObj is nullptr."); in ExecutePushAsset()
85 auto ret = SoftBusHandlerAsset::GetInstance().AssetBind(assetObj->dstNetworkId_, socketId); in ExecutePushAsset()
88 auto taskId = assetObj->srcBundleName_ + assetObj->sessionId_; in ExecutePushAsset()
89 AssetCallbackManager::GetInstance().NotifyAssetSendResult(taskId, assetObj, FileManagement::E_EVENT_HANDLER); in ExecutePushAsset()
93 SoftBusHandlerAsset::GetInstance().AddAssetObj(socketId, assetObj); in ExecutePushAsset()
95 auto fileList = GetFileList(assetObj->uris_, userId, assetObj in ExecutePushAsset()
237 HandleZip(const std::vector<std::string> &fileList, const sptr<AssetObj> &assetObj, std::string &sendFileName, bool &isSingleFile) HandleZip() argument
266 HandlePushAssetFail(int32_t socketId, const sptr<AssetObj> &assetObj) HandlePushAssetFail() argument
[all...]
H A Dasset_callback_manager.cpp106 const sptr<AssetObj> &assetObj, in NotifyAssetRecvFinished()
114 assetObj->sessionId_.c_str(), assetObj->dstBundleName_.c_str()); in NotifyAssetRecvFinished()
116 callback->OnFinished(srcNetworkId, assetObj, result); in NotifyAssetRecvFinished()
122 const sptr<AssetObj> &assetObj, in NotifyAssetSendResult()
136 iter->second->OnSendResult(assetObj, result); in NotifyAssetSendResult()
105 NotifyAssetRecvFinished(const std::string &srcNetworkId, const sptr<AssetObj> &assetObj, int32_t result) NotifyAssetRecvFinished() argument
121 NotifyAssetSendResult(const std::string &taskId, const sptr<AssetObj> &assetObj, int32_t result) NotifyAssetSendResult() argument
H A Dasset_send_callback_proxy.cpp31 int32_t AssetSendCallbackProxy::OnSendResult(const sptr<AssetObj> &assetObj, int32_t result) in OnSendResult() argument
41 if (!data.WriteParcelable(assetObj)) { in OnSendResult()
H A Dasset_recv_callback_proxy.cpp75 const sptr<AssetObj> &assetObj, in OnFinished()
90 if (!data.WriteParcelable(assetObj)) { in OnFinished()
74 OnFinished(const std::string &srcNetworkId, const sptr<AssetObj> &assetObj, int32_t result) OnFinished() argument
/foundation/filemanagement/dfs_service/frameworks/native/distributed_file_inner/include/asset/
H A Dasset_obj.h38 AssetObj(const AssetObj &assetObj) in AssetObj()
39 : sessionId_(assetObj.sessionId_), in AssetObj()
40 dstNetworkId_(assetObj.dstNetworkId_), in AssetObj()
41 srcBundleName_(assetObj.srcBundleName_), in AssetObj()
42 dstBundleName_(assetObj.dstBundleName_), in AssetObj()
43 uris_(assetObj.uris_) in AssetObj()
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/network/softbus/
H A Dsoftbus_asset_send_listener.cpp54 auto assetObj = SoftBusHandlerAsset::GetInstance().GetAssetObj(socketId); in OnSendAssetFinished() local
55 if (assetObj == nullptr) { in OnSendAssetFinished()
56 LOGE("OnSendAssetFinished get assetObj is nullptr"); in OnSendAssetFinished()
59 auto taskId = assetObj->srcBundleName_ + assetObj->sessionId_; in OnSendAssetFinished()
60 AssetCallbackManager::GetInstance().NotifyAssetSendResult(taskId, assetObj, FileManagement::E_OK); in OnSendAssetFinished()
77 auto assetObj = SoftBusHandlerAsset::GetInstance().GetAssetObj(socketId); in OnSendAssetError() local
78 if (assetObj == nullptr) { in OnSendAssetError()
79 LOGE("OnSendAssetError get assetObj is nullptr"); in OnSendAssetError()
82 auto taskId = assetObj in OnSendAssetError()
[all...]
H A Dsoftbus_asset_recv_listener.cpp91 sptr<AssetObj> assetObj (new (std::nothrow) AssetObj()); in OnRecvAssetStart()
92 int32_t ret = SoftBusHandlerAsset::GetInstance().GenerateAssetObjInfo(socketId, filePath, assetObj); in OnRecvAssetStart()
98 assetObj->dstNetworkId_, in OnRecvAssetStart()
99 assetObj->sessionId_, in OnRecvAssetStart()
100 assetObj->dstBundleName_); in OnRecvAssetStart()
116 sptr<AssetObj> assetObj (new (std::nothrow) AssetObj()); in OnRecvAssetFinished()
117 int32_t ret = SoftBusHandlerAsset::GetInstance().GenerateAssetObjInfo(socketId, firstFilePath, assetObj); in OnRecvAssetFinished()
125 ret = HandleSingleFile(socketId, filePath, assetObj); in OnRecvAssetFinished()
127 ret = HandleZipFile(socketId, filePath, assetObj); in OnRecvAssetFinished()
132 AssetCallbackManager::GetInstance().NotifyAssetRecvFinished(srcNetworkId, assetObj, in OnRecvAssetFinished()
242 HandleSingleFile(int32_t socketId, const std::string &filePath, const sptr<AssetObj> &assetObj) HandleSingleFile() argument
264 HandleZipFile(int32_t socketId, const std::string &filePath, const sptr<AssetObj> &assetObj) HandleZipFile() argument
[all...]
H A Dsoftbus_handler_asset.cpp184 auto assetObj = GetAssetObj(socketId); in AssetSendFile() local
185 if (assetObj == nullptr) { in AssetSendFile()
186 LOGE("get assetObj fail."); in AssetSendFile()
189 if (!IsSameAccount(assetObj->dstNetworkId_)) { in AssetSendFile()
197 auto dstFile = GetDstFile(sendFile, assetObj->srcBundleName_, in AssetSendFile()
198 assetObj->dstBundleName_, assetObj->sessionId_, isSingleFile); in AssetSendFile()
253 void SoftBusHandlerAsset::AddAssetObj(int32_t socketId, const sptr<AssetObj> &assetObj) in AddAssetObj() argument
258 LOGI("assetObj exist."); in AddAssetObj()
261 assetObjMap_.insert(std::pair<int32_t, sptr<AssetObj>>(socketId, assetObj)); in AddAssetObj()
285 GenerateAssetObjInfo(int32_t socketId, const std::string &fileName, const sptr<AssetObj> &assetObj) GenerateAssetObjInfo() argument
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/
H A Dobject_data_listener.cpp58 int32_t ObjectAssetsRecvListener::OnFinished(const std::string &srcNetworkId, const sptr<AssetObj> &assetObj, in OnFinished() argument
61 if (assetObj == nullptr) { in OnFinished()
68 auto objectKey = assetObj->dstBundleName_+assetObj->sessionId_; in OnFinished()
70 assetObj->uris_.size()); in OnFinished()
71 ObjectStoreManager::GetInstance()->NotifyAssetsReady(objectKey, assetObj->dstBundleName_, srcNetworkId); in OnFinished()
H A Dobject_asset_loader.cpp167 int32_t ObjectAssetLoader::PushAsset(int32_t userId, const sptr<AssetObj> &assetObj, in PushAsset() argument
173 assetObj->uris_.size(), assetObj->dstBundleName_.c_str(), assetObj->sessionId_.c_str()); in PushAsset()
174 auto status = Storage::DistributedFile::DistributedFileDaemonManager::GetInstance().PushAsset(userId, assetObj, in PushAsset()
178 status, assetObj->uris_.size(), assetObj->dstBundleName_.c_str(), assetObj->sessionId_.c_str()); in PushAsset()
185 int32_t ObjectAssetsSendListener::OnSendResult(const sptr<AssetObj> &assetObj, int32_t result) in OnSendResult() argument
187 if (assetObj in OnSendResult()
[all...]
H A Dobject_asset_loader.h39 int32_t OnSendResult(const sptr<AssetObj> &assetObj, int32_t result) override;
50 int32_t PushAsset(int32_t userId, const sptr<AssetObj> &assetObj,
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/ipc/
H A Dasset_send_callback_proxy_test.cpp82 sptr<AssetObj> assetObj (new (std::nothrow) AssetObj()); in HWTEST_F()
85 auto ret = proxy_->OnSendResult(assetObj, 0); in HWTEST_F()
90 ret = proxy_->OnSendResult(assetObj, 0); in HWTEST_F()
96 ret = proxy_->OnSendResult(assetObj, 0); in HWTEST_F()
103 ret = testProxy->OnSendResult(assetObj, 0); in HWTEST_F()
110 ret = proxy_->OnSendResult(assetObj, 0); in HWTEST_F()
124 sptr<AssetObj> assetObj (new (std::nothrow) AssetObj()); in HWTEST_F()
130 auto ret = proxy_->OnSendResult(assetObj, 0); in HWTEST_F()
H A Dasset_callback_manager_test.cpp143 sptr<AssetObj> assetObj (new (std::nothrow) AssetObj()); in HWTEST_F()
144 AssetCallbackManager::GetInstance().NotifyAssetRecvFinished("srcNetworkId", assetObj, 0); in HWTEST_F()
169 sptr<AssetObj> assetObj (new (std::nothrow) AssetObj()); in HWTEST_F()
170 AssetCallbackManager::GetInstance().NotifyAssetSendResult("test3", assetObj, 0); in HWTEST_F()
171 AssetCallbackManager::GetInstance().NotifyAssetSendResult("test", assetObj, 0); in HWTEST_F()
172 AssetCallbackManager::GetInstance().NotifyAssetSendResult("test2", assetObj, 0); in HWTEST_F()
H A Dasset_recv_callback_proxy_test.cpp164 sptr<AssetObj> assetObj (new (std::nothrow) AssetObj()); in HWTEST_F()
167 auto ret = proxy_->OnFinished("srcNetworkId", assetObj, 0); in HWTEST_F()
172 ret = proxy_->OnFinished("srcNetworkId", assetObj, 0); in HWTEST_F()
178 ret = proxy_->OnFinished("srcNetworkId", assetObj, 0); in HWTEST_F()
185 ret = proxy_->OnFinished("srcNetworkId", assetObj, 0); in HWTEST_F()
199 sptr<AssetObj> assetObj (new (std::nothrow) AssetObj()); in HWTEST_F()
205 auto ret = testProxy->OnFinished("srcNetworkId", assetObj, 0); in HWTEST_F()
214 ret = proxy_->OnFinished("srcNetworkId", assetObj, 0); in HWTEST_F()
228 sptr<AssetObj> assetObj (new (std::nothrow) AssetObj()); in HWTEST_F()
236 auto ret = proxy_->OnFinished("srcNetworkId", assetObj, in HWTEST_F()
[all...]
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/softbus/
H A Dsoftbus_asset_send_listener_test.cpp83 sptr<AssetObj> assetObj(new (std::nothrow) AssetObj()); in HWTEST_F()
86 SoftBusHandlerAsset::GetInstance().AddAssetObj(socket, assetObj); in HWTEST_F()
117 sptr<AssetObj> assetObj(new (std::nothrow) AssetObj()); in HWTEST_F()
118 SoftBusHandlerAsset::GetInstance().AddAssetObj(socket, assetObj); in HWTEST_F()
145 sptr<AssetObj> assetObj(new (std::nothrow) AssetObj()); in HWTEST_F()
146 SoftBusHandlerAsset::GetInstance().AddAssetObj(socket, assetObj); in HWTEST_F()
H A Dsoftbus_handler_asset_test.cpp286 sptr<AssetObj> assetObj (new (std::nothrow) AssetObj()); in HWTEST_F()
287 softBusHandlerAsset.AddAssetObj(0, assetObj); in HWTEST_F()
288 softBusHandlerAsset.AddAssetObj(0, assetObj); in HWTEST_F()
296 EXPECT_EQ(softBusHandlerAsset.GetAssetObj(0), assetObj); in HWTEST_F()
349 sptr<AssetObj> assetObj (new (std::nothrow) AssetObj()); in HWTEST_F()
350 softBusHandlerAsset.AddAssetObj(0, assetObj); in HWTEST_F()
355 assetObj->dstNetworkId_ = "testNetWork"; in HWTEST_F()
356 assetObj->srcBundleName_ = "demoA"; in HWTEST_F()
357 assetObj->dstBundleName_ = "demoB"; in HWTEST_F()
358 assetObj in HWTEST_F()
[all...]
H A Dsoftbus_asset_recv_listener_test.cpp262 sptr<AssetObj> assetObj = new (std::nothrow) AssetObj(); in HWTEST_F() local
263 assetObj->dstBundleName_ = "demoB"; in HWTEST_F()
264 EXPECT_EQ(SoftbusAssetRecvListener::HandleSingleFile(2, fileName, assetObj), ERR_BAD_VALUE); in HWTEST_F()
267 EXPECT_EQ(SoftbusAssetRecvListener::HandleSingleFile(2, fileName, assetObj), ERR_BAD_VALUE); in HWTEST_F()
281 sptr<AssetObj> assetObj = new (std::nothrow) AssetObj(); in HWTEST_F() local
282 assetObj->dstBundleName_ = "demoB"; in HWTEST_F()
283 EXPECT_EQ(SoftbusAssetRecvListener::HandleZipFile(2, fileName, assetObj), ERR_BAD_VALUE); in HWTEST_F()
286 EXPECT_EQ(SoftbusAssetRecvListener::HandleZipFile(2, fileName, assetObj), ERR_BAD_VALUE); in HWTEST_F()
/foundation/filemanagement/dfs_service/test/unittests/distributed_file_inner/asset/
H A Dasset_send_callback_stub_test.cpp32 MOCK_METHOD2(OnSendResult, int32_t(const sptr<AssetObj> &assetObj, int32_t result));
127 sptr<AssetObj> assetObj(new (std::nothrow) AssetObj()); in HWTEST_F()
128 data.WriteParcelable(assetObj); in HWTEST_F()
133 data.WriteParcelable(assetObj); in HWTEST_F()
153 sptr<AssetObj> assetObj(new (std::nothrow) AssetObj()); in HWTEST_F()
154 data.WriteParcelable(assetObj); in HWTEST_F()
H A Dasset_recv_callback_stub_test.cpp36 const sptr<AssetObj> &assetObj,
184 sptr<AssetObj> assetObj(new (std::nothrow) AssetObj()); in HWTEST_F()
185 data.WriteParcelable(assetObj); in HWTEST_F()
190 data.WriteParcelable(assetObj); in HWTEST_F()
211 sptr<AssetObj> assetObj(new (std::nothrow) AssetObj()); in HWTEST_F()
212 data.WriteParcelable(assetObj); in HWTEST_F()
/foundation/filemanagement/dfs_service/frameworks/native/distributed_file_inner/src/asset/
H A Dasset_send_callback_stub.cpp50 sptr<AssetObj> assetObj = data.ReadParcelable<AssetObj>(); in HandleOnSendResult() local
51 if (!assetObj) { in HandleOnSendResult()
61 int32_t res = OnSendResult(assetObj, result); in HandleOnSendResult()
H A Dasset_recv_callback_stub.cpp89 sptr<AssetObj> assetObj = data.ReadParcelable<AssetObj>(); in HandleOnFinished() local
90 if (!assetObj) { in HandleOnFinished()
100 int32_t res = OnFinished(srcNetworkId, assetObj, result); in HandleOnFinished()
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/include/ipc/
H A Ddaemon_event.h31 PushAssetData(int32_t userId, const sptr<AssetObj> &assetObj) in PushAssetData()
32 : userId_(userId), assetObj_(assetObj) in PushAssetData()
H A Ddaemon_execute.h51 const sptr<AssetObj> &assetObj,
54 void HandlePushAssetFail(int32_t socketId, const sptr<AssetObj> &assetObj);
H A Dasset_callback_manager.h45 const sptr<AssetObj> &assetObj,
48 const sptr<AssetObj> &assetObj,
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/include/network/softbus/
H A Dsoftbus_asset_recv_listener.h43 static int32_t HandleSingleFile(int32_t socketId, const std::string &filePath, const sptr<AssetObj> &assetObj);
44 static int32_t HandleZipFile(int32_t socketId, const std::string &filePath, const sptr<AssetObj> &assetObj);

Completed in 11 milliseconds

12