| /rocksdb-6.9/table/plain/ |
| D | plain_table_key_coding.cc | 66 *bytes_read = 1; in DecodeSize()
78 *bytes_read = tmp_bytes_read + 1; in DecodeSize()
255 *bytes_read = in ReadVarint32NonMmap()
273 *bytes_read += user_key_size + 1; in ReadInternalKey()
285 *bytes_read += user_key_size + 8; in ReadInternalKey()
309 *bytes_read = tmp_read; in NextPlainEncodingKey()
359 *bytes_read += my_bytes_read; in NextPrefixEncodingKey()
458 assert(bytes_read != nullptr); in NextKey()
470 *bytes_read += value_size_bytes; in NextKey()
475 *bytes_read += value_size; in NextKey()
[all …]
|
| D | plain_table_key_coding.h | 107 uint32_t* bytes_read);
110 uint32_t* bytes_read);
159 Slice* internal_key, Slice* value, uint32_t* bytes_read,
163 Slice* internal_key, uint32_t* bytes_read,
178 Slice* internal_key, uint32_t* bytes_read,
182 Slice* internal_key, uint32_t* bytes_read,
185 ParsedInternalKey* parsed_key, uint32_t* bytes_read,
189 uint32_t* bytes_read);
|
| D | plain_table_reader.cc | 537 uint32_t bytes_read; in Next() local
539 &bytes_read, seekable); in Next()
543 *offset = *offset + bytes_read; in Next()
|
| /rocksdb-6.9/memtable/ |
| D | memtablerep_bench.cc | 209 bytes_read_(bytes_read), in BenchmarkThread()
231 uint64_t* bytes_written, uint64_t* bytes_read, in FillBenchmarkThread() argument
419 uint64_t bytes_read = 0; in Run() local
437 if (bytes_read > 0) { in Run()
438 auto MiB_read = static_cast<double>(bytes_read) / (1 << 20); in Run()
470 uint64_t* bytes_read, bool /*write*/, in RunThreads() argument
486 uint64_t* bytes_read, bool /*write*/, in RunThreads() argument
510 uint64_t* bytes_read, bool /*write*/, in RunThreads() argument
514 table_, key_gen_, bytes_written, bytes_read, sequence_, in RunThreads()
537 uint64_t* bytes_read, bool /*write*/, in RunThreads() argument
[all …]
|
| /rocksdb-6.9/env/ |
| D | env_hdfs.cc | 92 tSize bytes_read = 0; in Read() local
97 bytes_read = hdfsRead(fileSys_, hfile_, buffer, remaining_bytes); in Read()
98 if (bytes_read <= 0) { in Read()
101 assert(bytes_read <= remaining_bytes); in Read()
103 total_bytes_read += bytes_read; in Read()
104 remaining_bytes -= bytes_read; in Read()
105 buffer += bytes_read; in Read()
112 if (bytes_read < 0) { in Read()
127 ssize_t bytes_read = hdfsPread(fileSys_, hfile_, offset, in Read() local
131 *result = Slice(scratch, (bytes_read < 0) ? 0 : bytes_read); in Read()
[all …]
|
| D | io_posix.cc | 695 size_t bytes_read = static_cast<size_t>(cqe->res); in MultiRead() local
697 "PosixRandomAccessFile::MultiRead:io_uring_result", &bytes_read); in MultiRead()
698 if (bytes_read == req_wrap->iov.iov_len) { in MultiRead()
701 } else if (bytes_read == 0) { in MultiRead()
713 } else if (bytes_read < req_wrap->iov.iov_len) { in MultiRead()
714 assert(bytes_read > 0); in MultiRead()
715 assert(bytes_read + req_wrap->finished_len < req->len); in MultiRead()
716 req_wrap->finished_len += bytes_read; in MultiRead()
|
| D | env_test.cc | 1146 size_t& bytes_read = *static_cast<size_t*>(arg); in TEST_P() local
1148 bytes_read = 0; in TEST_P()
1150 bytes_read = static_cast<size_t>( in TEST_P()
1151 rnd.Uniform(static_cast<int>(bytes_read))); in TEST_P()
1220 size_t& bytes_read = *static_cast<size_t*>(arg); in TEST_F() local
1222 bytes_read = 0; in TEST_F()
1224 bytes_read = static_cast<size_t>( in TEST_F()
1225 rnd.Uniform(static_cast<int>(bytes_read))); in TEST_F()
|
| /rocksdb-6.9/port/win/ |
| D | io_win.cc | 107 uint64_t offset, size_t& bytes_read) { in pread() argument
110 bytes_read = 0; in pread()
135 bytes_read = bytesRead; in pread()
606 uint64_t offset, size_t& bytes_read) const { in PositionedReadInternal()
607 return pread(this, src, numBytes, offset, bytes_read); in PositionedReadInternal()
625 size_t bytes_read = 0; // out param in PositionedRead() local
627 *result = Slice(scratch, bytes_read); in PositionedRead()
662 size_t& bytes_read) const { in PositionedReadInternal()
696 size_t bytes_read = 0; in ReadImpl() local
697 s = PositionedReadInternal(scratch, n, offset, bytes_read); in ReadImpl()
[all …]
|
| D | io_win.h | 52 uint64_t offset, size_t& bytes_read);
102 uint64_t offset, size_t& bytes_read) const;
238 uint64_t offset, size_t& bytes_read) const;
|
| /rocksdb-6.9/monitoring/ |
| D | iostats_context.cc | 26 bytes_read = 0; in Reset()
46 IOSTATS_CONTEXT_OUTPUT(bytes_read); in ToString()
|
| D | iostats_context_test.cc | 13 get_iostats_context()->bytes_read = 12345; in TEST()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | iostats_context.h | 29 uint64_t bytes_read; member
|
| /rocksdb-6.9/file/ |
| D | random_access_file_reader.cc | 147 IOSTATS_ADD_IF_POSITIVE(bytes_read, result->size()); in Read()
282 IOSTATS_ADD_IF_POSITIVE(bytes_read, read_reqs[i].result.size()); in MultiRead()
|
| D | sequence_file_reader.cc | 51 IOSTATS_ADD(bytes_read, result->size()); in Read()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_job.cc | 381 IOSTATS_RESET(bytes_read); in ReportStartedCompaction()
1451 RecordTick(stats_, COMPACT_READ_BYTES, IOSTATS(bytes_read)); in RecordCompactionIOStats()
1453 ThreadStatus::COMPACTION_BYTES_READ, IOSTATS(bytes_read)); in RecordCompactionIOStats()
1454 IOSTATS_RESET(bytes_read); in RecordCompactionIOStats()
1635 uint64_t* bytes_read, in UpdateCompactionInputStatsHelper() argument
1643 *bytes_read += file_meta->fd.GetFileSize(); in UpdateCompactionInputStatsHelper()
|
| D | compaction_job.h | 141 int* num_files, uint64_t* bytes_read, int input_level);
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.cc | 1753 uint64_t bytes_read = 0; in MultiGet() local
1801 bytes_read += value->size(); in MultiGet()
1821 RecordTick(stats_, NUMBER_MULTIGET_BYTES_READ, bytes_read); in MultiGet()
1822 RecordInHistogram(stats_, BYTES_PER_MULTIGET, bytes_read); in MultiGet()
1823 PERF_COUNTER_ADD(multiget_read_bytes, bytes_read); in MultiGet()
2223 uint64_t bytes_read = 0; in MultiGetImpl() local
2227 bytes_read += key->value->size(); in MultiGetImpl()
2235 RecordTick(stats_, NUMBER_MULTIGET_BYTES_READ, bytes_read); in MultiGetImpl()
2236 RecordInHistogram(stats_, BYTES_PER_MULTIGET, bytes_read); in MultiGetImpl()
2237 PERF_COUNTER_ADD(multiget_read_bytes, bytes_read); in MultiGetImpl()
|
| /rocksdb-6.9/db/ |
| D | db_test_util.h | 431 std::atomic<size_t>* bytes_read) in NewRandomAccessFile()
434 bytes_read_(bytes_read) {} in NewRandomAccessFile()
|
| D | internal_stats.cc | 90 uint64_t bytes_read = in PrepareLevelStats() local
99 (*level_stats)[LevelStatType::READ_GB] = bytes_read / kGB; in PrepareLevelStats()
107 (*level_stats)[LevelStatType::READ_MBPS] = bytes_read / kMB / elapsed; in PrepareLevelStats()
|
| D | db_iterator_test.cc | 2147 size_t bytes_read = env_->random_read_bytes_counter_; in TEST_P() local
2163 ASSERT_GT(bytes_read_readahead, bytes_read); in TEST_P()
|
| /rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/ |
| D | gtest-all.cc | 7911 int bytes_read; in ReadAndInterpretStatusByte() local
7918 bytes_read = posix::Read(read_fd(), &flag, 1); in ReadAndInterpretStatusByte()
7919 } while (bytes_read == -1 && errno == EINTR); in ReadAndInterpretStatusByte()
7921 if (bytes_read == 0) { in ReadAndInterpretStatusByte()
7923 } else if (bytes_read == 1) { in ReadAndInterpretStatusByte()
10538 size_t bytes_read = 0; // # of bytes read so far in ReadEntireFile() local
10545 bytes_last_read = fread(buffer+bytes_read, 1, file_size-bytes_read, file); in ReadEntireFile()
10546 bytes_read += bytes_last_read; in ReadEntireFile()
10547 } while (bytes_last_read > 0 && bytes_read < file_size); in ReadEntireFile()
10549 const std::string content(buffer, bytes_read); in ReadEntireFile()
|