Home
last modified time | relevance | path

Searched refs:current_time (Results 1 – 19 of 19) sorted by relevance

/rocksdb-6.9/utilities/blob_db/
Dblob_compaction_filter.h37 uint64_t current_time, Statistics* stats) in BlobIndexCompactionFilterBase() argument
39 current_time_(current_time), in BlobIndexCompactionFilterBase()
74 uint64_t current_time, Statistics* stats) in BlobIndexCompactionFilter() argument
75 : BlobIndexCompactionFilterBase(std::move(context), current_time, stats) { in BlobIndexCompactionFilter()
85 uint64_t current_time, Statistics* stats) in BlobIndexCompactionFilterGC() argument
86 : BlobIndexCompactionFilterBase(std::move(context), current_time, stats), in BlobIndexCompactionFilterGC()
Dblob_compaction_filter.cc289 int64_t current_time = 0; in CreateCompactionFilter() local
290 Status s = env()->GetCurrentTime(&current_time); in CreateCompactionFilter()
294 assert(current_time >= 0); in CreateCompactionFilter()
302 std::move(context), current_time, statistics())); in CreateCompactionFilter()
310 int64_t current_time = 0; in CreateCompactionFilter() local
311 Status s = env()->GetCurrentTime(&current_time); in CreateCompactionFilter()
315 assert(current_time >= 0); in CreateCompactionFilter()
324 std::move(context), std::move(context_gc), current_time, statistics())); in CreateCompactionFilter()
Dblob_file.cc191 int64_t current_time = 0; in GetReader() local
192 env->GetCurrentTime(&current_time); in GetReader()
193 last_access_.store(current_time); in GetReader()
/rocksdb-6.9/tools/
Dreport_lite_binary_size.sh33 current_time="\"time\": $(date +%s)"
39 …scribe_log="{\"int\":{$current_time, $commit_time, $binary_size}, \"normal\":{$commit_hash, $build…
Dregression_test.sh158 current_time=$(date +"%F-%H:%M:%S")
159 RESULT_PATH=${RESULT_PATH:-"$1/results/$current_time"}
Ddb_bench_tool.cc1928 int64_t current_time = 0; in PrintThreadStatus() local
1929 FLAGS_env->GetCurrentTime(&current_time); in PrintThreadStatus()
/rocksdb-6.9/db/compaction/
Dcompaction_picker_fifo.cc55 const uint64_t current_time = static_cast<uint64_t>(_current_time); in PickTTLCompaction() local
71 if (current_time > mutable_cf_options.ttl) { in PickTTLCompaction()
76 creation_time >= (current_time - mutable_cf_options.ttl)) { in PickTTLCompaction()
Dcompaction_job.cc1509 uint64_t current_time = static_cast<uint64_t>(temp_current_time); in OpenCompactionOutputFile() local
1513 oldest_ancester_time = current_time; in OpenCompactionOutputFile()
1522 out.meta.file_creation_time = current_time; in OpenCompactionOutputFile()
1553 sub_compact->compaction->max_output_file_size(), current_time)); in OpenCompactionOutputFile()
/rocksdb-6.9/db/
Dimport_column_family_job.cc142 uint64_t current_time = kUnknownOldestAncesterTime; in Run() local
144 current_time = oldest_ancester_time = in Run()
156 oldest_ancester_time, current_time, kUnknownFileChecksum, in Run()
Dflush_job.cc368 const uint64_t current_time = static_cast<uint64_t>(_current_time); in WriteLevel0Table() local
375 meta_.oldest_ancester_time = std::min(current_time, oldest_key_time); in WriteLevel0Table()
376 meta_.file_creation_time = current_time; in WriteLevel0Table()
392 current_time); in WriteLevel0Table()
Dwal_manager.cc143 int64_t current_time; in PurgeObsoleteWALFiles() local
144 Status s = env_->GetCurrentTime(&current_time); in PurgeObsoleteWALFiles()
151 uint64_t const now_seconds = static_cast<uint64_t>(current_time); in PurgeObsoleteWALFiles()
Dexternal_sst_file_ingestion_job.cc251 uint64_t current_time = kUnknownFileCreationTime; in Run() local
254 current_time = oldest_ancester_time = in Run()
262 current_time, kUnknownFileChecksum, kUnknownFileChecksumFuncName); in Run()
Dmemtable.cc222 int64_t current_time = 0; in UpdateOldestKeyTime() local
223 auto s = env_->GetCurrentTime(&current_time); in UpdateOldestKeyTime()
225 assert(current_time >= 0); in UpdateOldestKeyTime()
228 oldest_key_time, static_cast<uint64_t>(current_time), in UpdateOldestKeyTime()
Drepair.cc414 const uint64_t current_time = static_cast<uint64_t>(_current_time); in ConvertLogToTable() local
438 -1 /* level */, current_time, write_hint); in ConvertLogToTable()
Dversion_set.cc2333 const uint64_t current_time = static_cast<uint64_t>(_current_time); in GetExpiredTtlFilesCount() local
2338 oldest_ancester_time < (current_time - mutable_cf_options.ttl)) { in GetExpiredTtlFilesCount()
2487 const uint64_t current_time = static_cast<uint64_t>(_current_time); in ComputeExpiredTtlFiles() local
2494 oldest_ancester_time < (current_time - ttl)) { in ComputeExpiredTtlFiles()
2514 const uint64_t current_time = static_cast<uint64_t>(temp_current_time); in ComputeFilesMarkedForPeriodicCompaction() local
2518 if (periodic_compaction_seconds > current_time) { in ComputeFilesMarkedForPeriodicCompaction()
2523 current_time - periodic_compaction_seconds; in ComputeFilesMarkedForPeriodicCompaction()
/rocksdb-6.9/monitoring/
Dthread_status_util.cc60 uint64_t current_time = Env::Default()->NowMicros(); in SetThreadOperation() local
61 thread_updater_local_cache_->SetOperationStartTime(current_time); in SetThreadOperation()
/rocksdb-6.9/env/
Dfs_posix.cc753 int64_t current_time = 0; in LockFile() local
755 Env::Default()->GetCurrentTime(&current_time); in LockFile()
756 lhi.acquire_time = current_time; in LockFile()
/rocksdb-6.9/utilities/ttl/
Dttl_test.cc34 Status GetCurrentTime(int64_t* current_time) override { in GetCurrentTime() argument
35 *current_time = current_time_; in GetCurrentTime()
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc1221 const uint64_t current_time = static_cast<uint64_t>(_current_time); in WriteLevel0TableForRecovery() local
1222 meta.oldest_ancester_time = current_time; in WriteLevel0TableForRecovery()
1254 -1 /* level */, current_time, write_hint); in WriteLevel0TableForRecovery()