| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| _service.py | 45 def _unary_response(argument, implementation, rpc, servicer_context):
47 response = implementation(argument, servicer_context)
54 def _stream_response(argument, implementation, rpc, servicer_context):
56 response_iterator = implementation(argument, servicer_context)
73 def unary_unary(implementation, rpc, request, servicer_context):
74 _unary_response(request, implementation, rpc, servicer_context)
77 def unary_stream(implementation, rpc, request, servicer_context):
78 _stream_response(request, implementation, rpc, servicer_context)
81 def stream_unary(implementation, rpc, handler, servicer_context):
83 _RequestIterator(rpc, handler), implementation, rpc, servicer_context)
[all...] |
| _server.py | 33 def service(implementation, rpc, servicer_context):
34 _service.unary_unary(implementation, rpc, request, servicer_context)
41 def service(implementation, rpc, servicer_context):
42 _service.unary_stream(implementation, rpc, request, servicer_context)
49 def service(implementation, rpc, servicer_context):
50 _service.stream_unary(implementation, rpc, handler, servicer_context)
57 def service(implementation, rpc, servicer_context):
58 _service.stream_stream(implementation, rpc, handler, servicer_context)
75 servicer_context = _servicer_context.ServicerContext(
82 servicer_context,
[all...] |
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| _metadata_test.py | 90 def validate_client_metadata(test, servicer_context):
91 invocation_metadata = servicer_context.invocation_metadata()
101 def handle_unary_unary(test, request, servicer_context):
102 validate_client_metadata(test, servicer_context)
103 servicer_context.send_initial_metadata(_INITIAL_METADATA)
104 servicer_context.set_trailing_metadata(_TRAILING_METADATA)
108 def handle_unary_stream(test, request, servicer_context):
109 validate_client_metadata(test, servicer_context)
110 servicer_context.send_initial_metadata(_INITIAL_METADATA)
111 servicer_context.set_trailing_metadata(_TRAILING_METADATA
[all...] |
| _invocation_defects_test.py | 62 def handle_unary_unary(self, request, servicer_context):
64 if servicer_context is not None:
65 servicer_context.set_trailing_metadata(((
71 def handle_unary_stream(self, request, servicer_context):
76 if servicer_context is not None:
77 servicer_context.set_trailing_metadata(((
82 def handle_stream_unary(self, request_iterator, servicer_context):
83 if servicer_context is not None:
84 servicer_context.invocation_metadata()
91 if servicer_context is not None
[all...] |
| _compression_test.py | 28 def handle_unary(request, servicer_context):
29 servicer_context.send_initial_metadata([('grpc-internal-encoding-request',
34 def handle_stream(request_iterator, servicer_context):
37 servicer_context.send_initial_metadata([('grpc-internal-encoding-request',
|
| _session_cache_test.py | 46 def handle_unary_unary(request, servicer_context):
48 _ID: servicer_context.peer_identities(),
49 _ID_KEY: servicer_context.peer_identity_key(),
50 _AUTH_CTX: servicer_context.auth_context()
|
| _exit_scenarios.py | 59 def hang_unary_unary(request, servicer_context):
63 def hang_unary_stream(request, servicer_context):
67 def hang_partial_unary_stream(request, servicer_context):
73 def hang_stream_unary(request_iterator, servicer_context):
77 def hang_partial_stream_unary(request_iterator, servicer_context):
83 def hang_stream_stream(request_iterator, servicer_context):
87 def hang_partial_stream_stream(request_iterator, servicer_context):
|
| _empty_message_test.py | 31 def handle_unary_unary(request, servicer_context):
35 def handle_unary_stream(request, servicer_context):
40 def handle_stream_unary(request_iterator, servicer_context):
46 def handle_stream_stream(request_iterator, servicer_context):
|
| _interceptor_test.py | 65 def handle_unary_unary(self, request, servicer_context):
67 if servicer_context is not None:
68 servicer_context.set_trailing_metadata(((
74 def handle_unary_stream(self, request, servicer_context):
79 if servicer_context is not None:
80 servicer_context.set_trailing_metadata(((
85 def handle_stream_unary(self, request_iterator, servicer_context):
86 if servicer_context is not None:
87 servicer_context.invocation_metadata()
94 if servicer_context is not None
[all...] |
| _auth_context_test.py | 53 def handle_unary_unary(request, servicer_context):
55 _ID: servicer_context.peer_identities(),
56 _ID_KEY: servicer_context.peer_identity_key(),
57 _AUTH_CTX: servicer_context.auth_context()
|
| _resource_exhausted_test.py | 67 def handle_unary_unary(trigger, request, servicer_context):
72 def handle_unary_stream(trigger, request, servicer_context):
78 def handle_stream_unary(trigger, request_iterator, servicer_context):
86 def handle_stream_stream(trigger, request_iterator, servicer_context):
|
| _rpc_test.py | 64 def handle_unary_unary(self, request, servicer_context):
66 if servicer_context is not None:
67 servicer_context.set_trailing_metadata(((
74 servicer_context.is_active()
75 servicer_context.time_remaining()
78 def handle_unary_stream(self, request, servicer_context):
83 if servicer_context is not None:
84 servicer_context.set_trailing_metadata(((
89 def handle_stream_unary(self, request_iterator, servicer_context):
90 if servicer_context is not None
[all...] |
| _channel_close_test.py | 37 def stream_stream(self, request_iterator, servicer_context):
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| _server_adaptations.py | 37 def __init__(self, servicer_context):
38 self._servicer_context = servicer_context
49 def __init__(self, servicer_context):
50 self._servicer_context = servicer_context
88 def adaptation(request, servicer_context):
90 _FaceServicerContext(servicer_context))
97 def adaptation(request_iterator, servicer_context):
99 _FaceServicerContext(servicer_context))
159 servicer_context):
164 if not servicer_context.is_active() or thread_joined.is_set()
[all...] |
| /external/grpc-grpc/src/python/grpcio_tests/tests/interop/ |
| methods.py | 36 def _maybe_echo_metadata(servicer_context):
38 invocation_metadata = dict(servicer_context.invocation_metadata())
42 servicer_context.send_initial_metadata((initial_metadatum,))
46 servicer_context.set_trailing_metadata((trailing_metadatum,))
49 def _maybe_echo_status_and_message(request, servicer_context):
52 servicer_context.set_code(request.response_status.code)
53 servicer_context.set_details(request.response_status.message)
|
