| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_service_impl.cpp | 289 Status KVDBServiceImpl::PutSwitch(const AppId &appId, const SwitchData &data) in PutSwitch() argument
321 Status KVDBServiceImpl::GetSwitch(const AppId &appId, const std::string &networkId, SwitchData &data) in GetSwitch() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | db_common.cpp | 112 void DBCommon::PrintHexVector(const std::vector<uint8_t> &data, int line, const std::string &tag) in PrintHexVector() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_store_sqlite_ext.cpp | 714 SaveChangedData(const std::string &hashFileName, const std::string &tableName, const std::string &columnName, const DistributedDB::Type &data, ChangeType option) SaveChangedData() argument
769 DistributedDB::Type data; DataChangedObserver() local
887 AuthorizerCallback([[gnu::unused]] void *data, int operation, const char *tableNameChar, const char *, const char *, const char *) AuthorizerCallback() argument
982 LogCommitHookCallback(void *data, sqlite3 *db, const char *zDb, int size) LogCommitHookCallback() argument
998 RollbackHookCallback(void* data) RollbackHookCallback() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer.cpp | 539 bool CloudSyncer::IsDataContainDuplicateAsset(const std::vector<Field> &assetFields, VBucket &data) in IsDataContainDuplicateAsset() argument
715 GetAssetsFromVBucket(VBucket &data) GetAssetsFromVBucket() argument
[all...] |
| H A D | cloud_syncer_extend.cpp | 1181 bool CloudSyncer::IsNeedUpdateAsset(const VBucket &data) in IsNeedUpdateAsset() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
| H A D | distributeddb_nb_cursor_testcase.cpp | 111 PragmaData data = static_cast<PragmaData>(&cacheMode); in SetResultSetCacheMode() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 225 VBucket data; in InsertRecordWithoutPk2LocalAndCloud() local
259 VBucket data; in InsertCloudTableRecord() local
391 VBucket data; UpdateDiffType() local
440 std::vector<VBucket> data; CheckAssetForAssetTest006() local
524 QueryCountCallback(void *data, int count, char **colValue, char **colName) QueryCountCallback() argument
550 std::vector<VBucket> data; CheckCloudTotalCount() local
945 VBucket data; UpdateCloudAssetForDownloadAssetTest003() local
1009 VBucket data; InsertCloudForCloudProcessNotify001() local
1567 VBucket data; HWTEST_F() local
[all...] |
| H A D | distributeddb_cloud_check_sync_test.cpp | 169 int QueryCountCallback(void *data, int count, char **colValue, char **colName) in QueryCountCallback() argument
358 VBucket data; in InsertCloudTableRecord() local
426 std::vector<VBucket> data; CheckCloudTableCount() local
1942 auto data = static_cast<PragmaData>(&logicDelete); HWTEST_F() local
1962 auto data = static_cast<PragmaData>(&logicDelete); HWTEST_F() local
2012 auto data = static_cast<PragmaData>(&logicDelete); HWTEST_F() local
2055 auto data = static_cast<PragmaData>(&logicDelete); HWTEST_F() local
2085 auto data = static_cast<PragmaData>(&logicDelete); HWTEST_F() local
2103 auto data = static_cast<PragmaData>(&logicDelete); HWTEST_F() local
2397 VBucket data; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/cj/src/ |
| H A D | distributed_kv_store_impl.cpp | 81 auto& data = blob.Data(); in KVValueToValueType() local
119 PushData(const ValueType &value, std::vector<uint8_t> &data, uint8_t tag) PushData() argument
153 std::vector<uint8_t> data; ValueTypeToKVValue() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 1049 RowDataWithLog data; GetDataItemForSync() local
1500 GetRowDatas(sqlite3_stmt *stmt, bool isMemDb, std::vector<std::string> &colNames, std::vector<RelationalRowData *> &data) GetRowDatas() argument
1543 ExecuteQueryBySqlStmt(const std::string &sql, const std::vector<std::string> &bindArgs, int packetSize, std::vector<std::string> &colNames, std::vector<RelationalRowData *> &data) ExecuteQueryBySqlStmt() argument
1635 VBucket data; GetCloudDataForSync() local
[all...] |
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 191 FillCloudAssetForUpload(OpType opType, const TableSchema &tableSchema, const CloudSyncBatch &data) FillCloudAssetForUpload() argument
242 FillCloudVersionForUpload(const OpType opType, const CloudSyncData &data) FillCloudVersionForUpload() argument
286 InitFillUploadAssetStatement(OpType opType, const TableSchema &tableSchema, const CloudSyncBatch &data, const int &index, sqlite3_stmt *&statement) InitFillUploadAssetStatement() argument
1345 FillHandleWithOpType(const OpType opType, const CloudSyncData &data, bool fillAsset, bool ignoreEmptyGid, const TableSchema &tableSchema) FillHandleWithOpType() argument
1803 GetWaitCompensatedSyncDataPk(const TableSchema &table, std::vector<VBucket> &data) GetWaitCompensatedSyncDataPk() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_tools_unit_test.cpp | 706 void KvStoreObserverUnitTest::OnChange(const KvStoreChangedData& data) in OnChange() argument
717 void KvStoreObserverUnitTest::OnChange(const DistributedDB::StoreChangedData &data) in OnChange() argument
723 OnChange(DistributedDB::StoreObserver::StoreChangedInfo &&data) OnChange() argument
729 OnChange(DistributedDB::Origin origin, const std::string &originalId, DistributedDB::ChangedData &&data) OnChange() argument
786 OnChange(const StoreChangedData &data) OnChange() argument
795 OnChange( DistributedDB::Origin origin, const std::string &originalId, DistributedDB::ChangedData &&data) OnChange() argument
1331 SelectData(sqlite3 *db, const DistributedDB::TableSchema &schema, std::vector<DistributedDB::VBucket> &data) SelectData() argument
1408 VBucket data; InsertCloudRecord() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_nb_delegate_test.cpp | 3236 PragmaData data = static_cast<PragmaData>(&autoSync); HWTEST_F() local
3367 std::map<std::string, VariantData> data; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_manager.cpp | 131 Save(const std::string &appId, const std::string &sessionId, const ObjectRecord &data, const std::string &deviceId, sptr<IRemoteObject> callback) Save() argument
179 PushAssets(const std::string &srcBundleName, const std::string &dstBundleName, const std::string &sessionId, const ObjectRecord &data, const std::string &deviceId) PushAssets() argument
408 auto data = GetObjectData(changedData, saveInfo, hasAsset); NotifyChange() local
425 std::map<std::string, ObjectRecord> data; GetObjectData() local
462 ComputeStatus(const std::string& objectKey, const SaveInfo& saveInfo, const std::map<std::string, ObjectRecord>& data) ComputeStatus() argument
488 NotifyDataChanged(const std::map<std::string, ObjectRecord>& data, const SaveInfo& saveInfo) NotifyDataChanged() argument
499 WaitAssets(const std::string& objectKey, const SaveInfo& saveInfo, const std::map<std::string, ObjectRecord>& data) WaitAssets() argument
515 PullAssets(const std::map<std::string, ObjectRecord>& data, const SaveInfo& saveInfo) PullAssets() argument
633 DoNotify(uint32_t tokenId, const CallbackInfo& value, const std::map<std::string, ObjectRecord>& data, bool allReady) DoNotify() argument
836 SaveToStore(const std::string &appId, const std::string &sessionId, const std::string &toDeviceId, const ObjectRecord &data) SaveToStore() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 376 Asset data = std::get<Asset>(item.second); in ObtainAssetFromVBucket() local
379 Assets data = std::get<Assets>(item.second); in ObtainAssetFromVBucket() local
862 bool CloudStorageUtils::ChkFillCloudAssetParam(const CloudSyncBatch &data, int errCode) in ChkFillCloudAssetParam() argument
1063 GetTypeCaseInsensitive(const std::string &fieldName, const VBucket &vBucket, Type &data) GetTypeCaseInsensitive() argument
1206 BindStepConsistentFlagStmt(sqlite3_stmt *stmt, const VBucket &data, const std::set<std::string> &gidFilters) BindStepConsistentFlagStmt() argument
1264 IdentifyCloudType(const CloudUploadRecorder &recorder, CloudSyncData &cloudSyncData, VBucket &data, VBucket &log, VBucket &flags) IdentifyCloudType() argument
1279 IdentifyCloudTypeInner(CloudSyncData &cloudSyncData, VBucket &data, VBucket &log, VBucket &flags) IdentifyCloudTypeInner() argument
1331 IsAbnormalData(const VBucket &data) IsAbnormalData() argument
1356 GetDataItemFromCloudData(VBucket &data) GetDataItemFromCloudData() argument
1380 GetDataItemFromCloudVersionData(VBucket &data) GetDataItemFromCloudVersionData() argument
1390 GetBytesFromCloudData(const std::string &field, VBucket &data, Bytes &bytes) GetBytesFromCloudData() argument
1402 GetStringFromCloudData(const std::string &field, VBucket &data, std::string &str) GetStringFromCloudData() argument
1412 GetUInt64FromCloudData(const std::string &field, VBucket &data, uint64_t &number) GetUInt64FromCloudData() argument
1439 GetSystemRecordFromCloudData(VBucket &data) GetSystemRecordFromCloudData() argument
1488 GetSyncQueryByPk(const std::string &tableName, const std::vector<VBucket> &data, bool isKv, QuerySyncObject &querySyncObject) GetSyncQueryByPk() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_relational_ver_p2p_sync_test.cpp | 513 void CheckVirtualData(const std::string &tableName, std::map<std::string, DataValue> &data) in CheckVirtualData() argument
527 void CheckVirtualData(std::map<std::string, DataValue> &data) in CheckVirtualData() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync.cpp | 995 const std::vector<SendDataItem> &data = packet->GetData(); DataRequestRecv() local
1216 uint64_t data = packet->GetData(); AckRecv() local
1340 const std::vector<SendDataItem> &data = packet->GetData(); RunPermissionCheck() local
1369 uint64_t data = static_cast<uint64_t>(packetLen) * static_cast<uint64_t>(context->GetTimeoutTime()) / mtuSize_; SendResetWatchDogPacket() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_utils.cpp | 116 void SQLiteUtils::SqliteLogCallback(void *data, int err, const char *msg) in SqliteLogCallback() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 150 VBucket data; in GenerateDataRecords() local
256 int QueryStatusCallback(void *data, int count, char **colValue, char **colName) in QueryStatusCallback() argument
[all...] |
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | sqlite_connection.cpp | 1013 auto data = static_cast<const uint8_t *>(sqlite3_value_blob(argv[0])); in MergeAssets() local
1038 auto data in MergeAsset() local
[all...] |
| /foundation/distributedhardware/device_manager/services/implementation/src/authentication/ |
| H A D | dm_auth_manager.cpp | 1917 bool DmAuthManager::AuthDeviceTransmit(int64_t requestId, const uint8_t *data, uint32_t dataLen) in AuthDeviceTransmit() argument
|
| /foundation/distributedhardware/device_manager/services/service/src/softbus/ |
| H A D | softbus_listener.cpp | 91 static void OnBytesReceived(int sessionId, const void *data, unsigned int dataLen) in OnBytesReceived() argument
106 static void OnPinHolderBytesReceived(int sessionId, const void *data, unsigned int dataLen) in OnPinHolderBytesReceived() argument
[all...] |
| /foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
| H A D | rdb_predicates_test.cpp | 564 time_t RdbStorePredicateTest::DateMakeTime(std::vector<int> data)
in DateMakeTime() argument
|
| /foundation/distributeddatamgr/udmf/framework/ndkimpl/unittest/ |
| H A D | udmf_test.cpp | 316 OH_UdmfData data;
in HWTEST_F() local
420 OH_UdmfData data;
in HWTEST_F() local
1063 OH_UdmfData *data = OH_UdmfData_Create();
in HWTEST_F() local
1079 OH_UdmfData *data = OH_UdmfData_Create();
in HWTEST_F() local
1096 OH_UdmfData *data = OH_UdmfData_Create(); HWTEST_F() local
1112 OH_UdmfData *data = OH_UdmfData_Create(); HWTEST_F() local
1139 OH_UdmfData *data = OH_UdmfData_Create(); HWTEST_F() local
1155 OH_UdmfData *data = OH_UdmfData_Create(); HWTEST_F() local
1221 OH_UdmfData* data = OH_UdmfData_Create(); HWTEST_F() local
1509 OH_UdmfData data; HWTEST_F() local
1538 OH_UdmfData *data = OH_UdmfData_Create(); HWTEST_F() local
1600 OH_UdmfData *data = OH_UdmfData_Create(); HWTEST_F() local
1630 OH_UdmfData data; HWTEST_F() local
1659 OH_UdmfData *data = OH_UdmfData_Create(); HWTEST_F() local
1720 OH_UdmfData *data = OH_UdmfData_Create(); HWTEST_F() local
1750 OH_UdmfData data; HWTEST_F() local
1788 OH_UdmfData data; HWTEST_F() local
1886 OH_UdmfData data; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/relational_store/interfaces/ndk/src/ |
| H A D | relational_store.cpp | 1053 Rdb_KeyInfo::Rdb_KeyData *data = (Rdb_KeyInfo::Rdb_KeyData *)(details + count); in OnChange() local
[all...] |