| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_db_proxy.cpp | 102 std::shared_ptr<ICloudDb> cloudDb = iCloudDb_; in BatchInsert() local
106 int errCode = InnerAction(context, cloudDb, INSERT); in BatchInsert()
119 std::shared_ptr<ICloudDb> cloudDb = iCloudDb_; in BatchUpdate() local
123 int errCode = InnerAction(context, cloudDb, UPDATE); in BatchUpdate()
137 std::shared_ptr<ICloudDb> cloudDb = iCloudDb_; in BatchDelete() local
140 int errCode = InnerAction(context, cloudDb, DELETE); in BatchDelete()
152 std::shared_ptr<ICloudDb> cloudDb = iCloudDb_; in Query() local
156 int errCode = InnerAction(context, cloudDb, QUERY); in Query()
177 std::shared_ptr<ICloudDb> cloudDb = iCloudDb_; in Lock() local
180 int errCode = InnerAction(context, cloudDb, LOC in Lock()
192 std::shared_ptr<ICloudDb> cloudDb = iCloudDb_; UnLock() local
239 std::shared_ptr<ICloudDb> cloudDb = iCloudDb_; HeartBeat() local
311 std::shared_ptr<ICloudDb> cloudDb = iCloudDb_; GetEmptyCursor() local
321 InnerAction(const std::shared_ptr<CloudActionContext> &context, const std::shared_ptr<ICloudDb> &cloudDb, InnerActionCode action) InnerAction() argument
331 DMLActionTask(const std::shared_ptr<CloudActionContext> &context, const std::shared_ptr<ICloudDb> &cloudDb, InnerActionCode action) DMLActionTask() argument
373 InnerActionTask(const std::shared_ptr<CloudActionContext> &context, const std::shared_ptr<ICloudDb> &cloudDb, InnerActionCode action) InnerActionTask() argument
416 InnerActionLock(const std::shared_ptr<CloudActionContext> &context, const std::shared_ptr<ICloudDb> &cloudDb) InnerActionLock() argument
433 InnerActionGetEmptyCursor(const std::shared_ptr<CloudActionContext> &context, const std::shared_ptr<ICloudDb> &cloudDb) InnerActionGetEmptyCursor() argument
476 QueryAction(const std::shared_ptr<CloudActionContext> &context, const std::shared_ptr<ICloudDb> &cloudDb) QueryAction() argument
[all...] |
| H A D | cloud_db_proxy.h | 151 const std::shared_ptr<ICloudDb> &cloudDb, InnerActionCode action);
154 const std::shared_ptr<ICloudDb> &cloudDb, InnerActionCode action);
157 const std::shared_ptr<ICloudDb> &cloudDb, InnerActionCode action);
160 const std::shared_ptr<ICloudDb> &cloudDb);
163 const std::shared_ptr<ICloudDb> &cloudDb);
168 const std::shared_ptr<ICloudDb> &cloudDb);
|
| H A D | cloud_syncer_extend.cpp | 497 for (auto &[user, cloudDb] : cloudDBs) { in GenerateCompensatedSync()
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/cloud_extension/ |
| H A D | cloud_extension_stub.js | 291 this.cloudDb = i1;
295 if (this.cloudDb === undefined) {
303 let m2 = await this.cloudDb.generateId(l2);
321 let e3 = await this.cloudDb.insert(n2, o2, p2);
333 let e3 = await this.cloudDb.update(q2, r2, s2);
344 let e3 = await this.cloudDb.delete(v1, t2);
360 let g3 = await this.cloudDb.query(u2, v2, w2, x2);
371 let y2 = await this.cloudDb.lock();
380 let a3 = await this.cloudDb.heartbeat(z2);
389 let c3 = await this.cloudDb
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | cloud_server_impl.cpp | 649 OhCloudExtCloudDatabase *cloudDb = OhCloudExtCloudDbNew(hapInfo.userID, in ConnectCloudDB() local
652 return cloudDb != nullptr ? std::make_shared<CloudDbImpl>(cloudDb) : nullptr; in ConnectCloudDB()
662 OhCloudExtCloudDatabase *cloudDb = OhCloudExtCloudDbNew( in ConnectCloudDB() local
664 return cloudDb != nullptr ? std::make_shared<CloudDbImpl>(cloudDb) : nullptr; in ConnectCloudDB()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_store_delegate_impl.h | 56 DBStatus SetCloudDB(const std::shared_ptr<ICloudDb> &cloudDb) override;
|
| H A D | relational_store_delegate_impl.cpp | 239 DBStatus RelationalStoreDelegateImpl::SetCloudDB(const std::shared_ptr<ICloudDb> &cloudDb) in SetCloudDB() argument
241 if (conn_ == nullptr || conn_->SetCloudDB(cloudDb) != E_OK) { in SetCloudDB()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_store_connection.h | 50 int SetCloudDB(const std::shared_ptr<ICloudDb> &cloudDb) override;
|
| H A D | sqlite_relational_store_connection.cpp | 303 int SQLiteRelationalStoreConnection::SetCloudDB(const std::shared_ptr<ICloudDb> &cloudDb) in SetCloudDB() argument
311 return store->SetCloudDB(cloudDb); in SetCloudDB()
|
| H A D | sqlite_relational_store.h | 86 int SetCloudDB(const std::shared_ptr<ICloudDb> &cloudDb);
|
| H A D | sqlite_relational_store.cpp | 935 int SQLiteRelationalStore::SetCloudDB(const std::shared_ptr<ICloudDb> &cloudDb) in SetCloudDB() argument
941 cloudSyncer_->SetCloudDB(cloudDb); in SetCloudDB()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | relational_store_connection.h | 66 virtual int SetCloudDB(const std::shared_ptr<ICloudDb> &cloudDb) = 0;
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/relational/ |
| H A D | relational_store_delegate.h | 73 DB_API virtual DBStatus SetCloudDB(const std::shared_ptr<ICloudDb> &cloudDb) = 0;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | rdb_general_store_test.cpp | 126 DBStatus SetCloudDB(const std::shared_ptr<ICloudDb> &cloudDb) override
|