| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
| H A D | asset_change_timer.cpp | 44 const std::string &sessionId, const std::string &assetKey, std::shared_ptr<ObjectWatcher> watcher) in OnAssetChanged()
46 StartTimer(sessionId, assetKey, watcher); in OnAssetChanged()
50 const std::string &sessionId, const std::string &assetKey, std::shared_ptr<ObjectWatcher> watcher) in StartTimer()
52 std::string key = sessionId + ASSET_SEPARATOR + assetKey; in StartTimer()
56 executor_->Schedule(std::chrono::milliseconds(WAIT_INTERVAL), ProcessTask(sessionId, assetKey, watcher)); in StartTimer()
63 const std::string &sessionId, const std::string &assetKey, std::shared_ptr<ObjectWatcher> watcher) in ProcessTask()
66 LOG_DEBUG("Start working on a task, sessionId: %{public}s, assetKey: %{public}s", sessionId.c_str(), in ProcessTask()
67 assetKey.c_str()); in ProcessTask()
68 StopTimer(sessionId, assetKey); in ProcessTask()
69 uint32_t status = HandleAssetChanges(sessionId, assetKey); in ProcessTask()
43 OnAssetChanged( const std::string &sessionId, const std::string &assetKey, std::shared_ptr<ObjectWatcher> watcher) OnAssetChanged() argument
49 StartTimer( const std::string &sessionId, const std::string &assetKey, std::shared_ptr<ObjectWatcher> watcher) StartTimer() argument
62 ProcessTask( const std::string &sessionId, const std::string &assetKey, std::shared_ptr<ObjectWatcher> watcher) ProcessTask() argument
78 StopTimer(const std::string &sessionId, const std::string &assetKey) StopTimer() argument
86 HandleAssetChanges(const std::string &sessionId, const std::string &assetKey) HandleAssetChanges() argument
115 GetAssetValue(const std::string &sessionId, const std::string &assetKey, Asset &assetValue) GetAssetValue() argument
[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, assetValu in BindAssetStore()
[all...] |
| H A D | distributed_object_store_impl.cpp | 158 [=](const std::string &sessionId, const std::string &assetKey, std::shared_ptr<ObjectWatcher> objectWatcher) { in Watch()
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()
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()
|
| /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<ObjectWatcher> watcher);
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);
|
| /foundation/filemanagement/dfs_service/adapter/cloud_adapter_example/src/ |
| H A D | cloud_asset_read_session_impl.cpp | 23 std::string assetKey, in CloudAssetReadSessionImpl()
25 : CloudAssetReadSession(recordType, recordId, assetKey, assetPath) in CloudAssetReadSessionImpl()
21 CloudAssetReadSessionImpl(std::string recordType, std::string recordId, std::string assetKey, std::string assetPath) CloudAssetReadSessionImpl() argument
|
| H A D | cloud_database_impl.cpp | 30 std::string assetKey, in NewAssetReadSession()
33 return std::make_shared<CloudAssetReadSessionImpl>(recordType, recordId, assetKey, assetPath); in NewAssetReadSession()
28 NewAssetReadSession(std::string recordType, std::string recordId, std::string assetKey, std::string assetPath) NewAssetReadSession() argument
|
| /foundation/filemanagement/dfs_service/frameworks/native/cloud_file_kit_inner/src/ |
| H A D | cloud_database.cpp | 28 std::string assetKey, in NewAssetReadSession()
31 return std::make_shared<CloudAssetReadSession>(recordType, recordId, assetKey, assetPath); in NewAssetReadSession()
26 NewAssetReadSession(std::string recordType, std::string recordId, std::string assetKey, std::string assetPath) NewAssetReadSession() argument
|
| H A D | cloud_asset_read_session.cpp | 24 std::string assetKey, in CloudAssetReadSession()
22 CloudAssetReadSession(std::string recordType, std::string recordId, std::string assetKey, std::string assetPath) CloudAssetReadSession() argument
|
| /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,
|
| /foundation/filemanagement/dfs_service/interfaces/inner_api/native/cloud_file_kit_inner/ |
| H A D | cloud_database.h | 31 std::string assetKey,
|
| H A D | cloud_asset_read_session.h | 27 CloudAssetReadSession(std::string recordType, std::string recordId, std::string assetKey, std::string assetPath);
|
| /foundation/distributeddatamgr/data_object/interfaces/innerkits/ |
| H A D | distributed_object.h | 159 * @param assetKey Indicates the assetKey key.
164 virtual uint32_t BindAssetStore(const std::string &assetKey, AssetBindInfo &bindInfo) = 0;
|
| /foundation/filemanagement/dfs_service/test/unittests/cloud_disk/mock/ |
| H A D | file_operations_helper_mock.cpp | 142 string assetKey = ""; in FindCloudDiskFile() local
146 make_shared<CloudFile::CloudAssetReadSession>(recordType, recordId, assetKey, assetPath); in FindCloudDiskFile()
|
| /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()
365 std::make_shared<ParametersType>("assetKey", "string"));
in JSBindAssetStore()
380 uint32_t status = ctxt->wrapper->GetObject()->BindAssetStore(ctxt->assetKey, ctxt->bindInfo);
in JSBindAssetStore()
|
| /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()
|