| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.cpp | 33 int SqliteCloudKvStore::GetMetaData(const Key &key, Value &value) const in GetMetaData() argument
343 GetIdentify() const GetIdentify() argument
530 GetCloudSyncConfig() const GetCloudSyncConfig() argument
[all...] |
| H A D | sqlite_query_helper.cpp | 161 FilterSymbolToAddBracketLink(std::string &querySql, bool isNeedLink) const FilterSymbolToAddBracketLink() argument
345 BindSyncDataCheckStmt(sqlite3_stmt *statement, const Key &hashKey) const BindSyncDataCheckStmt() argument
554 BindTimeRange(sqlite3_stmt *&statement, int &index, uint64_t beginTime, uint64_t endTime) const BindTimeRange() argument
569 BindObjNodes(sqlite3_stmt *&statement, int &index) const BindObjNodes() argument
644 MapRelationalSymbolToSql(const QueryObjNode &queryNode, bool placeholder) const MapRelationalSymbolToSql() argument
656 MapLogicSymbolToSql(const QueryObjNode &queryNode) const MapLogicSymbolToSql() argument
694 MapValueToSql(const QueryObjNode &queryNode, bool placeholder) const MapValueToSql() argument
729 BindFieldValue(sqlite3_stmt *statement, const QueryObjNode &queryNode, int &index) const BindFieldValue() argument
797 AssembleSqlForSuggestIndex(const std::string &baseSql, const std::string &filter) const AssembleSqlForSuggestIndex() argument
807 CheckAndFormatSuggestIndex() const CheckAndFormatSuggestIndex() argument
826 MapKeysInSubCondition(const std::string &accessStr) const MapKeysInSubCondition() argument
1125 MapKeysInToSql(size_t keysNum) const MapKeysInToSql() argument
1138 BindKeysToStmt(const std::set<Key> &keys, sqlite3_stmt *&statement, int &index) const BindKeysToStmt() argument
[all...] |
| H A D | sqlite_multi_ver_transaction.cpp | 238 Get(const Key &key, Value &value) const Get() argument
260 GetValueForTrimSlice(const Key &hashKey, const Version version, Value &value) const GetValueForTrimSlice() argument
301 GetEntries(const Key &keyPrefix, std::vector<Entry> &entries) const GetEntries() argument
449 GetDiffEntries(const Version &begin, const Version &end, MultiVerDiffData &data) const GetDiffEntries() argument
501 GetMaxVersion(MultiVerDataType type, Version &maxVersion) const GetMaxVersion() argument
563 GetPrePutValues(const Version &versionInfo, Timestamp timestamp, std::vector<Value> &values) const GetPrePutValues() argument
664 GetEntriesByVersion(Version version, std::list<MultiVerTrimedVersionData> &data) const GetEntriesByVersion() argument
697 GetEntriesByVersion(const Version &versionInfo, std::vector<MultiVerKvEntry *> &entries) const GetEntriesByVersion() argument
743 GetCurrentMaxTimestamp() const GetCurrentMaxTimestamp() argument
766 UpdateTimestampByVersion(const Version &version, Timestamp stamp) const UpdateTimestampByVersion() argument
811 IsDataChanged() const IsDataChanged() argument
849 GetVersion() const GetVersion() argument
854 GetOverwrittenClearTypeEntries(Version clearVersion, std::list<MultiVerTrimedVersionData> &data) const GetOverwrittenClearTypeEntries() argument
901 GetOverwrittenNonClearTypeEntries(Version version, const Key &hashKey, std::list<MultiVerTrimedVersionData> &data) const GetOverwrittenNonClearTypeEntries() argument
1113 ClassifyDiffEntries(int errCode, uint64_t flag, const Value &value, MultiVerEntryData &item, MultiVerDiffData &data) const ClassifyDiffEntries() argument
1143 GetClearId() const GetClearId() argument
1174 BindClearIdAndVersion(sqlite3_stmt *statement, int index) const BindClearIdAndVersion() argument
1204 BindQueryEntryArgs(sqlite3_stmt *statement, const Key &key) const BindQueryEntryArgs() argument
1215 BindQueryEntriesArgs(sqlite3_stmt *statement, const Key &key) const BindQueryEntriesArgs() argument
1260 BindAddRecordArgs(sqlite3_stmt *statement, const Key &key, const Value &value, const MultiVerEntryAuxData &data) const BindAddRecordArgs() argument
1301 GetOneEntry(const GetEntriesStatements &statements, const Key &lastKey, Entry &entry, int &errCode) const GetOneEntry() argument
1356 IsRecordCleared(const Timestamp timestamp) const IsRecordCleared() argument
1368 CheckIfNeedSaveRecord(sqlite3_stmt *statement, const MultiVerKvEntry *multiVerKvEntry, bool &isNeedSave, Value &origVal) const CheckIfNeedSaveRecord() argument
1426 CheckIfNeedSaveRecord(const MultiVerKvEntry *multiVerKvEntry, bool &isNeedSave, Value &value) const CheckIfNeedSaveRecord() argument
1449 PrepareForGetEntries(const Key &keyPrefix, GetEntriesStatements &statements) const PrepareForGetEntries() argument
1475 ReleaseGetEntriesStatements(GetEntriesStatements &statements) const ReleaseGetEntriesStatements() argument
1483 GetKeyAndValueByHashKey(sqlite3_stmt *statement, const Key &hashKey, Key &key, Value &value, bool isNeedReadKey) const GetKeyAndValueByHashKey() argument
1512 GetOriginKeyValueByHash(MultiVerEntryData &item, Value &value) const GetOriginKeyValueByHash() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | sync_task_context.cpp | 208 bool SyncTaskContext::IsTargetQueueEmpty() const in IsTargetQueueEmpty() argument
214 int SyncTaskContext::GetOperationStatus() const in GetOperationStatus() argument
228 int SyncTaskContext::GetMode() const in GetMode() argument
279 uint32_t SyncTaskContext::GetSyncId() const in GetSyncId() argument
285 std::string SyncTaskContext::GetDeviceId() const in GetDeviceId() argument
295 int SyncTaskContext::GetTaskExecStatus() const in GetTaskExecStatus() argument
300 bool SyncTaskContext::IsAutoSync() const in IsAutoSync() argument
357 int SyncTaskContext::GetRetryTime() const in GetRetryTime() argument
367 int SyncTaskContext::GetRetryStatus() const in GetRetryStatus() argument
372 GetTimerId() const GetTimerId() argument
377 GetRequestSessionId() const GetRequestSessionId() argument
387 GetSequenceId() const GetSequenceId() argument
402 GetPacketId() const GetPacketId() argument
407 GetTimeoutTime() const GetTimeoutTime() argument
422 GetTimeOffset() const GetTimeOffset() argument
472 GetCurrentLocalTime() const GetCurrentLocalTime() argument
512 GetRemoteSoftwareVersion() const GetRemoteSoftwareVersion() argument
518 GetRemoteSoftwareVersionId() const GetRemoteSoftwareVersionId() argument
524 IsCommNormal() const IsCommNormal() argument
651 GetTaskErrCode() const GetTaskErrCode() argument
661 IsSyncTaskNeedRetry() const IsSyncTaskNeedRetry() argument
671 GetSyncRetryTimes() const GetSyncRetryTimes() argument
679 GetSyncRetryTimeout(int retryTime) const GetSyncRetryTimeout() argument
693 IsAutoLiftWaterMark() const IsAutoLiftWaterMark() argument
708 IsAutoSubscribe() const IsAutoSubscribe() argument
713 IsCurrentSyncTaskCanBeSkipped() const IsCurrentSyncTaskCanBeSkipped() argument
749 RunPermissionCheck(uint8_t flag) const RunPermissionCheck() argument
798 GetAndIncSyncOperation() const GetAndIncSyncOperation() argument
820 IsSchemaCompatible() const IsSchemaCompatible() argument
[all...] |
| H A D | ability_sync.cpp | 54 uint32_t AbilitySyncRequestPacket::GetProtocolVersion() const in GetProtocolVersion() argument
64 int32_t AbilitySyncRequestPacket::GetSendCode() const in GetSendCode() argument
74 uint32_t AbilitySyncRequestPacket::GetSoftwareVersion() const in GetSoftwareVersion() argument
84 std::string AbilitySyncRequestPacket::GetSchema() const in GetSchema() argument
94 uint32_t AbilitySyncRequestPacket::GetSchemaType() const in GetSchemaType() argument
104 int32_t AbilitySyncRequestPacket::GetSecLabel() const in GetSecLabel() argument
114 int32_t AbilitySyncRequestPacket::GetSecFlag() const in GetSecFlag() argument
124 uint64_t AbilitySyncRequestPacket::GetDbCreateTime() const in GetDbCreateTime() argument
129 uint32_t AbilitySyncRequestPacket::CalculateLen() const in CalculateLen() argument
156 GetDbAbility() const GetDbAbility() argument
171 GetSchemaVersion() const GetSchemaVersion() argument
204 GetSoftwareVersion() const GetSoftwareVersion() argument
209 GetProtocolVersion() const GetProtocolVersion() argument
219 GetAckCode() const GetAckCode() argument
229 GetSchema() const GetSchema() argument
239 GetSchemaType() const GetSchemaType() argument
249 GetSecLabel() const GetSecLabel() argument
259 GetSecFlag() const GetSecFlag() argument
269 GetPermitSync() const GetPermitSync() argument
279 GetRequirePeerConvert() const GetRequirePeerConvert() argument
289 GetDbCreateTime() const GetDbCreateTime() argument
294 GetSchemaVersion() const GetSchemaVersion() argument
304 CalculateLen() const CalculateLen() argument
332 GetDbAbility() const GetDbAbility() argument
347 GetRelationalSyncOpinion() const GetRelationalSyncOpinion() argument
505 GetAbilitySyncFinishedStatus() const GetAbilitySyncFinishedStatus() argument
526 SecLabelCheck(const AbilitySyncRequestPacket *packet) const SecLabelCheck() argument
596 GetPacketSecOption(const ISyncTaskContext *context, SecurityOption &option) const GetPacketSecOption() argument
960 SetAbilityRequestBodyInfo(uint16_t remoteCommunicatorVersion, const ISyncTaskContext *context, AbilitySyncRequestPacket &packet) const SetAbilityRequestBodyInfo() argument
1015 SetAbilityAckBodyInfo(const ISyncTaskContext *context, int ackCode, bool isAckNotify, AbilitySyncAckPacket &ackPacket) const SetAbilityAckBodyInfo() argument
1074 AckMsgCheck(const Message *message, ISyncTaskContext *context) const AckMsgCheck() argument
1103 IsSingleKvVer() const IsSingleKvVer() argument
1107 IsSingleRelationalVer() const IsSingleRelationalVer() argument
1229 MakeRelationSyncOpinion(const AbilitySyncRequestPacket *packet, const std::string &remoteSchema) const MakeRelationSyncOpinion() argument
[all...] |
| H A D | generic_syncer.cpp | 511 IsValidMode(int mode) const IsValidMode() argument
520 SyncConditionCheck(const SyncParma ¶m, const ISyncEngine *engine, ISyncInterface *storage) const SyncConditionCheck() argument
528 IsValidDevices(const std::vector<std::string> &devices) const IsValidDevices() argument
659 GetQueuedSyncSize(int *queuedSyncSize) const GetQueuedSyncSize() argument
681 GetQueuedSyncLimit(int *queuedSyncLimit) const GetQueuedSyncLimit() argument
692 IsManualSync(int inMode) const IsManualSync() argument
715 IsQueuedManualSyncFull(int mode, bool wait) const IsQueuedManualSyncFull() argument
765 GetLocalIdentity(std::string &outTarget) const GetLocalIdentity() argument
777 GetOnlineDevices(std::vector<std::string> &devices) const GetOnlineDevices() argument
832 GetSyncDevicesStr(const std::vector<std::string> &devices) const GetSyncDevicesStr() argument
845 StatusCheck() const StatusCheck() argument
858 SyncPreCheck(const SyncParma ¶m) const SyncPreCheck() argument
1076 GetSyncDataSize(const std::string &device, size_t &size) const GetSyncDataSize() argument
1139 GetHashDeviceId(const std::string &clientId, std::string &hashDevId) const GetHashDeviceId() argument
[all...] |
| H A D | meta_data.cpp | 150 TimeOffset Metadata::GetLocalTimeOffset() const in GetLocalTimeOffset() argument
197 GetLastLocalTime() const GetLastLocalTime() argument
253 GetMetadataFromDb(const std::vector<uint8_t> &key, std::vector<uint8_t> &outValue) const GetMetadataFromDb() argument
282 StringToLong(const std::vector<uint8_t> &value) const StringToLong() argument
546 GetQueryLastTimestamp(const DeviceID &deviceId, const std::string &queryId) const GetQueryLastTimestamp() argument
611 GetHashDeviceId(const std::string &clientId, std::string &hashDevId) const GetHashDeviceId() argument
632 LockWaterMark() const LockWaterMark() argument
637 UnlockWaterMark() const UnlockWaterMark() argument
[all...] |
| H A D | sync_engine.cpp | 198 void SyncEngine::BroadCastDataChanged() const in BroadCastDataChanged() argument
224 void SyncEngine::GetOnlineDevices(std::vector<std::string> &devices) const in GetOnlineDevices() argument
571 GetMsgSize(const Message *inMsg) const GetMsgSize() argument
701 GetQueueCacheSize() const GetQueueCacheSize() argument
706 GetDiscardMsgNum() const GetDiscardMsgNum() argument
711 GetMaxExecNum() const GetMaxExecNum() argument
721 GetLabel() const GetLabel() argument
726 GetSyncRetry() const GetSyncRetry() argument
1011 SubscribeLimitCheck(const std::vector<std::string> &devices, QuerySyncObject &query) const SubscribeLimitCheck() argument
1036 IsEngineActive() const IsEngineActive() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | schema_object.cpp | 176 IsSchemaValid() const IsSchemaValid() argument
181 GetSchemaType() const GetSchemaType() argument
186 ToSchemaString() const ToSchemaString() argument
191 GetSkipSize() const GetSkipSize() argument
196 GetIndexInfo() const GetIndexInfo() argument
205 IsIndexExist(const IndexName &indexName) const IsIndexExist() argument
213 CheckQueryableAndGetFieldType(const FieldPath &inPath, FieldType &outType) const CheckQueryableAndGetFieldType() argument
229 CompareAgainstSchemaString(const std::string &inSchemaString) const CompareAgainstSchemaString() argument
235 CompareAgainstSchemaString(const std::string &inSchemaString, IndexDifference &indexDiffer) const CompareAgainstSchemaString() argument
248 CompareAgainstSchemaObject(const SchemaObject &inSchemaObject) const CompareAgainstSchemaObject() argument
254 CompareAgainstSchemaObject(const SchemaObject &inSchemaObject, IndexDifference &indexDiffer) const CompareAgainstSchemaObject() argument
293 CheckValueAndAmendIfNeed(ValueSource sourceType, ValueObject &inValue) const CheckValueAndAmendIfNeed() argument
314 VerifyValue(ValueSource sourceType, const Value &inValue) const VerifyValue() argument
319 VerifyValue(ValueSource sourceType, const RawValue &inValue) const VerifyValue() argument
350 ExtractValue(ValueSource sourceType, RawString inPath, const RawValue &inValue, TypeValue &outExtract, std::vector<uint8_t> *cache) const ExtractValue() argument
451 CheckMetaFieldCountAndType(const JsonObject& inJsonObject) const CheckMetaFieldCountAndType() argument
581 CheckSchemaDefineItemDecideAttribute(const JsonObject& inJsonObject, const FieldPath &inPath, FieldType inType, SchemaAttribute &outAttr) const CheckSchemaDefineItemDecideAttribute() argument
743 CompareSchemaVersionMode(const SchemaObject &newSchema) const CompareSchemaVersionMode() argument
765 CompareSchemaSkipSize(const SchemaObject &newSchema) const CompareSchemaSkipSize() argument
775 CompareSchemaDefine(const SchemaObject &newSchema) const CompareSchemaDefine() argument
822 CompareSchemaDefineByDepth(const SchemaDefine &oldDefine, const SchemaDefine &newDefine) const CompareSchemaDefineByDepth() argument
851 CompareSchemaAttribute(const SchemaAttribute &oldAttr, const SchemaAttribute &newAttr) const CompareSchemaAttribute() argument
896 CompareSchemaDefaultValue(const SchemaAttribute &oldAttr, const SchemaAttribute &newAttr) const CompareSchemaDefaultValue() argument
957 CompareSchemaIndexes(const SchemaObject &newSchema, IndexDifference &indexDiffer) const CompareSchemaIndexes() argument
1084 CheckValue(const ValueObject &inValue, std::set<FieldPath> &lackingPaths) const CheckValue() argument
1127 AmendValueIfNeed(ValueObject &inValue, const std::set<FieldPath> &lackingPaths, bool &amended) const AmendValueIfNeed() argument
[all...] |
| H A D | flatbuffer_schema.cpp | 48 std::string SchemaObject::FlatBufferSchema::GetDescription() const in GetDescription() argument
177 int SchemaObject::FlatBufferSchema::CompareFlatBufferDefine(const FlatBufferSchema &other) const in CompareFlatBufferDefine() argument
225 int SchemaObject::FlatBufferSchema::VerifyFlatBufferValue(const RawValu argument
426 ExtractFlatBufferValue(RawString inPath, const RawValue &inValue, TypeValue &outExtract, bool tryNoSizePrefix) const ExtractFlatBufferValue() argument
476 GetSchema() const GetSchema() argument
638 CollectRawIndexInfos(const reflection::Field &field, RawIndexInfos &indexCollect) const CollectRawIndexInfos() argument
867 CompareTableOrStructDefine(const PairConstPointer<reflection::Schema> &bothSchema, const PairConstPointer<reflection::Object> &bothObject, bool isRoot, std::set<std::string> &compared) const CompareTableOrStructDefine() argument
910 CompareStruct(const PairConstPointer<reflection::Schema> &bothSchema, const PairConstPointer<reflection::Field> &bothField, std::set<std::string> &compared) const CompareStruct() argument
979 CompareFlatBufferDefine(const FlatBufferSchema &other) const CompareFlatBufferDefine() argument
985 VerifyFlatBufferValue(const RawValue &inValue, bool tryNoSizePrefix) const VerifyFlatBufferValue() argument
992 ExtractFlatBufferValue(RawString inPath, const RawValue &inValue, TypeValue &outExtract, bool tryNoSizePrefix) const ExtractFlatBufferValue() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/ |
| H A D | js_single_kv_store.cpp | 91 bool JsSingleKVStore::IsSchemaStore() const in IsSchemaStore() argument
101 bool JsSingleKVStore::IsSystemApp() const in IsSystemApp() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| H A D | multi_ver_storage_executor.cpp | 65 int MultiVerStorageExecutor::GetMetaData(const Key &key, Value &value) const in GetMetaData() argument
75 int MultiVerStorageExecutor::GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &commitMap) const in GetDeviceLatestCommit() argument
108 int MultiVerStorageExecutor::GetCommitTree(const std::map<std::string, MultiVerCommitNode> &commitMap, in GetCommitTree() argument
150 int MultiVerStorageExecutor::GetCommitData(const MultiVerCommitNode &commit, in GetCommitData() argument
196 bool MultiVerStorageExecutor::IsCommitExisted(const MultiVerCommitNod argument
237 IsValueSliceExisted(const ValueSliceHash &value, int &errCode) const IsValueSliceExisted() argument
258 GetValueSlice(const ValueSliceHash &hashValue, ValueSlice &sliceValue) const GetValueSlice() argument
269 GetValueSliceInner(const SliceTransaction *sliceTransaction, const ValueSliceHash &hashValue, ValueSlice &sliceValue) const GetValueSliceInner() argument
586 GetDiffEntries(const CommitID &begin, const CommitID &end, MultiVerDiffData &data) const GetDiffEntries() argument
635 Get(const Key &key, Value &value) const Get() argument
658 GetEntries(const Key &keyPrefix, std::vector<Entry> &entries) const GetEntries() argument
980 TransferDiffEntries(MultiVerDiffData &data) const TransferDiffEntries() argument
1011 TransferToUserValue(const Value &savedValue, Value &value) const TransferToUserValue() argument
1095 GetResolvedConflictEntries(const MultiVerCommitNode &commitItem, std::vector<MultiVerKvEntry *> &entries) const GetResolvedConflictEntries() argument
1143 GetParentCommitId(const CommitID &commitId, CommitID &parentId, Version &curVersion) const GetParentCommitId() argument
1162 AllocNewCommitId(CommitID &commitId) const AllocNewCommitId() argument
1170 FillAndCommitLogEntry(const Version &versionInfo, CommitID &commitId, uint64_t timestamp) const FillAndCommitLogEntry() argument
1216 FillCommitByForeign(IKvDBCommit *commit, const MultiVerCommitNode &multiVerCommit, const Version &versionInfo, const CommitID &commitId, bool isMerge) const FillCommitByForeign() argument
1253 FillAndCommitLogEntry(const Version &versionInfo, const MultiVerCommitNode &multiVerCommit, CommitID &commitId, bool isMerge, Timestamp ×tamp) const FillAndCommitLogEntry() argument
1345 GetCurrentReadVersion() const GetCurrentReadVersion() argument
1350 GetAllCommitsInTree(std::list<MultiVerCommitNode> &commits) const GetAllCommitsInTree() argument
1359 GetEntriesByVersion(Version version, std::list<MultiVerTrimedVersionData> &data) const GetEntriesByVersion() argument
1387 GetOverwrittenClearTypeEntries(Version clearVersion, std::list<MultiVerTrimedVersionData> &data) const GetOverwrittenClearTypeEntries() argument
1416 GetOverwrittenNonClearTypeEntries(Version version, const Key &hashKey, std::list<MultiVerTrimedVersionData> &data) const GetOverwrittenNonClearTypeEntries() argument
[all...] |
| H A D | multi_ver_natural_store.cpp | 325 int MultiVerNaturalStore::CheckSubStorageVersion(const KvDBProperties &kvDBProp, bool &isSubStorageAllExist) const in CheckSubStorageVersion() argument
476 int MultiVerNaturalStore::GetInterfaceType() const in GetInterfaceType() argument
494 GetIdentifier() const GetIdentifier() argument
501 GetStringIdentifier() const GetStringIdentifier() argument
509 GetMaxTimestamp(Timestamp &stamp) const GetMaxTimestamp() argument
522 GetMetaData(const Key &key, Value &value) const GetMetaData() argument
556 GetAllMetaKeys(std::vector<Key> &keys) const GetAllMetaKeys() argument
561 IsCommitExisted(const MultiVerCommitNode &commit) const IsCommitExisted() argument
574 GetDeviceLatestCommit(std::map<std::string, MultiVerCommitNode> &commitMap) const GetDeviceLatestCommit() argument
587 GetCommitTree(const std::map<std::string, MultiVerCommitNode> &commitMap, std::vector<MultiVerCommitNode> &commits) const GetCommitTree() argument
601 GetCommitData(const MultiVerCommitNode &commit, std::vector<MultiVerKvEntry *> &entries) const GetCommitData() argument
638 IsValueSliceExisted(const ValueSliceHash &value) const IsValueSliceExisted() argument
651 GetValueSlice(const ValueSliceHash &hashValue, ValueSlice &sliceValue) const GetValueSlice() argument
664 PutValueSlice(const ValueSliceHash &hashValue, const ValueSlice &sliceValue) const PutValueSlice() argument
715 TransferSyncCommitDevInfo(MultiVerCommitNode &commit, const std::string &devId, bool isSyncedIn) const TransferSyncCommitDevInfo() argument
835 GetDiffEntries(const CommitID &begin, const CommitID &end, MultiVerDiffData &data) const GetDiffEntries() argument
881 CompareVerDataAndLog(IKvDBMultiVerTransaction *transaction) const CompareVerDataAndLog() argument
920 GetMaxCommitVersion() const GetMaxCommitVersion() argument
930 GetHandle(bool isWrite, int &errCode, bool isTrimming, OperatePerm perm) const GetHandle() argument
962 ReleaseHandle(MultiVerStorageExecutor *&handle, bool isTrimming) const ReleaseHandle() argument
1014 GetCurrentTag(std::vector<uint8_t> &tag) const GetCurrentTag() argument
1036 GetMaxTrimmableVersion() const GetMaxTrimmableVersion() argument
1045 TransObserverTypeToRegisterFunctionType(int observerType, RegisterFuncType &type) const TransObserverTypeToRegisterFunctionType() argument
1054 GetDbProperties() const GetDbProperties() argument
1087 GetKvDBSize(const KvDBProperties &properties, uint64_t &size) const GetKvDBSize() argument
1124 CheckVersion(const KvDBProperties &kvDBProp) const CheckVersion() argument
1144 CheckOverallVersionViaVersionFile(const KvDBProperties &kvDBProp, bool &isVerFileExist) const CheckOverallVersionViaVersionFile() argument
1175 GetVersionFilePath(const KvDBProperties &kvDBProp, std::string &outPath) const GetVersionFilePath() argument
1187 DeleteMetaDataByPrefixKey(const Key &keyPrefix) const DeleteMetaDataByPrefixKey() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_data_service.cpp | 641 GetPid() const GetPid() argument
743 SetCompatibleIdentify(const AppDistributedKv::DeviceInfo &info) const SetCompatibleIdentify() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | kvdb_manager.cpp | 486 IsOpenMemoryDb(const KvDBProperties &properties, const std::map<std::string, IKvDB *> &cache) const IsOpenMemoryDb() argument
546 GetKvDBFromCacheByIdentify(const std::string &identifier, const std::map<std::string, IKvDB *> &cache) const GetKvDBFromCacheByIdentify() argument
756 FindAndGetKvDBFromCache(const KvDBProperties &properties, int &errCode) const FindAndGetKvDBFromCache() argument
786 FindKvDBFromCache(const KvDBProperties &properties, const std::map<std::string, IKvDB *> &cache, bool isNeedCheckPasswd, int &errCode) const FindKvDBFromCache() argument
976 CheckKvDBProperties(const IKvDB *kvDB, const KvDBProperties &properties, bool isNeedCheckPasswd) const CheckKvDBProperties() argument
1030 FindKvDB(const std::string &identifier) const FindKvDB() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_state_machine.cpp | 273 const std::vector<StateSwitchTable> &SingleVerSyncStateMachine::GetStateSwitchTables() const in GetStateSwitchTables() argument
371 DoInitiactiveDataSyncWithSlidingWindow() const DoInitiactiveDataSyncWithSlidingWindow() argument
432 DoInitiactiveControlSync() const DoInitiactiveControlSync() argument
457 DoWaitForDataRecv() const DoWaitForDataRecv() argument
473 DoTimeSync() const DoTimeSync() argument
495 DoAbilitySync() const DoAbilitySync() argument
526 GetEventAfterTimeSync(int mode) const GetEventAfterTimeSync() argument
855 GetSyncOperationStatus(int errCode) const GetSyncOperationStatus() argument
920 IsPacketValid(const Message *inMsg) const IsPacketValid() argument
967 CheckIsStartPullResponse() const CheckIsStartPullResponse() argument
1028 TransformErrCodeToEvent(int errCode) const TransformErrCodeToEvent() argument
1056 IsNeedResetWatchdog(const Message *inMsg) const IsNeedResetWatchdog() argument
1077 TransforTimeOutErrCodeToEvent() const TransforTimeOutErrCodeToEvent() argument
1086 IsNeedErrCodeHandle(uint32_t sessionId) const IsNeedErrCodeHandle() argument
1159 GetSyncType(uint32_t messageId) const GetSyncType() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
| H A D | table_info.cpp | 28 const std::string &FieldInfo::GetFieldName() const in GetFieldName() argument
38 const std::string &FieldInfo::GetDataType() const in GetDataType() argument
112 IsNotNull() const IsNotNull() argument
122 HasDefaultValue() const HasDefaultValue() argument
127 GetDefaultValue() const GetDefaultValue() argument
139 GetStorageType() const GetStorageType() argument
149 GetColumnId() const GetColumnId() argument
159 ToAttributeString() const ToAttributeString() argument
173 CompareWithField(const FieldInfo &inField, bool isLite) const CompareWithField() argument
197 IsAssetType() const IsAssetType() argument
202 IsAssetsType() const IsAssetsType() argument
207 GetCollateType() const GetCollateType() argument
217 GetTableName() const GetTableName() argument
227 GetOriginTableName() const GetOriginTableName() argument
242 GetSharedTableMark() const GetSharedTableMark() argument
252 GetAutoIncrement() const GetAutoIncrement() argument
262 GetTableSyncType() const GetTableSyncType() argument
267 GetCreateTableSql() const GetCreateTableSql() argument
283 GetFields() const GetFields() argument
288 GetFieldInfos() const GetFieldInfos() argument
309 GetFieldName(uint32_t cid) const GetFieldName() argument
317 IsValid() const IsValid() argument
327 GetIndexDefine() const GetIndexDefine() argument
332 GetUniqueDefine() const GetUniqueDefine() argument
348 GetPrimaryKey() const GetPrimaryKey() argument
353 GetIdentifyKey() const GetIdentifyKey() argument
382 AddFieldDefineString(std::string &attrStr) const AddFieldDefineString() argument
397 AddIndexDefineString(std::string &attrStr) const AddIndexDefineString() argument
419 AddUniqueDefineString(std::string &attrStr) const AddUniqueDefineString() argument
438 CompareWithTable(const TableInfo &inTableInfo, const std::string &schemaVersion) const CompareWithTable() argument
474 CompareWithPrimaryKey(const std::map<int, FieldName> &local, const std::map<int, FieldName> &remote) const CompareWithPrimaryKey() argument
491 CompareWithTableFields(const FieldInfoMap &inTableFields, bool isLite) const CompareWithTableFields() argument
532 CompareCompositeFields(const CompositeFields &local, const CompositeFields &remote) const CompareCompositeFields() argument
547 CompareWithTableUnique(const std::vector<CompositeFields> &inTableUnique) const CompareWithTableUnique() argument
565 CompareWithTableIndex(const IndexInfoMap &inTableIndex) const CompareWithTableIndex() argument
614 CompareWithLiteTableFields(const FieldInfoMap &liteTableFields) const CompareWithLiteTableFields() argument
650 CompareWithLiteSchemaTable(const TableInfo &liteTableInfo) const CompareWithLiteSchemaTable() argument
669 ToTableInfoString(const std::string &schemaVersion) const ToTableInfoString() argument
707 GetSchemaDefine() const GetSchemaDefine() argument
730 GetTableId() const GetTableId() argument
735 Empty() const Empty() argument
780 GetTrackerTable() const GetTrackerTable() argument
795 GetTableReference() const GetTableReference() argument
800 IsNoPkTable() const IsNoPkTable() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | kv_store_nb_delegate_impl.cpp | 84 DBStatus KvStoreNbDelegateImpl::Get(const Key &key, Value &value) const in Get() argument
91 DBStatus KvStoreNbDelegateImpl::GetEntries(const Key &keyPrefix, std::vector<Entry> &entries) const in GetEntries() argument
98 DBStatus KvStoreNbDelegateImpl::GetEntries(const Key &keyPrefix, KvStoreResultSet *&resultSet) const in GetEntries() argument
125 DBStatus KvStoreNbDelegateImpl::GetEntries(const Quer argument
146 GetEntries(const Query &query, KvStoreResultSet *&resultSet) const GetEntries() argument
173 GetCount(const Query &query, int &count) const GetCount() argument
265 GetLocal(const Key &key, Value &value) const GetLocal() argument
272 GetLocalEntries(const Key &keyPrefix, std::vector<Entry> &entries) const GetLocalEntries() argument
540 GetStoreId() const GetStoreId() argument
604 OnDeviceSyncProcess(const std::map<std::string, DeviceSyncProcess> &processMap, const DeviceSyncProcessCallback &onProcess) const OnDeviceSyncProcess() argument
882 CheckIntegrity() const CheckIntegrity() argument
892 GetSecurityOption(SecurityOption &option) const GetSecurityOption() argument
916 GetInner(const IOption &option, const Key &key, Value &value) const GetInner() argument
934 GetEntriesInner(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const GetEntriesInner() argument
990 OnSyncComplete(const std::map<std::string, int> &statuses, const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete) const OnSyncComplete() argument
1099 GetKeys(const Key &keyPrefix, std::vector<Key> &keys) const GetKeys() argument
1115 GetSyncDataSize(const std::string &device) const GetSyncDataSize() argument
1316 GetDeviceEntries(const std::string &device, std::vector<Entry> &entries) const GetDeviceEntries() argument
1330 GetDatabaseStatus() const GetDatabaseStatus() argument
[all...] |
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_store_config.cpp | 46 std::string RdbStoreConfig::GetName() const in GetName() argument
54 std::string RdbStoreConfig::GetPath() const in GetPath() argument
62 StorageMode RdbStoreConfig::GetStorageMode() const in GetStorageMode() argument
70 std::string RdbStoreConfig::GetJournalMode() const in GetJournalMode() argument
78 std::string RdbStoreConfig::GetSyncMode() const in GetSyncMode() argument
86 IsReadOnly() const IsReadOnly() argument
94 IsMemoryRdb() const IsMemoryRdb() argument
102 GetDatabaseFileType() const GetDatabaseFileType() argument
143 IsAutoCheck() const IsAutoCheck() argument
151 GetJournalSize() const GetJournalSize() argument
159 GetPageSize() const GetPageSize() argument
167 GetEncryptAlgo() const GetEncryptAlgo() argument
191 GetDistributedType() const GetDistributedType() argument
206 GetBundleName() const GetBundleName() argument
216 GetModuleName() const GetModuleName() argument
231 GetArea() const GetArea() argument
300 GetSecurityLevel() const GetSecurityLevel() argument
310 IsEncrypt() const IsEncrypt() argument
315 IsCreateNecessary() const IsCreateNecessary() argument
325 GetReadConSize() const GetReadConSize() argument
341 RestoreEncryptKey(const std::vector<uint8_t> &encryptKey) const RestoreEncryptKey() argument
354 GetEncryptKey() const GetEncryptKey() argument
359 ChangeEncryptKey() const ChangeEncryptKey() argument
371 GetNewEncryptKey() const GetNewEncryptKey() argument
376 Initialize() const Initialize() argument
381 GenerateEncryptedKey() const GenerateEncryptedKey() argument
432 GetScalarFunctions() const GetScalarFunctions() argument
442 GetDataGroupId() const GetDataGroupId() argument
452 GetAutoClean() const GetAutoClean() argument
463 IsVector() const IsVector() argument
473 GetCustomDir() const GetCustomDir() argument
483 GetVisitorDir() const GetVisitorDir() argument
488 IsSearchable() const IsSearchable() argument
498 GetWriteTime() const GetWriteTime() argument
508 GetReadTime() const GetReadTime() argument
523 GetRoleType() const GetRoleType() argument
533 GetDBType() const GetDBType() argument
543 GetAllowRebuild() const GetAllowRebuild() argument
553 GetIntegrityCheck() const GetIntegrityCheck() argument
563 GetPluginLibs() const GetPluginLibs() argument
568 GetIter() const GetIter() argument
573 SetIter(int32_t iter) const SetIter() argument
578 GetHaMode() const GetHaMode() argument
598 GetCryptoParam() const GetCryptoParam() argument
610 IsValid() const IsValid() argument
[all...] |
| H A D | rdb_store.cpp | 81 bool RdbStore::ModifyTime::NeedConvert() const in NeedConvert() argument
411 IsOpen() const IsOpen() argument
416 IsReadOnly() const IsReadOnly() argument
421 IsMemoryRdb() const IsMemoryRdb() argument
518 IsSlaveDiffFromMaster() const IsSlaveDiffFromMaster() argument
523 GetDbType() const GetDbType() argument
543 GetBackupStatus() const GetBackupStatus() argument
[all...] |
| /foundation/distributeddatamgr/pasteboard/framework/innerkits/src/ |
| H A D | paste_data_record.cpp | 281 GetHtmlText() const GetHtmlText() argument
286 GetMimeType() const GetMimeType() argument
291 GetPlainText() const GetPlainText() argument
296 GetPixelMap() const GetPixelMap() argument
301 GetUri() const GetUri() argument
320 GetOrginUri() const GetOrginUri() argument
333 GetWant() const GetWant() argument
338 GetCustomData() const GetCustomData() argument
343 ConvertToText() const ConvertToText() argument
500 GetConvertUri() const GetConvertUri() argument
518 GetTextContent() const GetTextContent() argument
528 GetDetails() const GetDetails() argument
538 GetSystemDefinedContent() const GetSystemDefinedContent() argument
542 GetUDType() const GetUDType() argument
552 GetValidMimeTypes(const std::vector<std::string>& mimeTypes) const GetValidMimeTypes() argument
564 GetValidTypes(const std::vector<std::string> &types) const GetValidTypes() argument
576 HasEmptyEntry() const HasEmptyEntry() argument
646 GetUdtTypes() const GetUdtTypes() argument
656 GetMimeTypes() const GetMimeTypes() argument
753 GetEntries() const GetEntries() argument
768 GetDataId() const GetDataId() argument
778 GetRecordId() const GetRecordId() argument
788 IsDelayRecord() const IsDelayRecord() argument
814 GetFd() const GetFd() argument
[all...] |
| H A D | paste_data.cpp | 122 GetProperty() const GetProperty() argument
246 GetRecordAt(std::size_t index) const GetRecordAt() argument
255 GetRecordCount() const GetRecordCount() argument
316 AllRecords() const AllRecords() argument
321 IsDraggedData() const IsDraggedData() argument
326 IsLocalPaste() const IsLocalPaste() argument
356 GetBundleName() const GetBundleName() argument
366 GetOrginAuthority() const GetOrginAuthority() argument
528 IsValid() const IsValid() argument
543 IsDelayData() const IsDelayData() argument
553 IsDelayRecord() const IsDelayRecord() argument
563 GetDataId() const GetDataId() argument
568 Marshalling(Parcel &parcel) const Marshalling() argument
811 GetDeviceId() const GetDeviceId() argument
821 GetPasteId() const GetPasteId() argument
[all...] |
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/rdb/src/ |
| H A D | napi_rdb_predicates.cpp | 880 std::shared_ptr<NativeRdb::RdbPredicates> RdbPredicatesProxy::GetPredicates() const in GetPredicates() argument
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/componentmanager/ |
| H A D | component_manager.cpp | 657 GetDHType(const std::string &uuid, const std::string &dhId) const GetDHType() argument
[all...] |
| /foundation/filemanagement/storage_service/services/storage_daemon/crypto/src/ |
| H A D | base_key.cpp | 156 GetCandidateVersion() const GetCandidateVersion() argument
176 GetCandidateDir() const GetCandidateDir() argument
188 GetNextCandidateDir() const GetNextCandidateDir() argument
860 SyncKeyDir() const StoreKey() argument
1039 KeyEncryptTypeToString(KeyEncryptType keyEncryptType_) const StoreKey() argument
[all...] |