| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
| H A D | asset_change_timer.cpp | 46 StartTimer(sessionId, assetKey, watcher); in OnAssetChanged()
52 std::string key = sessionId + ASSET_SEPARATOR + assetKey; in StartTimer()
67 assetKey.c_str()); in ProcessTask()
68 StopTimer(sessionId, assetKey); in ProcessTask()
69 uint32_t status = HandleAssetChanges(sessionId, assetKey); in ProcessTask()
72 sessionId.c_str(), assetKey.c_str()); in ProcessTask()
73 watcher->OnChanged(sessionId, { assetKey }); in ProcessTask()
80 std::string key = sessionId + ASSET_SEPARATOR + assetKey; in StopTimer()
89 if (!GetAssetValue(sessionId, assetKey, assetValue)) { in HandleAssetChanges()
91 sessionId.c_str(), assetKey.c_str()); in HandleAssetChanges()
[all …]
|
| H A D | distributed_object_impl.cpp | 118 uint32_t DistributedObjectImpl::GetAssetValue(const std::string &assetKey, Asset &assetValue) in GetAssetValue() argument
121 auto status = GetDouble(assetKey + STATUS_SUFFIX, assetStatus); in GetAssetValue()
125 status = GetString(assetKey + NAME_SUFFIX, assetValue.name); in GetAssetValue()
127 status = GetString(assetKey + URI_SUFFIX, assetValue.uri); in GetAssetValue()
129 status = GetString(assetKey + PATH_SUFFIX, assetValue.path); in GetAssetValue()
131 status = GetString(assetKey + CREATE_TIME_SUFFIX, assetValue.createTime); in GetAssetValue()
133 status = GetString(assetKey + MODIFY_TIME_SUFFIX, assetValue.modifyTime); in GetAssetValue()
135 status = GetString(assetKey + SIZE_SUFFIX, assetValue.size); in GetAssetValue()
152 uint32_t DistributedObjectImpl::BindAssetStore(const std::string &assetKey, AssetBindInfo &bindInfo) in BindAssetStore() argument
155 auto status = GetAssetValue(assetKey, assetValue); in BindAssetStore()
|
| H A D | distributed_object_store_impl.cpp | 158 …[=](const std::string &sessionId, const std::string &assetKey, std::shared_ptr<ObjectWatcher> obje… in Watch() argument
160 assetChangeTimer->OnAssetChanged(sessionId, assetKey, objectWatcher); in Watch()
224 std::string assetKey; in OnChanged() local
225 if (FindChangedAssetKey(str, assetKey)) { in OnChanged()
226 transferKeys.insert(assetKey); in OnChanged()
233 for (auto &assetKey : transferKeys) { in OnChanged() local
234 assetChangeCallback_(sessionId, assetKey, objectWatcher_); in OnChanged()
242 bool WatcherProxy::FindChangedAssetKey(const std::string &changedKey, std::string &assetKey) in FindChangedAssetKey() argument
247 assetKey = changedKey.substr(0, dotPos); in FindChangedAssetKey()
|
| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/adaptor/ |
| H A D | asset_change_timer.h | 28 …const std::string &sessionId, const std::string &assetKey, std::shared_ptr<ObjectWatcher> watcher);
36 …void StartTimer(const std::string &sessionId, const std::string &assetKey, std::shared_ptr<ObjectW…
37 void StopTimer(const std::string &sessionId, const std::string &assetKey);
39 …const std::string &sessionId, const std::string &assetKey, std::shared_ptr<ObjectWatcher> watcher);
40 uint32_t HandleAssetChanges(const std::string &sessionId, const std::string &assetKey);
41 … bool GetAssetValue(const std::string &sessionId, const std::string &assetKey, Asset &assetValue);
|
| H A D | distributed_object_impl.h | 40 uint32_t BindAssetStore(const std::string &assetKey, AssetBindInfo &bindInfo) override;
43 uint32_t GetAssetValue(const std::string &assetKey, Asset &assetValue);
|
| H A D | distributed_objectstore_impl.h | 68 const std::string &assetKey, std::shared_ptr<ObjectWatcher> watcher)>;
75 bool FindChangedAssetKey(const std::string &changedKey, std::string &assetKey);
|
| /ohos5.0/foundation/filemanagement/dfs_service/adapter/cloud_adapter_example/src/ |
| H A D | cloud_asset_read_session_impl.cpp | 23 std::string assetKey, in CloudAssetReadSessionImpl() argument
25 : CloudAssetReadSession(recordType, recordId, assetKey, assetPath) in CloudAssetReadSessionImpl()
|
| H A D | cloud_database_impl.cpp | 30 std::string assetKey, in NewAssetReadSession() argument
33 return std::make_shared<CloudAssetReadSessionImpl>(recordType, recordId, assetKey, assetPath); in NewAssetReadSession()
|
| /ohos5.0/foundation/filemanagement/dfs_service/frameworks/native/cloud_file_kit_inner/src/ |
| H A D | cloud_database.cpp | 28 std::string assetKey, in NewAssetReadSession() argument
31 return std::make_shared<CloudAssetReadSession>(recordType, recordId, assetKey, assetPath); in NewAssetReadSession()
|
| H A D | cloud_asset_read_session.cpp | 24 std::string assetKey, in CloudAssetReadSession() argument
|
| /ohos5.0/foundation/filemanagement/dfs_service/adapter/cloud_adapter_example/include/ |
| H A D | cloud_asset_read_session_impl.h | 26 std::string assetKey,
|
| H A D | cloud_database_impl.h | 27 std::string assetKey,
|
| /ohos5.0/foundation/filemanagement/dfs_service/interfaces/inner_api/native/cloud_file_kit_inner/ |
| H A D | cloud_asset_read_session.h | 27 …CloudAssetReadSession(std::string recordType, std::string recordId, std::string assetKey, std::str…
|
| H A D | cloud_database.h | 31 std::string assetKey,
|
| /ohos5.0/foundation/distributeddatamgr/data_object/interfaces/innerkits/ |
| H A D | distributed_object.h | 164 virtual uint32_t BindAssetStore(const std::string &assetKey, AssetBindInfo &bindInfo) = 0;
|
| /ohos5.0/foundation/filemanagement/dfs_service/test/unittests/cloud_disk/mock/ |
| H A D | file_operations_helper_mock.cpp | 140 string assetKey = ""; in FindCloudDiskFile() local
144 make_shared<CloudFile::CloudAssetReadSession>(recordType, recordId, assetKey, assetPath); in FindCloudDiskFile()
|
| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/adaptor/ |
| H A D | js_distributedobject.cpp | 356 std::string assetKey; in JSBindAssetStore() member
363 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->assetKey); in JSBindAssetStore()
380 … uint32_t status = ctxt->wrapper->GetObject()->BindAssetStore(ctxt->assetKey, ctxt->bindInfo); in JSBindAssetStore()
|
| /ohos5.0/docs/zh-cn/application-dev/reference/apis-arkdata/ |
| H A D | js-apis-data-distributedobject.md | 634 bindAssetStore(assetKey: string, bindInfo: BindInfo, callback: AsyncCallback<void>): void
646 …| assetKey | string | 是 | 待绑定的融合资产在分布式对象中的键值。 …
716 bindAssetStore(assetKey: string, bindInfo: BindInfo): Promise<void>
728 …| assetKey | string | 是 | 待绑定的融合资产在分布式对象中的键值。 …
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_manager.cpp | 597 std::set<std::string> assetKey; in GetAssetsFromDBRecords() local
600 if (!IsAssetKey(key) || assetKey.find(assetPrefix) != assetKey.end() || in GetAssetsFromDBRecords()
628 assetKey.insert(assetPrefix); in GetAssetsFromDBRecords()
|
| /ohos5.0/docs/en/application-dev/reference/apis-arkdata/ |
| H A D | js-apis-data-distributedobject.md | 635 bindAssetStore(assetKey: string, bindInfo: BindInfo, callback: AsyncCallback<void>): void
647 …| assetKey | string | Yes | Key of the joint asset in the distributed data obj…
717 bindAssetStore(assetKey: string, bindInfo: BindInfo): Promise<void>
729 …| assetKey | string | Yes | Key of the joint asset in the distributed data objec…
|
| /ohos5.0/docs/zh-cn/application-dev/database/ |
| H A D | data-sync-of-distributed-data-object.md | 146 | bindAssetStore(assetKey: string, bindInfo: BindInfo, callback: AsyncCallback<void>): void |…
|
| /ohos5.0/docs/en/application-dev/database/ |
| H A D | data-sync-of-distributed-data-object.md | 146 | bindAssetStore(assetKey: string, bindInfo: BindInfo, callback: AsyncCallback<void>): void |…
|