Lines Matching refs:impl

1390   DBImpl* impl = new DBImpl(db_options, dbname, seq_per_batch, batch_per_txn);  in Open()  local
1391 s = impl->env_->CreateDirIfMissing(impl->immutable_db_options_.wal_dir); in Open()
1394 for (auto& db_path : impl->immutable_db_options_.db_paths) { in Open()
1403 s = impl->env_->CreateDirIfMissing(path); in Open()
1412 impl->error_handler_.EnableAutoRecovery(); in Open()
1416 s = impl->CreateArchivalDirectory(); 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()
1428 s = impl->Recover(column_families, false, false, false, &recovered_seq); in Open()
1430 uint64_t new_log_number = impl->versions_->NewFileNumber(); in Open()
1433 impl->GetWalPreallocateBlockSize(max_write_buffer_size); in Open()
1434 s = impl->CreateWAL(new_log_number, 0 /*recycle_log_number*/, in Open()
1437 InstrumentedMutexLock wl(&impl->log_write_mutex_); in Open()
1438 impl->logfile_number_ = new_log_number; in Open()
1440 impl->logs_.emplace_back(new_log_number, new_log); in Open()
1447 impl->versions_->GetColumnFamilySet()->GetColumnFamily(cf.name); in Open()
1450 new ColumnFamilyHandleImpl(cfd, impl, &impl->mutex_)); in Open()
1451 impl->NewThreadStatusCfInfo(cfd); in Open()
1456 impl->mutex_.Unlock(); in Open()
1457 s = impl->CreateColumnFamily(cf.options, cf.name, &handle); in Open()
1458 impl->mutex_.Lock(); in Open()
1473 for (auto cfd : *impl->versions_->GetColumnFamilySet()) { in Open()
1474 impl->InstallSuperVersionAndScheduleWork( in Open()
1478 if (impl->two_write_queues_) { in Open()
1479 impl->log_write_mutex_.Lock(); in Open()
1481 impl->alive_log_files_.push_back( in Open()
1482 DBImpl::LogFileNumberSize(impl->logfile_number_)); in Open()
1483 if (impl->two_write_queues_) { in Open()
1484 impl->log_write_mutex_.Unlock(); in Open()
1487 impl->DeleteObsoleteFiles(); in Open()
1488 s = impl->directories_.GetDbDir()->Fsync(IOOptions(), nullptr); in Open()
1505 log::Writer* log_writer = impl->logs_.back().writer; in Open()
1506 s = impl->WriteToWAL(empty_batch, log_writer, &log_used, &log_size); in Open()
1509 s = impl->FlushWAL(false); in Open()
1511 s = log_writer->file()->Sync(impl->immutable_db_options_.use_fsync); in Open()
1517 if (s.ok() && impl->immutable_db_options_.persist_stats_to_disk) { in Open()
1519 s = impl->PersistentStatsProcessFormatVersion(); in Open()
1523 for (auto cfd : *impl->versions_->GetColumnFamilySet()) { in Open()
1537 impl->is_snapshot_supported_ = false; in Open()
1556 persist_options_status = impl->WriteOptionsFile( in Open()
1559 *dbptr = impl; in Open()
1560 impl->opened_successfully_ = true; in Open()
1561 impl->MaybeScheduleFlushOrCompaction(); in Open()
1563 impl->mutex_.Unlock(); in Open()
1567 impl->immutable_db_options_.sst_file_manager.get()); in Open()
1579 impl->mutex_.Lock(); in Open()
1580 impl->versions_->GetLiveFilesMetaData(&metadata); in Open()
1581 impl->mutex_.Unlock(); in Open()
1593 paths.emplace_back(impl->immutable_db_options_.db_paths[0].path); in Open()
1604 impl->immutable_db_options_.env->GetChildren(path, &existing_files); in Open()
1629 impl->immutable_db_options_.db_paths[0].path); in Open()
1634 ROCKS_LOG_HEADER(impl->immutable_db_options_.info_log, "DB pointer %p", in Open()
1635 impl); in Open()
1636 LogFlush(impl->immutable_db_options_.info_log); in Open()
1637 assert(impl->TEST_WALBufferIsEmpty()); in Open()
1647 impl->StartTimedTasks(); in Open()
1654 delete impl; in Open()