Home
last modified time | relevance | path

Searched refs:execute_batch (Results 1 – 4 of 4) sorted by relevance

/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/
Dcallback_common.pyx.pxi77 async def execute_batch(GrpcCallWrapper grpc_call_wrapper, function
88 CallbackFailureHandler('execute_batch', operations, ExecuteBatchError))
125 await execute_batch(grpc_call_wrapper, ops, loop)
147 await execute_batch(grpc_call_wrapper, ops, loop)
158 await execute_batch(grpc_call_wrapper, ops, loop)
165 await execute_batch(grpc_call_wrapper, ops, loop)
184 await execute_batch(grpc_call_wrapper, ops, loop)
Dcall.pyx.pxi313 await execute_batch(self,
338 await execute_batch(self, ops, self._loop)
380 await execute_batch(self, ops, self._loop)
408 await execute_batch(self,
457 await execute_batch(self,
Dserver.pyx.pxi416 await execute_batch(rpc_state, finish_ops, loop)
484 await execute_batch(rpc_state, finish_ops, loop)
699 await execute_batch(rpc_state, ops, loop)
/third_party/grpc/src/core/lib/surface/
Dcall.cc287 static void execute_batch(grpc_call* call,
645 static void execute_batch(grpc_call* call, in execute_batch() function
721 execute_batch(c, op, &state->start_batch); in cancel_with_error()
1936 execute_batch(call, stream_op, &bctl->start_batch); in call_start_batch()