241 static void TrickleCQNext(TrickledCHTTP2* fixture, void** t, bool* ok,  in TrickleCQNext()  argument
244     fixture->Log(iteration);  in TrickleCQNext()
246         fixture->cq()->AsyncNext(t, ok, gpr_inf_past(GPR_CLOCK_MONOTONIC))) {  in TrickleCQNext()
248         fixture->Step(iteration != -1);  in TrickleCQNext()
261   std::unique_ptr<TrickledCHTTP2> fixture(new TrickledCHTTP2(  in BM_PumpStreamServerToClient_Trickle()  local
274     service.RequestBidiStream(&svr_ctx, &response_rw, fixture->cq(),  in BM_PumpStreamServerToClient_Trickle()
275                               fixture->cq(), tag(0));  in BM_PumpStreamServerToClient_Trickle()
277         EchoTestService::NewStub(fixture->channel()));  in BM_PumpStreamServerToClient_Trickle()
279     auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1));  in BM_PumpStreamServerToClient_Trickle()
284       TrickleCQNext(fixture.get(), &t, &ok, -1);  in BM_PumpStreamServerToClient_Trickle()
295         TrickleCQNext(fixture.get(), &t, &ok,  in BM_PumpStreamServerToClient_Trickle()
326       TrickleCQNext(fixture.get(), &t, &ok, -1);  in BM_PumpStreamServerToClient_Trickle()
336   fixture->Finish(state);  in BM_PumpStreamServerToClient_Trickle()
337   fixture.reset();  in BM_PumpStreamServerToClient_Trickle()
355   std::unique_ptr<TrickledCHTTP2> fixture(new TrickledCHTTP2(  in BM_PumpUnbalancedUnary_Trickle()  local
382                       &server_env[0]->response_writer, fixture->cq(),  in BM_PumpUnbalancedUnary_Trickle()
383                       fixture->cq(), tag(0));  in BM_PumpUnbalancedUnary_Trickle()
385                       &server_env[1]->response_writer, fixture->cq(),  in BM_PumpUnbalancedUnary_Trickle()
386                       fixture->cq(), tag(1));  in BM_PumpUnbalancedUnary_Trickle()
388       EchoTestService::NewStub(fixture->channel()));  in BM_PumpUnbalancedUnary_Trickle()
394         stub->AsyncEcho(&cli_ctx, send_request, fixture->cq()));  in BM_PumpUnbalancedUnary_Trickle()
398     TrickleCQNext(fixture.get(), &t, &ok, in_warmup ? -1 : state.iterations());  in BM_PumpUnbalancedUnary_Trickle()
405       TrickleCQNext(fixture.get(), &t, &ok,  in BM_PumpUnbalancedUnary_Trickle()
417                         fixture->cq(), fixture->cq(), tag(slot));  in BM_PumpUnbalancedUnary_Trickle()
434   fixture->Finish(state);  in BM_PumpUnbalancedUnary_Trickle()
435   fixture.reset();  in BM_PumpUnbalancedUnary_Trickle()