Home
last modified time | relevance | path

Searched refs:pinnable_val (Results 1 – 20 of 20) sorted by relevance

/rocksdb-6.9/examples/
Dsimple_example.cc54 PinnableSlice pinnable_val; in main() local
56 assert(pinnable_val == "value"); in main()
63 PinnableSlice pinnable_val(&string_val); in main() local
65 assert(pinnable_val == "value"); in main()
67 assert(pinnable_val.IsPinned() || string_val == "value"); in main()
70 PinnableSlice pinnable_val; in main() local
71 db->Get(ReadOptions(), db->DefaultColumnFamily(), "key1", &pinnable_val); in main()
74 pinnable_val.Reset(); in main()
75 db->Get(ReadOptions(), db->DefaultColumnFamily(), "key2", &pinnable_val); in main()
76 assert(pinnable_val == "value"); in main()
[all …]
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index.cc800 PinnableSlice pinnable_val(value); in GetFromBatchAndDB() local
801 assert(!pinnable_val.IsPinned()); in GetFromBatchAndDB()
805 value->assign(pinnable_val.data(), pinnable_val.size()); in GetFromBatchAndDB()
824 PinnableSlice pinnable_val(value); in GetFromBatchAndDB() local
825 assert(!pinnable_val.IsPinned()); in GetFromBatchAndDB()
829 value->assign(pinnable_val.data(), pinnable_val.size()); in GetFromBatchAndDB()
862 pinnable_val->PinSelf(); in GetFromBatchAndDB()
906 merge_data = pinnable_val; in GetFromBatchAndDB()
916 pinnable_val->Reset(); in GetFromBatchAndDB()
918 pinnable_val->PinSelf(); in GetFromBatchAndDB()
[all …]
/rocksdb-6.9/include/rocksdb/utilities/
Dtransaction.h186 PinnableSlice* pinnable_val) { in Get() argument
187 assert(pinnable_val != nullptr); in Get()
188 auto s = Get(options, column_family, key, pinnable_val->GetSelf()); in Get()
189 pinnable_val->PinSelf(); in Get()
196 PinnableSlice* pinnable_val) { in Get() argument
197 assert(pinnable_val != nullptr); in Get()
198 auto s = Get(options, key, pinnable_val->GetSelf()); in Get()
199 pinnable_val->PinSelf(); in Get()
263 const Slice& key, PinnableSlice* pinnable_val,
266 if (pinnable_val == nullptr) {
[all …]
/rocksdb-6.9/utilities/transactions/
Dtransaction_base.cc245 PinnableSlice pinnable_val(value); in Get() local
246 assert(!pinnable_val.IsPinned()); in Get()
248 if (s.ok() && pinnable_val.IsPinned()) { in Get()
249 value->assign(pinnable_val.data(), pinnable_val.size()); in Get()
258 pinnable_val); in Get()
276 PinnableSlice pinnable_val(value); in GetForUpdate() local
277 assert(!pinnable_val.IsPinned()); in GetForUpdate()
279 if (s.ok() && pinnable_val.IsPinned()) { in GetForUpdate()
280 value->assign(pinnable_val.data(), pinnable_val.size()); in GetForUpdate()
300 if (s.ok() && pinnable_val != nullptr) { in GetForUpdate()
[all …]
Dtransaction_test.cc5928 pinnable_val.Reset(); in TEST_P()
5932 pinnable_val.Reset(); in TEST_P()
5936 pinnable_val.Reset(); in TEST_P()
5940 pinnable_val.Reset(); in TEST_P()
5966 pinnable_val.Reset(); in TEST_P()
5970 pinnable_val.Reset(); in TEST_P()
5974 pinnable_val.Reset(); in TEST_P()
5999 pinnable_val.Reset(); in TEST_P()
6002 pinnable_val.Reset(); in TEST_P()
6026 pinnable_val.Reset(); in TEST_P()
[all …]
Dwrite_prepared_transaction_test.cc968 PinnableSlice pinnable_val; in TEST_P() local
972 pinnable_val.Reset(); in TEST_P()
980 pinnable_val.Reset(); in TEST_P()
991 pinnable_val.Reset(); in TEST_P()
1441 pinnable_val.Reset(); in TEST_P()
1445 pinnable_val.Reset(); in TEST_P()
1554 PinnableSlice pinnable_val; in TEST_P() local
1831 pinnable_val.Reset(); in TEST_P()
1858 pinnable_val.Reset(); in TEST_P()
1912 pinnable_val.Reset(); in TEST_P()
[all …]
Dwrite_prepared_txn.cc67 const Slice& key, PinnableSlice* pinnable_val) { in Get() argument
74 pinnable_val, &callback); in Get()
290 PinnableSlice pinnable_val; in RollbackInternal() local
295 get_impl_options.value = &pinnable_val; in RollbackInternal()
301 s = rollback_batch_->Put(cf_handle, key, pinnable_val); in RollbackInternal()
Dwrite_unprepared_txn_db.cc100 PinnableSlice pinnable_val; in RollbackRecoveredTransaction() local
105 get_impl_options.value = &pinnable_val; in RollbackRecoveredTransaction()
111 s = rollback_batch_->Put(cf_handle, key, pinnable_val); in RollbackRecoveredTransaction()
Dwrite_unprepared_txn.cc647 PinnableSlice pinnable_val; in WriteRollbackKeys() local
651 get_impl_options.value = &pinnable_val; in WriteRollbackKeys()
657 s = rollback_batch->Put(cf_handle, key, pinnable_val); in WriteRollbackKeys()
Dtransaction_base.h74 PinnableSlice* pinnable_val, bool exclusive,
/rocksdb-6.9/db/db_impl/
Ddb_impl_readonly.cc32 PinnableSlice* pinnable_val) { in Get() argument
33 assert(pinnable_val != nullptr); in Get()
51 if (super_version->mem->Get(lkey, pinnable_val->GetSelf(), in Get()
54 pinnable_val->PinSelf(); in Get()
58 super_version->current->Get(read_options, lkey, pinnable_val, in Get()
64 size_t size = pinnable_val->size(); in Get()
Ddb_impl_secondary.cc319 const Slice& key, PinnableSlice* pinnable_val) { in GetImpl() argument
320 assert(pinnable_val != nullptr); in GetImpl()
343 if (super_version->mem->Get(lkey, pinnable_val->GetSelf(), in GetImpl()
347 pinnable_val->PinSelf(); in GetImpl()
351 lkey, pinnable_val->GetSelf(), /*timestamp=*/nullptr, &s, in GetImpl()
354 pinnable_val->PinSelf(); in GetImpl()
363 super_version->current->Get(read_options, lkey, pinnable_val, in GetImpl()
372 size_t size = pinnable_val->size(); in GetImpl()
Ddb_impl.cc1791 PinnableSlice pinnable_val; in MultiGet() local
1793 super_version->current->Get(read_options, lkey, &pinnable_val, timestamp, in MultiGet()
1796 value->assign(pinnable_val.data(), pinnable_val.size()); in MultiGet()
2506 PinnableSlice pinnable_val; in KeyMayExist() local
2509 get_impl_options.value = &pinnable_val; in KeyMayExist()
2513 value->assign(pinnable_val.data(), pinnable_val.size()); in KeyMayExist()
/rocksdb-6.9/db/
Dcompacted_db_impl.cc69 PinnableSlice pinnable_val; in MultiGet() local
72 GetContext::kNotFound, keys[idx], &pinnable_val, in MultiGet()
76 value.assign(pinnable_val.data(), pinnable_val.size()); in MultiGet()
Ddb_test2.cc3011 PinnableSlice pinnable_val; in TEST_F() local
3017 get_impl_options.value = &pinnable_val; in TEST_F()
3024 ASSERT_EQ(value + std::to_string(seq), pinnable_val.ToString()); in TEST_F()
/rocksdb-6.9/include/rocksdb/
Ddb.h402 PinnableSlice pinnable_val(value); in Get()
403 assert(!pinnable_val.IsPinned()); in Get()
404 auto s = Get(options, column_family, key, &pinnable_val); in Get()
405 if (s.ok() && pinnable_val.IsPinned()) { in Get()
406 value->assign(pinnable_val.data(), pinnable_val.size()); in Get()
424 PinnableSlice pinnable_val(value); in Get()
425 assert(!pinnable_val.IsPinned()); in Get()
426 auto s = Get(options, column_family, key, &pinnable_val, timestamp); in Get()
427 if (s.ok() && pinnable_val.IsPinned()) { in Get()
428 value->assign(pinnable_val.data(), pinnable_val.size()); in Get()
/rocksdb-6.9/docs/_posts/
D2017-08-24-pinnableslice.markdown29 PinnableSlice pinnable_val;
31 auto s = db->Get(opt, cf, key, &pinnable_val);
33 pinnable_val.Reset(); // then release it immediately
/rocksdb-6.9/table/
Dget_context.cc44 PinnableSlice* pinnable_val, std::string* timestamp, bool* value_found, in GetContext() argument
55 pinnable_val_(pinnable_val), in GetContext()
77 PinnableSlice* pinnable_val, bool* value_found, MergeContext* merge_context, in GetContext() argument
82 pinnable_val, nullptr, value_found, merge_context, do_merge, in GetContext()
/rocksdb-6.9/utilities/ttl/
Ddb_ttl_impl.cc188 Status DBWithTTLImpl::StripTS(PinnableSlice* pinnable_val) { in StripTS() argument
190 if (pinnable_val->size() < kTSLength) { in StripTS()
194 pinnable_val->remove_suffix(kTSLength); in StripTS()
/rocksdb-6.9/tools/
Ddb_bench_tool.cc4879 PinnableSlice pinnable_val; in ReadToRowCache() local
4892 &pinnable_val); in ReadToRowCache()
4894 pinnable_val.Reset(); in ReadToRowCache()
4897 &pinnable_val); in ReadToRowCache()
4902 bytes += key.size() + pinnable_val.size(); in ReadToRowCache()
5043 PinnableSlice pinnable_val; in ReadRandom() local
5070 &pinnable_val); in ReadRandom()
5072 pinnable_val.Reset(); in ReadRandom()
5075 &pinnable_val); in ReadRandom()
5442 PinnableSlice pinnable_val; in MixGraph() local
[all …]