| /foundation/distributeddatamgr/relational_store/test/ndk/unittest/ |
| D | rdb_cursor_test.cpp | 119 OH_Cursor *cursor = OH_Rdb_Query(cursorTestRdbStore_, predicates, NULL, 0); variable
120 EXPECT_NE(cursor, NULL);
121 cursor->goToNextRow(cursor);
124 errCode = cursor->getColumnType(cursor, 0, &type);
127 errCode = cursor->getColumnType(cursor, 1, &type);
130 errCode = cursor->getColumnType(cursor, 2, &type);
133 errCode = cursor->getColumnType(cursor, 3, &type);
136 errCode = cursor->getColumnType(cursor, 4, &type);
139 errCode = cursor->getColumnType(cursor, 5, &type);
142 errCode = cursor->getColumnType(nullptr, 5, &type);
[all …]
|
| D | rdb_predicates_test.cpp | 129 OH_Cursor *cursor = OH_Rdb_Query(predicatesTestRdbStore_, predicates, NULL, 0); variable
130 EXPECT_NE(cursor, NULL);
132 errCode = cursor->getRowCount(cursor, &rowCount);
137 cursor->destroy(cursor);
155 OH_Cursor *cursor = OH_Rdb_Query(predicatesTestRdbStore_, predicates, NULL, 0); variable
156 EXPECT_NE(cursor, NULL);
158 errCode = cursor->getRowCount(cursor, &rowCount);
163 cursor->destroy(cursor);
180 OH_Cursor *cursor = OH_Rdb_Query(predicatesTestRdbStore_, predicates, NULL, 0); variable
181 EXPECT_NE(cursor, NULL);
[all …]
|
| D | rdb_store_test.cpp | 116 OH_Cursor *cursor = OH_Rdb_Query(storeTestRdbStore_, predicates, NULL, 0); variable
117 EXPECT_NE(cursor, NULL);
120 cursor->getRowCount(cursor, &rowCount);
123 errCode = cursor->goToNextRow(cursor);
127 cursor->getSize(cursor, 1, &size);
129 cursor->getText(cursor, 1, data1Value_1, size + 1);
133 cursor->getInt64(cursor, 2, &data2Value);
137 cursor->getReal(cursor, 3, &data3Value);
140 cursor->getSize(cursor, 4, &size);
142 cursor->getBlob(cursor, 4, data4Value, size);
[all …]
|
| /foundation/distributeddatamgr/relational_store/interfaces/ndk/include/ |
| D | oh_cursor.h | 96 int (*getColumnCount)(OH_Cursor *cursor, int *count);
108 int (*getColumnType)(OH_Cursor *cursor, int32_t columnIndex, OH_ColumnType *columnType);
121 int (*getColumnIndex)(OH_Cursor *cursor, const char *name, int *columnIndex);
135 int (*getColumnName)(OH_Cursor *cursor, int32_t columnIndex, char *name, int length);
147 int (*getRowCount)(OH_Cursor *cursor, int *count);
157 int (*goToNextRow)(OH_Cursor *cursor);
170 int (*getSize)(OH_Cursor *cursor, int32_t columnIndex, size_t *size);
184 int (*getText)(OH_Cursor *cursor, int32_t columnIndex, char *value, int length);
197 int (*getInt64)(OH_Cursor *cursor, int32_t columnIndex, int64_t *value);
210 int (*getReal)(OH_Cursor *cursor, int32_t columnIndex, double *value);
[all …]
|
| /foundation/distributeddatamgr/relational_store/interfaces/ndk/src/ |
| D | relational_cursor.h | 30 static int GetColumnCount(OH_Cursor *cursor, int *count);
31 static int GetColumnType(OH_Cursor *cursor, int32_t columnIndex, OH_ColumnType *columnType);
32 static int GetColumnIndex(OH_Cursor *cursor, const char *name, int *columnIndex);
33 static int GetColumnName(OH_Cursor *cursor, int32_t columnIndex, char *name, int length);
34 static int GetRowCount(OH_Cursor *cursor, int *count);
35 static int GoToNextRow(OH_Cursor *cursor);
36 static int GetSize(OH_Cursor *cursor, int32_t columnIndex, size_t *size);
37 static int GetText(OH_Cursor *cursor, int32_t columnIndex, char *value, int length);
38 static int GetInt64(OH_Cursor *cursor, int32_t columnIndex, int64_t *value);
39 static int GetReal(OH_Cursor *cursor, int32_t columnIndex, double *value);
[all …]
|
| D | relational_cursor.cpp | 30 int RelationalCursor::GetColumnCount(OH_Cursor *cursor, int *count) in GetColumnCount() argument
32 auto self = GetSelf(cursor); in GetColumnCount()
39 int RelationalCursor::GetColumnType(OH_Cursor *cursor, int32_t columnIndex, OH_ColumnType *columnTy… in GetColumnType() argument
41 auto self = GetSelf(cursor); in GetColumnType()
51 int RelationalCursor::GetColumnIndex(OH_Cursor *cursor, const char *name, int *columnIndex) in GetColumnIndex() argument
53 auto self = GetSelf(cursor); in GetColumnIndex()
60 int RelationalCursor::GetColumnName(OH_Cursor *cursor, int32_t columnIndex, char *name, int length) in GetColumnName() argument
62 auto self = GetSelf(cursor); in GetColumnName()
79 int RelationalCursor::GetRowCount(OH_Cursor *cursor, int *count) in GetRowCount() argument
81 auto self = GetSelf(cursor); in GetRowCount()
[all …]
|
| /foundation/filemanagement/dfs_service/services/cloudsyncservice/src/data_sync/ |
| D | data_handler.cpp | 35 void DataHandler::GetNextCursor(DriveKit::DKQueryCursor &cursor) in GetNextCursor() argument
38 cursor = startCursor_; in GetNextCursor()
41 cursor = tempNextCursor_; in GetNextCursor()
44 void DataHandler::SetTempStartCursor(const DriveKit::DKQueryCursor &cursor) in SetTempStartCursor() argument
46 tempStartCursor_ = cursor; in SetTempStartCursor()
50 void DataHandler::GetTempStartCursor(DriveKit::DKQueryCursor &cursor) in GetTempStartCursor() argument
52 cursor = tempStartCursor_; in GetTempStartCursor()
55 void DataHandler::SetTempNextCursor(const DriveKit::DKQueryCursor &cursor, bool isFinish) in SetTempNextCursor() argument
58 batchNo_, cursor.c_str(), isFinish); in SetTempNextCursor()
59 tempNextCursor_ = cursor; in SetTempNextCursor()
[all …]
|
| D | sdk_helper.cpp | 74 DriveKit::DKQueryCursor cursor, FetchRecordsCallback callback) in FetchRecords() argument
76 …tabase_->FetchRecords(context, cond.recordType, cond.desiredKeys, cond.limitRes, cursor, callback); in FetchRecords()
96 DriveKit::DKQueryCursor cursor, FetchDatabaseChangesCallback callback) in FetchDatabaseChanges() argument
98 … database_->FetchDatabaseChanges(context, cond.recordType, cond.desiredKeys, cond.limitRes, cursor, in FetchDatabaseChanges()
184 …t32_t SdkHelper::GetStartCursor(DriveKit::DKRecordType recordType, DriveKit::DKQueryCursor &cursor) in GetStartCursor() argument
186 auto err = database_->GetStartCursor(recordType, cursor); in GetStartCursor()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| D | rdb_cloud.cpp | 62 auto cursor = cloudDB_->Query(tableName, ValueProxy::Convert(std::move(extend))); in Query() local
63 if (cursor == nullptr) { in Query()
68 int32_t count = cursor->GetCount(); in Query()
70 auto err = cursor->MoveToFirst(); in Query()
73 err = cursor->GetEntry(entry); in Query()
78 err = cursor->MoveToNext(); in Query()
82 cursor->Get(SchemaMeta::CURSOR_FIELD, cursorFlag); in Query()
84 if (cursor->IsEnd()) { in Query()
|
| /foundation/communication/ipc/ipc/native/test/fuzztest/core/bufferobject_fuzzer/ |
| D | bufferobject_fuzzer.cpp | 92 ssize_t cursor = *(reinterpret_cast<const ssize_t*>(data)); in SetReceiveBufferWriteCursorTest() local
94 object.SetReceiveBufferWriteCursor(cursor); in SetReceiveBufferWriteCursorTest()
117 ssize_t cursor = *(reinterpret_cast<const ssize_t*>(data)); in SetReceiveBufferReadCursorTest() local
118 object.SetReceiveBufferReadCursor(cursor); in SetReceiveBufferReadCursorTest()
141 ssize_t cursor = *(reinterpret_cast<const ssize_t*>(data)); in SetSendBufferWriteCursorTest() local
142 object.SetSendBufferWriteCursor(cursor); in SetSendBufferWriteCursorTest()
165 ssize_t cursor = *(reinterpret_cast<const ssize_t*>(data)); in SetSendBufferReadCursorTest() local
166 object.SetSendBufferReadCursor(cursor); in SetSendBufferReadCursorTest()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| D | result_entries_window.cpp | 157 int cursor = begin; in LoadData() local
159 for (; cursor < target; cursor++) { in LoadData()
167 for (; cursor < totalCount_ && bufferSize < windowSize_; cursor++) { in LoadData()
|
| /foundation/filemanagement/dfs_service/test/unittests/cloudsync_sa/mock/ |
| D | dk_database_unnormal_mock.cpp | 42 DKQueryCursor cursor, in FetchRecords() argument
79 DKQueryCursor cursor, in FetchRecordsWithQuery() argument
89 DKQueryCursor cursor, in FetchDatabaseChanges() argument
95 DKError DKDatabase::GetStartCursor(DKRecordType recordType, DKQueryCursor &cursor) in GetStartCursor() argument
|
| D | dk_database_mock.cpp | 42 DKQueryCursor cursor, in FetchRecords() argument
79 DKQueryCursor cursor, in FetchRecordsWithQuery() argument
89 DKQueryCursor cursor, in FetchDatabaseChanges() argument
95 DKError DKDatabase::GetStartCursor(DKRecordType recordType, DKQueryCursor &cursor) in GetStartCursor() argument
|
| D | sdk_helper_mock.cpp | 53 DriveKit::DKQueryCursor cursor, FetchDatabaseChangesCallback callback) in FetchDatabaseChanges() argument
104 …t32_t SdkHelper::GetStartCursor(DriveKit::DKRecordType recordType, DriveKit::DKQueryCursor &cursor) in GetStartCursor() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| D | virtual_cloud_db.cpp | 210 std::string cursor = std::get<std::string>(extend[g_cursorField]); in Query() local
211 bool isIncreCursor = (cursor.substr(0, increPrefix_.size()) == increPrefix_); in Query()
213 TYPE_INDEX<std::string>, cursor.c_str()); in Query()
215 GetCloudData(cursor, isIncreCursor, incrementCloudData_[tableName], data); in Query()
217 cursor = cursor.empty() ? "0" : cursor; in Query()
218 GetCloudData(cursor, isIncreCursor, cloudData_[tableName], data); in Query()
227 void VirtualCloudDb::GetCloudData(const std::string &cursor, bool isIncreCursor, std::vector<CloudD… in GetCloudData() argument
232 if ((!isIncreCursor && std::stol(srcCursor) > std::stol(cursor)) || isIncreCursor) { in GetCloudData()
|
| /foundation/filemanagement/dfs_service/services/cloudsyncservice/include/data_sync/ |
| D | data_handler.h | 75 virtual void GetNextCursor(DriveKit::DKQueryCursor &cursor);
76 virtual void SetTempStartCursor(const DriveKit::DKQueryCursor &cursor);
77 virtual void GetTempStartCursor(DriveKit::DKQueryCursor &cursor);
78 virtual void SetTempNextCursor(const DriveKit::DKQueryCursor &cursor, bool isFinish);
|
| D | sdk_helper.h | 65 DriveKit::DKQueryCursor cursor, FetchDatabaseChangesCallback callback);
102 int32_t GetStartCursor(DriveKit::DKRecordType recordType, DriveKit::DKQueryCursor &cursor);
|
| /foundation/filemanagement/dfs_service/test/unittests/cloud_adapter/ |
| D | dk_database_test.cpp | 111 DKQueryCursor cursor = "FetchRecordsWithQuery"; variable
116 query, resultLimit, cursor, callback);
130 DKQueryCursor cursor = "FetchDatabaseChanges"; variable
134 DKError ret = mdkDatabase.GetStartCursor(recordType, cursor);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| D | rdb_result_set_impl_test.cpp | 42 std::shared_ptr<CursorMock::ResultSet> cursor; member in OHOS::Test::DistributedRDBTest::RdbResultSetImplTest
53 cursor = std::make_shared<CursorMock::ResultSet>(SIZE); in SetUp()
55 (*cursor)[i] = makeEntry(i); in SetUp()
57 auto cursorMock = std::make_shared<CursorMock>(cursor); in SetUp()
184 auto var = (*cursor)[index][Names[i].first];
|
| /foundation/filemanagement/dfs_service/adapter/cloud_adapter_example/src/ |
| D | dk_database.cpp | 55 DKQueryCursor cursor, in FetchRecords() argument
119 DKQueryCursor cursor, in FetchRecordsWithQuery() argument
129 DKQueryCursor cursor, in FetchDatabaseChanges() argument
141 DKError DKDatabase::GetStartCursor(DKRecordType recordType, DKQueryCursor &cursor) in GetStartCursor() argument
|
| /foundation/distributeddatamgr/pasteboard/framework/tlv/ |
| D | tlv_object.cpp | 225 bool TLVObject::Encode(std::vector<std::uint8_t> &buffer, size_t &cursor, size_t total) in Encode() argument
227 cursor_ = cursor; in Encode()
230 cursor = cursor_; in Encode()
233 bool TLVObject::Decode(const std::vector<std::uint8_t> &buffer, size_t &cursor, size_t total) in Decode() argument
235 cursor_ = cursor; in Decode()
238 cursor = cursor_; in Decode()
|
| /foundation/arkui/napi/scope_manager/ |
| D | native_scope_manager.cpp | 136 unw_cursor_t cursor; in BackTrace() local
139 unw_init_local(&cursor, &context); in BackTrace()
140 while (unw_step(&cursor) > 0) { in BackTrace()
142 unw_get_reg(&cursor, UNW_REG_IP, &pc); in BackTrace()
151 int ret = unw_get_proc_name(&cursor, sym, sizeof(sym), &offset); in BackTrace()
|
| /foundation/filemanagement/dfs_service/adapter/cloud_adapter_example/include/ |
| D | dk_database.h | 158 DKQueryCursor cursor,
198 DKQueryCursor cursor,
211 DKQueryCursor cursor,
214 DKError GetStartCursor(DKRecordType recordType, DKQueryCursor &cursor);
|
| /foundation/multimedia/image_framework/frameworks/innerkitsimpl/common/src/ |
| D | pixel_map.cpp | 1699 uint8_t PixelMap::ReadUint8(std::vector<uint8_t> &buff, int32_t &cursor) in ReadUint8() argument
1701 if (static_cast<size_t>(cursor + 1) > buff.size()) { in ReadUint8()
1705 return buff[cursor++]; in ReadUint8()
1727 int32_t PixelMap::ReadVarint(std::vector<uint8_t> &buff, int32_t &cursor) in ReadVarint() argument
1733 if (static_cast<size_t>(cursor + 1) > buff.size()) { in ReadVarint()
1737 item = int32_t(buff[cursor++]); in ReadVarint()
1751 uint8_t *PixelMap::ReadData(std::vector<uint8_t> &buff, int32_t size, int32_t &cursor) in ReadData() argument
1757 if (static_cast<size_t>(cursor + size) > buff.size()) { in ReadData()
1767 *(data + offset) = buff[cursor++]; in ReadData()
1819 int cursor = 0; in ReadTlvAttr() local
[all …]
|
| /foundation/graphic/graphic_2d/rosen/modules/platform/image_native/ |
| D | pixel_map.h | 218 static uint8_t ReadUint8(std::vector<uint8_t> &buff, int32_t &cursor);
221 static int32_t ReadVarint(std::vector<uint8_t> &buff, int32_t &cursor);
223 static uint8_t *ReadData(std::vector<uint8_t> &buff, int32_t size, int32_t &cursor);
|