Lines Matching refs:env_
118 : env_(raw_options.env), in DBImpl()
158 env_->UnlockFile(db_lock_); in ~DBImpl()
186 Status s = env_->NewWritableFile(manifest, &file); in NewDB()
202 s = SetCurrentFile(env_, dbname_, 1); in NewDB()
204 env_->DeleteFile(manifest); in NewDB()
230 env_->GetChildren(dbname_, &filenames); // Ignoring errors on purpose in DeleteObsoleteFiles()
268 env_->DeleteFile(dbname_ + "/" + filenames[i]); in DeleteObsoleteFiles()
280 env_->CreateDir(dbname_); in Recover()
282 Status s = env_->LockFile(LockFileName(dbname_), &db_lock_); in Recover()
287 if (!env_->FileExists(CurrentFileName(dbname_))) { in Recover()
320 s = env_->GetChildren(dbname_, &filenames); in Recover()
386 Status status = env_->NewSequentialFile(fname, &file); in RecoverLogFile()
394 reporter.env = env_; in RecoverLogFile()
460 if (env_->GetFileSize(fname, &lfile_size).ok() && in RecoverLogFile()
461 env_->NewAppendableFile(fname, &logfile_).ok()) { in RecoverLogFile()
491 const uint64_t start_micros = env_->NowMicros(); in WriteLevel0Table()
502 s = BuildTable(dbname_, env_, options_, table_cache_, iter, &meta); in WriteLevel0Table()
528 stats.micros = env_->NowMicros() - start_micros; in WriteLevel0Table()
659 env_->Schedule(&DBImpl::BGWork, this); in MaybeScheduleCompaction()
806 Status s = env_->NewWritableFile(fname, &compact->outfile); in OpenCompactionOutputFile()
888 const uint64_t start_micros = env_->NowMicros(); in DoCompactionWork()
919 const uint64_t imm_start = env_->NowMicros(); in DoCompactionWork()
926 imm_micros += (env_->NowMicros() - imm_start); in DoCompactionWork()
1023 stats.micros = env_->NowMicros() - start_micros - imm_micros; in DoCompactionWork()
1338 env_->SleepForMicroseconds(1000); in MakeRoomForWrite()
1359 s = env_->NewWritableFile(LogFileName(dbname_, new_log_number), &lfile); in MakeRoomForWrite()