77     auto* arg = static_cast<Arg*>(p);  in TEST_F()  local
83       for (int i = 0; i < static_cast<int>(r.Skewed(arg->burst) + 1); ++i) {  in TEST_F()
84         arg->limiter->Request(r.Uniform(arg->request_size - 1) + 1,  in TEST_F()
88       arg->limiter->Request(r.Uniform(arg->request_size - 1) + 1, Env::IO_LOW,  in TEST_F()
95     Arg arg(target, i / 4 + 1);  in TEST_F()  local
101         arg.limiter->SetBytesPerSecond(target);  in TEST_F()
105         env->StartThread(writer, &arg);  in TEST_F()
111           (arg.limiter->GetTotalBytesThrough() - old_total_bytes_through) *  in TEST_F()
113       old_total_bytes_through = arg.limiter->GetTotalBytesThrough();  in TEST_F()
117               arg.request_size - 1, target / 1024, rate / 1024,  in TEST_F()
142     auto* arg = static_cast<Arg*>(p);  in TEST_F()  local
143     arg->limiter->Request(arg->request_size, arg->pri, nullptr /* stats */,  in TEST_F()
160       Arg arg(target, Env::IO_HIGH, limiter);  in TEST_F()  local
165       env->StartThread(writer, &arg);  in TEST_F()
168       arg.limiter->SetBytesPerSecond(new_limit);  in TEST_F()