Lines Matching refs:env_
88 Env* env_; member in ROCKSDB_NAMESPACE::EnvPosixTest
90 EnvPosixTest() : env_(Env::Default()), direct_io_(false) {} in EnvPosixTest()
99 env_ = param_pair.first; in EnvPosixTestWithParam()
105 while (env_->GetThreadPoolQueueLen(Env::Priority::LOW) != 0) { in WaitThreadPoolsEmpty()
108 while (env_->GetThreadPoolQueueLen(Env::Priority::HIGH) != 0) { in WaitThreadPoolsEmpty()
123 env_->SetBackgroundThreads(1, static_cast<Env::Priority>(pri)); in TEST_F()
124 env_->Schedule(&SetBool, &called, static_cast<Env::Priority>(pri)); in TEST_F()
132 env_->StartThread(&SetBool, &called); in TEST_F()
133 env_->WaitForJoin(); in TEST_F()
141 if (env_->AreFilesSame("", "", &tmp).IsNotSupported()) { in TEST_F()
171 if (env_ == Env::Default()) { in TEST_F()
174 test::PerThreadDBPath(env_, "testfile"), in TEST_F()
175 test::PerThreadDBPath(env_, "testfile1")}; in TEST_F()
177 ASSERT_OK(env_->NewWritableFile(fileNames[0], &wfile, soptions)); in TEST_F()
178 ASSERT_OK(env_->NewWritableFile(fileNames[1], &wfile, soptions)); in TEST_F()
181 ASSERT_OK(env_->NewRandomRWFile(fileNames[1], &rwfile, soptions)); in TEST_F()
188 env_->DeleteFile(filename); in TEST_F()
191 env_->SetAllowNonOwnerAccess(false); in TEST_F()
192 ASSERT_OK(env_->NewWritableFile(fileNames[0], &wfile, soptions)); in TEST_F()
193 ASSERT_OK(env_->NewWritableFile(fileNames[1], &wfile, soptions)); in TEST_F()
195 ASSERT_OK(env_->NewRandomRWFile(fileNames[1], &rwfile, soptions)); in TEST_F()
201 env_->DeleteFile(filename); in TEST_F()
210 std::string fname = test::PerThreadDBPath(env_, "testfile"); in TEST_F()
214 ASSERT_OK(env_->NewWritableFile(fname, &wfile, soptions)); in TEST_F()
222 Status status = env_->NewMemoryMappedFileBuffer(fname, &mmap_buffer); in TEST_F()
246 Status status = env_->LoadLibrary("no-such-library", "", &library); in TEST_F()
249 status = env_->LoadLibrary("rocksdb", "", &library); in TEST_F()
257 ASSERT_OK(env_->LoadLibrary(library->Name(), "", &library)); in TEST_F()
268 ASSERT_NOK(env_->LoadLibrary("no-such-library", "/tmp", &library)); in TEST_F()
270 ASSERT_NOK(env_->LoadLibrary("dl", "/tmp", &library)); in TEST_F()
272 Status status = env_->LoadLibrary("rocksdb", "/tmp:./", &library); in TEST_F()
275 ASSERT_OK(env_->LoadLibrary(library->Name(), "", &library)); in TEST_F()
280 status = env_->LoadLibrary("rocksdb", "/tmp:" + cwd, &library); in TEST_F()
283 ASSERT_OK(env_->LoadLibrary(library->Name(), "", &library)); in TEST_F()
290 env_->SetBackgroundThreads(1, Env::LOW); in TEST_P()
294 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task, in TEST_P()
298 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &sleeping_task1, in TEST_P()
302 ASSERT_EQ(0, env_->UnSchedule(&called, Env::Priority::LOW)); in TEST_P()
305 ASSERT_EQ(1, env_->UnSchedule(&sleeping_task1, Env::Priority::LOW)); in TEST_P()
311 env_->Schedule(&SetBool, &called); in TEST_P()
351 env_->Schedule(&CB::Run, &cb1); in TEST_P()
352 env_->Schedule(&CB::Run, &cb2); in TEST_P()
353 env_->Schedule(&CB::Run, &cb3); in TEST_P()
354 env_->Schedule(&CB::Run, &cb4); in TEST_P()
382 env_->StartThread(&ThreadBody, &state); in TEST_P()
471 env_->SetBackgroundThreads(kLowPoolSize); in TEST_P()
472 env_->SetBackgroundThreads(kHighPoolSize, Env::Priority::HIGH); in TEST_P()
474 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
475 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
479 env_->Schedule(&CB::Run, &low_pool_job); in TEST_P()
480 env_->Schedule(&CB::Run, &high_pool_job, Env::Priority::HIGH); in TEST_P()
485 env_->GetThreadPoolQueueLen(Env::Priority::LOW) || in TEST_P()
487 env_->GetThreadPoolQueueLen(Env::Priority::HIGH)) { in TEST_P()
488 env_->SleepForMicroseconds(kDelayMicros); in TEST_P()
495 env_->GetThreadPoolQueueLen()); in TEST_P()
497 env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
499 env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
511 env_->SleepForMicroseconds(kDelayMicros); in TEST_P()
514 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
515 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
522 env_->IncBackgroundThreadsIfNeeded(kLowPoolSize - 1, Env::Priority::LOW); in TEST_P()
523 env_->IncBackgroundThreadsIfNeeded(kHighPoolSize + 1, Env::Priority::HIGH); in TEST_P()
529 env_->Schedule(&CB::Run, &low_pool_job); in TEST_P()
530 env_->Schedule(&CB::Run, &high_pool_job, Env::Priority::HIGH); in TEST_P()
535 env_->GetThreadPoolQueueLen(Env::Priority::LOW) || in TEST_P()
537 env_->GetThreadPoolQueueLen(Env::Priority::HIGH)) { in TEST_P()
538 env_->SleepForMicroseconds(kDelayMicros); in TEST_P()
544 env_->GetThreadPoolQueueLen()); in TEST_P()
546 env_->GetThreadPoolQueueLen(Env::Priority::LOW)); in TEST_P()
548 env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
560 env_->SleepForMicroseconds(kDelayMicros); in TEST_P()
563 env_->SetBackgroundThreads(kHighPoolSize, Env::Priority::HIGH); in TEST_P()
573 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
577 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &tasks[i], in TEST_P()
581 ASSERT_EQ(2U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
587 env_->SetBackgroundThreads(2, Env::Priority::HIGH); in TEST_P()
589 ASSERT_EQ(1U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
595 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
597 ASSERT_EQ(1U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
605 ASSERT_EQ(1U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
611 env_->SetBackgroundThreads(5, Env::Priority::HIGH); in TEST_P()
613 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
620 env_->SetBackgroundThreads(7, Env::Priority::HIGH); in TEST_P()
623 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
624 env_->SetBackgroundThreads(3, Env::Priority::HIGH); in TEST_P()
626 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
627 env_->SetBackgroundThreads(4, Env::Priority::HIGH); in TEST_P()
629 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
630 env_->SetBackgroundThreads(5, Env::Priority::HIGH); in TEST_P()
632 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
633 env_->SetBackgroundThreads(4, Env::Priority::HIGH); in TEST_P()
635 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
642 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &tasks[i], in TEST_P()
648 ASSERT_EQ(2U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
666 ASSERT_EQ(0U, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
672 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
691 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &tasks[8], in TEST_P()
693 env_->Schedule(&test::SleepingBackgroundTask::DoSleepTask, &tasks[9], in TEST_P()
696 ASSERT_GT(env_->GetThreadPoolQueueLen(Env::Priority::HIGH), (unsigned int)0); in TEST_P()
700 env_->SetBackgroundThreads(4, Env::Priority::HIGH); in TEST_P()
702 ASSERT_EQ((unsigned int)0, env_->GetThreadPoolQueueLen(Env::Priority::HIGH)); in TEST_P()
707 env_->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_P()
865 ASSERT_OK(env_->NewWritableFile(ift.name() + "/f", &writable_file, options)); in TEST_F()
881 ASSERT_OK(env_->NewSequentialFile(ift.name() + "/f", &seq_file, options)); in TEST_F()
897 if (env_ == Env::Default()) { in TEST_P()
903 ASSERT_OK(env_->NewWritableFile(fname, &wfile, soptions)); in TEST_P()
908 ASSERT_OK(env_->NewRandomAccessFile(fname, &file, soptions)); in TEST_P()
915 ASSERT_OK(env_->NewRandomAccessFile(fname, &file, soptions)); in TEST_P()
922 env_->SleepForMicroseconds(1000000); in TEST_P()
923 ASSERT_OK(env_->NewRandomAccessFile(fname, &file, soptions)); in TEST_P()
934 env_->DeleteFile(fname); in TEST_P()
942 if (env_ == Env::Default()) { in TEST_P()
964 ASSERT_OK(env_->DeleteFile(fname_test_fallocate)); in TEST_P()
974 ASSERT_OK(env_->NewWritableFile(fname, &wfile, soptions)); in TEST_P()
1031 if (env_ == Env::Default()) { in TEST_P()
1044 ASSERT_OK(env_->NewWritableFile(fnames[i], &wfile, soptions)); in TEST_P()
1052 ASSERT_OK(env_->NewRandomAccessFile(fname, &file, soptions)); in TEST_P()
1064 ASSERT_OK(env_->DeleteFile(fname)); in TEST_P()
1072 if (env_ == Env::Default()) { in TEST_P()
1086 ASSERT_OK(env_->NewWritableFile(fname, &wfile, soptions)); in TEST_P()
1093 ASSERT_OK(env_->NewRandomAccessFile(fname, &file, soptions)); in TEST_P()
1104 ASSERT_OK(env_->DeleteFile(fname)); in TEST_P()
1115 std::string fname = test::PerThreadDBPath(env_, "testfile"); in TEST_P()
1129 ASSERT_OK(env_->NewWritableFile(fname, &wfile, soptions)); in TEST_P()
1174 ASSERT_OK(env_->NewRandomAccessFile(fname, &file, soptions)); in TEST_P()
1190 std::string fname = test::PerThreadDBPath(env_, "testfile"); in TEST_F()
1200 ASSERT_OK(env_->NewWritableFile(fname, &wfile, soptions)); in TEST_F()
1264 ASSERT_OK(env_->NewRandomAccessFile(fname, &file, soptions)); in TEST_F()
1287 std::string fname = test::PerThreadDBPath(env_, "testfile"); in TEST_P()
1301 ASSERT_OK(env_->NewWritableFile(fname, &wfile, soptions)); in TEST_P()
1317 ASSERT_OK(env_->NewRandomAccessFile(fname, &file, soptions)); in TEST_P()
1334 ASSERT_OK(env_->NewSequentialFile(fname, &file, soptions)); in TEST_P()
1345 ASSERT_OK(env_->DeleteFile(fname)); in TEST_P()
1470 const std::string src = test::PerThreadDBPath(env_, "testfile"); in TEST_P()
1483 ASSERT_OK(env_->NewWritableFile(src, &srcfile, soptions)); in TEST_P()
1533 test::TmpDir(env_) + "/" + "testfile_" + std::to_string(i); in TEST_P()
1544 ASSERT_OK(env_->NewWritableFile(path, &file, soptions)); in TEST_P()
1552 ASSERT_OK(env_->GetChildrenFileAttributes(test::TmpDir(env_), &file_attrs)); in TEST_P()
1555 const std::string path = test::TmpDir(env_) + "/" + name; in TEST_P()
1562 ASSERT_OK(env_->GetFileSize(path, &size)); in TEST_P()
1726 const std::string path = test::PerThreadDBPath(env_, "random_rw_file"); in TEST_P()
1728 env_->DeleteFile(path); in TEST_P()
1733 ASSERT_NOK(env_->NewRandomRWFile(path, &file, EnvOptions())); in TEST_P()
1738 ASSERT_OK(env_->NewWritableFile(path, &wf, EnvOptions())); in TEST_P()
1741 ASSERT_OK(env_->NewRandomRWFile(path, &file, EnvOptions())); in TEST_P()
1779 ASSERT_OK(env_->NewRandomRWFile(path, &file, EnvOptions())); in TEST_P()
1795 env_->DeleteFile(path); in TEST_P()
1854 const std::string path = test::PerThreadDBPath(env_, "random_rw_file_rand"); in TEST_P()
1855 env_->DeleteFile(path); in TEST_P()
1861 ASSERT_NOK(env_->NewRandomRWFile(path, &file, EnvOptions())); in TEST_P()
1867 ASSERT_OK(env_->NewWritableFile(path, &wf, EnvOptions())); in TEST_P()
1870 ASSERT_OK(env_->NewRandomRWFile(path, &file, EnvOptions())); in TEST_P()
1890 ASSERT_OK(env_->NewRandomRWFile(path, &file, EnvOptions())); in TEST_P()
1896 env_->DeleteFile(path); in TEST_P()
1994 env_ = env_non_null ? (env_default ? Env::Default() : nullptr) : nullptr; in TEST_P()
2008 env_ = composite_env_ptr_.get(); in TEST_P()
2010 env_ = env_ptr_.get(); in TEST_P()
2019 Env* env_; in TEST_P() member in ROCKSDB_NAMESPACE::EnvFSTestWithParam
2029 opts.env = env_; in TEST_P()
2033 if (env_) { in TEST_P()
2035 ASSERT_EQ(fs_.get(), env_->GetFileSystem().get()); in TEST_P()
2037 ASSERT_NE(FileSystem::Default().get(), env_->GetFileSystem().get()); in TEST_P()