| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| _channel_rpc.py | 29 def terminate(self, response, trailing_metadata, code, details):
30 self._rpc_state.terminate_with_response(response, trailing_metadata,
48 def terminate(self, trailing_metadata, code, details):
49 self._rpc_state.terminate(trailing_metadata, code, details)
69 def terminate(self, response, trailing_metadata, code, details):
70 self._rpc_state.terminate_with_response(response, trailing_metadata,
94 def terminate(self, trailing_metadata, code, details):
95 self._rpc_state.terminate(trailing_metadata, code, details)
|
| _invocation.py | 46 trailing_metadata, unused_code, unused_details = handler.termination()
47 return trailing_metadata
80 def trailing_metadata(self): member in class:_Call
110 def trailing_metadata(self): member in class:_RpcErrorCall
229 def trailing_metadata(self): member in class:_FutureCall
317 def trailing_metadata(self): member in class:ResponseIteratorCall
|
| _rpc_state.py | 152 def terminate_with_response(self, response, trailing_metadata, code,
159 trailing_metadata)
164 def terminate(self, trailing_metadata, code, details):
169 trailing_metadata)
|
| /external/grpc-grpc/src/php/lib/Grpc/ |
| AbstractCall.php | 34 protected $trailing_metadata; variable
63 $this->trailing_metadata = null; variable
88 return $this->trailing_metadata;
|
| ClientStreamingCall.php | 76 $this->trailing_metadata = $status->metadata; variable
|
| BidiStreamingCall.php | 101 $this->trailing_metadata = $status_event->status->metadata; variable
|
| ServerStreamingCall.php | 84 $this->trailing_metadata = $status_event->status->metadata; variable
|
| UnaryCall.php | 69 $this->trailing_metadata = $status->metadata; variable
|
| /external/grpc-grpc/src/ruby/spec/generic/ |
| server_interceptors_spec.rb | 19 let(:trailing_metadata) { {} }
20 let(:service) { EchoService.new(trailing_metadata) }
33 let(:trailing_metadata) { { server_om: 'from_request_response' } }
57 expect(op.trailing_metadata).to eq(
67 let(:trailing_metadata) { { server_om: 'from_client_streamer' } }
92 expect(op.trailing_metadata).to eq(
102 let(:trailing_metadata) { { server_om: 'from_server_streamer' } }
133 expect(op.trailing_metadata).to eq(
142 let(:trailing_metadata) { { server_om: 'from_bidi_streamer' } }
173 expect(op.trailing_metadata).to eq
[all...] |
| /external/grpc-grpc/src/core/tsi/alts/handshaker/ |
| alts_tsi_event.h | 50 grpc_metadata_array trailing_metadata; member in struct:alts_tsi_event
|
| alts_tsi_event.cc | 46 grpc_metadata_array_init(&e->trailing_metadata);
70 grpc_metadata_array_destroy(&event->trailing_metadata);
|
| /external/grpc-grpc/src/ruby/spec/support/ |
| services.rb | 39 @trailing_metadata = kw
45 call.output_metadata.update(@trailing_metadata)
52 call.output_metadata.update(@trailing_metadata)
60 call.output_metadata.update(@trailing_metadata)
65 call.output_metadata.update(@trailing_metadata)
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| _rpc.py | 58 def _terminate(self, trailing_metadata, code, details):
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):
147 self._pending_trailing_metadata = trailing_metadata
|
| _servicer_context.py | 66 def set_trailing_metadata(self, trailing_metadata):
68 _common.fuss_with_metadata(trailing_metadata))
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/testing/ |
| _server_test.py | 45 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/core/lib/surface/ |
| call_log_batch.cc | 78 add_metadata(&b, op->data.send_status_from_server.trailing_metadata,
94 op->data.recv_status_on_client.trailing_metadata,
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| _metadata_code_details_test.py | 244 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...] |
| _metadata_test.py | 198 call.trailing_metadata()))
210 call.trailing_metadata()))
222 call.trailing_metadata()))
236 call.trailing_metadata()))
|
| /external/grpc-grpc/src/csharp/ext/ |
| grpc_csharp_ext.c | 58 grpc_metadata_array trailing_metadata; member in struct:grpcsharp_batch_context::__anon23304
63 grpc_metadata_array trailing_metadata; member in struct:grpcsharp_batch_context::__anon23305
205 &(ctx->send_status_from_server.trailing_metadata));
212 &(ctx->recv_status_on_client.trailing_metadata));
307 return &(ctx->recv_status_on_client.trailing_metadata);
600 ops[5].data.recv_status_on_client.trailing_metadata =
601 &(ctx->recv_status_on_client.trailing_metadata);
640 ops[3].data.recv_status_on_client.trailing_metadata =
641 &(ctx->recv_status_on_client.trailing_metadata);
680 ops[3].data.recv_status_on_client.trailing_metadata
[all...] |
| /external/grpc-grpc/src/php/ext/grpc/ |
| call.c | 282 grpc_metadata_array trailing_metadata; local
295 grpc_metadata_array_init(&trailing_metadata);
369 if (!create_metadata_array(inner_value, &trailing_metadata)) {
375 ops[op_num].data.send_status_from_server.trailing_metadata =
376 trailing_metadata.metadata;
378 trailing_metadata.count;
423 ops[op_num].data.recv_status_on_client.trailing_metadata =
523 grpc_php_metadata_array_destroy_including_entries(&trailing_metadata);
|
| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| rpc_desc.rb | 63 trailing_metadata: active_call.output_metadata
79 trailing_metadata: active_call.output_metadata
|
| active_call.rb | 49 :trailing_metadata, :status
175 @call.trailing_metadata = recv_status_batch_result.status.metadata
227 def server_unary_response(req, trailing_metadata: {},
238 code, details, trailing_metadata)
664 :write_flag=, :trailing_metadata)
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/ |
| __init__.py | 46 def terminate(self, response, trailing_metadata, code, details):
51 trailing_metadata: The RPC's trailing metadata.
89 def terminate(self, trailing_metadata, code, details):
93 trailing_metadata: The RPC's trailing metadata.
142 def terminate(self, response, trailing_metadata, code, details):
147 trailing_metadata: The RPC's trailing metadata.
205 def terminate(self, trailing_metadata, code, details):
209 trailing_metadata: The RPC's trailing metadata.
326 A (response, trailing_metadata, code, details) sequence with the RPC's
374 A (trailing_metadata, code, details) sequence with the RPC's trailin
[all...] |
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| operation.pyx.pxi | 90 def __cinit__(self, trailing_metadata, code, object details, int flags):
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 class:ReceiveStatusOnClientOperation
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| trailing_metadata.cc | 179 op->data.recv_status_on_client.trailing_metadata = &trailing_metadata_recv;
230 op->data.send_status_from_server.trailing_metadata = meta_t;
277 void trailing_metadata(grpc_end2end_test_config config) { function
|
