| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer_extend.cpp | 662 int CloudSyncer::GetUploadCountByTable(const CloudSyncer::TaskId &taskId, int64_t &count) in GetUploadCountByTable() argument
728 int64_t count in DoDownloadInNeed() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 136 void InsertUserTableRecord(sqlite3 *&db, int64_t begin, int64_t count, int64_t photoSize, bool assetIsNull) in InsertUserTableRecord() argument
183 void UpdateUserTableRecord(sqlite3 *&db, int64_t begin, int64_t count) in UpdateUserTableRecord() argument
198 void DeleteUserTableRecord(sqlite3 *&db, int64_t begin, int64_t count) in DeleteUserTableRecord() argument
213 InsertRecordWithoutPk2LocalAndCloud(sqlite3 *&db, int64_t begin, int64_t count, int photoSize) InsertRecordWithoutPk2LocalAndCloud() argument
250 InsertCloudTableRecord(int64_t begin, int64_t count, int64_t photoSize, bool assetIsNull) InsertCloudTableRecord() argument
524 QueryCountCallback(void *data, int count, char **colValue, char **colName) QueryCountCallback() argument
2350 int count = 10; 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
342 void DistributedDBCloudCheckSyncTest::InsertCloudTableRecord(int64_t begin, int64_t count, int64_t photoSize, in InsertCloudTableRecord() argument
348 InsertCloudTableRecord(const std::string &tableName, int64_t begin, int64_t count, int64_t photoSize, bool assetIsNull) InsertCloudTableRecord() argument
543 DeleteCloudDBData(int64_t begin, int64_t count) DeleteCloudDBData() argument
552 SetForkQueryForCloudPrioritySyncTest007(std::atomic<int> &count) SetForkQueryForCloudPrioritySyncTest007() argument
571 SetForkQueryForCloudPrioritySyncTest008(std::atomic<int> &count) SetForkQueryForCloudPrioritySyncTest008() argument
1361 std::atomic<int> count = 0; HWTEST_F() local
1424 std::atomic<int> count = 0; HWTEST_F() local
1558 std::atomic<int> count = 0; HWTEST_F() local
1991 const int count = 10; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 1424 int SQLiteSingleVerRelationalStorageExecutor::QueryCount(const std::string &tableName, int64_t &count) in QueryCount() argument
1440 GetUploadCountInner(const Timestamp ×tamp, SqliteQueryHelper &helper, std::string &sql, int64_t &count) GetUploadCountInner() argument
1460 GetUploadCount(const Timestamp ×tamp, bool isCloudForcePush, bool isCompensatedTask, QuerySyncObject &query, int64_t &count) GetUploadCount() argument
1473 GetAllUploadCount(const std::vector<Timestamp> ×tampVec, bool isCloudForcePush, bool isCompensatedTask, QuerySyncObject &query, int64_t &count) GetAllUploadCount() argument
[all...] |
| H A D | sqlite_relational_store.cpp | 363 int count = connectionCount_.fetch_sub(1, std::memory_order_seq_cst); in DecreaseConnectionCounter() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_tools_unit_test.cpp | 1227 int count = -1; in CheckTableRecords() local
1397 DistributedDB::DBStatus RelationalTestUtils::InsertCloudRecord(int64_t begin, int64_t count, in InsertCloudRecord() argument
1494 int count = 0; in DeleteRecord() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_nb_delegate_test.cpp | 1903 int count = -1; in HWTEST_F() local
3117 int count = -1; in HWTEST_F() local
3410 int64_t count = 0; in HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_executor.cpp | 701 OpenResultSet(const Key &keyPrefix, int &count) OpenResultSet() argument
739 OpenResultSet(QueryObject &queryObj, int &count) OpenResultSet() argument
791 OpenResultSetForCacheRowIdMode(const Key &keyPrefix, std::vector<int64_t> &rowIdCache, uint32_t cacheLimit, int &count) OpenResultSetForCacheRowIdMode() argument
815 OpenResultSetForCacheRowIdMode(QueryObject &queryObj, std::vector<int64_t> &rowIdCache, uint32_t cacheLimit, int &count) OpenResultSetForCacheRowIdMode() argument
903 int count = 0; // Ignored ReloadResultSetForCacheRowIdMode() local
919 int count = 0; // Ignored ReloadResultSetForCacheRowIdMode() local
1989 OpenResultSetForCacheRowIdModeCommon(std::vector<int64_t> &rowIdCache, uint32_t cacheLimit, int &count) OpenResultSetForCacheRowIdModeCommon() argument
2013 ResultSetLoadRowIdCache(std::vector<int64_t> &rowIdCache, uint32_t cacheLimit, uint32_t cacheStartPos, int &count) ResultSetLoadRowIdCache() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_relational_ver_p2p_sync_test.cpp | 632 int GetCount(sqlite3 *db, const string &sql, size_t &count) in GetCount() argument
1809 int count = 0; in HWTEST_F() local
2827 size_t count = 0; in HWTEST_F() local
2916 size_t count = 0; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | protocol_proto.cpp | 591 int count = length / sizeof(uint64_t); in CalculateXorSum() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | cloud_service_impl.cpp | 1196 int32_t count = cursor->GetCount(); in ConvertCursor() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/ |
| H A D | distributed_test_tools.cpp | 1418 GetRecordCntByKey(const std::string &dbName, const std::string &strSql, std::vector<DistributedDB::Key> &sqlParam, KvOption &option, int &count) global() argument
1462 QuerySpecifiedData(const std::string &dbName, const std::string &strSql, EncrypteAttribute &attribute, int &count) global() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 168 void InsertLocalData(sqlite3 *&db, int64_t begin, int64_t count, const std::string &tableName, bool isAssetNull = true) in InsertLocalData() argument
224 void DeleteLocalRecord(sqlite3 *&db, int64_t begin, int64_t count, const std::string &tableName) in DeleteLocalRecord() argument
233 void DeleteCloudDBData(int64_t begin, int64_t count, const std::string &tableName) in DeleteCloudDBData() argument
140 GenerateDataRecords( int64_t begin, int64_t count, int64_t gidStart, std::vector<VBucket> &record, std::vector<VBucket> &extend) GenerateDataRecords() argument
242 UpdateCloudDBData(int64_t begin, int64_t count, int64_t gidStart, int64_t versionStart, const std::string &tableName) UpdateCloudDBData() argument
256 QueryStatusCallback(void *data, int count, char **colValue, char **colName) QueryStatusCallback() argument
282 InsertCloudDBData(int64_t begin, int64_t count, int64_t gidStart, const std::string &tableName) InsertCloudDBData() argument
594 int count = 0; DataStatusTest001() local
616 int count = 0; DataStatusTest003() local
647 int count = 0; DataStatusTest004() local
689 int count = 0; DataStatusTest005() local
722 int count = 0; DataStatusTest006() local
757 int count = 0; DataStatusTest007() local
1120 std::atomic<int> count = 0; HWTEST_F() local
1170 std::atomic<int> count = 1; HWTEST_F() local
1297 std::atomic<int> count = 0; HWTEST_F() local
1400 std::atomic<int> count = 0; HWTEST_F() local
1784 std::atomic<int> count = 1; HWTEST_F() local
1824 std::atomic<int> count = 1; HWTEST_F() local
2049 int count = 0; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_store_impl.cpp | 180 int count = 0; in GetModifyTime() local
204 int count = 0; in GetModifyTimeByRowId() local
786 int count = 0; in GetHashKeyForLockRow() local
[all...] |
| /foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
| H A D | rdb_predicates_test.cpp | 755 int count = 1;
in ResultSize() local
1585 int count = 0;
in HWTEST_F() local
1634 int count = 0; HWTEST_F() local
1688 int count = ResultSize(allDataTypes1); HWTEST_F() local
1803 int count = 0; HWTEST_F() local
2381 int count = 0; HWTEST_F() local
2409 int count = 0; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/udmf/framework/ndkimpl/unittest/ |
| H A D | udmf_test.cpp | 367 unsigned int count = 0;
in HWTEST_F() local
392 unsigned int count = 0;
in HWTEST_F() local
448 unsigned int count = 0;
in HWTEST_F() local
546 unsigned int count = 0; HWTEST_F() local
573 unsigned int count = sizeof(entry); HWTEST_F() local
673 unsigned int count = sizeof(entry); HWTEST_F() local
689 unsigned int count = sizeof(entry); HWTEST_F() local
1196 unsigned int count = 0; HWTEST_F() local
2256 unsigned int count = 0; HWTEST_F() local
2296 unsigned int count = 0; HWTEST_F() local
2337 unsigned int count = 0; HWTEST_F() local
2377 unsigned int count = 0; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/relational_store/interfaces/ndk/src/ |
| H A D | relational_store.cpp | 651 int OH_Rdb_SetDistributedTables(OH_Rdb_Store *store, const char *tables[], uint32_t count, Rdb_DistributedType type, in OH_Rdb_SetDistributedTables() argument
998 auto count = devices.size(); in OnChange() local
869 OH_Rdb_CloudSync( OH_Rdb_Store *store, Rdb_SyncMode mode, const char *tables[], uint32_t count, const Rdb_ProgressObserver *observer) OH_Rdb_CloudSync() argument
1035 uint32_t count = changeInfo.size(); OnChange() local
[all...] |
| /foundation/filemanagement/dfs_service/services/cloudfiledaemon/src/fuse_manager/ |
| H A D | fuse_manager.cpp | 893 static void CloudForgetMulti(fuse_req_t req, size_t count, in CloudForgetMulti() argument
|
| /foundation/distributedhardware/distributed_input/common/include/ |
| H A D | input_hub.cpp | 156 size_t count = 0; in StartCollectInputEvents() local
197 size_t count = ReadInputEvent(readSize, *deviceByFd); in GetEvents() local
287 void InputHub::RecordDeviceChangeStates(Device *device, struct input_event readBuffer[], const size_t count) in RecordDeviceChangeStates() argument
309 CollectEvent(RawEvent *buffer, size_t &capacity, Device *device, struct input_event readBuffer[], const size_t count) CollectEvent() argument
345 size_t count = 0; ReadInputEvent() local
418 size_t count = 0; StartCollectInputHandler() local
1431 HandleTouchScreenEvent(struct input_event readBuffer[], const size_t count, std::vector<bool> &needFilted) HandleTouchScreenEvent() argument
1598 uint32_t count = 0; CheckTargetDevicesState() local
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/ |
| H A D | obex_headers.cpp | 588 void ObexHeader::AppendItemCount(const uint32_t count) in AppendItemCount() argument
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/ |
| H A D | btm_acl.c | 996 uint8_t count = 0; in BtmGetLeConnectingAddr() local
|
| /foundation/communication/dhcp/services/dhcp_client/src/ |
| H A D | dhcp_client_state_machine.cpp | 973 int count = 0; in ParseNetworkDnsInfo() local
996 void DhcpClientStateMachine::ParseNetworkDnsValue(struct DhcpIpResult *result, uint32_t uData, size_t &len, int &count) in ParseNetworkDnsValue() argument
[all...] |
| /foundation/communication/dhcp/test/fuzztest/dhcpclientfun_fuzzer/ |
| H A D | dhcpclientfun_fuzzer.cpp | 301 int count = static_cast<int>(data[0]); in CheckReadBytesFuzzerTest() local
618 int count = static_cast<int>(data[0]); in ParseNetworkDnsValueFuzzerTest() local
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/ |
| H A D | nstackx_dfile_session.c | 783 static void DFileSessionResolveBackPress(DFileSession *session, DataBackPressure backPress, uint32_t count) in DFileSessionResolveBackPress() argument
|
| H A D | nstackx_file_manager.c | 1905 uint32_t count = 0; in TaskGetReceivedFiles() local
|