Lines Matching refs:env_

94       SpecialEnv* env_;  in NewWritableFile()  member in leveldb::SpecialEnv::NewWritableFile::DataFile
99 : env_(env), in NewWritableFile()
104 if (env_->no_space_.Acquire_Load() != NULL) { in NewWritableFile()
114 if (env_->data_sync_error_.Acquire_Load() != NULL) { in NewWritableFile()
117 while (env_->delay_data_sync_.Acquire_Load() != NULL) { in NewWritableFile()
125 SpecialEnv* env_; in NewWritableFile() member in leveldb::SpecialEnv::NewWritableFile::ManifestFile
128 ManifestFile(SpecialEnv* env, WritableFile* b) : env_(env), base_(b) { } in NewWritableFile()
131 if (env_->manifest_write_error_.Acquire_Load() != NULL) { in NewWritableFile()
140 if (env_->manifest_sync_error_.Acquire_Load() != NULL) { in NewWritableFile()
205 SpecialEnv* env_; member in leveldb::DBTest
211 env_(new SpecialEnv(Env::Default())) { in DBTest()
222 delete env_; in ~DBTest()
418 env_->GetChildren(dbname_, &files); in CountFiles()
480 ASSERT_OK(env_->GetChildren(dbname_, &filenames)); in DeleteAnSSTFile()
485 ASSERT_OK(env_->DeleteFile(TableFileName(dbname_, number))); in DeleteAnSSTFile()
495 ASSERT_OK(env_->GetChildren(dbname_, &filenames)); in RenameLDBToSST()
503 ASSERT_OK(env_->RenameFile(from, to)); in RenameLDBToSST()
543 options.env = env_; in TEST()
550 env_->delay_data_sync_.Release_Store(env_); // Block sync calls in TEST()
554 env_->delay_data_sync_.Release_Store(NULL); // Release sync calls in TEST()
906 options.env = env_; in TEST()
1007 options.env = env_; in TEST()
1557 options.env = env_; in TEST()
1564 env_->no_space_.Release_Store(env_); // Force out-of-space errors in TEST()
1570 env_->no_space_.Release_Store(NULL); in TEST()
1577 options.env = env_; in TEST()
1580 env_->non_writable_.Release_Store(env_); // Force errors for new files in TEST()
1591 env_->non_writable_.Release_Store(NULL); in TEST()
1599 options.env = env_; in TEST()
1601 env_->data_sync_error_.Release_Store(env_); in TEST()
1615 env_->data_sync_error_.Release_Store(NULL); in TEST()
1636 ? &env_->manifest_sync_error_ in TEST()
1637 : &env_->manifest_write_error_; in TEST()
1641 options.env = env_; in TEST()
1655 error_type->Release_Store(env_); in TEST()
1712 env_->count_random_reads_ = true; in TEST()
1714 options.env = env_; in TEST()
1731 env_->delay_data_sync_.Release_Store(env_); in TEST()
1734 env_->random_read_counter_.Reset(); in TEST()
1738 int reads = env_->random_read_counter_.Read(); in TEST()
1744 env_->random_read_counter_.Reset(); in TEST()
1748 reads = env_->random_read_counter_.Read(); in TEST()
1752 env_->delay_data_sync_.Release_Store(NULL); in TEST()
1840 env_->StartThread(MTThreadBody, &thread[id]); in TEST()