Home
last modified time | relevance | path

Searched refs:initial_metadata (Results 1 – 25 of 41) sorted by relevance

12

/external/grpc-grpc/src/python/grpcio_tests/tests/testing/
D_server_test.py44 initial_metadata = rpc.initial_metadata()
54 initial_metadata = rpc.initial_metadata()
66 initial_metadata = rpc.initial_metadata()
76 initial_metadata = rpc.initial_metadata()
101 first_initial_metadata = rpc.initial_metadata()
102 second_initial_metadata = rpc.initial_metadata()
103 third_initial_metadata = rpc.initial_metadata()
132 initial_metadata = rpc.initial_metadata()
144 initial_metadata = rpc.initial_metadata()
159 initial_metadata = rpc.initial_metadata()
D_client_application.py195 initial_metadata = response_future_call.initial_metadata()
197 if initial_metadata is not None and cancelled:
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/
D_server_rpc.py23 def initial_metadata(self): member in UnaryUnaryServerRpc
24 return self._handler.initial_metadata()
38 def initial_metadata(self): member in UnaryStreamServerRpc
39 return self._handler.initial_metadata()
56 def initial_metadata(self): member in StreamUnaryServerRpc
57 return self._handler.initial_metadata()
77 def initial_metadata(self): member in StreamStreamServerRpc
78 return self._handler.initial_metadata()
D_handler.py27 def initial_metadata(self): member in Handler
70 def send_initial_metadata(self, initial_metadata): argument
72 self._initial_metadata = initial_metadata
116 def initial_metadata(self): member in _Handler
D_servicer_context.py59 def send_initial_metadata(self, initial_metadata): argument
61 _common.fuss_with_metadata(initial_metadata))
D_rpc.py120 def send_initial_metadata(self, initial_metadata): argument
125 self._handler.send_initial_metadata(initial_metadata)
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/
D_channel_rpc.py23 def send_initial_metadata(self, initial_metadata): argument
24 self._rpc_state.send_initial_metadata(initial_metadata)
39 def send_initial_metadata(self, initial_metadata): argument
40 self._rpc_state.send_initial_metadata(initial_metadata)
57 def send_initial_metadata(self, initial_metadata): argument
58 self._rpc_state.send_initial_metadata(initial_metadata)
79 def send_initial_metadata(self, initial_metadata): argument
80 self._rpc_state.send_initial_metadata(initial_metadata)
D_invocation.py42 return handler.initial_metadata()
77 def initial_metadata(self): member in _Call
107 def initial_metadata(self): member in _RpcErrorCall
226 def initial_metadata(self): member in _FutureCall
314 def initial_metadata(self): member in ResponseIteratorCall
D_rpc_state.py34 def initial_metadata(self): member in State
124 def send_initial_metadata(self, initial_metadata): argument
127 initial_metadata)
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/
D__init__.py31 def send_initial_metadata(self, initial_metadata): argument
65 def send_initial_metadata(self, initial_metadata): argument
107 def send_initial_metadata(self, initial_metadata): argument
161 def send_initial_metadata(self, initial_metadata): argument
303 def initial_metadata(self): member in UnaryUnaryServerRpc
339 def initial_metadata(self): member in UnaryStreamServerRpc
387 def initial_metadata(self): member in StreamUnaryServerRpc
438 def initial_metadata(self): member in StreamStreamServerRpc
D_common.py62 def initial_metadata(self): member in ChannelRpcHandler
122 def send_initial_metadata(self, initial_metadata): argument
/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc105 grpc_call_element* elem, grpc_metadata_batch* initial_metadata,
108 grpc_call_element* elem, grpc_metadata_batch* initial_metadata, in process_send_initial_metadata() argument
116 if (initial_metadata->idx.named.grpc_internal_encoding_request != nullptr) { in process_send_initial_metadata()
118 initial_metadata->idx.named.grpc_internal_encoding_request->md; in process_send_initial_metadata()
141 initial_metadata, in process_send_initial_metadata()
142 initial_metadata->idx.named.grpc_internal_encoding_request); in process_send_initial_metadata()
168 initial_metadata, &calld->stream_compression_algorithm_storage, in process_send_initial_metadata()
173 initial_metadata, &calld->compression_algorithm_storage, in process_send_initial_metadata()
182 initial_metadata, &calld->accept_encoding_storage, in process_send_initial_metadata()
190 if (!initial_metadata->idx.named.accept_encoding) { in process_send_initial_metadata()
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_metadata_code_details_test.py241 call.initial_metadata()))
253 received_initial_metadata = response_iterator_call.initial_metadata()
281 call.initial_metadata()))
294 received_initial_metadata = response_iterator_call.initial_metadata()
328 exception_context.exception.initial_metadata()))
348 response_iterator_call.initial_metadata()
386 exception_context.exception.initial_metadata()))
407 response_iterator_call.initial_metadata()
438 exception_context.exception.initial_metadata()))
452 received_initial_metadata = response_iterator_call.initial_metadata()
[all …]
D_metadata_test.py195 call.initial_metadata()))
205 call.initial_metadata()))
219 call.initial_metadata()))
231 call.initial_metadata()))
D_rpc_test.py474 self.assertIsNotNone(response_iterator.initial_metadata())
513 self.assertIsNotNone(response_iterator.initial_metadata())
538 self.assertIsNotNone(response_future.initial_metadata())
557 self.assertIsNotNone(response_iterator.initial_metadata())
575 self.assertIsNotNone(exception_context.exception.initial_metadata())
595 self.assertIsNotNone(response_future.initial_metadata())
641 self.assertIsNotNone(exception_context.exception.initial_metadata())
673 self.assertIsNotNone(response_future.initial_metadata())
/external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/
Dface.py107 def __init__(self, initial_metadata, terminal_metadata, code, details): argument
109 self.initial_metadata = initial_metadata
199 def initial_metadata(self): member in Call
268 def initial_metadata(self, initial_metadata): member in ServicerContext
324 def initial_metadata(self, initial_metadata): argument
/external/grpc-grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc55 auto* initial_metadata = in authority_start_transport_stream_op_batch() local
59 initial_metadata->idx.named.authority == nullptr) { in authority_start_transport_stream_op_batch()
61 initial_metadata, &calld->authority_storage, in authority_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/tsi/alts/handshaker/
Dalts_tsi_event.cc45 grpc_metadata_array_init(&e->initial_metadata); in alts_tsi_event_create()
69 grpc_metadata_array_destroy(&event->initial_metadata); in alts_tsi_event_destroy()
/external/grpc-grpc/src/core/lib/surface/
Dserver.cc73 grpc_metadata_array* initial_metadata; member
143 grpc_metadata_array initial_metadata; member
454 GPR_SWAP(grpc_metadata_array, *rc->initial_metadata, calld->initial_metadata); in publish_call()
817 &calld->initial_metadata; in accept_stream()
873 grpc_metadata_array_destroy(&calld->initial_metadata); in destroy_call_elem()
1377 grpc_metadata_array* initial_metadata, in grpc_server_request_call() argument
1389 (server, call, details, initial_metadata, cq_bound_to_call, in grpc_server_request_call()
1415 rc->initial_metadata = initial_metadata; in grpc_server_request_call()
1424 grpc_metadata_array* initial_metadata, grpc_byte_buffer** optional_payload, in grpc_server_request_registered_call() argument
1438 (server, rmp, call, deadline, initial_metadata, optional_payload, in grpc_server_request_registered_call()
[all …]
/external/grpc-grpc/src/cpp/ext/filters/census/
Dserver_filter.cc87 grpc_metadata_batch* initial_metadata = calld->recv_initial_metadata_; in OnDoneRecvInitialMetadataCb() local
88 GPR_ASSERT(initial_metadata != nullptr); in OnDoneRecvInitialMetadataCb()
93 FilterInitialMetadata(initial_metadata, &sml); in OnDoneRecvInitialMetadataCb()
/external/grpc-grpc/src/python/grpcio/grpc/
D_channel.py98 def __init__(self, due, initial_metadata, trailing_metadata, code, details): argument
103 self.initial_metadata = initial_metadata
125 if state.initial_metadata is None:
126 state.initial_metadata = ()
136 state.initial_metadata = batch_operation.initial_metadata()
387 def initial_metadata(self): member in _Rendezvous
389 while self._state.initial_metadata is None:
391 return self._state.initial_metadata
/external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/base/
Dbase.py157 initial_metadata=None, argument
282 initial_metadata=None, argument
/external/grpc-grpc/src/csharp/ext/
Dgrpc_csharp_ext.c565 grpc_metadata_array* initial_metadata, uint32_t initial_metadata_flags) { in grpcsharp_call_start_unary() argument
571 initial_metadata); in grpcsharp_call_start_unary()
615 grpc_metadata_array* initial_metadata, uint32_t initial_metadata_flags) { in grpcsharp_call_start_client_streaming() argument
621 initial_metadata); in grpcsharp_call_start_client_streaming()
656 grpc_metadata_array* initial_metadata, uint32_t initial_metadata_flags) { in grpcsharp_call_start_server_streaming() argument
662 initial_metadata); in grpcsharp_call_start_server_streaming()
695 grpc_metadata_array* initial_metadata, uint32_t initial_metadata_flags) { in grpcsharp_call_start_duplex_streaming() argument
701 initial_metadata); in grpcsharp_call_start_duplex_streaming()
839 grpc_metadata_array* initial_metadata) { in grpcsharp_call_send_initial_metadata() argument
845 initial_metadata); in grpcsharp_call_send_initial_metadata()
/external/grpc-grpc/src/python/grpcio_tests/tests/interop/
Dmethods.py385 initial_metadata = dict(response.initial_metadata())
386 if initial_metadata[_INITIAL_METADATA_KEY] != initial_metadata_value:
389 initial_metadata[_INITIAL_METADATA_KEY]))
394 initial_metadata[_TRAILING_METADATA_KEY]))
/external/grpc-grpc/src/python/grpcio/grpc/beta/
D_server_adaptations.py71 def initial_metadata(self, initial_metadata): member in _FaceServicerContext
73 _metadata.unbeta(initial_metadata))

12