| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_data_inserter.cpp | 90 const TableInfo &RelationalSyncDataInserter::GetLocalTable() const in GetLocalTable() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_engine.cpp | 280 bool StorageEngine::IsEngineCorrupted() const in IsEngineCorrupted() argument
351 bool StorageEngine::IsNeedTobeReleased() const in IsNeedTobeReleased() argument
357 const std::string &StorageEngine::GetIdentifier() const in GetIdentifier() argument
362 EngineState StorageEngine::GetEngineState() const in GetEngineState() argument
392 bool StorageEngine::IsExistConnection() const in IsExistConnection() argument
397 CheckEngineOption(const KvDBProperties &kvdbOption) const CheckEngineOption() argument
478 IsMigrating() const IsMigrating() argument
500 GetCacheRecordVersion() const GetCacheRecordVersion() argument
[all...] |
| H A D | sync_able_engine.cpp | 273 bool SyncAbleEngine::NeedStartSyncer() const in NeedStartSyncer() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_multi_ver_sync_db_interface.cpp | 32 int VirtualMultiVerSyncDBInterface::GetInterfaceType() const in GetInterfaceType() argument
47 std::vector<uint8_t> VirtualMultiVerSyncDBInterface::GetIdentifier() const in GetIdentifier() argument
52 void VirtualMultiVerSyncDBInterface::GetMaxTimestamp(Timestamp &stamp) const in GetMaxTimestamp() argument
57 int VirtualMultiVerSyncDBInterface::GetMetaData(const Key &key, Value &value) const in GetMetaData() argument
72 int VirtualMultiVerSyncDBInterface::GetAllMetaKeys(std::vector<Key> &keys) const in GetAllMetaKeys() argument
77 bool VirtualMultiVerSyncDBInterface::IsCommitExisted(const MultiVerCommitNod argument
82 GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &commits) const GetDeviceLatestCommit() argument
87 GetCommitTree(const std::map<std::string, MultiVerCommitNode> &inCommit, std::vector<MultiVerCommitNode> &outCommit) const GetCommitTree() argument
93 GetCommitData(const MultiVerCommitNode &commit, std::vector<MultiVerKvEntry *> &entries) const GetCommitData() argument
109 IsValueSliceExisted(const ValueSliceHash &value) const IsValueSliceExisted() argument
114 GetValueSlice(const ValueSliceHash &hashValue, ValueSlice &sliceValue) const GetValueSlice() argument
119 PutValueSlice(const ValueSliceHash &hashValue, const ValueSlice &sliceValue) const PutValueSlice() argument
136 TransferSyncCommitDevInfo(MultiVerCommitNode &commit, const std::string &devId, bool isSyncedIn) const TransferSyncCommitDevInfo() argument
228 GetDbProperties() const GetDbProperties() argument
233 DeleteMetaDataByPrefixKey(const Key &keyPrefix) const DeleteMetaDataByPrefixKey() argument
[all...] |
| H A D | virtual_communicator.cpp | 89 GetRemoteCommunicatorVersion(const std::string &deviceId, uint16_t &version) const GetRemoteCommunicatorVersion() argument
111 CallbackOnConnect(const std::string &target, bool isConnect) const CallbackOnConnect() argument
125 GetCommunicatorMtuSize() const GetCommunicatorMtuSize() argument
130 GetCommunicatorMtuSize(const std::string &target) const GetCommunicatorMtuSize() argument
140 GetTimeout() const GetTimeout() argument
146 GetTimeout(const std::string &target) const GetTimeout() argument
156 GetLocalIdentity(std::string &outTarget) const GetLocalIdentity() argument
184 GetDeviceId() const GetDeviceId() argument
189 IsEnabled() const IsEnabled() argument
194 IsDeviceOnline(const std::string &device) const IsDeviceOnline() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
| H A D | meta_data_manager.cpp | 73 bool MetaDataManager::Filter::operator()(const std::string &key) const in operator ()() argument
78 std::vector<uint8_t> MetaDataManager::Filter::GetKey() const in GetKey() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/ |
| H A D | data_share_profile_config.cpp | 38 bool Config::Marshal(json &node) const in Marshal() argument
56 bool LaunchInfo::Marshal(json &node) const in Marshal() argument
70 bool ProfileInfo::Marshal(json &node) const in Marshal() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_general_store.h | 124 HasWatcher() const HasWatcher() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/databaseutils/include/ |
| H A D | acl.h | 62 bool IsReadable() const { return (value_ & READ) == READ; } in IsReadable() argument
63 bool IsWritable() const { return (value_ & WRITE) == WRITE; } in IsWritable() argument
64 bool IsExecutable() const { return (value_ & EXECUTE) == EXECUTE; } in IsExecutable() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/common/ |
| H A D | lru_bucket.h | 43 size_t Size() const in Size() argument
48 size_t Capacity() const in Capacity() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
| H A D | event_loop_impl.cpp | 73 int GetType() const in GetType() argument
78 void GetEvent(EventImpl *&event) const in GetEvent() argument
83 EventsMask GetEvents() const in GetEvents() argument
88 EventTime GetTimeout() const in GetTimeout() argument
245 EventTime EventLoopImpl::GetTime() const in GetTime() argument
303 bool EventLoopImpl::IsInLoopThread(bool &started) const in IsInLoopThread() argument
313 bool EventLoopImpl::EventObjectExists(EventImpl *event) const in EventObjectExists() argument
318 bool EventLoopImpl::EventFdExists(const EventImpl *event) const in EventFdExists() argument
494 EventTime EventLoopImpl::CalSleepTime() const in CalSleepTime() argument
[all...] |
| H A D | event_impl.cpp | 223 int EventImpl::CheckStatus() const in CheckStatus() argument
235 bool EventImpl::IsTimer() const in IsTimer() argument
240 bool EventImpl::IsValidFd() const in IsValidFd() argument
245 EventFd EventImpl::GetEventFd() const in GetEventFd() argument
250 EventsMask EventImpl::GetEvents() const in GetEvents() argument
280 bool EventImpl::Attached(const EventLoopImpl *loop, bool &isLoopConfused) const in Attached() argument
327 GetTimeoutPoint(EventTime &timePoint) const GetTimeoutPoint() argument
365 IsValidArg(EventsMask events) const IsValidArg() argument
371 IsValidArg(EventTime timeout) const IsValidArg() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_linker.cpp | 211 std::set<std::string> CommunicatorLinker::GetOnlineRemoteTarget() const in GetOnlineRemoteTarget() argument
217 bool CommunicatorLinker::IsRemoteTargetOnline(const st argument
[all...] |
| H A D | db_status_adapter.cpp | 236 GetDBInfoHandle() const GetDBInfoHandle() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | syncer_proxy.cpp | 138 int SyncerProxy::GetQueuedSyncSize(int *queuedSyncSize) const in GetQueuedSyncSize() argument
154 GetQueuedSyncLimit(int *queuedSyncLimit) const GetQueuedSyncLimit() argument
178 GetLocalIdentity(std::string &outTarget) const GetLocalIdentity() argument
235 GetSyncDataSize(const std::string &device, size_t &size) const GetSyncDataSize() argument
243 GetHashDeviceId(const std::string &clientId, std::string &hashDevId) const GetHashDeviceId() argument
[all...] |
| H A D | remote_executor_packet.cpp | 25 uint32_t RemoteExecutorRequestPacket::GetVersion() const in GetVersion() argument
35 uint32_t RemoteExecutorRequestPacket::GetFlag() const in GetFlag() argument
45 const PreparedStmt &RemoteExecutorRequestPacket::GetPreparedStmt() const in GetPreparedStmt() argument
50 bool RemoteExecutorRequestPacket::IsNeedResponse() const in IsNeedResponse() argument
65 std::map<std::string, std::string> RemoteExecutorRequestPacket::GetExtraConditions() const in GetExtraConditions() argument
70 uint32_t RemoteExecutorRequestPacket::CalculateLen() const in CalculateLen() argument
95 int RemoteExecutorRequestPacket::Serialization(Parcel &parcel) const in Serialization() argument
184 GetSecLabel() const GetSecLabel() argument
200 GetVersion() const GetVersion() argument
210 GetFlag() const GetFlag() argument
220 GetAckCode() const GetAckCode() argument
235 MoveOutRowDataSet() const MoveOutRowDataSet() argument
240 IsLastAck() const IsLastAck() argument
250 CalculateLen() const CalculateLen() argument
262 Serialization(Parcel &parcel) const Serialization() argument
305 GetSecurityOption() const GetSecurityOption() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/ |
| H A D | rdb_subscriber_manager.cpp | 62 bool Key::operator==(const Key &rhs) const
in operator ==() argument
67 bool Key::operator!=(const Key &rhs) const
in operator !=() argument
71 operator <(const Key &rhs) const operator <() argument
87 operator >(const Key &rhs) const operator >() argument
91 operator <=(const Key &rhs) const operator <=() argument
95 operator >=(const Key &rhs) const operator >=() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/ |
| H A D | sqlite_store_executor_impl.cpp | 164 int SqliteStoreExecutorImpl::GetDataByKey(const std::string &collName, Key &key, Value &value) const in GetDataByKey() argument
190 GetDataById(const std::string &collName, Key &key, Value &value) const GetDataById() argument
239 GetDataByFilter(const std::string &collName, Key &key, const JsonObject &filterObj, std::pair<std::string, std::string> &values, int isIdExist) const GetDataByFilter() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/ |
| H A D | sqlite_local_kvdb_connection.cpp | 38 int SQLiteLocalKvDBConnection::Get(const IOption &option, const Key &key, Value &value) const in Get() argument
159 int SQLiteLocalKvDBConnection::GetEntries(const IOptio argument
266 GetSnapshot(IKvDBSnapshot *&snapshot) const GetSnapshot() argument
330 IsTransactionStarted() const IsTransactionStarted() argument
356 TranslateObserverModeToEventTypes(unsigned mode, std::list<int> &eventTypes) const TranslateObserverModeToEventTypes() argument
492 CheckDataStatus(const Key &key, const Value &value, bool isDeleted) const CheckDataStatus() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_executor_extend.cpp | 273 GetEntries(const std::string &device, std::vector<Entry> &entries) const GetEntries() argument
306 PrepareForUnSyncTotalByTime(Timestamp begin, Timestamp end, sqlite3_stmt *&statement, bool getDeletedData) const PrepareForUnSyncTotalByTime() argument
331 GetCountValue(sqlite3_stmt *&countStatement, uint32_t &total) const GetCountValue() argument
352 GetUnSyncTotalByTimestamp(Timestamp begin, Timestamp end, uint32_t &total) const GetUnSyncTotalByTimestamp() argument
362 GetDeletedSyncTotalByTimestamp(Timestamp begin, Timestamp end, uint32_t &total) const GetDeletedSyncTotalByTimestamp() argument
373 GetSyncTotalWithQuery(QueryObject &query, const std::pair<Timestamp, Timestamp> &timeRange, uint32_t &total) const GetSyncTotalWithQuery() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/nbdelegate_fuzzer/ |
| H A D | nbdelegate_fuzzer.cpp | 84 GetCallCount() const GetCallCount() argument
89 GetEntriesInserted() const GetEntriesInserted() argument
94 GetEntriesUpdated() const GetEntriesUpdated() argument
98 GetEntriesDeleted() const GetEntriesDeleted() argument
103 IsCleared() const IsCleared() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/security/ |
| H A D | security.cpp | 48 AppDistributedKv::ChangeLevelType Security::GetChangeLevelType() const in GetChangeLevelType() argument
59 bool Security::IsAccessControlled() const in IsAccessControlled() argument
80 DBStatus Security::GetSecurityOption(const std::string &filePath, SecurityOption &option) const in GetSecurityOption() argument
95 bool Security::CheckDeviceSecurityAbility(const st argument
121 IsXattrValueValid(const std::string& value) const IsXattrValueValid() argument
136 OnDeviceChanged(const AppDistributedKv::DeviceInfo &info, const AppDistributedKv::DeviceChangeType &type) const OnDeviceChanged() argument
163 IsExits(const std::string &file) const IsExits() argument
174 GetSensitiveByUuid(const std::string &uuid) const GetSensitiveByUuid() argument
197 EraseSensitiveByUuid(const std::string &uuid) const EraseSensitiveByUuid() argument
203 GetCurrentUserStatus() const GetCurrentUserStatus() argument
246 GetFileSecurityOption(const std::string &filePath, SecurityOption &option) const GetFileSecurityOption() argument
268 GetDirSecurityOption(const std::string &filePath, SecurityOption &option) const GetDirSecurityOption() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | cloud_cursor_impl.cpp | 81 int32_t CloudCursorImpl::GetColumnNames(std::vector<std::string> &names) const in GetColumnNames() argument
90 int32_t CloudCursorImpl::GetColumnName(int32_t col, std::string &name) const in GetColumnName() argument
99 int32_t CloudCursorImpl::GetColumnType(int32_t col) const in GetColumnType() argument
104 int32_t CloudCursorImpl::GetCount() const in GetCount() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/waterversion/ |
| H A D | water_version_manager.cpp | 311 Marshal(Serializable::json &node) const Marshal() argument
338 ToAnonymousString() const ToAnonymousString() argument
346 GetKey() const GetKey() argument
351 GetVersion() const GetVersion() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | kv_store_delegate_impl.cpp | 140 std::string KvStoreDelegateImpl::GetStoreId() const in GetStoreId() argument
[all...] |