Searched refs:rpc_event (Results 1 – 2 of 2) sorted by relevance
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _server.py | 216 def __init__(self, rpc_event, state, request_deserializer): argument
217 self._rpc_event = rpc_event
355 def _unary_request(rpc_event, state, request_deserializer): argument
362 rpc_event.call.start_server_batch(
364 _receive_message(state, rpc_event.call,
372 rpc_event.call_details.method)
373 _abort(state, rpc_event.call,
387 def _call_behavior(rpc_event, state, behavior, argument, request_deserializer): argument
388 context = _Context(rpc_event, state, request_deserializer)
394 _abort(state, rpc_event.call, cygrpc.StatusCode.unknown,
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _cancel_many_calls_test.py | 54 def __init__(self, state, completion_queue, rpc_event): argument
58 self._call = rpc_event.call
99 rpc_event = server_completion_queue.poll()
100 thread_pool.submit(_Handler(state, call_completion_queue, rpc_event))
|