| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
| H A D | distributeddb_kv_backup_test.cpp | 98 DBStatus status = g_manager->DeleteKvStore(STORE_ID_1); in TearDown() local 207 DBStatus status = g_kvBackupDelegate->Export(filePath, NULL_PASSWD); in HWTEST_F() local 271 DBStatus status = DistributedTestTools::PutBatch(*g_kvBackupDelegate, entriesBatch); in HWTEST_F() local 326 DBStatus status = DistributedTestTools::PutBatch(*g_kvBackupDelegate, entriesBatch); HWTEST_F() local 381 DBStatus status = DistributedTestTools::PutBatch(*g_kvBackupDelegate, entriesBatch); HWTEST_F() local 460 DBStatus status = DistributedTestTools::Put(*g_kvBackupDelegate, entriesBatch[0].key, entriesBatch[0].value); HWTEST_F() local 734 DBStatus status = DistributedTestTools::RegisterObserver(g_kvBackupDelegate, &observer); HWTEST_F() local 806 DBStatus status = getDelegateCallback.GetStatus(); HWTEST_F() local 864 DBStatus status = g_kvBackupDelegate->Rekey(g_passwd1); HWTEST_F() local 916 DBStatus status = delegate2->Import(filePath, NULL_PASSWD); HWTEST_F() local [all...] |
| H A D | distributeddb_kv_concurrency_crud_test.cpp | 68 DBStatus status; in ConcurOperThread() local 163 DBStatus status in TearDown() local 190 DBStatus status = DistributedTestTools::PutBatch(*g_kvStoreConcurDelegate, entriesBatch); HWTEST_F() local 278 DBStatus status = DistributedTestTools::PutBatch(*g_kvStoreConcurDelegate, entriesBatch); HWTEST_F() local 311 DBStatus status = DistributedTestTools::PutBatch(*g_kvStoreConcurDelegate, entriesBatch); HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
| H A D | flat_object_storage_engine.cpp | 48 auto status = DistributedDB::KvStoreDelegateManager::SetProcessLabel("objectstoreDB", bundleName); in Open() local 110 DistributedDB::DBStatus status; in CreateTable() local 122 RADAR_FAILED, status, FINISHED); CreateTable() local 132 RADAR_FAILED, status, FINISHED); CreateTable() local 169 DistributedDB::DBStatus status = delegate->GetEntries(emptyKey, resultSet); GetTable() local 210 auto status = delegate->Put(StringUtils::StrToBytes(itemKey), value); UpdateItem() local 238 auto status = delegate->PutBatch(entries); UpdateItems() local 258 auto status = storeManager_->CloseKvStore(delegates_.at(key)); DeleteTable() local 280 DistributedDB::DBStatus status = delegates_.at(key)->Get(StringUtils::StrToBytes(itemKey), value); GetItem() local 307 DistributedDB::DBStatus status = RegisterObserver() local 337 DistributedDB::DBStatus status = delegate->UnRegisterObserver(watcher.get()); UnRegisterObserver() local 402 DistributedDB::DBStatus status = kvstore->Sync(deviceIds, DistributedDB::SyncMode::SYNC_MODE_PULL_ONLY, onComplete); SyncAllData() local 424 DistributedDB::DBStatus status = delegates_.at(key)->GetEntries(StringUtils::StrToBytes(""), entries); GetItems() local 436 NotifyStatus(const std::string &sessionId, const std::string &deviceId, const std::string &status) NotifyStatus() argument [all...] |
| H A D | distributed_object_store_impl.cpp | 79 uint32_t status = flatObjectStore_->CreateObject(sessionId); in CreateObject() local 87 DistributedObject *DistributedObjectStoreImpl::CreateObject(const std::string &sessionId, uint32_t &status) in CreateObject() argument 117 uint32_t status in DeleteObject() local 162 uint32_t status = flatObjectStore_->Watch(object->GetSessionId(), watcherProxy); Watch() local 182 uint32_t status = flatObjectStore_->UnWatch(object->GetSessionId()); UnWatch() local [all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/common/ |
| H A D | value_proxy.cpp | 326 ConvertToDBStatus(const uint32_t &status) ConvertToDBStatus() argument 563 ConvertToDataStatus(const uint32_t &status) ConvertToDataStatus() argument [all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/ |
| H A D | rdb_subscriber_manager.cpp | 38 auto status = TemplateData::Add(key.uri, userId, key.bundleName, key.subscriberId, tpl);
in Add() local 48 auto status = TemplateData::Delete(key.uri, userId, key.bundleName, key.subscriberId);
in Delete() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | udmf_run_time_store_test.cpp | 136 int32_t status = store->PutEntries(entrysRand); in HWTEST_F() local 169 int32_t status = store->PutEntries(entrysRand); in HWTEST_F() local 203 int32_t status = store->PutEntries(entrysRand); HWTEST_F() local 235 int32_t status = store->PutEntries(entrysMix1); HWTEST_F() local 276 int32_t status = store->PutEntries(entrysRand); HWTEST_F() local 314 int32_t status = store->PutEntries(entrysRand); HWTEST_F() local 354 int32_t status = store->PutEntries(entrysRand); HWTEST_F() local 411 int32_t status = store->PutEntries(entrysMix1); HWTEST_F() local 441 auto status = store->PutEntries(entrysRand); HWTEST_F() local 471 int32_t status = store->PutEntries(entrysRand); HWTEST_F() local 507 int32_t status = store->PutEntries(entrysRand); HWTEST_F() local 549 auto status = store->GetSummary(KEY_PREFIX, summary); HWTEST_F() local [all...] |
| H A D | kvdb_service_impl_test.cpp | 151 Status status = manager.GetSingleKvStore(create, appId, id1, kvStore); in HWTEST_F() local 194 Status status = manager.GetSingleKvStore(create, appId, id1, kvStore); HWTEST_F() local 219 auto status = kvdbServiceImpl_->GetStoreIds(appId01, storeIds); HWTEST_F() local 236 auto status = kvdbServiceImpl_->Delete(appId, storeId); HWTEST_F() local 252 auto status = kvdbServiceImpl_->Delete(appId01, storeId01); HWTEST_F() local 270 auto status = kvdbServiceImpl_->Sync(appId, storeId, syncInfo); HWTEST_F() local 288 auto status = kvdbServiceImpl_->RegServiceNotifier(appId, notifier); HWTEST_F() local 305 auto status = kvdbServiceImpl_->UnregServiceNotifier(appId); HWTEST_F() local 323 auto status = kvdbServiceImpl_->SetSyncParam(appId, storeId, syncparam); HWTEST_F() local 341 auto status = kvdbServiceImpl_->GetSyncParam(appId, storeId, syncparam); HWTEST_F() local 358 auto status = kvdbServiceImpl_->EnableCapability(appId, storeId); HWTEST_F() local 375 auto status = kvdbServiceImpl_->DisableCapability(appId, storeId); HWTEST_F() local 394 auto status = kvdbServiceImpl_->SetCapability(appId, storeId, local, remote); HWTEST_F() local 412 auto status = kvdbServiceImpl_->AddSubscribeInfo(appId, storeId, syncInfo); HWTEST_F() local 430 auto status = kvdbServiceImpl_->RmvSubscribeInfo(appId, storeId, syncInfo); HWTEST_F() local 448 auto status = kvdbServiceImpl_->Subscribe(appId, storeId, observer); HWTEST_F() local 466 auto status = kvdbServiceImpl_->Unsubscribe(appId, storeId, observer); HWTEST_F() local 480 auto status = manager.GetSingleKvStore(create, appId, storeId, kvStore); HWTEST_F() local 497 auto status = kvdbServiceImpl_->BeforeCreate(appId, storeId, create); HWTEST_F() local 515 auto status = kvdbServiceImpl_->AfterCreate(appId, storeId, create, password); HWTEST_F() local 548 auto status = kvdbServiceImpl_->OnAppExit(uid, pid, tokenId, appId); HWTEST_F() local 565 auto status = kvdbServiceImpl_->OnUserChange(code, user, account); HWTEST_F() local 580 auto status = kvdbServiceImpl_->OnReady(device); HWTEST_F() local 597 Status status = manager.GetSingleKvStore(create, appId, id1, kvStore); HWTEST_F() local 624 Status status = manager.GetSingleKvStore(create, appId, id1, kvStore); HWTEST_F() local 661 Status status = manager.GetSingleKvStore(create, appId, id1, kvStore); HWTEST_F() local 710 auto status = kvdbServiceImpl_->ConvertDBMode(SyncMode::PUSH); HWTEST_F() local 726 auto status = kvdbServiceImpl_->ConvertGeneralSyncMode(SyncMode::PUSH, SyncAction::ACTION_SUBSCRIBE); HWTEST_F() local 749 auto status = kvdbServiceImpl_->ConvertType(SyncMode::PUSH); HWTEST_F() local 768 auto status = kvdbServiceImpl_->ConvertAction(Action::INSERT); HWTEST_F() local 787 auto status = kvdbServiceImpl_->GetSyncMode(true, true); HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/ |
| H A D | js_single_kv_store.cpp | 125 napi_status status = napi_typeof(env, argv[0], &type); in GetVariantArgs() local 392 Status status = Status::INVALID_ARGUMENT; Sync() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_register_syncdb_test.cpp | 224 DBStatus status = g_kvDelegatePtr->Put(key, value); in HWTEST_F() local 263 DBStatus status = g_kvDelegatePtr->PutBatch(entries); in HWTEST_F() local 294 DBStatus status = g_kvDelegatePtr->PutBatch(entries); in HWTEST_F() local 342 DBStatus status = g_kvDelegatePtr->Put(key, value1); in HWTEST_F() local 382 DBStatus status = g_kvDelegatePtr->Put(key, value); HWTEST_F() local 431 DBStatus status = g_kvDelegatePtr->Delete(key); HWTEST_F() local 462 DBStatus status = g_kvDelegatePtr->PutBatch(entries); HWTEST_F() local 511 DBStatus status = g_kvDelegatePtr->PutBatch(entries); HWTEST_F() local 564 DBStatus status = g_kvDelegatePtr->DeleteBatch(keys); HWTEST_F() local 595 DBStatus status = g_kvDelegatePtr->PutBatch(entries); HWTEST_F() local 641 DBStatus status = g_kvDelegatePtr->Clear(); HWTEST_F() local 909 DBStatus status = g_kvDelegatePtr->PutBatch(entries); HWTEST_F() local 1113 DBStatus status = g_kvDelegatePtr->PutBatch(entries); HWTEST_F() local 1205 DBStatus status = g_kvDelegatePtr->PutBatch(entries); HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_p2p_permission_sync_test.cpp | 133 DBStatus status = g_mgr.DeleteKvStore(STORE_ID); in TearDown() local 173 DBStatus status = OK; in HWTEST_F() local 238 DBStatus status = OK; HWTEST_F() local 316 DBStatus status = g_kvDelegatePtr->Put(key1, value1); HWTEST_F() local 395 DBStatus status = OK; HWTEST_F() local 459 DBStatus status = OK; HWTEST_F() local 527 DBStatus status = OK; HWTEST_F() local 595 DBStatus status = OK; HWTEST_F() local 653 DBStatus status = OK; HWTEST_F() local [all...] |
| H A D | distributeddb_single_ver_dlp_test.cpp | 302 DBStatus status = g_tool.SyncTest(delegatePtr1, { DEVICE_B }, SYNC_MODE_PUSH_ONLY, result); in HWTEST_F() local 332 DBStatus status = g_tool.SyncTest(delegatePtr1, { DEVICE_B }, SYNC_MODE_PUSH_ONLY, result); in HWTEST_F() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_meta_manager.cpp | 92 auto status = DmAdapter::GetInstance().StartWatchDeviceChange(&listener_, { "metaMgr" }); in InitMetaListener() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | cloud_cursor_impl.cpp | 47 auto status = OhCloudExtVectorGet(values_, 0, &values, reinterpret_cast<unsigned int *>(&valueLen)); in CloudCursorImpl() local 62 auto status = OhCloudExtCloudDbDataGetNextCursor( in CloudCursorImpl() local 154 auto status = OhCloudExtVectorGet(values_, index_, &values, reinterpret_cast<unsigned int *>(&valueLen)); in GetEntry() local 178 auto status = OhCloudExtValueBucketGetKeys(vb, &keys, reinterpret_cast<unsigned int *>(&keysLen)); in GetData() local 186 auto status = OhCloudExtVectorGet(pKeys.get(), i, &value, reinterpret_cast<unsigned int *>(&valueLen)); in GetData() local 208 int32_t status = ERRNO_SUCCESS; GetExtend() local 266 auto status = OhCloudExtVectorGet(values_, index_, &data, reinterpret_cast<unsigned int *>(&valueLen)); Get() local [all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/waterversion/ |
| H A D | water_version_manager.cpp | 409 auto status = versions_.Get(metaData.deviceId, metaData); in GenerateWaterVersion() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | kv_utils.cpp | 73 Status status = ToEntryKey(values, entry.key); in ToEntry() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/test/ |
| H A D | backup_manager_test.cpp | 76 auto status = DeleteBackUpFiles(kvStore_, baseDir, storeId);
in TearDown() local 97 Status status = StoreManager::GetInstance().Delete(appId, storeId, options.baseDir);
in CreateKVStore() local 140 auto status = kvStore_->Backup("testbackup", baseDir);
in HWTEST_F() local 155 auto status = kvStore_->Backup("testbackup", baseDir); HWTEST_F() local 173 auto status = kvStore_->Backup("testbackup", baseDir); HWTEST_F() local 188 auto status = kvStore_->Put({ "Put Test" }, { "Put Value" }); HWTEST_F() local 230 auto status = kvStore_->DeleteBackup(files, baseDir, results); HWTEST_F() local 273 auto status = DeleteBackUpFiles(kvStoreEncrypt, baseDir, storeId); HWTEST_F() local 313 auto status = DeleteBackUpFiles(kvStoreEncrypt, baseDir, storeId); HWTEST_F() local 368 auto status = DeleteBackUpFiles(kvStoreEncrypt, baseDir, storeId); HWTEST_F() local 423 auto status = DeleteBackUpFiles(kvStoreEncrypt, baseDir, storeId); HWTEST_F() local 450 auto status = kvStoreEncrypt->Put({ "Put Test" }, { "Put Value" }); HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | store_util.cpp | 145 Status StoreUtil::ConvertStatus(DBStatus status) in ConvertStatus() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | icloud_syncer.h | 35 ProcessStatus status = ProcessStatus::PREPARED; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_query_object_helper_test.cpp | 298 DBStatus status; in HWTEST_F() local
|
| /foundation/distributeddatamgr/kv_store/test/distributedtest/single_kvstore_client/ |
| H A D | distributed_test_agent.cpp | 119 auto status = manager_.GetSingleKvStore(options, appId, storeId, singleKvStore_);
in SetUp() local 180 auto status = singleKvStore_->Get(key, value);
in Get() local 194 auto status = singleKvStore_->Put(key, value);
in Put() local 202 auto status = singleKvStore_->Sync(devices, syncMode); Sync() local [all...] |
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/src/ |
| H A D | object_store_test.cpp | 189 uint32_t status = -1; in HWTEST_F() local 223 uint32_t status = -1; in HWTEST_F() local 244 uint32_t status = -1; in HWTEST_F() local 269 uint32_t status = objectStore->Get("", &Object1); HWTEST_F() local 288 uint32_t status = objectStore->Watch(nullptr, watcher); HWTEST_F() local 320 uint32_t status = objectStore->Watch(object, watcher); HWTEST_F() local 1208 DistributedDB::DBStatus status = DistributedDB::DBStatus::OK; HWTEST_F() local 1314 uint32_t status = 0; HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/ |
| H A D | account_delegate_normal_impl.cpp | 98 auto status = AccountSA::OsAccountManager::IsOsAccountVerified(userId, res); in IsVerified() local 126 uint32_t status = static_cast<uint32_t>(account.status); in UpdateUserStatus() local 214 int32_t status = AccountSA::OsAccountManager::GetForegroundOsAccountLocalId(foregroundUserId); in QueryForegroundUserId() local [all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/ |
| H A D | auto_cache.cpp | 294 auto status = store_->Close(); in Close() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_cloud.cpp | 222 DBStatus status = DB_ERROR; in ConvertQuery() local
|