| /rocksdb-6.9/memtable/ |
| D | memtablerep_bench.cc | 203 uint64_t* bytes_written, uint64_t* bytes_read, in BenchmarkThread() argument
208 bytes_written_(bytes_written), in BenchmarkThread()
231 uint64_t* bytes_written, uint64_t* bytes_read, in FillBenchmarkThread() argument
291 uint64_t* bytes_written, uint64_t* bytes_read, in ReadBenchmarkThread() argument
337 uint64_t* bytes_written, uint64_t* bytes_read, in SeqReadBenchmarkThread() argument
385 uint64_t* bytes_written, in SeqConcurrentReadBenchmarkThread() argument
418 uint64_t bytes_written = 0; in Run() local
422 RunThreads(&threads, &bytes_written, &bytes_read, true, &read_hits); in Run()
427 if (bytes_written > 0) { in Run()
514 table_, key_gen_, bytes_written, bytes_read, sequence_, in RunThreads()
[all …]
|
| /rocksdb-6.9/db/ |
| D | internal_stats.h | 149 uint64_t bytes_written; member
181 bytes_written(0), in CompactionStats()
200 bytes_written(0), in CompactionStats()
225 bytes_written(c.bytes_written), in CompactionStats()
245 bytes_written = c.bytes_written;
267 this->bytes_written = 0; in Clear()
286 this->bytes_written += c.bytes_written; in Add()
307 this->bytes_written -= c.bytes_written; in Subtract()
638 uint64_t bytes_written; member
|
| D | flush_job.cc | 143 IOSTATS_RESET(bytes_written); in ReportStartedFlush()
157 RecordTick(stats_, FLUSH_WRITE_BYTES, IOSTATS(bytes_written)); in RecordFlushIOStats()
159 ThreadStatus::FLUSH_BYTES_WRITTEN, IOSTATS(bytes_written)); in RecordFlushIOStats()
160 IOSTATS_RESET(bytes_written); in RecordFlushIOStats()
439 stats.bytes_written = meta_.fd.GetFileSize(); in WriteLevel0Table()
|
| D | builder.cc | 169 IOSTATS(bytes_written) >= kReportFlushIOStatsEvery) { in BuildTable()
171 ThreadStatus::FLUSH_BYTES_WRITTEN, IOSTATS(bytes_written)); in BuildTable()
|
| D | internal_stats.cc | 92 int64_t bytes_new = stats.bytes_written - stats.bytes_read_output_level; in PrepareLevelStats()
103 (*level_stats)[LevelStatType::WRITE_GB] = stats.bytes_written / kGB; in PrepareLevelStats()
109 stats.bytes_written / kMB / elapsed; in PrepareLevelStats()
1150 : static_cast<double>(comp_stats_[level].bytes_written) / in DumpCFMapStats()
1160 double w_amp = compaction_stats_sum->bytes_written / in DumpCFMapStats()
1265 interval_stats.bytes_written / static_cast<double>(interval_ingest); in DumpCFStatsNoFileHistogram()
1325 compact_bytes_write += comp_stats_[level].bytes_written; in DumpCFStatsNoFileHistogram()
|
| D | external_sst_file_ingestion_job.cc | 287 stats.bytes_written = f.fd.GetFileSize(); in UpdateStats()
|
| D | external_sst_file_test.cc | 2134 bytes_copied += stats.bytes_written; in TEST_P()
|
| /rocksdb-6.9/port/win/ |
| D | io_win.cc | 71 uint64_t offset, size_t& bytes_written) { in pwrite() argument
74 bytes_written = 0; in pwrite()
99 bytes_written = bytesWritten; in pwrite()
774 size_t bytes_written = 0; // out param in AppendImpl() local
797 bytes_written = bytesWritten; in AppendImpl()
802 if (bytes_written == data.size()) { in AppendImpl()
806 next_write_offset_ += bytes_written; in AppendImpl()
828 size_t bytes_written = 0; in PositionedAppendImpl() local
829 Status s = pwrite(file_data_, data, offset, bytes_written); in PositionedAppendImpl()
832 if (bytes_written == data.size()) { in PositionedAppendImpl()
[all …]
|
| D | io_win.h | 49 uint64_t offset, size_t& bytes_written);
|
| /rocksdb-6.9/monitoring/ |
| D | iostats_context.cc | 27 bytes_written = 0; in Reset()
47 IOSTATS_CONTEXT_OUTPUT(bytes_written); in ToString()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_job.cc | 380 IOSTATS_RESET(bytes_written); in ReportStartedCompaction()
738 read_write_amp = (stats.bytes_written + stats.bytes_read_output_level + in Install()
741 write_amp = stats.bytes_written / in Install()
749 stats.bytes_written / static_cast<double>(stats.micros); in Install()
765 stats.bytes_written / 1048576.0, read_write_amp, write_amp, in Install()
1455 RecordTick(stats_, COMPACT_WRITE_BYTES, IOSTATS(bytes_written)); in RecordCompactionIOStats()
1457 ThreadStatus::COMPACTION_BYTES_WRITTEN, IOSTATS(bytes_written)); in RecordCompactionIOStats()
1458 IOSTATS_RESET(bytes_written); in RecordCompactionIOStats()
1624 compaction_stats_.bytes_written += out.meta.fd.file_size; in UpdateCompactionStats()
1666 compaction_job_stats_->total_output_bytes = stats.bytes_written; in UpdateCompactionJobStats()
|
| /rocksdb-6.9/env/ |
| D | mock_env.cc | 263 size_t bytes_written = 0; in Append() local
264 while (bytes_written < data.size()) { in Append()
265 auto bytes = RequestToken(data.size() - bytes_written); in Append()
266 Status s = file_->Append(Slice(data.data() + bytes_written, bytes)); in Append()
270 bytes_written += bytes; in Append()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | iostats_context.h | 27 uint64_t bytes_written; member
|
| /rocksdb-6.9/file/ |
| D | writable_file_writer.cc | 337 IOSTATS_ADD(bytes_written, allowed); in WriteBuffered()
415 IOSTATS_ADD(bytes_written, size); in WriteDirect()
|
| /rocksdb-6.9/utilities/backupable/ |
| D | backupable_db_test.cc | 488 size_t bytes_written = 0; in FillDB() local
492 bytes_written += key.size() + value.size(); in FillDB()
496 return bytes_written; in FillDB()
1418 size_t bytes_written = FillDB(db_.get(), 0, 100000); in TEST_F() local
1424 (bytes_written * kMicrosPerSec) / limit.first; in TEST_F()
1435 (bytes_written * kMicrosPerSec) / limit.second; in TEST_F()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_open.cc | 1280 stats.bytes_written = meta.fd.GetFileSize(); in WriteLevel0TableForRecovery()
|