diff --git a/services/distributeddataservice/service/object/include/object_data_listener.h b/services/distributeddataservice/service/object/include/object_data_listener.h
index 3c1bfdea0dee7cf4dfb4303b42b3b5f2684d64a6..7c3140c7b0f33f3e8c307a09416d3146b8ebdd45 100644
--- a/services/distributeddataservice/service/object/include/object_data_listener.h
+++ b/services/distributeddataservice/service/object/include/object_data_listener.h
@@ -38,6 +38,9 @@ public:
                   const std::string &dstBundleName) override;
     int32_t OnFinished(const std::string &srcNetworkId,
                      const sptr<AssetObj> &assetObj, int32_t result) override;
+    int32_t OnRecvProgress(const std::string &srcNetworkId,
+                     const sptr<AssetObj> &assetObj, 
+                     uint64_t totalBytes, uint64_t processBytes) override;   
 };
 }  // namespace DistributedObject
 }  // namespace OHOS
diff --git a/services/distributeddataservice/service/object/src/object_data_listener.cpp b/services/distributeddataservice/service/object/src/object_data_listener.cpp
index e7a7a5d0abcd44de8af8b2ac9b582c17ab887a3b..8451fa30db0c17007ad091486b11208bc8377eb9 100644
--- a/services/distributeddataservice/service/object/src/object_data_listener.cpp
+++ b/services/distributeddataservice/service/object/src/object_data_listener.cpp
@@ -71,5 +71,22 @@ int32_t ObjectAssetsRecvListener::OnFinished(const std::string &srcNetworkId, co
     ObjectStoreManager::GetInstance()->NotifyAssetsReady(objectKey, assetObj->dstBundleName_, srcNetworkId);
     return OBJECT_SUCCESS;
 }
+
+
+int32_t ObjectAssetsRecvListener::OnRecvProgress(const std::string &srcNetworkId, const sptr<AssetObj> &assetObj,
+    uint64_t totalBytes, uint64_t processBytes)
+{
+    if (assetObj == nullptr) {
+        ZLOGE("OnRecvProgress error! srcNetworkId:%{public}s",
+            DistributedData::Anonymous::Change(srcNetworkId).c_str());
+        return OBJECT_INNER_ERROR;
+    }
+
+    auto objectKey = assetObj->dstBundleName_ + assetObj->sessionId_;
+    ZLOGI("OnRecvProgress, srcNetworkId: %{public}s, objectKey:%{public}s, totalBytes: %{public}llu,"
+        "processBytes: %{public}llu.",
+        DistributedData::Anonymous::Change(srcNetworkId).c_str(), objectKey.c_str(), totalBytes, processBytes);
+    return OBJECT_SUCCESS;
+}
 }  // namespace DistributedObject
 }  // namespace OHOS