Lines Matching refs:env

61   void WaitUntilScheduled(int job_count, Env* env) {  in WaitUntilScheduled()  argument
63 env->SleepForMicroseconds(1000); in WaitUntilScheduled()
122 Env* env = Env::Default(); in TEST_F() local
127 env->SetBackgroundThreads(kHighPriorityThreads, Env::HIGH); in TEST_F()
128 env->SetBackgroundThreads(kLowPriorityThreads, Env::LOW); in TEST_F()
135 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
139 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
143 kSimulatedHighPriThreads + kSimulatedLowPriThreads, env); in TEST_F()
148 env->GetThreadList(&thread_list); in TEST_F()
169 env->GetThreadList(&thread_list); in TEST_F()
215 Env* env = Env::Default(); in TEST_F() local
249 env->SetBackgroundThreads( in TEST_F()
251 env->SetBackgroundThreads( in TEST_F()
256 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
259 flush_write_task.WaitUntilScheduled(kFlushWriteTasks, env); in TEST_F()
262 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
265 compaction_write_task.WaitUntilScheduled(kCompactionWriteTasks, env); in TEST_F()
268 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
271 compaction_read_task.WaitUntilScheduled(kCompactionReadTasks, env); in TEST_F()
274 env->Schedule(&SimulatedBackgroundTask::DoSimulatedTask, in TEST_F()
277 compaction_wait_task.WaitUntilScheduled(kCompactionWaitTasks, env); in TEST_F()
284 env->GetThreadList(&thread_list); in TEST_F()
296 env->GetThreadList(&thread_list); in TEST_F()
308 env->GetThreadList(&thread_list); in TEST_F()
320 env->GetThreadList(&thread_list); in TEST_F()
332 env->GetThreadList(&thread_list); in TEST_F()