diff --git a/db/db_impl.cc b/db/db_impl.cc index 058ef78..6d7af36 100644 --- a/db/db_impl.cc +++ b/db/db_impl.cc @@ -622,34 +622,6 @@ void DBImpl::TEST_CompactRange(int level, const Slice* begin, manual.end = &end_storage; } - if (level == config::kNumLevels - 1) { - // TTL: TODO: update files in the last level - mutex_.AssertHeld(); - - Compaction* c; - c = versions_->CompactRange(level, nullptr, nullptr); - - Iterator* files = versions_->MakeInputIterator(c); - - while (files->Valid() && !shutting_down_.load(std::memory_order_acquire)) { - std::string value = files->value().ToString(); - uint64_t ddl; - DecodeDeadLineValue(&value, ddl); - - if (ddl != 0) { - if (ddl <= std::time(nullptr)) { - c->edit()->RemoveFile(c->level(), number); - versions_->LogAndApply(c->edit(), &mutex_); - } - } - - - files->Next(); - } - - return; - } // ttl end - MutexLock l(&mutex_); while (!manual.done && !shutting_down_.load(std::memory_order_acquire) && bg_error_.ok()) { diff --git a/db/db_test.cc b/db/db_test.cc index a4a84cd..32d2892 100644 --- a/db/db_test.cc +++ b/db/db_test.cc @@ -2117,6 +2117,9 @@ class ModelDB : public DB { Status Put(const WriteOptions& o, const Slice& k, const Slice& v) override { return DB::Put(o, k, v); } + Status Put(const WriteOptions& o, const Slice& k, const Slice& v, uint64_t ttl) override { + return DB::Put(o, k, v, ttl); + } Status Delete(const WriteOptions& o, const Slice& key) override { return DB::Delete(o, key); }