Home
last modified time | relevance | path

Searched refs:CompressAlgorithm (Results 1 – 23 of 23) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Ddata_compression.cpp20 void DataCompression::GetCompressionAlgo(std::set<CompressAlgorithm> &algorithmSet) in GetCompressionAlgo()
28 int DataCompression::TransferCompressionAlgo(uint32_t compressAlgoType, CompressAlgorithm &algoType) in TransferCompressionAlgo()
38 DataCompression *DataCompression::GetInstance(CompressAlgorithm algo) in GetInstance()
48 void DataCompression::Register(CompressAlgorithm algo, DataCompression *compressionPtr) in Register()
57 std::map<CompressAlgorithm, DataCompression *> &DataCompression::GetCompressionAlgos() in GetCompressionAlgos()
59 static std::map<CompressAlgorithm, DataCompression *> compressionAlgos; in GetCompressionAlgos()
63 std::map<uint32_t, CompressAlgorithm> &DataCompression::GetTransMap() in GetTransMap()
65 static std::map<uint32_t, CompressAlgorithm> transferMap; in GetTransMap()
H A Dzlib_compression.cpp30 DataCompression::Register(CompressAlgorithm::ZLIB, this); in ZlibCompression()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Ddata_compression.h27 static DataCompression *GetInstance(CompressAlgorithm algo);
28 static void GetCompressionAlgo(std::set<CompressAlgorithm> &algorithmSet);
29 static int TransferCompressionAlgo(uint32_t compressAlgoType, CompressAlgorithm &algoType);
41 static void Register(CompressAlgorithm algo, DataCompression *compression);
44 static std::map<CompressAlgorithm, DataCompression *> &GetCompressionAlgos();
45 static std::map<uint32_t, CompressAlgorithm> &GetTransMap();
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_data_compression_test.cpp97 …EXPECT_EQ(DataCompression::GetInstance(CompressAlgorithm::ZLIB)->Compress(srcData, compressedData)…
105 EXPECT_EQ(DataCompression::GetInstance(CompressAlgorithm::ZLIB)->Uncompress(
129 …EXPECT_EQ(DataCompression::GetInstance(CompressAlgorithm::ZLIB)->Compress(srcData, compressedData)…
142 EXPECT_EQ(DataCompression::GetInstance(CompressAlgorithm::ZLIB)->Uncompress(
165 …EXPECT_EQ(DataCompression::GetInstance(CompressAlgorithm::ZLIB)->Compress(srcData, compressedData)…
174 EXPECT_EQ(DataCompression::GetInstance(CompressAlgorithm::ZLIB)->Uncompress(
184 EXPECT_EQ(DataCompression::GetInstance(CompressAlgorithm::ZLIB)->Uncompress(
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_task_context.cpp409 std::set<CompressAlgorithm> SingleVerSyncTaskContext::GetRemoteCompressAlgo() const in GetRemoteCompressAlgo()
412 std::set<CompressAlgorithm> compressAlgoSet; in GetRemoteCompressAlgo()
415 compressAlgoSet.insert(static_cast<CompressAlgorithm>(algo.first)); in GetRemoteCompressAlgo()
423 static std::map<CompressAlgorithm, std::string> algoMap = {{CompressAlgorithm::ZLIB, "zlib"}}; in GetRemoteCompressAlgoStr()
424 std::set<CompressAlgorithm> remoteCompressAlgoSet = GetRemoteCompressAlgo(); in GetRemoteCompressAlgoStr()
455 CompressAlgorithm SingleVerSyncTaskContext::ChooseCompressAlgo() const in ChooseCompressAlgo()
457 std::set<CompressAlgorithm> remoteAlgo = GetRemoteCompressAlgo(); in ChooseCompressAlgo()
459 return CompressAlgorithm::NONE; in ChooseCompressAlgo()
461 std::set<CompressAlgorithm> localAlgorithmSet; in ChooseCompressAlgo()
463 std::set<CompressAlgorithm> algoIntersection; in ChooseCompressAlgo()
[all …]
H A Dsingle_ver_data_packet.h108 void SetCompressAlgo(CompressAlgorithm algo);
109 CompressAlgorithm GetCompressAlgo() const;
142 … CompressAlgorithm algo_ = CompressAlgorithm::NONE; // used for param while serialize compress data
H A Dsingle_ver_sync_task_context.h120 std::set<CompressAlgorithm> GetRemoteCompressAlgo() const;
123 CompressAlgorithm ChooseCompressAlgo() const;
H A Dsingle_ver_data_packet.cpp246 void DataRequestPacket::SetCompressAlgo(CompressAlgorithm algo) in SetCompressAlgo()
251 CompressAlgorithm DataRequestPacket::GetCompressAlgo() const in GetCompressAlgo()
H A Dsingle_ver_data_sync.cpp327 CompressAlgorithm remoteAlgo = context->ChooseCompressAlgo(); in GetMatchData()
328 if (needCompressOnSync && remoteAlgo != CompressAlgorithm::NONE) { in GetMatchData()
695 CompressAlgorithm curAlgo = context->ChooseCompressAlgo(); in FillDataRequestPacket()
697 …if (!syncData.compressedEntries.empty() && needCompressOnSync && curAlgo != CompressAlgorithm::NON… in FillDataRequestPacket()
1664 CompressAlgorithm remoteAlgo = context->ChooseCompressAlgo(); in GetReSendData()
1665 if (needCompressOnSync && remoteAlgo != CompressAlgorithm::NONE) { in GetReSendData()
1751 CompressAlgorithm curAlgo = context->ChooseCompressAlgo(); in FillRequestReSendPacket()
1752 if (needCompressOnSync && curAlgo != CompressAlgorithm::NONE) { in FillRequestReSendPacket()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dgeneric_single_ver_kv_entry.h28 CompressAlgorithm compressAlgo = CompressAlgorithm::ZLIB;
81 uint32_t destLen, CompressAlgorithm algo);
83 …ector<uint8_t> &compressedEntries, Parcel &parcel, uint32_t targetVersion, CompressAlgorithm algo);
H A Dgeneric_single_ver_kv_entry.cpp397 uint32_t destLen, CompressAlgorithm algo) in Uncompress()
419 …vector<uint8_t> &compressedEntries, Parcel &parcel, uint32_t targetVersion, CompressAlgorithm algo) in SerializeCompressedDatas()
433 CompressAlgorithm compressAlgo = CompressAlgorithm::NONE; in DeSerializeCompressedDatas()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dsync_config.cpp29 {static_cast<uint8_t>(CompressAlgorithm::ZLIB), DATABASE_COMPRESSION_ZLIB},
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_natural_store.h132 int GetCompressionAlgo(std::set<CompressAlgorithm> &algorithmSet) const override;
H A Drd_single_ver_natural_store.cpp502 int RdSingleVerNaturalStore::GetCompressionAlgo(std::set<CompressAlgorithm> &algorithmSet) const in GetCompressionAlgo()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dsync_generic_interface.h134 virtual int GetCompressionAlgo(std::set<CompressAlgorithm> &algorithmSet) const in GetCompressionAlgo()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/include/
H A Dtypes_export.h210 enum class CompressAlgorithm : uint8_t { enum
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_single_ver_sync_db_Interface.h116 int GetCompressionAlgo(std::set<CompressAlgorithm> &algorithmSet) const override;
H A Dvirtual_single_ver_sync_db_Interface.cpp463 int VirtualSingleVerSyncDBInterface::GetCompressionAlgo(std::set<CompressAlgorithm> &algorithmSet) … in GetCompressionAlgo()
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp624 {CompressAlgorithm::ZLIB, SOFTWARE_VERSION_CURRENT}) == E_OK);
625 packet->SetCompressAlgo(CompressAlgorithm::ZLIB);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_natural_store.h174 int GetCompressionAlgo(std::set<CompressAlgorithm> &algorithmSet) const override;
H A Dsqlite_single_ver_natural_store_extend.cpp323 int SQLiteSingleVerNaturalStore::GetCompressionAlgo(std::set<CompressAlgorithm> &algorithmSet) const in GetCompressionAlgo()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h121 int GetCompressionAlgo(std::set<CompressAlgorithm> &algorithmSet) const override;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp716 int RelationalSyncAbleStorage::GetCompressionAlgo(std::set<CompressAlgorithm> &algorithmSet) const in GetCompressionAlgo()