61       : env_(env), cond_count_(&mu_), count_(0) {}  in env_()  function
77     uint64_t start = env_->NowMicros();  in WaitFor()
79       uint64_t now = env_->NowMicros();  in WaitFor()
81       if (env_->NowMicros() - start > /*10s*/ 10 * 1000 * 1000) {  in WaitFor()
99   Env* env_;
216       SpecialEnv* env_;  in NewWritableFile()
221           : env_(env), base_(std::move(base)) {}  in NewWritableFile()
223         if (env_->table_write_callback_) {  in NewWritableFile()
224           (*env_->table_write_callback_)();  in NewWritableFile()
226         if (env_->drop_writes_.load(std::memory_order_acquire)) {  in NewWritableFile()
229         } else if (env_->no_space_.load(std::memory_order_acquire)) {  in NewWritableFile()
232           env_->bytes_written_ += data.size();  in NewWritableFile()
237         if (env_->table_write_callback_) {  in NewWritableFile()
238           (*env_->table_write_callback_)();  in NewWritableFile()
240         if (env_->drop_writes_.load(std::memory_order_acquire)) {  in NewWritableFile()
243         } else if (env_->no_space_.load(std::memory_order_acquire)) {  in NewWritableFile()
246           env_->bytes_written_ += data.size();  in NewWritableFile()
275         ++env_->sync_counter_;  in NewWritableFile()
276         while (env_->delay_sstable_sync_.load(std::memory_order_acquire)) {  in NewWritableFile()
277           env_->SleepForMicroseconds(100000);  in NewWritableFile()
301           : env_(env), base_(std::move(b)) {}  in NewWritableFile()
303         if (env_->manifest_write_error_.load(std::memory_order_acquire)) {  in NewWritableFile()
313         ++env_->sync_counter_;  in NewWritableFile()
314         if (env_->manifest_sync_error_.load(std::memory_order_acquire)) {  in NewWritableFile()
326       SpecialEnv* env_;  in NewWritableFile()
332           : env_(env), base_(std::move(b)) {  in NewWritableFile()
333         env_->num_open_wal_file_.fetch_add(1);  in NewWritableFile()
335       virtual ~WalFile() { env_->num_open_wal_file_.fetch_add(-1); }  in NewWritableFile()
341         if (env_->log_write_error_.load(std::memory_order_acquire)) {  in NewWritableFile()
345               env_->log_write_slowdown_.load(std::memory_order_acquire);  in NewWritableFile()
347             env_->SleepForMicroseconds(slowdown);  in NewWritableFile()
371         ++env_->sync_counter_;  in NewWritableFile()
375         return env_->is_wal_sync_thread_safe_.load();  in NewWritableFile()
382       SpecialEnv* env_;  in NewWritableFile()
704   SpecialEnv* env_;  variable