Home
last modified time | relevance | path

Searched refs:GetFileSize (Results 1 – 25 of 99) sorted by relevance

1234

/rocksdb-6.9/utilities/
Denv_mirror_test.cc43 ASSERT_TRUE(!env_->GetFileSize("/dir/non_existent", &file_size).ok()); in TEST_F()
55 ASSERT_OK(env_->GetFileSize("/dir/f", &file_size)); in TEST_F()
73 ASSERT_OK(env_->GetFileSize("/dir/f", &file_size)); in TEST_F()
75 ASSERT_OK(a_->GetFileSize("/dir/f", &file_size)); in TEST_F()
77 ASSERT_OK(b_->GetFileSize("/dir/f", &file_size)); in TEST_F()
85 ASSERT_OK(env_->GetFileSize("/dir/g", &file_size)); in TEST_F()
88 ASSERT_OK(a_->GetFileSize("/dir/g", &file_size)); in TEST_F()
91 ASSERT_OK(b_->GetFileSize("/dir/g", &file_size)); in TEST_F()
Denv_librados_test.cc118 ASSERT_TRUE(!env_->GetFileSize("/dir/non_existent", &file_size).ok()); in TEST_F()
128 ASSERT_OK(env_->GetFileSize("/dir/f", &file_size)); in TEST_F()
141 ASSERT_OK(env_->GetFileSize("/dir/f", &file_size)); in TEST_F()
150 ASSERT_OK(env_->GetFileSize("/dir/g", &file_size)); in TEST_F()
325 ASSERT_EQ(writable_file->GetFileSize(), kWriteSize); in TEST_F()
327 ASSERT_EQ(writable_file->GetFileSize(), truncSize); in TEST_F()
817 ASSERT_TRUE(!env_->GetFileSize(dir_non_existent.c_str(), &file_size).ok()); in TEST_F()
827 ASSERT_OK(env_->GetFileSize(dir_f.c_str(), &file_size)); in TEST_F()
840 ASSERT_OK(env_->GetFileSize(dir_f.c_str(), &file_size)); in TEST_F()
849 ASSERT_OK(env_->GetFileSize(dir_g.c_str(), &file_size)); in TEST_F()
Denv_mirror.cc159 uint64_t GetFileSize() override { in GetFileSize() function in ROCKSDB_NAMESPACE::WritableFileMirror
160 uint64_t as = a_->GetFileSize(); in GetFileSize()
161 assert(as == b_->GetFileSize()); in GetFileSize()
Denv_timed.cc99 Status GetFileSize(const std::string& fname, uint64_t* file_size) override { in GetFileSize() function in ROCKSDB_NAMESPACE::TimedEnv
101 return EnvWrapper::GetFileSize(fname, file_size); in GetFileSize()
/rocksdb-6.9/db/
Ddb_info_dumper.cc53 env->GetFileSize(dbname + "/" + file, &file_size); in DumpDBFileSummary()
58 env->GetFileSize(dbname + "/" + file, &file_size); in DumpDBFileSummary()
111 env->GetFileSize(options.wal_dir + "/" + file, &file_size); in DumpDBFileSummary()
Dflush_job.cc403 meta_.fd.GetNumber(), meta_.fd.GetFileSize(), in WriteLevel0Table()
417 if (s.ok() && meta_.fd.GetFileSize() > 0) { in WriteLevel0Table()
424 meta_.fd.GetFileSize(), meta_.smallest, meta_.largest, in WriteLevel0Table()
439 stats.bytes_written = meta_.fd.GetFileSize(); in WriteLevel0Table()
443 meta_.fd.GetFileSize()); in WriteLevel0Table()
Dexternal_sst_file_ingestion_job.cc259 f.picked_level, f.fd.GetNumber(), f.fd.GetPathId(), f.fd.GetFileSize(), in Run()
287 stats.bytes_written = f.fd.GetFileSize(); in UpdateStats()
289 stats.bytes_moved = f.fd.GetFileSize(); in UpdateStats()
295 f.fd.GetFileSize()); in UpdateStats()
364 Status status = fs_->GetFileSize(external_file, IOOptions(), in GetIngestedFileInfo()
Dwal_manager.cc206 s = env_->GetFileSize(file_path, &file_size); in PurgeObsoleteWALFiles()
313 s = env_->GetFileSize(LogFileName(path, number), &size_bytes); in GetSortedWalsOfType()
318 s = env_->GetFileSize(archived_file, &size_bytes); in GetSortedWalsOfType()
431 s = env_->GetFileSize(LogFileName(db_options_.wal_dir, number), &size_bytes); in GetLiveWalFile()
Dbuilder.cc201 assert(meta->fd.GetFileSize() > 0); in BuildTable()
259 if (!s.ok() || meta->fd.GetFileSize() == 0) { in BuildTable()
263 if (meta->fd.GetFileSize() == 0) { in BuildTable()
Dversion_set.cc1450 level_size += file->fd.GetFileSize(); in GetColumnFamilyMetaData()
2260 level_size += f->fd.GetFileSize(); in EstimateCompactionBytesNeeded()
2282 level_size2 += f->fd.GetFileSize(); in EstimateCompactionBytesNeeded()
2290 level_size += f->fd.GetFileSize(); in EstimateCompactionBytesNeeded()
2309 bytes_next_level += f->fd.GetFileSize(); in EstimateCompactionBytesNeeded()
3235 total_size += f->fd.GetFileSize(); in CalculateBaseBytes()
3257 l0_size += f->fd.GetFileSize(); in CalculateBaseBytes()
5420 result = f.fd.GetFileSize(); in ApproximateOffsetOf()
5460 assert(f.fd.GetFileSize() >= start_offset); in ApproximateSize()
5461 return f.fd.GetFileSize() - start_offset; in ApproximateSize()
[all …]
Drepair.cc211 bytes += tables_[i].meta.fd.GetFileSize(); in Run()
444 if (meta.fd.GetFileSize() > 0) { in ConvertLogToTable()
480 Status status = env_->GetFileSize(fname, &file_size); in ScanTable()
586 table->meta.fd.GetFileSize(), table->meta.smallest, in AddTables()
Dimport_column_family_job.cc153 f.fd.GetFileSize(), f.smallest_internal_key, in Run()
204 Status status = fs_->GetFileSize(external_file, IOOptions(), in GetIngestedFileInfo()
/rocksdb-6.9/env/
Denv_basic_test.cc139 ASSERT_TRUE(!env_->GetFileSize(test_dir_ + "/non_existent", &file_size).ok()); in TEST_P()
150 ASSERT_OK(env_->GetFileSize(test_dir_ + "/f", &file_size)); in TEST_P()
169 ASSERT_OK(env_->GetFileSize(test_dir_ + "/f1", &file_size)); in TEST_P()
178 ASSERT_OK(env_->GetFileSize(test_dir_ + "/g", &file_size)); in TEST_P()
183 ASSERT_OK(env_->GetFileSize(test_dir_ + "/g", &file_size)); in TEST_P()
Dmock_env_test.cc35 ASSERT_TRUE(writable_file->GetFileSize() == kGood.size()); in TEST_F()
54 ASSERT_TRUE(writable_file->GetFileSize() == kGood.size() + kCorrupted.size()); in TEST_F()
Dcomposite_env_wrapper.h164 uint64_t GetFileSize() override { in GetFileSize() function
167 return target_->GetFileSize(io_opts, &dbg); in GetFileSize()
430 Status GetFileSize(const std::string& f, uint64_t* s) override { in GetFileSize() function
433 return file_system_->GetFileSize(f, io_opts, s, &dbg); in GetFileSize()
754 uint64_t GetFileSize(const IOOptions& /*options*/, in GetFileSize() function
756 return target_->GetFileSize(); in GetFileSize()
986 IOStatus GetFileSize(const std::string& f, const IOOptions& /*options*/, in GetFileSize() function
988 return status_to_io_status(target_->GetFileSize(f, s)); in GetFileSize()
Denv_encryption.cc203 auto offset = file_->GetFileSize(); // size including prefix in Append()
261 uint64_t GetFileSize() override { in GetFileSize() function in ROCKSDB_NAMESPACE::EncryptedWritableFile
262 return file_->GetFileSize() - prefixLength_; in GetFileSize()
670 Status GetFileSize(const std::string& fname, uint64_t* file_size) override { in GetFileSize() function in ROCKSDB_NAMESPACE::EncryptedEnv
671 auto status = EnvWrapper::GetFileSize(fname, file_size); in GetFileSize()
/rocksdb-6.9/db/compaction/
Dcompaction.cc61 sum += files[i]->fd.GetFileSize(); in TotalFileSize()
339 file->fd.GetFileSize() + TotalFileSize(file_grand_parents); in IsTrivialMove()
432 size += f->fd.GetFileSize(); in CalculateTotalInputSize()
457 AppendHumanBytes(files.at(i)->fd.GetFileSize(), sztxt, 16); in InputSummary()
498 preallocation_size += file->fd.GetFileSize(); in OutputFilePreallocationSize()
/rocksdb-6.9/include/rocksdb/utilities/
Denv_mirror.h118 Status GetFileSize(const std::string& f, uint64_t* s) override { in GetFileSize() function
120 Status as = a_->GetFileSize(f, &asize); in GetFileSize()
121 Status bs = b_->GetFileSize(f, &bsize); in GetFileSize()
/rocksdb-6.9/utilities/trace/
Dfile_trace_reader_writer.cc89 uint64_t FileTraceWriter::GetFileSize() { return file_writer_->GetFileSize(); } in GetFileSize() function in ROCKSDB_NAMESPACE::FileTraceWriter
/rocksdb-6.9/logging/
Denv_logger_test.cc64 ASSERT_EQ(env_->GetFileSize(kLogFile, &file_size), Status::OK()); in TEST_F()
105 ASSERT_EQ(env_->GetFileSize(kLogFile, &file_size), Status::OK()); in TEST_F()
/rocksdb-6.9/include/rocksdb/
Dfile_system.h349 if (!(s = GetFileSize(path, options, &(*result)[result_size].size_bytes, in GetChildrenFileAttributes()
392 virtual IOStatus GetFileSize(const std::string& fname,
796 virtual uint64_t GetFileSize(const IOOptions& /*options*/, in GetFileSize() function
1102 IOStatus GetFileSize(const std::string& f, const IOOptions& options, in GetFileSize() function
1104 return target_->GetFileSize(f, options, s, dbg); in GetFileSize()
1307 uint64_t GetFileSize(const IOOptions& options, IODebugContext* dbg) override { in GetFileSize() function
1308 return target_->GetFileSize(options, dbg); in GetFileSize()
Denv.h319 virtual Status GetFileSize(const std::string& fname, uint64_t* file_size) = 0;
817 virtual uint64_t GetFileSize() { return 0; } in GetFileSize() function
1250 Status GetFileSize(const std::string& f, uint64_t* s) override { in GetFileSize() function
1251 return target_->GetFileSize(f, s); in GetFileSize()
1495 uint64_t GetFileSize() override { return target_->GetFileSize(); } in GetFileSize() function
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc545 s = env_->GetFileSize(fname, &bytes); in Recover()
774 if (env_->GetFileSize(fname, &bytes).ok()) { in RecoverLogFiles()
1155 s = env_->GetFileSize(fname, &log.size); in RestoreAliveLogFiles()
1260 meta.fd.GetFileSize(), s.ToString().c_str()); in WriteLevel0TableForRecovery()
1269 if (s.ok() && meta.fd.GetFileSize() > 0) { in WriteLevel0TableForRecovery()
1271 meta.fd.GetFileSize(), meta.smallest, meta.largest, in WriteLevel0TableForRecovery()
1280 stats.bytes_written = meta.fd.GetFileSize(); in WriteLevel0TableForRecovery()
1284 meta.fd.GetFileSize()); in WriteLevel0TableForRecovery()
1285 RecordTick(stats_, COMPACT_WRITE_BYTES, meta.fd.GetFileSize()); in WriteLevel0TableForRecovery()
/rocksdb-6.9/file/
Dsst_file_manager_impl.cc65 Status s = fs_->GetFileSize(file_path, IOOptions(), &file_size, nullptr); in OnAddFile()
97 size_added_by_compaction += filemeta->fd.GetFileSize(); in OnCompactionCompletion()
168 size_added_by_compaction += filemeta->fd.GetFileSize(); in EnoughRoomForCompaction()
/rocksdb-6.9/java/rocksjni/
Dtrace_writer_jnicallback.h26 virtual uint64_t GetFileSize();

1234