Searched refs:Pluck (Results 1 – 7 of 7) sorted by relevance
192 cq_.Pluck(&ops); /// status ignored in WaitForInitialMetadata()214 return cq_.Pluck(&ops) && ops.got_message; in Read()227 GPR_CODEGEN_ASSERT(cq_.Pluck(&ops)); in Finish()259 cq_.Pluck(&ops);309 cq_.Pluck(&ops); // status ignored in WaitForInitialMetadata()339 return cq_.Pluck(&ops); in Write()346 return cq_.Pluck(&ops); in WritesDone()362 GPR_CODEGEN_ASSERT(cq_.Pluck(&finish_ops_)); in Finish()392 cq_.Pluck(&ops);460 cq_.Pluck(&ops); // status ignored in WaitForInitialMetadata()[all …]
86 param.call->cq()->Pluck(&ops); in RunHandler()131 param.call->cq()->Pluck(&ops); in RunHandler()175 param.call->cq()->Pluck(¶m.server_context->pending_ops_); in RunHandler()177 param.call->cq()->Pluck(&ops); in RunHandler()224 param.call->cq()->Pluck(¶m.server_context->pending_ops_); in RunHandler()226 param.call->cq()->Pluck(&ops); in RunHandler()298 param.call->cq()->Pluck(&ops); in RunHandler()
72 if (cq.Pluck(&ops)) { in BlockingUnaryCallImpl()
299 bool Pluck(internal::CompletionQueueTag* tag) { in Pluck() function
62 public CompletionQueueEvent Pluck(IntPtr tag) in Pluck() method in Grpc.Core.Internal.CompletionQueueSafeHandle
108 var ev = cq.Pluck(ctx.Handle); in UnaryCall()
249 GPR_ASSERT(cq_.Pluck(&ignored_tag) == false); in Run()