Home
last modified time | relevance | path

Searched refs:offset (Results 1 – 25 of 108) sorted by relevance

12345

/rocksdb-6.9/utilities/cassandra/
Dcassandra_format_test.cc35 std::size_t offset = 0; in TEST() local
37 offset += sizeof(int8_t); in TEST()
39 offset += sizeof(int8_t); in TEST()
41 offset += sizeof(int64_t); in TEST()
43 offset += sizeof(int32_t); in TEST()
88 std::size_t offset = 0; in TEST() local
90 offset += sizeof(int8_t); in TEST()
98 offset += sizeof(data); in TEST()
157 std::size_t offset = 0; in TEST() local
202 std::size_t offset = 0; in TEST() local
[all …]
Dcassandra_serialize_test.cc58 offset = dest.size(); in TEST()
62 offset = dest.size(); in TEST()
66 offset = dest.size(); in TEST()
70 offset = dest.size(); in TEST()
119 offset = dest.size(); in TEST()
123 offset = dest.size(); in TEST()
127 offset = dest.size(); in TEST()
131 offset = dest.size(); in TEST()
165 offset = dest.size(); in TEST()
169 offset = dest.size(); in TEST()
[all …]
Dformat.cc83 offset += sizeof(mask); in Deserialize()
85 offset += sizeof(index); in Deserialize()
142 std::size_t offset) { in Deserialize() argument
144 offset += sizeof(mask); in Deserialize()
146 offset += sizeof(index); in Deserialize()
154 offset += value_size; in Deserialize()
193 offset += sizeof(mask); in Deserialize()
195 offset += sizeof(index); in Deserialize()
306 std::size_t offset = 0; in Deserialize() local
314 if (offset == size) { in Deserialize()
[all …]
Dserialize.h24 T Deserialize(const char* src, std::size_t offset=0);
50 inline int8_t Deserialize<int8_t>(const char* src, std::size_t offset) {
51 return static_cast<int8_t>(src[offset]);
55 inline int32_t Deserialize<int32_t>(const char* src, std::size_t offset) {
58 result |= static_cast<int32_t>(static_cast<unsigned char>(src[offset + i]))
65 inline int64_t Deserialize<int64_t>(const char* src, std::size_t offset) {
68 result |= static_cast<int64_t>(static_cast<unsigned char>(src[offset + i]))
/rocksdb-6.9/env/
Dio_posix.cc84 (void)offset; in Fadvise()
137 offset += done; in PosixPositionedWrite()
277 offset += r; in PositionedRead()
305 (void)offset; in InvalidateCache()
588 offset += r; in Read()
794 (void)offset; in InvalidateCache()
842 if (offset > length_) { in Read()
856 (void)offset; in InvalidateCache()
1076 (void)offset; in InvalidateCache()
1298 (void)offset; in InvalidateCache()
[all …]
Denv_encryption.cc95 offset += prefixLength_; // Skip prefix in PositionedRead()
100 offset_ = offset + result->size(); in PositionedRead()
127 Status Read(uint64_t offset, size_t n, Slice* result, in Read() argument
130 offset += prefixLength_; in Read()
140 Status Prefetch(uint64_t offset, size_t n) override { in Prefetch() argument
142 return file_->Prefetch(offset + prefixLength_, n); in Prefetch()
228 offset += prefixLength_; in PositionedAppend()
297 file_->PrepareWrite(offset + prefixLength_, len); in PrepareWrite()
333 offset += prefixLength_; in Write()
346 status = file_->Write(offset, dataToWrite); in Write()
[all …]
Dcomposite_env_wrapper.h40 return target_->InvalidateCache(offset, length); in InvalidateCache()
59 Status Read(uint64_t offset, size_t n, Slice* result, in Read() argument
73 fs_reqs[i].offset = reqs[i].offset; in MultiRead()
85 Status Prefetch(uint64_t offset, size_t n) override { in Prefetch() argument
88 return target_->Prefetch(offset, n, io_opts, &dbg); in Prefetch()
101 return target_->InvalidateCache(offset, length); in InvalidateCache()
184 return target_->InvalidateCache(offset, length); in InvalidateCache()
196 target_->PrepareWrite(offset, len, io_opts, &dbg); in PrepareWrite()
634 IOStatus PositionedRead(uint64_t offset, size_t n, in PositionedRead() argument
667 req.offset = fs_reqs[i].offset; in MultiRead()
[all …]
Dio_posix.h141 virtual IOStatus PositionedRead(uint64_t offset, size_t n,
145 virtual IOStatus InvalidateCache(size_t offset, size_t length) override;
193 virtual IOStatus Read(uint64_t offset, size_t n, const IOOptions& opts,
208 virtual IOStatus InvalidateCache(size_t offset, size_t length) override;
245 virtual IOStatus PositionedAppend(const Slice& data, uint64_t offset,
261 virtual IOStatus Allocate(uint64_t offset, uint64_t len,
265 virtual IOStatus RangeSync(uint64_t offset, uint64_t nbytes,
285 virtual IOStatus Read(uint64_t offset, size_t n, const IOOptions& opts,
341 virtual IOStatus Allocate(uint64_t offset, uint64_t len,
353 virtual IOStatus Write(uint64_t offset, const Slice& data,
[all …]
/rocksdb-6.9/port/win/
Dio_win.cc71 uint64_t offset, size_t& bytes_written) { in pwrite() argument
86 offsetUnion.QuadPart = offset; in pwrite()
107 uint64_t offset, size_t& bytes_read) { in pread() argument
119 offsetUnion.QuadPart = offset; in pread()
217 if (offset > length_) { in Read()
220 } else if (offset + n > length_) { in Read()
319 ULARGE_INTEGER offset; in MapNewRegion() local
320 offset.QuadPart = file_offset_; in MapNewRegion()
324 MapViewOfFileEx(hMap_, FILE_MAP_WRITE, offset.HighPart, offset.LowPart, in MapNewRegion()
661 uint64_t offset, in PositionedReadInternal() argument
[all …]
Dio_win.h49 uint64_t offset, size_t& bytes_written);
52 uint64_t offset, size_t& bytes_read);
102 uint64_t offset, size_t& bytes_read) const;
141 virtual Status Read(uint64_t offset, size_t n, Slice* result,
226 virtual Status Allocate(uint64_t offset, uint64_t len) override;
245 Status ReadImpl(uint64_t offset, size_t n, Slice* result,
268 virtual Status Read(uint64_t offset, size_t n, Slice* result,
311 Status PositionedAppendImpl(const Slice& data, uint64_t offset);
329 Status AllocateImpl(uint64_t offset, uint64_t len);
375 virtual Status Allocate(uint64_t offset, uint64_t len) override;
[all …]
/rocksdb-6.9/file/
Dreadahead_raf.cc38 Status Read(uint64_t offset, size_t n, Slice* result, in Read() argument
42 return file_->Read(offset, n, result, scratch); in Read()
52 if (TryReadFromCache(offset, n, &cached_len, scratch) && in Read()
74 Status Prefetch(uint64_t offset, size_t n) override { in Prefetch() argument
83 size_t offset_ = static_cast<size_t>(offset); in Prefetch()
101 return file_->InvalidateCache(offset, length); in InvalidateCache()
113 if (offset < buffer_offset_ || in TryReadFromCache()
118 uint64_t offset_in_buffer = offset - buffer_offset_; in TryReadFromCache()
128 Status ReadIntoBuffer(uint64_t offset, size_t n) const { in ReadIntoBuffer() argument
132 assert(IsFileSectorAligned(offset, alignment_)); in ReadIntoBuffer()
[all …]
Dfile_prefetch_buffer.cc25 uint64_t offset, size_t n, in Prefetch() argument
31 size_t offset_ = static_cast<size_t>(offset); in Prefetch()
48 if (buffer_.CurrentSize() > 0 && offset >= buffer_offset_ && in Prefetch()
49 offset <= buffer_offset_ + buffer_.CurrentSize()) { in Prefetch()
50 if (offset + n <= buffer_offset_ + buffer_.CurrentSize()) { in Prefetch()
99 bool FilePrefetchBuffer::TryReadFromCache(uint64_t offset, size_t n, in TryReadFromCache() argument
101 if (track_min_offset_ && offset < min_offset_read_) { in TryReadFromCache()
102 min_offset_read_ = static_cast<size_t>(offset); in TryReadFromCache()
104 if (!enable_ || offset < buffer_offset_) { in TryReadFromCache()
112 if (offset + n > buffer_offset_ + buffer_.CurrentSize()) { in TryReadFromCache()
[all …]
Drandom_access_file_reader.cc24 Status RandomAccessFileReader::Read(uint64_t offset, size_t n, Slice* result, in Read() argument
40 TruncateToPageBoundary(alignment, static_cast<size_t>(offset)); in Read()
158 return static_cast<size_t>(r.offset) + r.len; in End()
163 req.offset = static_cast<uint64_t>( in Align()
164 TruncateToPageBoundary(alignment, static_cast<size_t>(r.offset))); in Align()
165 req.len = Roundup(End(r), alignment) - req.offset; in Align()
177 size_t dest_offset = static_cast<size_t>(dest->offset); in TryMerge()
178 size_t src_offset = static_cast<size_t>(src.offset); in TryMerge()
185 dest->len = std::max(dest_end, src_end) - dest->offset; in TryMerge()
264 uint64_t offset = r.offset - fs_r.offset; in MultiRead() local
[all …]
Drandom_access_file_reader_test.cc72 ASSERT_EQ(content.substr(r.offset, r.len), r.result.ToString()); in AssertResult()
127 r0.offset = 0; in TEST_F()
132 r1.offset = alignment() / 2; in TEST_F()
158 r0.offset = 0; in TEST_F()
163 r1.offset = alignment() / 2; in TEST_F()
168 r2.offset = 2 * alignment() - alignment() / 4; in TEST_F()
195 r0.offset = alignment() / 4; in TEST_F()
200 r1.offset = alignment() + alignment() / 4; in TEST_F()
205 r2.offset = 2 * alignment() + alignment() / 4; in TEST_F()
230 r0.offset = alignment() / 4; in TEST_F()
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/util/
DBytewiseComparatorTest.java394 private int offset = -1;
408 return offset > -1 && offset < entries.size();
413 offset = 0;
418 offset = entries.size() - 1;
424 for(offset = 0; offset < entries.size(); offset++) {
435 for(offset = entries.size()-1; offset >= 0; offset--) {
464 offset++;
470 if(offset >= 0) {
471 offset--;
477 if(offset < 0 || offset >= entries.size()) {
[all …]
/rocksdb-6.9/utilities/
Denv_mirror.cc55 Status as = a_->InvalidateCache(offset, length); in InvalidateCache()
56 Status bs = b_->InvalidateCache(offset, length); in InvalidateCache()
70 Status as = a_->Read(offset, n, result, scratch); in Read()
111 Status as = a_->PositionedAppend(data, offset); in PositionedAppend()
112 Status bs = b_->PositionedAppend(data, offset); in PositionedAppend()
174 Status as = a_->InvalidateCache(offset, length); in InvalidateCache()
175 Status bs = b_->InvalidateCache(offset, length); in InvalidateCache()
182 Status as = a_->Allocate(offset, length); in Allocate()
183 Status bs = b_->Allocate(offset, length); in Allocate()
188 Status as = a_->RangeSync(offset, nbytes); in RangeSync()
[all …]
/rocksdb-6.9/util/
Dfile_reader_writer_test.cc60 EXPECT_EQ(offset % 4096, 0u); in TEST_F()
297 ASSERT_EQ(str.substr(offset, std::min(n, strLen - offset)), in TEST_P()
298 Read(offset, n)); in TEST_P()
314 ASSERT_EQ(str.substr(offset, std::min(n, strLen - offset)), in TEST_P()
315 Read(offset, n)); in TEST_P()
389 size_t offset = 0; in TEST_P() local
395 ASSERT_EQ(str.substr(offset, std::min(n, strLen - offset)), Read(n)); in TEST_P()
397 offset = std::min(offset + n, strLen); in TEST_P()
412 size_t offset = 0; in TEST_P() local
419 ASSERT_EQ(str.substr(offset, std::min(n, strLen - offset)), Read(n)); in TEST_P()
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DRocksDB.java637 checkBounds(offset, len, key.length); in put()
687 checkBounds(offset, len, key.length); in put()
732 checkBounds(offset, len, key.length); in put()
839 checkBounds(offset, len, key.length); in put()
1384 checkBounds(offset, len, key.length); in merge()
1429 checkBounds(offset, len, key.length); in merge()
2397 final int offset, final int len, in keyMayExist() argument
2517 key, offset, len, valueHolder); in keyMayExist()
2584 key, offset, len); in keyMayExist()
2590 key, offset, len); in keyMayExist()
[all …]
/rocksdb-6.9/utilities/blob_db/
Dblob_dump_tool.cc56 uint64_t offset = 0; in Run() local
59 s = DumpBlobLogHeader(&offset, &compression); in Run()
72 while (offset < footer_offset) { in Run()
94 Status BlobDumpTool::Read(uint64_t offset, size_t size, Slice* result) { in Read() argument
104 Status s = reader_->Read(offset, size, result, buffer_.get(), nullptr); in Read()
114 Status BlobDumpTool::DumpBlobLogHeader(uint64_t* offset, in DumpBlobLogHeader() argument
139 *offset = BlobLogHeader::kSize; in DumpBlobLogHeader()
181 *offset, *offset); in DumpRecord()
184 Status s = Read(*offset, BlobLogRecord::kHeaderSize, &slice); in DumpRecord()
200 *offset += BlobLogRecord::kHeaderSize; in DumpRecord()
[all …]
/rocksdb-6.9/include/rocksdb/
Dfile_system.h589 uint64_t offset; member
859 (offset + len + block_size - 1) / block_size; in PrepareWrite()
912 virtual IOStatus Write(uint64_t offset, const Slice& data,
1216 return target_->InvalidateCache(offset, length); in InvalidateCache()
1244 return target_->Prefetch(offset, n, options, dbg); in Prefetch()
1255 return target_->InvalidateCache(offset, length); in InvalidateCache()
1325 return target_->InvalidateCache(offset, length); in InvalidateCache()
1330 return target_->RangeSync(offset, nbytes, options, dbg); in RangeSync()
1335 target_->PrepareWrite(offset, len, options, dbg); in PrepareWrite()
1340 return target_->Allocate(offset, len, options, dbg); in Allocate()
[all …]
Denv.h619 uint64_t offset; member
875 (offset + len + block_size - 1) / block_size; in PrepareWrite()
1418 return target_->InvalidateCache(offset, length); in InvalidateCache()
1442 return target_->Prefetch(offset, n); in Prefetch()
1453 return target_->InvalidateCache(offset, length); in InvalidateCache()
1466 return target_->PositionedAppend(data, offset); in PositionedAppend()
1511 return target_->InvalidateCache(offset, length); in InvalidateCache()
1515 return target_->RangeSync(offset, nbytes); in RangeSync()
1519 target_->PrepareWrite(offset, len); in PrepareWrite()
1523 return target_->Allocate(offset, len); in Allocate()
[all …]
/rocksdb-6.9/table/plain/
Dplain_table_reader.cc441 *offset = file_info_.data_end_offset; in GetOffset()
444 *offset = prefix_index_offset; in GetOffset()
477 *offset = file_offset; in GetOffset()
497 *offset = low_key_offset; in GetOffset()
505 *offset = file_info_.data_end_offset; in GetOffset()
528 if (*offset == file_info_.data_end_offset) { in Next()
529 *offset = file_info_.data_end_offset; in Next()
533 if (*offset > file_info_.data_end_offset) { in Next()
543 *offset = *offset + bytes_read; in Next()
581 uint32_t offset; in Get() local
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DKeyMayExistTest.java58 final int offset = builder.toString().length(); in keyMayExist() local
60 final int len = builder.toString().length() - offset; in keyMayExist()
65 db.put(sliceKey, offset, len, sliceValue, 0, sliceValue.length); in keyMayExist()
67 exists = db.keyMayExist(sliceKey, offset, len, holder); in keyMayExist()
72 exists = db.keyMayExist(sliceKey, offset, len, null); in keyMayExist()
85 exists = db.keyMayExist(readOptions, sliceKey, offset, len, holder); in keyMayExist()
90 exists = db.keyMayExist(readOptions, sliceKey, offset, len, null); in keyMayExist()
106 exists = db.keyMayExist(columnFamilyHandleList.get(0), sliceKey, offset, len, in keyMayExist()
112 exists = db.keyMayExist(columnFamilyHandleList.get(0), sliceKey, offset, len, in keyMayExist()
130 sliceKey, offset, len, holder); in keyMayExist()
[all …]
/rocksdb-6.9/table/block_based/
Dblock_based_filter_block.cc221 const BlockContents& contents, const char** data, const char** offset, in ParseFieldsFromBlock() argument
224 assert(offset); in ParseFieldsFromBlock()
239 *offset = (*data) + last_word; in ParseFieldsFromBlock()
260 const char* offset = nullptr; in MayMatch() local
263 if (!ParseFieldsFromBlock(*filter_block.GetValue(), &data, &offset, &num, in MayMatch()
270 const uint32_t start = DecodeFixed32(offset + index * 4); in MayMatch()
271 const uint32_t limit = DecodeFixed32(offset + index * 4 + 4); in MayMatch()
272 if (start <= limit && limit <= (uint32_t)(offset - data)) { in MayMatch()
318 const char* offset = nullptr; in ToString() local
334 uint32_t start = DecodeFixed32(offset + index * 4); in ToString()
[all …]
/rocksdb-6.9/db/
Dcorruption_test.cc167 if (offset < 0) { in CorruptFile()
169 if (-offset > sbuf.st_size) { in CorruptFile()
170 offset = 0; in CorruptFile()
172 offset = static_cast<int>(sbuf.st_size + offset); in CorruptFile()
175 if (offset > sbuf.st_size) { in CorruptFile()
176 offset = static_cast<int>(sbuf.st_size); in CorruptFile()
178 if (offset + bytes_to_corrupt > sbuf.st_size) { in CorruptFile()
179 bytes_to_corrupt = static_cast<int>(sbuf.st_size - offset); in CorruptFile()
187 contents[i + offset] ^= 0x80; in CorruptFile()
196 void Corrupt(FileType filetype, int offset, int bytes_to_corrupt) { in Corrupt() argument
[all …]

12345