Home
last modified time | relevance | path

Searched refs:DistributedDB (Results 1 - 25 of 975) sorted by relevance

12345678910>>...39

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_single_ver_natural_store_testcase.h42 static void GetSyncData001(DistributedDB::SQLiteSingleVerNaturalStore *&store,
43 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
45 static void GetSyncData002(DistributedDB::SQLiteSingleVerNaturalStore *&store,
46 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
48 static void GetSyncData003(DistributedDB::SQLiteSingleVerNaturalStore *&store,
49 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
51 static void GetSyncData004(DistributedDB::SQLiteSingleVerNaturalStore *&store,
52 DistributedDB::SQLiteSingleVerNaturalStoreConnection *&connection);
54 static void GetSyncData005(DistributedDB::SQLiteSingleVerNaturalStore *&store,
55 DistributedDB
[all...]
H A Ddistributeddb_storage_rd_single_ver_natural_store_testcase.h43 static void SyncDatabaseOperate001(DistributedDB::RdSingleVerNaturalStore *&store,
44 DistributedDB::RdSingleVerNaturalStoreConnection *&connection);
46 static void SyncDatabaseOperate003(DistributedDB::RdSingleVerNaturalStore *&store,
47 DistributedDB::RdSingleVerNaturalStoreConnection *&connection);
49 static void SyncDatabaseOperate005(DistributedDB::RdSingleVerNaturalStore *&store,
50 DistributedDB::RdSingleVerNaturalStoreConnection *&connection);
52 static void SyncDatabaseOperate006(DistributedDB::RdSingleVerNaturalStore *&store,
53 DistributedDB::RdSingleVerNaturalStoreConnection *&connection);
58 static void TestMetaDataPutAndGet(DistributedDB::RdSingleVerNaturalStore *&store,
59 DistributedDB
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_transaction_testcase.h28 static void StartTransaction001(DistributedDB::KvStoreDelegate *&kvDelegatePtr);
30 static void StartTransaction002(DistributedDB::KvStoreDelegate *&kvDelegatePtr);
32 static void StartTransaction003(DistributedDB::KvStoreDelegate *&kvDelegatePtr);
34 static void StartTransaction004(DistributedDB::KvStoreDelegate *&kvDelegatePtr, const std::string &storeId,
35 bool localOnly, DistributedDB::KvStoreDelegateManager &mgr,
36 DistributedDB::KvStoreSnapshotDelegate *&snapshotDelegatePtr);
38 static void StartTransaction005(DistributedDB::KvStoreDelegate *&kvDelegatePtr, const std::string &storeId,
39 bool localOnly, DistributedDB::KvStoreDelegateManager &mgr);
41 static void Commit001(DistributedDB::KvStoreDelegate *&kvDelegatePtr);
43 static void Commit002(DistributedDB
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/include/
H A Ddistributeddb_nb_test_tools.h42 DistributedDB::CipherType cipher = DistributedDB::CipherType::DEFAULT; // cipher type
49 DistributedDB::SecurityOption secOption;
50 DistributedDB::KvStoreObserver *observer = nullptr;
51 DistributedDB::Key key;
54 DistributedDB::KvStoreNbConflictNotifier notifier = nullptr;
55 int conflictResolvePolicy = DistributedDB::LAST_WIN;
61 Option(bool createIfNecessary, bool isMemoryDb, bool isEncryptedDb, DistributedDB::CipherType cipher, in Option()
68 Option(bool createIfNecessary, bool isMemoryDb, bool isEncryptedDb, const DistributedDB::CipherType &cipher, in Option()
69 const std::vector<uint8_t> &passwd, const DistributedDB in Option()
[all...]
H A Ddistributeddb_data_generator.h384 const DistributedDB::Key KEY_1 = { 'k', '1' };
385 const DistributedDB::Key KEY_2 = { 'k', '2' };
386 const DistributedDB::Key KEY_3 = { 'k', '3' };
387 const DistributedDB::Key KEY_4 = { 'k', '4' };
388 const DistributedDB::Key KEY_5 = { 'k', '5' };
389 const DistributedDB::Key KEY_6 = { 'k', '6' };
390 const DistributedDB::Key KEY_7 = { 'k', '7' };
391 const DistributedDB::Key KEY_8 = { 'k', '8' };
392 const DistributedDB::Key KEY_9 = { 'k', '9' };
393 const DistributedDB
[all...]
H A Ddistributed_test_tools.h53 DistributedDB::CipherType cipher = DistributedDB::CipherType::DEFAULT; // cipher type
56 bool isEncryptedDb1, DistributedDB::CipherType cipher1, std::vector<uint8_t> passwd1) in KvOption()
96 const static KvOption g_createKvDiskUnencrypted(true, false, false, DistributedDB::CipherType::DEFAULT,
98 const static KvOption g_createKvDiskEncrypted(true, false, true, DistributedDB::CipherType::DEFAULT,
100 const static KvOption g_createLocalDiskUnencrypted(true, true, false, DistributedDB::CipherType::DEFAULT,
102 const static KvOption g_createLocalDiskEncrypted(true, true, true, DistributedDB::CipherType::DEFAULT,
106 bool CompareEntriesVector(std::vector<DistributedDB::Entry>& retVec,
107 std::vector<DistributedDB::Entry>& expectVec);
108 void PutUniqueKey(std::vector<DistributedDB
[all...]
H A Ddelegate_callback.h32 void Callback(DistributedDB::DBStatus status, DistributedDB::KvStoreSnapshotDelegate *kvStoreSnapshotDelegate);
33 void CallbackKv(DistributedDB::DBStatus status, const DistributedDB::Value &value);
35 DistributedDB::DBStatus GetStatus();
36 const DistributedDB::Value &GetValue();
38 const DistributedDB::KvStoreSnapshotDelegate *GetKvStoreSnapshot() in GetKvStoreSnapshot()
44 DistributedDB::DBStatus status_ = DistributedDB::DBStatus::INVALID_ARGS;
45 DistributedDB
[all...]
H A Dkv_store_observer_impl.h31 class KvStoreObserverImpl final : public DistributedDB::KvStoreObserver {
33 void OnChange(const DistributedDB::KvStoreChangedData &data);
45 const std::list<DistributedDB::Entry> GetInsertList() const;
47 const std::list<DistributedDB::Entry> GetUpdateList() const;
49 const std::list<DistributedDB::Entry> GetDeleteList() const;
65 const std::list<DistributedDB::Entry> GetCumulatedInsertList() const;
67 const std::list<DistributedDB::Entry> GetCumulatedUpdateList() const;
69 const std::list<DistributedDB::Entry> GetCumulatedDeleteList() const;
72 std::list<DistributedDB::Entry> insertedEntries_ = {};
73 std::list<DistributedDB
[all...]
H A Ddistributeddb_schema_test_tools.h265 static DistributedDB::Entry GenerateFixedLenJsonSchemaRecord(const unsigned long serialNo,
267 static std::vector<DistributedDB::Entry> GenerateFixedJsonSchemaRecords(
269 std::vector<DistributedDB::Key> &allKeys);
270 static DistributedDB::Entry GenerateFixedLenSchemaPerfRecord(const uint64_t presetRecordsCnt,
277 static bool CombinationCheckQueryResult(DistributedDB::KvStoreNbDelegate &delegate,
278 const DistributedDB::Query &query, std::vector<DistributedDB::Entry> &expectEntry,
279 const DistributedDB::DBStatus status, bool canGetCount);
280 static DistributedDB::Value GenSchemaValue(DistributedDB
[all...]
H A Dkv_store_snapshot_callback.h34 void Callback(DistributedDB::DBStatus status, const std::vector<DistributedDB::Entry> &entriesVec);
35 DistributedDB::DBStatus GetStatus();
36 std::vector<DistributedDB::Entry> GetEntries();
39 DistributedDB::DBStatus status_ = DistributedDB::DBStatus::INVALID_ARGS;
40 std::vector<DistributedDB::Entry> entriesVec_ = {};
H A Ddelegate_kv_mgr_callback.h32 void Callback(DistributedDB::DBStatus status, DistributedDB::KvStoreDelegate *kvStoreDelegate);
34 DistributedDB::DBStatus GetStatus();
36 const DistributedDB::KvStoreDelegate *GetKvStore();
39 DistributedDB::DBStatus status_ = DistributedDB::DBStatus::INVALID_ARGS;
40 DistributedDB::KvStoreDelegate *kvStoreDelegate_ = nullptr;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_tools_unit_test.h71 int messageId_ = DistributedDB::INVALID_MESSAGE_ID;
72 uint16_t messageType_ = DistributedDB::TYPE_INVALID;
75 int sendCode_ = DistributedDB::E_OK;
77 int32_t mode_ = DistributedDB::PUSH;
78 DistributedDB::WaterMark localMark_ = 0;
79 DistributedDB::WaterMark peerMark_ = 0;
80 DistributedDB::WaterMark deleteMark_ = 0;
131 static void KvStoreDelegateCallback(DistributedDB::DBStatus, DistributedDB::KvStoreDelegate*,
132 DistributedDB
[all...]
H A Ddistributeddb_data_generate_unit_test.h61 const DistributedDB::Key KEY_1 = {'1'};
62 const DistributedDB::Value VALUE_1 = {'a'};
63 const DistributedDB::Key KEY_2 = {'2'};
64 const DistributedDB::Value VALUE_2 = {'b'};
65 const DistributedDB::Key KEY_3 = {'3'};
66 const DistributedDB::Value VALUE_3 = {'c'};
67 const DistributedDB::Key KEY_4 = {'4'};
68 const DistributedDB::Value VALUE_4 = {'d'};
69 const DistributedDB::Key KEY_5 = {'5'};
70 const DistributedDB
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/include/
H A Ddistributeddb_nb_cursor_testcase.h26 static void ResultSetDb001(DistributedDB::KvStoreNbDelegate *delegate, bool isRowIdMode);
27 static void ResultSetDb002(DistributedDB::KvStoreNbDelegate *delegate, bool isRowIdMode);
28 static void ResultSetDb003(DistributedDB::KvStoreNbDelegate *delegate, bool isRowIdMode);
29 static void ResultSetDb004(DistributedDB::KvStoreNbDelegate *delegate, bool isRowIdMode);
30 static void ResultSetDb005(DistributedDB::KvStoreNbDelegate *delegate, bool isRowIdMode);
31 static void ResultSetDb006(DistributedDB::KvStoreNbDelegate *delegate, bool isRowIdMode);
32 static void ResultSetDb007(DistributedDB::KvStoreNbDelegate *delegate, bool isRowIdMode);
33 static void ResultSetDb008(DistributedDB::KvStoreNbDelegate *delegate, bool isRowIdMode);
34 static void ResultSetDb009(DistributedDB::KvStoreNbDelegate *delegate, bool isRowIdMode);
35 static void ResultSetDb010(DistributedDB
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/iprocesscommunicator_fuzzer/
H A Diprocesscommunicator_fuzzer.cpp24 using namespace DistributedDB;
32 class ProcessCommunicatorFuzzTest : public DistributedDB::IProcessCommunicator {
36 DistributedDB::DBStatus Start(const std::string &processLabel) override
38 return DistributedDB::OK;
41 DistributedDB::DBStatus Stop() override
43 return DistributedDB::OK;
45 DistributedDB::DBStatus RegOnDeviceChange(const DistributedDB::OnDeviceChange &callback) override
48 return DistributedDB::OK;
50 DistributedDB
[all...]
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/src/
H A Dprocess_communicator_impl_test.cpp71 EXPECT_EQ(DistributedDB::DBStatus::DB_ERROR, ret); in HWTEST_F()
73 EXPECT_EQ(DistributedDB::DBStatus::DB_ERROR, ret); in HWTEST_F()
87 EXPECT_EQ(DistributedDB::DBStatus::OK, ret); in HWTEST_F()
89 EXPECT_EQ(DistributedDB::DBStatus::OK, ret); in HWTEST_F()
101 processCommunicator->RegOnDeviceChange([](const DistributedDB::DeviceInfos &devInfo, bool isOnline) -> void { in HWTEST_F()
104 EXPECT_EQ(DistributedDB::DBStatus::OK, ret); in HWTEST_F()
106 EXPECT_EQ(DistributedDB::DBStatus::OK, ret); in HWTEST_F()
119 processCommunicator->RegOnDeviceChange([](const DistributedDB::DeviceInfos &devInfo, bool isOnline) -> void { in HWTEST_F()
122 EXPECT_EQ(DistributedDB::DBStatus::OK, ret); in HWTEST_F()
123 ret = processCommunicator->RegOnDeviceChange([](const DistributedDB in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_common.h31 DistributedDB::AdapterStub *adapterHandle = nullptr;
32 DistributedDB::CommunicatorAggregator *commAggrHandle = nullptr;
42 const std::shared_ptr<DistributedDB::DBStatusAdapter> &adapter);
75 class ExtendHeaderHandleTest : public DistributedDB::ExtendHeaderHandle {
77 explicit ExtendHeaderHandleTest(const DistributedDB::ExtendInfo &info) : headSize_(0) in ExtendHeaderHandleTest()
89 DistributedDB::DBStatus GetHeadDataSize(uint32_t &headSize) override
94 return DistributedDB::OK;
97 DistributedDB::DBStatus FillHeadData(uint8_t *data, uint32_t headSize, uint32_t totalLen) override
100 DistributedDB::HostToNet(info.magic);
101 DistributedDB
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dprocess_communication_impl.h26 class ProcessCommunicationImpl : public DistributedDB::IProcessCommunicator {
28 using DBStatus = DistributedDB::DBStatus;
29 using OnDeviceChange = DistributedDB::OnDeviceChange;
30 using OnDataReceive = DistributedDB::OnDataReceive;
41 DBStatus SendData(const DistributedDB::DeviceInfos &dstDevInfo, const uint8_t *data, uint32_t length) override;
43 uint32_t GetMtuSize(const DistributedDB::DeviceInfos &devInfo) override;
44 DistributedDB::DeviceInfos GetLocalDeviceInfos() override;
45 std::vector<DistributedDB::DeviceInfos> GetRemoteOnlineDeviceInfosList() override;
46 bool IsSameProcessLabelStartedOnPeerDevice(const DistributedDB::DeviceInfos &peerDevInfo) override;
47 std::shared_ptr<DistributedDB
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/relational/
H A Drelational_store_client.h30 std::map<std::string, DistributedDB::ChangeProperties> tableData;
34 using StoreObserver = DistributedDB::StoreObserver;
36 DB_API DistributedDB::DBStatus RegisterClientObserver(sqlite3 *db, const ClientObserver &clientObserver);
38 DB_API DistributedDB::DBStatus UnRegisterClientObserver(sqlite3 *db);
40 DB_API DistributedDB::DBStatus RegisterStoreObserver(sqlite3 *db, const std::shared_ptr<StoreObserver> &storeObserver);
42 DB_API DistributedDB::DBStatus UnregisterStoreObserver(sqlite3 *db,
45 DB_API DistributedDB::DBStatus UnregisterStoreObserver(sqlite3 *db);
47 DB_API DistributedDB::DBStatus DropLogicDeletedData(sqlite3 *db, const std::string &tableName, uint64_t cursor);
49 DB_API DistributedDB::DBStatus Lock(const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey,
52 DB_API DistributedDB
[all...]
/foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/
H A Drelational_store_client.h24 namespace DistributedDB { namespace
37 DistributedDB::DBStatus UnRegisterClientObserver(sqlite3 *db);
39 DistributedDB::DBStatus RegisterStoreObserver(sqlite3 *db,
40 const std::shared_ptr<DistributedDB::StoreObserver> &storeObserver);
42 DistributedDB::DBStatus UnregisterStoreObserver(sqlite3 *db,
43 const std::shared_ptr<DistributedDB::StoreObserver> &storeObserver);
45 DistributedDB::DBStatus UnregisterStoreObserver(sqlite3 *db);
47 DistributedDB::DBStatus Lock(
50 DistributedDB::DBStatus UnLock(
52 DistributedDB
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/
H A Ddb_store_mock.h22 class DBStoreMock : public DistributedDB::KvStoreNbDelegate {
24 using DBStatus = DistributedDB::DBStatus;
25 using Entry = DistributedDB::Entry;
26 using Key = DistributedDB::Key;
27 using Value = DistributedDB::Value;
28 using KvStoreResultSet = DistributedDB::KvStoreResultSet;
29 using Query = DistributedDB::Query;
30 using KvStoreNbPublishOnConflict = DistributedDB::KvStoreNbPublishOnConflict;
31 using KvStoreObserver = DistributedDB::KvStoreObserver;
32 using SyncMode = DistributedDB
[all...]
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/
H A Dflat_object_storage_engine.cpp48 auto status = DistributedDB::KvStoreDelegateManager::SetProcessLabel("objectstoreDB", bundleName); in Open()
49 if (status != DistributedDB::DBStatus::OK) { in Open()
52 status = DistributedDB::KvStoreDelegateManager::SetProcessCommunicator( in Open()
54 if (status != DistributedDB::DBStatus::OK) { in Open()
58 storeManager_ = std::make_shared<DistributedDB::KvStoreDelegateManager>(bundleName, "default"); in Open()
59 DistributedDB::KvStoreConfig config; in Open()
80 const std::map<std::string, DistributedDB::DBStatus> &devices, std::shared_ptr<StatusWatcher> statusWatcher) in OnComplete()
87 item.second == DistributedDB::OK ? "online" : "offline"); in OnComplete()
109 DistributedDB::KvStoreNbDelegate *kvStore = nullptr; in CreateTable()
110 DistributedDB in CreateTable()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/test/
H A Dstore_util_test.cpp56 ASSERT_EQ(dbsecurity.securityLabel, DistributedDB::NOT_SET); in HWTEST_F()
57 ASSERT_EQ(dbsecurity.securityFlag, DistributedDB::ECE); in HWTEST_F()
60 ASSERT_EQ(dbsecurity.securityLabel, DistributedDB::NOT_SET); in HWTEST_F()
61 ASSERT_EQ(dbsecurity.securityFlag, DistributedDB::ECE); in HWTEST_F()
64 ASSERT_EQ(dbsecurity.securityLabel, DistributedDB::S3); in HWTEST_F()
65 ASSERT_EQ(dbsecurity.securityFlag, DistributedDB::SECE); in HWTEST_F()
68 ASSERT_EQ(dbsecurity.securityLabel, DistributedDB::S4); in HWTEST_F()
69 ASSERT_EQ(dbsecurity.securityFlag, DistributedDB::ECE); in HWTEST_F()
81 StoreUtil::DBSecurity dbSec = { DistributedDB::NOT_SET, DistributedDB in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/
H A Ddistributeddb_nb_test_tools.cpp31 using namespace DistributedDB;
246 bool DistributedDBNbTestTools::isValueEquals(const DistributedDB::Value &v1, const DistributedDB::Value &v2) in isValueEquals()
257 DistributedDB::DBStatus DistributedDBNbTestTools::Get(DistributedDB::KvStoreNbDelegate &kvStoreNbDelegate, in Get()
258 const DistributedDB::Key &key, DistributedDB::Value &value) in Get()
263 DistributedDB::DBStatus DistributedDBNbTestTools::GetEntries(DistributedDB::KvStoreNbDelegate &kvStoreNbDelegate, in GetEntries()
264 const DistributedDB in GetEntries()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dvalue_proxy_test.cpp37 std::vector<DistributedDB::VBucket> dbVBuckets; in HWTEST_F()
55 std::vector<DistributedDB::VBucket> dbVBuckets = { in HWTEST_F()
137 DistributedDB::Asset dbAsset0 { .name = "dbname", .uri = "dburi" }; in HWTEST_F()
138 DistributedDB::Asset dbAsset1 { .name = "dbname", .uri = "dburi" }; in HWTEST_F()
139 std::map<std::string, DistributedDB::Asset> dbMap { { "asset0", dbAsset0 }, { "asset1", dbAsset1 } }; in HWTEST_F()
145 DistributedDB::Assets dbAssets { dbAsset0, dbAsset1 }; in HWTEST_F()
146 std::map<std::string, DistributedDB::Assets> dbAssetsMap { {"dbAssets", dbAssets} }; in HWTEST_F()
169 DistributedDB::VBucket transferredAsset = ValueProxy::Convert(nMap); in HWTEST_F()
171 auto asset = std::get<DistributedDB::Asset>(transferredAsset.find("asset0")->second); in HWTEST_F()
176 DistributedDB in HWTEST_F()
[all...]

Completed in 18 milliseconds

12345678910>>...39