Home
last modified time | relevance | path

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

1234567

/external/grpc-grpc/src/php/tests/interop/
Dinterop_server.php29 $trailing_metadata = [];
38 $trailing_metadata = [
43 return [$initial_metadata, $trailing_metadata];
48 $trailing_metadata = [] argument
56 $trailing_metadata
64 list($initial_metadata, $trailing_metadata) =
66 $context->setStatus(\Grpc\Status::ok($trailing_metadata));
75 list($initial_metadata, $trailing_metadata) =
79 $trailing_metadata
91 $context->setStatus($echo_status ?? \Grpc\Status::ok($trailing_metadata));
[all …]
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/
D_channel_rpc.py28 def terminate(self, response, trailing_metadata, code, details): argument
30 response, trailing_metadata, code, details
47 def terminate(self, trailing_metadata, code, details): argument
48 self._rpc_state.terminate(trailing_metadata, code, details)
67 def terminate(self, response, trailing_metadata, code, details): argument
69 response, trailing_metadata, code, details
92 def terminate(self, trailing_metadata, code, details): argument
93 self._rpc_state.terminate(trailing_metadata, code, details)
D_invocation.py46 trailing_metadata, unused_code, unused_details = handler.termination()
47 return trailing_metadata
79 def trailing_metadata(self): member in _Call
108 def trailing_metadata(self): member in _RpcErrorCall
225 def trailing_metadata(self): member in _FutureCall
311 def trailing_metadata(self): member in ResponseIteratorCall
D_rpc_state.py159 self, response, trailing_metadata, code, details argument
166 trailing_metadata
172 def terminate(self, trailing_metadata, code, details): argument
177 trailing_metadata
/external/grpc-grpc/src/python/grpcio_status/grpc_status/
D_async.py36 trailing_metadata = await call.trailing_metadata()
37 if trailing_metadata is None:
39 for key, value in trailing_metadata:
Drpc_status.py48 if call.trailing_metadata() is None:
50 for key, value in call.trailing_metadata():
82 trailing_metadata=(
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/
D_rpc.py57 def _terminate(self, trailing_metadata, code, details): argument
60 self._handler.send_termination(trailing_metadata, code, details)
66 trailing_metadata = _common.FUSSED_EMPTY_METADATA
68 trailing_metadata = self._pending_trailing_metadata
74 self._terminate(trailing_metadata, code, details)
147 def set_trailing_metadata(self, trailing_metadata): argument
149 self._pending_trailing_metadata = trailing_metadata
/external/grpc-grpc/src/python/grpcio_tests/tests_aio/unit/
Daio_rpc_error_test.py40 trailing_metadata=_TEST_TRAILING_METADATA,
50 aio_rpc_error.trailing_metadata(), _TEST_TRAILING_METADATA
60 trailing_metadata=_TEST_TRAILING_METADATA,
72 loaded_error.trailing_metadata(), _TEST_TRAILING_METADATA
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_metadata_code_details_test.py282 _SERVER_TRAILING_METADATA, call.trailing_metadata()
309 response_iterator_call.trailing_metadata(),
334 _SERVER_TRAILING_METADATA, call.trailing_metadata()
362 response_iterator_call.trailing_metadata(),
393 exception_context.exception.trailing_metadata(),
432 response_iterator_call.trailing_metadata(),
467 exception_context.exception.trailing_metadata(),
507 response_iterator_call.trailing_metadata(),
534 exception_context.exception.trailing_metadata(),
564 response_iterator_call.trailing_metadata(),
[all …]
D_metadata_test.py211 _EXPECTED_TRAILING_METADATA, call.trailing_metadata()
229 _EXPECTED_TRAILING_METADATA, call.trailing_metadata()
248 _EXPECTED_TRAILING_METADATA, call.trailing_metadata()
269 _EXPECTED_TRAILING_METADATA, call.trailing_metadata()
/external/rust/android-crates-io/crates/grpcio/src/task/
Dpromise.rs26 pub trailing_metadata: UnownedMetadata, field
33 trailing_metadata: Option<UnownedMetadata>, in new()
40 let trailing_metadata = if let Some(m) = trailing_metadata { in new() localVariable
48 trailing_metadata, in new()
/external/rust/android-crates-io/crates/grpcio-sys/
Dgrpc_wrap.cc83 grpc_metadata_array trailing_metadata; member
88 grpc_metadata_array trailing_metadata; member
255 &(ctx->send_status_from_server.trailing_metadata)); in grpcwrap_batch_context_destroy()
262 &(ctx->recv_status_on_client.trailing_metadata)); in grpcwrap_batch_context_destroy()
294 &(ctx->recv_status_on_client.trailing_metadata)); in grpcwrap_batch_context_take_recv_status_on_client_trailing_metadata()
347 return &(ctx->recv_status_on_client.trailing_metadata); in grpcwrap_batch_context_recv_status_on_client_trailing_metadata()
523 ops[5].data.recv_status_on_client.trailing_metadata = in grpcwrap_call_start_unary()
524 &(ctx->recv_status_on_client.trailing_metadata); in grpcwrap_call_start_unary()
565 ops[3].data.recv_status_on_client.trailing_metadata = in grpcwrap_call_start_client_streaming()
566 &(ctx->recv_status_on_client.trailing_metadata); in grpcwrap_call_start_client_streaming()
[all …]
/external/grpc-grpc/src/core/load_balancing/grpclb/
Dclient_load_reporting_filter.cc73 ServerMetadataHandle trailing_metadata) { in MakeCallPromise() argument
76 trailing_metadata->get(GrpcStreamNetworkState()) == in MakeCallPromise()
80 return trailing_metadata; in MakeCallPromise()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc75 ServerMetadataHandle trailing_metadata) { in MakeCallPromise() argument
78 trailing_metadata->get(GrpcStreamNetworkState()) == in MakeCallPromise()
82 return trailing_metadata; in MakeCallPromise()
/external/rust/android-crates-io/crates/grpcio/src/call/
Dclient.rs209 trailing_metadata: UnownedMetadata, field
221 trailing_metadata: UnownedMetadata::empty(), in new()
243 self.trailing_metadata = data.trailing_metadata; in wait_for_batch_future()
264 Ok(unsafe { self.trailing_metadata.assume_valid() }) in trailers()
291 self.trailing_metadata = data.trailing_metadata; in poll()
311 trailing_metadata: UnownedMetadata, field
323 trailing_metadata: UnownedMetadata::empty(), in new()
350 self.trailing_metadata = data.trailing_metadata; in wait_for_batch_future()
370 Ok(unsafe { self.trailing_metadata.assume_valid() }) in trailers()
401 self.trailing_metadata = data.trailing_metadata; in poll()
/external/grpc-grpc/src/python/grpcio_tests/tests/testing/
D_server_test.py50 response, trailing_metadata, code, details = rpc.termination()
63 trailing_metadata, code, details = rpc.termination()
76 response, trailing_metadata, code, details = rpc.termination()
102 trailing_metadata, code, details = rpc.termination()
179 response, trailing_metadata, code, details = rpc.termination()
197 response, trailing_metadata, code, details = rpc.termination()
215 response, trailing_metadata, code, details = rpc.termination()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/transport/binder/utils/
Dtransport_stream_receiver_impl.cc100 std::pair<absl::StatusOr<Metadata>, int> trailing_metadata{}; in RegisterRecvTrailingMetadata() local
109 trailing_metadata = std::move(iter->second.front()); in RegisterRecvTrailingMetadata()
117 cb(std::move(trailing_metadata.first), trailing_metadata.second); in RegisterRecvTrailingMetadata()
161 StreamIdentifier id, absl::StatusOr<Metadata> trailing_metadata, in NotifyRecvTrailingMetadata() argument
177 pending_trailing_metadata_[id].emplace(std::move(trailing_metadata), in NotifyRecvTrailingMetadata()
182 cb(std::move(trailing_metadata), status); in NotifyRecvTrailingMetadata()
/external/grpc-grpc/src/core/ext/transport/binder/utils/
Dtransport_stream_receiver_impl.cc100 std::pair<absl::StatusOr<Metadata>, int> trailing_metadata{}; in RegisterRecvTrailingMetadata() local
109 trailing_metadata = std::move(iter->second.front()); in RegisterRecvTrailingMetadata()
117 cb(std::move(trailing_metadata.first), trailing_metadata.second); in RegisterRecvTrailingMetadata()
161 StreamIdentifier id, absl::StatusOr<Metadata> trailing_metadata, in NotifyRecvTrailingMetadata() argument
177 pending_trailing_metadata_[id].emplace(std::move(trailing_metadata), in NotifyRecvTrailingMetadata()
182 cb(std::move(trailing_metadata), status); in NotifyRecvTrailingMetadata()
/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/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/backend_metrics/
Dbackend_metric_filter.cc126 [this](ServerMetadataHandle trailing_metadata) { in MakeCallPromise() argument
133 return trailing_metadata; in MakeCallPromise()
143 trailing_metadata->Set( in MakeCallPromise()
149 return trailing_metadata; in MakeCallPromise()
/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/python/grpcio/grpc/_cython/_cygrpc/aio/
Drpc_status.pyx.pxi24 tuple trailing_metadata, argument
28 self._trailing_metadata = trailing_metadata
37 cpdef tuple trailing_metadata(self): member in AioRpcStatus
/external/grpc-grpc/src/python/grpcio/grpc/aio/
D_base_server.py185 trailing_metadata: MetadataType = tuple(),
206 def set_trailing_metadata(self, trailing_metadata: MetadataType) -> None:
314 def trailing_metadata(self): member in ServicerContext
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/
D__init__.py44 def terminate(self, response, trailing_metadata, code, details): argument
87 def terminate(self, trailing_metadata, code, details): argument
140 def terminate(self, response, trailing_metadata, code, details): argument
203 def terminate(self, trailing_metadata, code, details): argument
/external/grpc-grpc/src/php/ext/grpc/
Dcall.c291 grpc_metadata_array trailing_metadata; in PHP_METHOD() local
304 grpc_metadata_array_init(&trailing_metadata); in PHP_METHOD()
383 if (!create_metadata_array(inner_value, &trailing_metadata)) { in PHP_METHOD()
389 ops[op_num].data.send_status_from_server.trailing_metadata = in PHP_METHOD()
390 trailing_metadata.metadata; in PHP_METHOD()
392 trailing_metadata.count; in PHP_METHOD()
437 ops[op_num].data.recv_status_on_client.trailing_metadata = in PHP_METHOD()
527 grpc_php_metadata_array_destroy_including_entries(&trailing_metadata); in PHP_METHOD()

1234567