Home
last modified time | relevance | path

Searched refs:expiration (Results 1 – 21 of 21) sorted by relevance

/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc734 uint64_t expiration) const { in FindBlobFileLocked()
858 assert(expiration != kNoExpiration); in SelectBlobFileTTL()
1022 if (expiration == kNoExpiration) { in PutBlobValue()
1050 if (expiration != kNoExpiration) { in PutBlobValue()
1062 if (expiration != kNoExpiration) { in PutBlobValue()
1309 if (expiration == kNoExpiration) { in AppendBlob()
1370 if (expiration != nullptr) { in GetBlobValue()
1372 *expiration = blob_index.expiration(); in GetBlobValue()
1374 *expiration = kNoExpiration; in GetBlobValue()
1595 if (expiration != nullptr) { in GetImpl()
[all …]
Dblob_db_impl.h109 uint64_t* expiration) override;
138 const Slice& value, uint64_t expiration) override;
222 PinnableSlice* value, uint64_t* expiration = nullptr);
225 PinnableSlice* value, uint64_t* expiration = nullptr);
253 const Slice& value, uint64_t expiration,
258 const Slice& value, uint64_t expiration,
274 Status SelectBlobFileTTL(uint64_t expiration,
277 std::shared_ptr<BlobFile> FindBlobFileLocked(uint64_t expiration) const;
Dblob_log_writer.cc80 uint64_t expiration, uint64_t* key_offset, in AddRecord() argument
86 ConstructBlobHeader(&buf, key, val, expiration); in AddRecord()
105 const Slice& val, uint64_t expiration) { in ConstructBlobHeader() argument
109 record.expiration = expiration; in ConstructBlobHeader()
Dblob_db.h126 const Slice& value, uint64_t expiration) = 0;
129 const Slice& value, uint64_t expiration) { in PutUntil() argument
134 return PutUntil(options, key, value, expiration); in PutUntil()
145 PinnableSlice* value, uint64_t* expiration) = 0;
147 PinnableSlice* value, uint64_t* expiration) { in Get() argument
148 return Get(options, DefaultColumnFamily(), key, value, expiration); in Get()
Dblob_db_test.cc48 expiration(_expiration), in BlobIndexVersion()
54 uint64_t expiration = kNoExpiration; member
158 expiration)); in PutRandomUntil()
279 const uint64_t expiration = in VerifyBaseDBBlobIndex() local
281 ASSERT_EQ(expiration, expected_version.expiration); in VerifyBaseDBBlobIndex()
360 uint64_t expiration = rnd.Next() % 100 + 50; in TEST_F() local
406 uint64_t expiration; in TEST_F() local
409 ASSERT_EQ(kNoExpiration, expiration); in TEST_F()
412 ASSERT_EQ(300 /* = 100 + 200 */, expiration); in TEST_F()
1174 ASSERT_OK(PutUntil(key, value, expiration)); in TEST_F()
[all …]
Dblob_file.h199 void ExtendExpirationRange(uint64_t expiration) { in ExtendExpirationRange() argument
200 expiration_range_.first = std::min(expiration_range_.first, expiration); in ExtendExpirationRange()
201 expiration_range_.second = std::max(expiration_range_.second, expiration); in ExtendExpirationRange()
Dblob_log_writer.h49 const Slice& val, uint64_t expiration);
54 Status AddRecord(const Slice& key, const Slice& val, uint64_t expiration,
Dblob_log_format.cc106 PutFixed64(dst, expiration); in EncodeHeaderTo()
126 !GetFixed64(&src, &expiration) || !GetFixed32(&src, &header_crc) || in DecodeHeaderFrom()
Dblob_compaction_filter.cc28 if (blob_index.HasTTL() && blob_index.expiration() <= current_time_) { in FilterV2()
43 blob_index.expiration() < context_.evict_expiration_up_to) { in FilterV2()
Dblob_log_format.h114 uint64_t expiration = 0; member
Dblob_dump_tool.cc198 fprintf(stdout, " expiration : %" PRIu64 "\n", record.expiration); in DumpRecord()
/rocksdb-6.9/db/blob/
Dblob_index.h61 uint64_t expiration() const { in expiration() function
131 static void EncodeInlinedTTL(std::string* dst, uint64_t expiration, in EncodeInlinedTTL() argument
137 PutVarint64(dst, expiration); in EncodeInlinedTTL()
154 static void EncodeBlobTTL(std::string* dst, uint64_t expiration, in EncodeBlobTTL() argument
161 PutVarint64(dst, expiration); in EncodeBlobTTL()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DTransactionOptions.java118 public TransactionOptions setExpiration(final long expiration) { in setExpiration() argument
120 setExpiration(nativeHandle_, expiration); in setExpiration()
181 private native void setExpiration(final long handle, final long expiration); in setExpiration() argument
/rocksdb-6.9/java/rocksjni/
Dtransaction_options.cc114 return opts->expiration; in Java_org_rocksdb_TransactionOptions_getExpiration()
128 opts->expiration = jexpiration; in Java_org_rocksdb_TransactionOptions_setExpiration()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DTransactionOptionsTest.java47 public void expiration() { in expiration() method in TransactionOptionsTest
/rocksdb-6.9/db/compaction/
Dcompaction_job_test.cc118 uint64_t size, uint64_t expiration) { in BlobStrTTL() argument
120 BlobIndex::EncodeBlobTTL(&blob_index, expiration, blob_file_number, offset, in BlobStrTTL()
126 uint64_t expiration) { in BlobStrInlinedTTL() argument
128 BlobIndex::EncodeInlinedTTL(&blob_index, expiration, value); in BlobStrInlinedTTL()
/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction.cc76 if (txn_options.expiration >= 0) { in Initialize()
77 expiration_time_ = start_time_ + txn_options.expiration * 1000; in Initialize()
Dtransaction_test.cc1189 txn_options.expiration = 500; // 500ms in TEST_P()
1438 txn_options.expiration = 1000000; in TEST_P()
3288 txn_options.expiration = 0; in TEST_P()
3334 txn_options.expiration = 0; in TEST_P()
3338 txn_options.expiration = -1; in TEST_P()
4560 txn_options0.expiration = 100; // 100ms in TEST_P()
4598 txn_options.expiration = 100; // 100ms in TEST_P()
4618 txn_options.expiration = 6000000; // 100 minutes in TEST_P()
4624 txn_options2.expiration = 10; // 10ms in TEST_P()
4646 txn_options2.expiration = 100000000; in TEST_P()
[all …]
/rocksdb-6.9/include/rocksdb/utilities/
Dtransaction_db.h158 int64_t expiration = -1; member
/rocksdb-6.9/db/
Dc.cc3805 rocksdb_transaction_options_t* opt, int64_t expiration) { in rocksdb_transaction_options_set_expiration() argument
3806 opt->rep.expiration = expiration; in rocksdb_transaction_options_set_expiration()
/rocksdb-6.9/include/rocksdb/
Dc.h1736 rocksdb_transaction_options_t* opt, int64_t expiration);