Home
last modified time | relevance | path

Searched refs:impl (Results 1 – 10 of 10) sorted by relevance

/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc1391 s = impl->env_->CreateDirIfMissing(impl->immutable_db_options_.wal_dir); in Open()
1419 delete impl; in Open()
1423 impl->wal_in_db_path_ = IsWalDirSameAsDBPath(&impl->immutable_db_options_); in Open()
1425 impl->mutex_.Lock(); in Open()
1450 new ColumnFamilyHandleImpl(cfd, impl, &impl->mutex_)); in Open()
1559 *dbptr = impl; in Open()
1563 impl->mutex_.Unlock(); in Open()
1579 impl->mutex_.Lock(); in Open()
1581 impl->mutex_.Unlock(); in Open()
1635 impl); in Open()
[all …]
Ddb_impl_readonly.cc166 DBImplReadOnly* impl = new DBImplReadOnly(db_options, dbname); in OpenForReadOnly() local
167 impl->mutex_.Lock(); in OpenForReadOnly()
168 Status s = impl->Recover(column_families, true /* read only */, in OpenForReadOnly()
174 impl->versions_->GetColumnFamilySet()->GetColumnFamily(cf.name); in OpenForReadOnly()
179 handles->push_back(new ColumnFamilyHandleImpl(cfd, impl, &impl->mutex_)); in OpenForReadOnly()
183 for (auto cfd : *impl->versions_->GetColumnFamilySet()) { in OpenForReadOnly()
185 cfd->InstallSuperVersion(&sv_context, &impl->mutex_); in OpenForReadOnly()
188 impl->mutex_.Unlock(); in OpenForReadOnly()
191 *dbptr = impl; in OpenForReadOnly()
193 impl->NewThreadStatusCfInfo( in OpenForReadOnly()
[all …]
Ddb_impl_secondary.cc611 dbname, &impl->immutable_db_options_, impl->file_options_, in OpenAsSecondary()
612 impl->table_cache_.get(), impl->write_buffer_manager_, in OpenAsSecondary()
613 &impl->write_controller_)); in OpenAsSecondary()
614 impl->column_family_memtables_.reset( in OpenAsSecondary()
616 impl->wal_in_db_path_ = IsWalDirSameAsDBPath(&impl->immutable_db_options_); in OpenAsSecondary()
618 impl->mutex_.Lock(); in OpenAsSecondary()
628 handles->push_back(new ColumnFamilyHandleImpl(cfd, impl, &impl->mutex_)); in OpenAsSecondary()
638 impl->mutex_.Unlock(); in OpenAsSecondary()
641 *dbptr = impl; in OpenAsSecondary()
643 impl->NewThreadStatusCfInfo( in OpenAsSecondary()
[all …]
/rocksdb-6.9/utilities/persistent_cache/
Dhash_table_bench.cc58 explicit HashTableBenchmark(HashTableImpl<size_t, std::string>* impl, in HashTableBenchmark() argument
63 : impl_(impl), in HashTableBenchmark()
287 ROCKSDB_NAMESPACE::SimpleImpl impl; in main() local
289 &impl, FLAGS_nsec, FLAGS_nthread_write, FLAGS_nthread_read, in main()
297 ROCKSDB_NAMESPACE::GranularLockImpl impl; in main() local
299 &impl, FLAGS_nsec, FLAGS_nthread_write, FLAGS_nthread_read, in main()
/rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/
Dgtest-all.cc4128 impl->set_current_test_info(this); in Run()
4164 impl->set_current_test_info(NULL); in Run()
4256 impl->set_current_test_case(this); in Run()
4276 impl->set_current_test_case(NULL); in Run()
6009 return impl()->disabled_test_count(); in disabled_test_count()
6026 return impl()->start_timestamp(); in start_timestamp()
6031 return impl()->elapsed_time(); in elapsed_time()
6044 return impl()->GetTestCase(i); in GetTestCase()
6050 return *impl()->ad_hoc_test_result(); in ad_hoc_test_result()
6062 return *impl()->listeners(); in listeners()
[all …]
Dgtest.h11563 explicit ParamIterator(ParamIteratorInterface<T>* impl) : impl_(impl) {}
11591 explicit ParamGenerator(ParamGeneratorInterface<T>* impl) : impl_(impl) {}
21103 internal::UnitTestImpl* impl() { return impl_; }
21104 const internal::UnitTestImpl* impl() const { return impl_; }
/rocksdb-6.9/db/
Dversion_set_test.cc684 std::unique_ptr<DBImpl> impl(new DBImpl(DBOptions(), dbname_)); in PrepareManifest() local
686 impl->GetDbIdentityFromIdentityFile(&db_id); in PrepareManifest()
1413 std::unique_ptr<DBImpl> impl(new DBImpl(DBOptions(), dbname_)); in PrepareManifest() local
1415 impl->GetDbIdentityFromIdentityFile(&db_id); in PrepareManifest()
1738 std::unique_ptr<DBImpl> impl(new DBImpl(DBOptions(), dbname_)); in PrepareManifest() local
1740 impl->GetDbIdentityFromIdentityFile(&db_id); in PrepareManifest()
Dflush_job_test.cc67 DBImpl* impl = new DBImpl(DBOptions(), dbname_); in NewDB() local
69 impl->GetDbIdentityFromIdentityFile(&db_id); in NewDB()
/rocksdb-6.9/db/compaction/
Dcompaction_job_test.cc260 DBImpl* impl = new DBImpl(DBOptions(), dbname_); in NewDB() local
262 impl->GetDbIdentityFromIdentityFile(&db_id); in NewDB()
/rocksdb-6.9/util/
Dfilter_bench.cc80 DEFINE_uint32(impl, 0,