Home
last modified time | relevance | path

Searched refs:StorageProxy (Results 1 – 25 of 25) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dstorage_proxy.cpp24 StorageProxy::StorageProxy(ICloudSyncStorageInterface *iCloud) in StorageProxy() function in DistributedDB::StorageProxy
31 std::shared_ptr<StorageProxy> StorageProxy::GetCloudDb(ICloudSyncStorageInterface *iCloud) in GetCloudDb()
33 std::shared_ptr<StorageProxy> proxy = std::make_shared<StorageProxy>(iCloud); in GetCloudDb()
38 void StorageProxy::Init() in Init()
43 int StorageProxy::Close() in Close()
139 int StorageProxy::Commit() in Commit()
152 int StorageProxy::Rollback() in Rollback()
504 int StorageProxy::ClearAllTempSyncTrigger() in ClearAllTempSyncTrigger()
609 void StorageProxy::OnSyncFinish() in OnSyncFinish()
618 void StorageProxy::OnUploadStart() in OnUploadStart()
[all …]
/ohos5.0/foundation/arkui/ace_engine/test/unittest/core/common/storage/
H A Dstorage_test.cpp45 StorageProxy* firstTestGetInstance;
46 firstTestGetInstance = StorageProxy::GetInstance();
53 StorageProxy* secondTestGetInstance;
54 secondTestGetInstance = StorageProxy::GetInstance();
70 StorageProxy::GetInstance()->SetDelegate(nullptr);
72 RefPtr<Storage> stroage = StorageProxy::GetInstance()->GetStorage();
89 StorageProxy::GetInstance()->SetDistributedDelegate(nullptr);
94 …RefPtr<Storage> distributedStorage = StorageProxy::GetInstance()->GetStorage(testSessionId, notifi…
111 StorageProxy::GetInstance()->SetDelegate(std::make_unique<MockStorageProxyImpl>());
113 RefPtr<Storage> stroage = StorageProxy::GetInstance()->GetStorage();
[all …]
/ohos5.0/foundation/arkui/ace_engine/frameworks/core/common/storage/
H A Dstorage_proxy.cpp21 StorageProxy* StorageProxy::inst_ = nullptr;
23 StorageProxy* StorageProxy::GetInstance() in GetInstance()
26 inst_ = new StorageProxy(); in GetInstance()
31 void StorageProxy::SetDelegate(std::unique_ptr<StorageInterface>&& delegate) in SetDelegate()
36 void StorageProxy::SetDistributedDelegate(std::unique_ptr<StorageInterface>&& delegate) in SetDistributedDelegate()
41 RefPtr<Storage> StorageProxy::GetStorage() const in GetStorage()
47 RefPtr<Storage> StorageProxy::GetStorage(const std::string& sessionId, in GetStorage()
H A Dstorage_proxy.h24 class ACE_FORCE_EXPORT StorageProxy : public StorageInterface {
26 ACE_EXPORT static StorageProxy* GetInstance();
32 StorageProxy() = default;
33 ~StorageProxy() = default;
38 static StorageProxy* inst_;
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/storage/src/
H A Dnapi_storage.cpp52 StorageProxy::StorageProxy(std::shared_ptr<OHOS::NativePreferences::Preferences> &value) in StorageProxy() function in OHOS::StorageJsKit::StorageProxy
57 StorageProxy::~StorageProxy() in ~StorageProxy()
67 StorageProxy *obj = static_cast<StorageProxy *>(nativeObject); in Destructor()
149 StorageProxy *obj = new (std::nothrow) StorageProxy(preference); in New()
216 StorageProxy *obj = nullptr; in GetValueSync()
358 StorageProxy *obj = reinterpret_cast<StorageProxy *>(context->boundObj); in GetValue()
448 StorageProxy *obj = reinterpret_cast<StorageProxy *>(context->boundObj); in SetValue()
503 StorageProxy *obj = reinterpret_cast<StorageProxy *>(context->boundObj); in Delete()
551 StorageProxy *obj = reinterpret_cast<StorageProxy *>(context->boundObj); in HasKey()
576 StorageProxy *obj = reinterpret_cast<StorageProxy *>(context->boundObj); in Flush()
[all …]
H A Dentry_point_storage.cpp28 StorageProxy::Init(env, exports); in Init()
H A Dnapi_storage_helper.cpp47 NAPI_CALL(env, StorageProxy::NewInstance(env, args[0], &instance)); in GetStorageSync()
87 auto ret = StorageProxy::NewInstance(env, path, &result); in GetStorage()
/ohos5.0/foundation/arkui/ace_engine/frameworks/bridge/declarative_frontend/jsview/
H A Djs_persistent.cpp72 if (!StorageProxy::GetInstance()->GetStorage()) { in Set()
76 StorageProxy::GetInstance()->GetStorage()->SetString(key, value); in Set()
89 auto storage = StorageProxy::GetInstance()->GetStorage(); in Get()
117 if (!StorageProxy::GetInstance()->GetStorage()) { in Has()
121 std::string value = StorageProxy::GetInstance()->GetStorage()->GetString(key); in Has()
136 if (!StorageProxy::GetInstance()->GetStorage()) { in Delete()
140 StorageProxy::GetInstance()->GetStorage()->Delete(key); in Delete()
150 if (!StorageProxy::GetInstance()->GetStorage()) { in Clear()
154 StorageProxy::GetInstance()->GetStorage()->Clear(); in Clear()
/ohos5.0/foundation/arkui/ace_engine/frameworks/bridge/cj_frontend/interfaces/cj_ffi/state_manage/
H A Dcj_persistent_storage_ffi.cpp34 std::string valueStr = StorageProxy::GetInstance()->GetStorage()->GetString(key); in GetValueFromStorage()
49 if (!StorageProxy::GetInstance()->GetStorage()) { in SetValueToStorage()
53 StorageProxy::GetInstance()->GetStorage()->SetString(key, value); in SetValueToStorage()
192 StorageProxy::GetInstance()->GetStorage()->Delete(key); in FfiOHOSAceFrameworkPersistentDelete()
206 StorageProxy::GetInstance()->GetStorage()->Clear(); in FfiOHOSAceFrameworkPersistentClear()
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/storage/include/
H A Dnapi_storage.h33 class StorageProxy {
41 explicit StorageProxy(std::shared_ptr<OHOS::NativePreferences::Preferences> &value);
42 ~StorageProxy();
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dstorage_proxy.h33 class StorageProxy {
35 StorageProxy(ICloudSyncStorageInterface *iCloud);
36 virtual ~StorageProxy() {}; in ~StorageProxy()
38 static std::shared_ptr<StorageProxy> GetCloudDb(ICloudSyncStorageInterface *iCloud);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_meta_data_test.cpp44 std::shared_ptr<StorageProxy> g_storageProxy = nullptr;
87 std::shared_ptr<StorageProxy> GetStorageProxy(ICloudSyncStorageInterface *store) in GetStorageProxy()
89 return StorageProxy::GetCloudDb(store); in GetStorageProxy()
217 StorageProxy proxyObj(nullptr);
276 StorageProxy proxyObj(nullptr);
H A Ddistributeddb_cloud_save_cloud_data_test.cpp251 std::shared_ptr<StorageProxy> GetStorageProxy(ICloudSyncStorageInterface *store) in GetStorageProxy()
253 return StorageProxy::GetCloudDb(store); in GetStorageProxy()
269 std::shared_ptr<StorageProxy> storageProxy = GetStorageProxy(g_cloudStore); in GetInfoByPrimaryKeyOrGidTest()
460 std::shared_ptr<StorageProxy> storageProxy = GetStorageProxy(g_cloudStore); in VbucketWithoutPrimaryDataTest()
537 std::shared_ptr<StorageProxy> storageProxy = GetStorageProxy(g_cloudStore); in PrimaryKeyCollateTest()
840 std::shared_ptr<StorageProxy> storageProxy = GetStorageProxy(g_cloudStore); in SaveCloudDataTest()
1064 std::shared_ptr<StorageProxy> storageProxy = GetStorageProxy(g_cloudStore);
1097 std::shared_ptr<StorageProxy> storageProxy = GetStorageProxy(g_cloudStore);
1149 std::shared_ptr<StorageProxy> storageProxy = GetStorageProxy(g_cloudStore);
1183 std::shared_ptr<StorageProxy> storageProxy = GetStorageProxy(g_cloudStore);
[all …]
/ohos5.0/foundation/arkui/ace_engine/adapter/ohos/entrance/
H A Dcapability_registry.cpp30 StorageProxy::GetInstance()->SetDelegate(std::make_unique<StorageProxyImpl>()); in Register()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/storage_fuzzer/
H A Dstorage_fuzzer.cpp52 std::shared_ptr<StorageProxy> g_storageProxy = nullptr;
158 std::shared_ptr<StorageProxy> GetStorageProxy(ICloudSyncStorageInterface *store) in GetStorageProxy()
160 return StorageProxy::GetCloudDb(store); in GetStorageProxy()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dvirtual_cloud_syncer.h22 explicit VirtualCloudSyncer(std::shared_ptr<StorageProxy> storageProxy);
H A Ddistributeddb_cloud_db_proxy_test.cpp302 auto cloudSyncer = new(std::nothrow) VirtualCloudSyncer(StorageProxy::GetCloudDb(iCloud.get()));
394 auto cloudSyncer = new(std::nothrow) VirtualCloudSyncer(StorageProxy::GetCloudDb(iCloud.get()));
637 auto cloudSyncer = new(std::nothrow) VirtualCloudSyncer(StorageProxy::GetCloudDb(iCloud.get()));
677 auto cloudSyncer = new(std::nothrow) VirtualCloudSyncer(StorageProxy::GetCloudDb(iCloud.get()));
716 auto cloudSyncer = new(std::nothrow) VirtualCloudSyncer(StorageProxy::GetCloudDb(iCloud.get()));
H A Dvirtual_cloud_syncer.cpp19 VirtualCloudSyncer::VirtualCloudSyncer(std::shared_ptr<StorageProxy> storageProxy) in VirtualCloudSyncer()
H A Dcloud_syncer_test.h36 class TestStorageProxy : public StorageProxy {
38 explicit TestStorageProxy(ICloudSyncStorageInterface *iCloud) : StorageProxy(iCloud) in TestStorageProxy()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer.h43 explicit CloudSyncer(std::shared_ptr<StorageProxy> storageProxy, bool isKvScene = false,
451 std::shared_ptr<StorageProxy> storageProxy_;
H A Dcloud_syncer.cpp38 … std::shared_ptr<StorageProxy> storageProxy, bool isKvScene, SingleVerConflictResolvePolicy policy) in CloudSyncer()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dsync_able_kvdb.cpp529 …StorageProxy::GetCloudDb(cloudStorage), true, static_cast<SingleVerConflictResolvePolicy>(conflict… in StartCloudSyncer()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp71 std::shared_ptr<StorageProxy> g_storageProxy = nullptr;
376 std::shared_ptr<StorageProxy> GetStorageProxy(ICloudSyncStorageInterface *store) in GetStorageProxy()
378 return StorageProxy::GetCloudDb(store); in GetStorageProxy()
/ohos5.0/foundation/arkui/ace_engine/build/
H A Dlibace.map246 OHOS::Ace::StorageProxy::*;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_store.cpp305 … cloudSyncer_ = new (std::nothrow) CloudSyncer(StorageProxy::GetCloudDb(storageEngine_), false); in Open()