Home
last modified time | relevance | path

Searched refs:ttl (Results 1 – 25 of 67) sorted by relevance

123

/rocksdb-6.9/db/
Ddb_options_test.cc615 options.ttl = 0; in TEST_F()
621 options.ttl = 0; in TEST_F()
627 options.ttl = 100; in TEST_F()
633 options.ttl = 100; in TEST_F()
646 options.ttl = 0; in TEST_F()
650 options.ttl = 100; in TEST_F()
658 options.ttl = 0; in TEST_F()
662 options.ttl = 100; in TEST_F()
670 options.ttl = 200; in TEST_F()
726 options.ttl = 0; in TEST_F()
[all …]
Dcolumn_family.cc352 if (result.ttl == kDefaultTtl) { in SanitizeOptions()
355 result.ttl = kAdjustedTtl; in SanitizeOptions()
357 result.ttl = 0; in SanitizeOptions()
375 if (result.ttl == 0) { in SanitizeOptions()
380 result.ttl = result.periodic_compaction_seconds; in SanitizeOptions()
383 result.ttl = std::min(result.ttl, result.periodic_compaction_seconds); in SanitizeOptions()
390 if (result.compaction_style == kCompactionStyleUniversal && result.ttl != 0) { in SanitizeOptions()
393 std::min(result.ttl, result.periodic_compaction_seconds); in SanitizeOptions()
395 result.periodic_compaction_seconds = result.ttl; in SanitizeOptions()
1301 if (cf_options.ttl > 0 && cf_options.ttl != kDefaultTtl) { in ValidateOptions()
Dmerge_test.cc74 std::shared_ptr<DB> OpenDb(const std::string& dbname, const bool ttl = false, in OpenDb() argument
85 if (ttl) { in OpenDb()
93 assert(!ttl); in OpenDb()
/rocksdb-6.9/utilities/ttl/
Ddb_ttl_impl.cc23 new TtlCompactionFilter(ttl, env, options->compaction_filter); in SanitizeOptions()
27 ttl, env, options->compaction_filter_factory)); in SanitizeOptions()
61 Status s = DBWithTTL::Open(options, dbname, &db, ttl, read_only); in OpenTtlDB()
71 DBWithTTL** dbptr, int32_t ttl, bool read_only) { in Open() argument
80 dbptr, {ttl}, read_only); in Open()
127 ColumnFamilyHandle** handle, int ttl) { in CreateColumnFamilyWithTtl() argument
129 DBWithTTLImpl::SanitizeOptions(ttl, &sanitized_options, GetEnv()); in CreateColumnFamilyWithTtl()
175 if (ttl <= 0) { // Data is fresh if TTL is non-positive in IsStale()
184 return (timestamp_value + ttl) < curtime; in IsStale()
323 void DBWithTTLImpl::SetTtl(ColumnFamilyHandle *h, int32_t ttl) { in SetTtl() argument
[all …]
Ddb_ttl_impl.h30 static void SanitizeOptions(int32_t ttl, ColumnFamilyOptions* options,
42 int ttl) override;
84 static bool IsStale(const Slice& value, int32_t ttl, Env* env);
100 void SetTtl(int32_t ttl) override { SetTtl(DefaultColumnFamily(), ttl); } in SetTtl() argument
102 void SetTtl(ColumnFamilyHandle *h, int32_t ttl) override;
154 int32_t ttl, Env* env, const CompactionFilter* user_comp_filter,
157 : ttl_(ttl), in ttl_() argument
205 int32_t ttl, Env* env, in TtlCompactionFilterFactory() argument
207 : ttl_(ttl), env_(env), user_comp_filter_factory_(comp_filter_factory) {} in TtlCompactionFilterFactory()
222 void SetTtl(int32_t ttl) { in SetTtl() argument
[all …]
Dttl_test.cc70 void OpenTtl(int32_t ttl) { in OpenTtl() argument
72 ASSERT_OK(DBWithTTL::Open(options_, dbname_, &db_ttl_, ttl)); in OpenTtl()
76 void OpenTtlWithTestCompaction(int32_t ttl) { in OpenTtlWithTestCompaction() argument
80 OpenTtl(ttl); in OpenTtlWithTestCompaction()
84 void OpenReadOnlyTtl(int32_t ttl) { in OpenReadOnlyTtl() argument
86 ASSERT_OK(DBWithTTL::Open(options_, dbname_, &db_ttl_, ttl, true)); in OpenReadOnlyTtl()
299 void SetTtl(int32_t ttl, ColumnFamilyHandle* cf = nullptr) { in SetTtl() argument
301 cf == nullptr ? db_ttl_->SetTtl(ttl) : db_ttl_->SetTtl(cf, ttl); in SetTtl()
Dttl_test.cc.d1 utilities/ttl/ttl_test.cc.d utilities/ttl/ttl_test.o: \
2 utilities/ttl/ttl_test.cc include/rocksdb/compaction_filter.h \
Ddb_ttl_impl.cc.d1 utilities/ttl/db_ttl_impl.cc.d utilities/ttl/db_ttl_impl.o: \
2 utilities/ttl/db_ttl_impl.cc utilities/ttl/db_ttl_impl.h \
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DTtlDB.java86 final int ttl, final boolean readOnly) throws RocksDBException { in open() argument
87 return new TtlDB(open(options.nativeHandle_, db_path, ttl, readOnly)); in open()
209 final int ttl) throws RocksDBException { in createColumnFamilyWithTtl() argument
213 columnFamilyDescriptor.getOptions().nativeHandle_, ttl)); in createColumnFamilyWithTtl()
234 final String db_path, final int ttl, final boolean readOnly) in open() argument
241 final byte[] columnFamilyName, final long columnFamilyOptions, int ttl) in createColumnFamilyWithTtl() argument
DMutableColumnFamilyOptions.java120 ttl(ValueType.LONG); enumConstant
460 public MutableColumnFamilyOptionsBuilder setTtl(final long ttl) { in setTtl() argument
461 return setLong(CompactionOption.ttl, ttl); in setTtl()
465 public long ttl() { in ttl() method in MutableColumnFamilyOptions.MutableColumnFamilyOptionsBuilder
466 return getLong(CompactionOption.ttl); in ttl()
DColumnFamilyOptions.java779 public ColumnFamilyOptions setTtl(final long ttl) { in setTtl() argument
780 setTtl(nativeHandle_, ttl); in setTtl()
785 public long ttl() { in ttl() method in ColumnFamilyOptions
786 return ttl(nativeHandle_); in ttl()
978 private native void setTtl(final long handle, final long ttl); in setTtl() argument
979 private native long ttl(final long handle); in ttl() method in ColumnFamilyOptions
DAdvancedMutableColumnFamilyOptionsInterface.java453 T setTtl(final long ttl); in setTtl() argument
463 long ttl(); in ttl() method
DOptions.java1736 public Options setTtl(final long ttl) { in setTtl() argument
1737 setTtl(nativeHandle_, ttl); in setTtl()
1742 public long ttl() { in ttl() method in Options
1743 return ttl(nativeHandle_); in ttl()
2153 private native void setTtl(final long handle, final long ttl); in setTtl() argument
2154 private native long ttl(final long handle); in ttl() method in Options
/rocksdb-6.9/include/rocksdb/utilities/
Ddb_ttl.h51 ColumnFamilyHandle** handle, int ttl) = 0;
54 DBWithTTL** dbptr, int32_t ttl = 0,
63 virtual void SetTtl(int32_t ttl) = 0;
65 virtual void SetTtl(ColumnFamilyHandle* h, int32_t ttl) = 0;
Dutility_db.h30 StackableDB** dbptr, int32_t ttl = 0, bool read_only = false);
/rocksdb-6.9/options/
Dcf_options.h158 ttl(options.ttl), in MutableCFOptions()
194 ttl(0), in MutableCFOptions()
245 uint64_t ttl; member
Doptions.cc88 ttl(options.ttl), in AdvancedColumnFamilyOptions()
356 ttl); in Dump()
/rocksdb-6.9/db/compaction/
Dcompaction_picker_fifo.cc40 assert(mutable_cf_options.ttl > 0); in PickTTLCompaction()
71 if (current_time > mutable_cf_options.ttl) { in PickTTLCompaction()
76 creation_time >= (current_time - mutable_cf_options.ttl)) { in PickTTLCompaction()
206 if (mutable_cf_options.ttl > 0) { in PickCompaction()
/rocksdb-6.9/tools/advisor/test/input_files/
DOPTIONS-00000519 ttl=0
35 ttl=0
/rocksdb-6.9/utilities/blob_db/
Dblob_db.h112 const Slice& value, uint64_t ttl) = 0;
115 const Slice& value, uint64_t ttl) { in PutWithTTL() argument
120 return PutWithTTL(options, key, value, ttl); in PutWithTTL()
Dblob_db_test.cc129 Status PutWithTTL(const Slice &key, const Slice &value, uint64_t ttl, in PutWithTTL() argument
131 Status s = blob_db_->PutWithTTL(WriteOptions(), key, value, ttl); in PutWithTTL()
142 void PutRandomWithTTL(const std::string &key, uint64_t ttl, Random *rnd, in PutRandomWithTTL() argument
293 uint64_t ttl = rnd.Next() % 86400; in InsertBlobs() local
294 PutRandomWithTTL("key" + ToString(i % 500), ttl, &rnd, nullptr); in InsertBlobs()
334 uint64_t ttl = rnd.Next() % 100; in TEST_F() local
335 PutRandomWithTTL("key" + ToString(i), ttl, &rnd, in TEST_F()
336 (ttl <= 50 ? nullptr : &data)); in TEST_F()
1284 uint64_t ttl = rnd.Next() % 120 + 1; in TEST_F() local
1285 ASSERT_OK(PutWithTTL(key, value, ttl, &data)); in TEST_F()
[all …]
/rocksdb-6.9/utilities/cassandra/
Dformat.cc102 int32_t ttl in ExpiringColumn() argument
104 ttl_(ttl) {} in ExpiringColumn()
155 int32_t ttl = ROCKSDB_NAMESPACE::cassandra::Deserialize<int32_t>(src, offset); in Deserialize() local
157 mask, index, timestamp, value_size, value, ttl); in Deserialize()
Dcassandra_format_test.cc74 int32_t ttl = 3600; in TEST() local
76 sizeof(data), data, ttl); in TEST()
99 EXPECT_EQ(Deserialize<int32_t>(dest.c_str(), offset), ttl); in TEST()
/rocksdb-6.9/include/rocksdb/
Dadvanced_options.h662 uint64_t ttl = 0xfffffffffffffffe; member
/rocksdb-6.9/
Dsrc.mk246 utilities/ttl/db_ttl_impl.cc \
472 utilities/ttl/ttl_test.cc \
539 java/rocksjni/ttl.cc \

123