Home
last modified time | relevance | path

Searched refs:trailing_metadata (Results 1 – 25 of 146) sorted by relevance

123456

/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/
D_channel_rpc.py29 def terminate(self, response, trailing_metadata, code, details): argument
30 self._rpc_state.terminate_with_response(response, trailing_metadata,
48 def terminate(self, trailing_metadata, code, details): argument
49 self._rpc_state.terminate(trailing_metadata, code, details)
69 def terminate(self, response, trailing_metadata, code, details): argument
70 self._rpc_state.terminate_with_response(response, trailing_metadata,
94 def terminate(self, trailing_metadata, code, details): argument
95 self._rpc_state.terminate(trailing_metadata, code, details)
D_invocation.py46 trailing_metadata, unused_code, unused_details = handler.termination()
47 return trailing_metadata
80 def trailing_metadata(self): member in _Call
110 def trailing_metadata(self): member in _RpcErrorCall
229 def trailing_metadata(self): member in _FutureCall
317 def trailing_metadata(self): member in ResponseIteratorCall
D_rpc_state.py152 def terminate_with_response(self, response, trailing_metadata, code, argument
159 trailing_metadata)
164 def terminate(self, trailing_metadata, code, details): argument
169 trailing_metadata)
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/
D_rpc.py58 def _terminate(self, trailing_metadata, code, details): argument
61 self._handler.send_termination(trailing_metadata, code, details)
67 trailing_metadata = _common.FUSSED_EMPTY_METADATA
69 trailing_metadata = self._pending_trailing_metadata
75 self._terminate(trailing_metadata, code, details)
145 def set_trailing_metadata(self, trailing_metadata): argument
147 self._pending_trailing_metadata = trailing_metadata
D_servicer_context.py66 def set_trailing_metadata(self, trailing_metadata): argument
68 _common.fuss_with_metadata(trailing_metadata))
/external/grpc-grpc/src/python/grpcio_tests/tests/testing/
D_server_test.py45 response, trailing_metadata, code, details = rpc.termination()
55 trailing_metadata, code, details = rpc.termination()
67 response, trailing_metadata, code, details = rpc.termination()
90 trailing_metadata, code, details = rpc.termination()
133 response, trailing_metadata, code, details = rpc.termination()
148 response, trailing_metadata, code, details = rpc.termination()
163 response, trailing_metadata, code, details = rpc.termination()
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_metadata_code_details_test.py244 call.trailing_metadata()))
265 response_iterator_call.trailing_metadata()))
284 call.trailing_metadata()))
306 response_iterator_call.trailing_metadata()))
332 exception_context.exception.trailing_metadata()))
362 response_iterator_call.trailing_metadata()))
390 exception_context.exception.trailing_metadata()))
421 response_iterator_call.trailing_metadata()))
442 exception_context.exception.trailing_metadata()))
465 response_iterator_call.trailing_metadata()))
[all …]
D_metadata_test.py198 call.trailing_metadata()))
210 call.trailing_metadata()))
222 call.trailing_metadata()))
236 call.trailing_metadata()))
D_rpc_test.py477 self.assertIsNotNone(response_iterator.trailing_metadata())
516 self.assertIsNotNone(response_iterator.trailing_metadata())
541 self.assertIsNotNone(response_future.trailing_metadata())
560 self.assertIsNotNone(response_iterator.trailing_metadata())
579 self.assertIsNotNone(exception_context.exception.trailing_metadata())
598 self.assertIsNotNone(response_future.trailing_metadata())
645 self.assertIsNotNone(exception_context.exception.trailing_metadata())
676 self.assertIsNotNone(response_future.trailing_metadata())
/external/grpc-grpc/src/csharp/ext/
Dgrpc_csharp_ext.c58 grpc_metadata_array trailing_metadata; member
63 grpc_metadata_array trailing_metadata; member
205 &(ctx->send_status_from_server.trailing_metadata)); in grpcsharp_batch_context_reset()
212 &(ctx->recv_status_on_client.trailing_metadata)); in grpcsharp_batch_context_reset()
307 return &(ctx->recv_status_on_client.trailing_metadata); in grpcsharp_batch_context_recv_status_on_client_trailing_metadata()
600 ops[5].data.recv_status_on_client.trailing_metadata = in grpcsharp_call_start_unary()
601 &(ctx->recv_status_on_client.trailing_metadata); in grpcsharp_call_start_unary()
640 ops[3].data.recv_status_on_client.trailing_metadata = in grpcsharp_call_start_client_streaming()
641 &(ctx->recv_status_on_client.trailing_metadata); in grpcsharp_call_start_client_streaming()
680 ops[3].data.recv_status_on_client.trailing_metadata = in grpcsharp_call_start_server_streaming()
[all …]
/external/grpc-grpc/src/ruby/spec/generic/
Dserver_interceptors_spec.rb20 let(:service) { EchoService.new(trailing_metadata) }
57 expect(op.trailing_metadata).to eq(
92 expect(op.trailing_metadata).to eq(
133 expect(op.trailing_metadata).to eq(
173 expect(op.trailing_metadata).to eq(
/external/grpc-grpc/src/php/lib/Grpc/
DAbstractCall.php34 protected $trailing_metadata; variable in Grpc\\AbstractCall
63 $this->trailing_metadata = null;
88 return $this->trailing_metadata;
/external/grpc-grpc/src/php/ext/grpc/
Dcall.c282 grpc_metadata_array trailing_metadata; in PHP_METHOD() local
295 grpc_metadata_array_init(&trailing_metadata); in PHP_METHOD()
369 if (!create_metadata_array(inner_value, &trailing_metadata)) { in PHP_METHOD()
375 ops[op_num].data.send_status_from_server.trailing_metadata = in PHP_METHOD()
376 trailing_metadata.metadata; in PHP_METHOD()
378 trailing_metadata.count; in PHP_METHOD()
423 ops[op_num].data.recv_status_on_client.trailing_metadata = in PHP_METHOD()
523 grpc_php_metadata_array_destroy_including_entries(&trailing_metadata); in PHP_METHOD()
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/
D__init__.py46 def terminate(self, response, trailing_metadata, code, details): argument
89 def terminate(self, trailing_metadata, code, details): argument
142 def terminate(self, response, trailing_metadata, code, details): argument
205 def terminate(self, trailing_metadata, code, details): argument
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Doperation.pyx.pxi90 def __cinit__(self, trailing_metadata, code, object details, int flags): argument
91 self._trailing_metadata = trailing_metadata
105 self.c_op.data.send_status_from_server.trailing_metadata = (
196 self.c_op.data.receive_status_on_client.trailing_metadata = (
217 def trailing_metadata(self): member in ReceiveStatusOnClientOperation
/external/grpc-grpc/src/core/tsi/alts/handshaker/
Dalts_tsi_event.cc46 grpc_metadata_array_init(&e->trailing_metadata); in alts_tsi_event_create()
70 grpc_metadata_array_destroy(&event->trailing_metadata); in alts_tsi_event_destroy()
/external/grpc-grpc/src/ruby/pb/test/
Dclient.rb610 if not op.trailing_metadata.has_key?(trailing_metadata_key)
612 elsif op.trailing_metadata[trailing_metadata_key] !=
616 "Received: #{op.trailing_metadata[trailing_metadata_key]}"
638 if not duplex_op.trailing_metadata[trailing_metadata_key]
640 elsif duplex_op.trailing_metadata[trailing_metadata_key] !=
644 "Received: #{duplex_op.trailing_metadata[trailing_metadata_key]}"
/external/grpc-grpc/src/core/lib/surface/
Dcall_log_batch.cc78 add_metadata(&b, op->data.send_status_from_server.trailing_metadata, in grpc_op_string()
94 op->data.recv_status_on_client.trailing_metadata, in grpc_op_string()
/external/grpc-grpc/src/python/grpcio/grpc/
D_channel.py98 def __init__(self, due, initial_metadata, trailing_metadata, code, details): argument
105 self.trailing_metadata = trailing_metadata
127 state.trailing_metadata = ()
148 state.trailing_metadata = batch_operation.trailing_metadata()
393 def trailing_metadata(self): member in _Rendezvous
395 while self._state.trailing_metadata is None:
397 return self._state.trailing_metadata
D_server.py99 self.trailing_metadata = None
141 state.trailing_metadata, effective_code, effective_details,
147 state.trailing_metadata, effective_code, effective_details,
278 def set_trailing_metadata(self, trailing_metadata): argument
280 self._state.trailing_metadata = trailing_metadata
466 state.trailing_metadata, code, details, _EMPTY_FLAGS),
/external/grpc-grpc/src/ruby/lib/grpc/generic/
Dactive_call.rb175 @call.trailing_metadata = recv_status_batch_result.status.metadata
227 def server_unary_response(req, trailing_metadata: {}, argument
238 code, details, trailing_metadata)
Drpc_desc.rb63 trailing_metadata: active_call.output_metadata
79 trailing_metadata: active_call.output_metadata
/external/grpc-grpc/test/core/end2end/tests/
Dtrailing_metadata.cc179 op->data.recv_status_on_client.trailing_metadata = &trailing_metadata_recv; in test_request_response_with_metadata_and_payload()
230 op->data.send_status_from_server.trailing_metadata = meta_t; in test_request_response_with_metadata_and_payload()
277 void trailing_metadata(grpc_end2end_test_config config) { in trailing_metadata() function
Dmax_concurrent_streams.cc130 op->data.recv_status_on_client.trailing_metadata = &trailing_metadata_recv; in simple_request_body()
278 op->data.recv_status_on_client.trailing_metadata = &trailing_metadata_recv1; in test_max_concurrent_streams()
312 op->data.recv_status_on_client.trailing_metadata = &trailing_metadata_recv2; in test_max_concurrent_streams()
520 op->data.recv_status_on_client.trailing_metadata = &trailing_metadata_recv1; in test_max_concurrent_streams_with_timeout_on_first()
558 op->data.recv_status_on_client.trailing_metadata = &trailing_metadata_recv2; in test_max_concurrent_streams_with_timeout_on_first()
716 op->data.recv_status_on_client.trailing_metadata = &trailing_metadata_recv1; in test_max_concurrent_streams_with_timeout_on_second()
754 op->data.recv_status_on_client.trailing_metadata = &trailing_metadata_recv2; in test_max_concurrent_streams_with_timeout_on_second()
/external/grpc-grpc/include/grpc/impl/codegen/
Dgrpc_types.h568 grpc_metadata* trailing_metadata; member
597 grpc_metadata_array* trailing_metadata; member

123456