| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | Http2ClientStreamTransportStateTest.java | 240 Metadata trailers = new Metadata(); in transportTrailersReceived_notifiesListener() local
241 trailers.put(testStatusMashaller, "200"); in transportTrailersReceived_notifiesListener()
242 trailers.put(Metadata.Key.of("content-type", Metadata.ASCII_STRING_MARSHALLER), in transportTrailersReceived_notifiesListener()
244 trailers.put(Metadata.Key.of("grpc-status", Metadata.ASCII_STRING_MARSHALLER), "0"); in transportTrailersReceived_notifiesListener()
245 state.transportTrailersReceived(trailers); in transportTrailersReceived_notifiesListener()
248 verify(mockListener).closed(Status.OK, PROCESSED, trailers); in transportTrailersReceived_notifiesListener()
260 Metadata trailers = new Metadata(); in transportTrailersReceived_afterHeaders() local
261 trailers.put(Metadata.Key.of("grpc-status", Metadata.ASCII_STRING_MARSHALLER), "0"); in transportTrailersReceived_afterHeaders()
262 state.transportTrailersReceived(trailers); in transportTrailersReceived_afterHeaders()
265 verify(mockListener).closed(Status.OK, PROCESSED, trailers); in transportTrailersReceived_afterHeaders()
[all …]
|
| D | ForwardingClientStreamListenerTest.java | 63 Metadata trailers = new Metadata(); in closedTest() local
64 forward.closed(status, trailers); in closedTest()
65 verify(mock).closed(same(status), same(trailers)); in closedTest()
|
| D | NoopClientStreamListener.java | 36 public void closed(Status status, Metadata trailers) {} in closed() argument
39 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) {} in closed() argument
|
| D | AbstractServerStreamTest.java | 311 Metadata trailers = new Metadata(); in close_sendsTrailers() local
312 stream.close(Status.INTERNAL, trailers); in close_sendsTrailers()
320 Metadata trailers = new Metadata(); in close_sendTrailersClearsReservedFields() local
321 trailers.put(InternalStatus.CODE_KEY, Status.OK); in close_sendTrailersClearsReservedFields()
322 trailers.put(InternalStatus.MESSAGE_KEY, "Everything's super."); in close_sendTrailersClearsReservedFields()
325 stream.close(closeStatus, trailers); in close_sendTrailersClearsReservedFields()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | StatusRuntimeException.java | 30 private final Metadata trailers; field in StatusRuntimeException
49 public StatusRuntimeException(Status status, @Nullable Metadata trailers) { in StatusRuntimeException() argument
50 this(status, trailers, /*fillInStackTrace=*/ true); in StatusRuntimeException()
53 StatusRuntimeException(Status status, @Nullable Metadata trailers, boolean fillInStackTrace) { in StatusRuntimeException() argument
56 this.trailers = trailers; in StatusRuntimeException()
86 return trailers; in getTrailers()
|
| D | StatusException.java | 29 private final Metadata trailers; field in StatusException
47 public StatusException(Status status, @Nullable Metadata trailers) { in StatusException() argument
48 this(status, trailers, /*fillInStackTrace=*/ true); in StatusException()
51 StatusException(Status status, @Nullable Metadata trailers, boolean fillInStackTrace) { in StatusException() argument
54 this.trailers = trailers; in StatusException()
84 return trailers; in getTrailers()
|
| D | PartialForwardingClientCallListener.java | 38 public void onClose(Status status, Metadata trailers) { in onClose() argument
39 delegate().onClose(status, trailers); in onClose()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | Http2ClientStreamTransportState.java | 79 Status status, boolean stopDelivery, Metadata trailers); in http2ProcessingFailed() argument
163 protected void transportTrailersReceived(Metadata trailers) { in transportTrailersReceived() argument
164 Preconditions.checkNotNull(trailers, "trailers"); in transportTrailersReceived()
166 transportError = validateInitialMetadata(trailers); in transportTrailersReceived()
168 transportErrorMetadata = trailers; in transportTrailersReceived()
172 transportError = transportError.augmentDescription("trailers: " + trailers); in transportTrailersReceived()
175 Status status = statusFromTrailers(trailers); in transportTrailersReceived()
176 stripTransportDetails(trailers); in transportTrailersReceived()
177 inboundTrailersReceived(trailers, status); in transportTrailersReceived()
184 private Status statusFromTrailers(Metadata trailers) { in statusFromTrailers() argument
[all …]
|
| D | AbstractClientStream.java | 231 private Metadata trailers; field in AbstractClientStream.TransportState
265 trailers = new Metadata(); in deframerClosed()
267 transportReportStatus(trailerStatus, false, trailers); in deframerClosed()
370 protected void inboundTrailersReceived(Metadata trailers, Status status) { in inboundTrailersReceived() argument
372 checkNotNull(trailers, "trailers"); in inboundTrailersReceived()
375 new Object[]{status, trailers}); in inboundTrailersReceived()
378 this.trailers = trailers; in inboundTrailersReceived()
396 final Metadata trailers) { in transportReportStatus() argument
397 transportReportStatus(status, RpcProgress.PROCESSED, stopDelivery, trailers); in transportReportStatus()
417 final Metadata trailers) { in transportReportStatus() argument
[all …]
|
| D | AbstractServerStream.java | 62 void writeTrailers(Metadata trailers, boolean headersSent, Status status); in writeTrailers() argument
126 public final void close(Status status, Metadata trailers) { in close() argument
128 Preconditions.checkNotNull(trailers, "trailers"); in close()
132 addStatusToTrailers(trailers, status); in close()
137 abstractServerStreamSink().writeTrailers(trailers, headersSent, status); in close()
141 private void addStatusToTrailers(Metadata trailers, Status status) { in addStatusToTrailers() argument
142 trailers.discardAll(InternalStatus.CODE_KEY); in addStatusToTrailers()
143 trailers.discardAll(InternalStatus.MESSAGE_KEY); in addStatusToTrailers()
144 trailers.put(InternalStatus.CODE_KEY, status); in addStatusToTrailers()
146 trailers.put(InternalStatus.MESSAGE_KEY, status.getDescription()); in addStatusToTrailers()
|
| D | ForwardingClientStreamListener.java | 33 public void closed(Status status, Metadata trailers) { in closed() argument
34 delegate().closed(status, trailers); in closed()
38 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed() argument
39 delegate().closed(status, rpcProgress, trailers); in closed()
|
| D | ClientStreamListener.java | 49 void closed(Status status, Metadata trailers); in closed() argument
64 void closed(Status status, RpcProgress rpcProgress, Metadata trailers); in closed() argument
|
| D | ClientCallImpl.java | 458 private void closeObserver(Listener<RespT> observer, Status status, Metadata trailers) { in closeObserver() argument
459 observer.onClose(status, trailers); in closeObserver()
542 private void close(Status status, Metadata trailers) { in close() argument
546 closeObserver(observer, status, trailers); in close()
554 public void closed(Status status, Metadata trailers) { in closed() argument
555 closed(status, RpcProgress.PROCESSED, trailers); in closed()
559 public void closed(Status status, RpcProgress rpcProgress, Metadata trailers) { in closed() argument
568 trailers = new Metadata(); in closed()
572 final Metadata savedTrailers = trailers; in closed()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | RpcException.cs | 30 private readonly Metadata trailers; field in Grpc.Core.RpcException
54 … public RpcException(Status status, Metadata trailers) : this(status, trailers, status.ToString()) in RpcException() argument
64 public RpcException(Status status, Metadata trailers, string message) : base(message) in RpcException() argument
67 this.trailers = GrpcPreconditions.CheckNotNull(trailers); in RpcException()
101 return trailers;
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | ClientSideStatus.cs | 31 readonly Metadata trailers; field
33 public ClientSideStatus(Status status, Metadata trailers) in ClientSideStatus()
36 this.trailers = trailers; in ClientSideStatus()
51 return this.trailers;
|
| /external/rust/crates/nix/src/sys/ |
| D | sendfile.rs | 52 trailers: Option<&'a [&'a [u8]]>
57 trailers.map(|s| s.iter().map(|b| IoVec::from_slice(b)).collect());
66 trailers: {
134 trailers: Option<&[&[u8]]>,
144 let hdtr = headers.or(trailers).map(|_| SendfileHeaderTrailer::new(headers, trailers));
187 trailers: Option<&[&[u8]]>
190 let hdtr = headers.or(trailers).map(|_| SendfileHeaderTrailer::new(headers, trailers));
|
| /external/python/cpython3/Lib/lib2to3/fixes/ |
| D | fix_filter.py | 62 trailers = []
65 trailers.append(t.clone())
76 new = Node(syms.power, [new] + trailers, prefix="")
83 new = Node(syms.power, [new] + trailers, prefix="")
91 new = Node(syms.power, [Name("list"), ArgList([new])] + trailers)
|
| D | fix_zip.py | 37 trailers = []
39 trailers = [n.clone() for n in results['trailers']]
40 for n in trailers:
44 new = Node(syms.power, [Name("list"), ArgList([new])] + trailers)
|
| D | fix_map.py | 68 trailers = []
71 trailers.append(t.clone())
82 new = Node(syms.power, [new] + trailers, prefix="")
106 new = Node(syms.power, [Name("list"), ArgList([new])] + trailers)
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/ |
| D | DetailErrorSample.java | 79 Metadata trailers = new Metadata(); in run()
80 trailers.put(DEBUG_INFO_TRAILER_KEY, DEBUG_INFO); in run()
82 .asRuntimeException(trailers)); in run()
102 Metadata trailers = Status.trailersFromThrowable(t); in verifyErrorReply() local
104 Verify.verify(trailers.containsKey(DEBUG_INFO_TRAILER_KEY)); in verifyErrorReply()
107 Verify.verify(trailers.get(DEBUG_INFO_TRAILER_KEY).equals(DEBUG_INFO)); in verifyErrorReply()
208 public void onClose(Status status, Metadata trailers) { in advancedAsyncCall()
210 Verify.verify(trailers.containsKey(DEBUG_INFO_TRAILER_KEY)); in advancedAsyncCall()
212 Verify.verify(trailers.get(DEBUG_INFO_TRAILER_KEY).equals(DEBUG_INFO)); in advancedAsyncCall()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 269 assertNotNull(clientStreamListener.trailers.get(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in frameAfterRstStreamShouldNotBreakClientChannel()
441 assertNotNull(clientStreamListener.trailers.get(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in shutdownNowKillsClientStream()
479 assertNotNull(clientStreamListener.trailers.get(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in shutdownNowKillsServerStream()
572 assertNotNull(clientStreamListener2.trailers.get(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in newStream_duringShutdown()
586 assertNotNull(clientStreamListener.trailers.get(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in newStream_duringShutdown()
606 assertNotNull(clientStreamListener.trailers.get(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in newStream_afterTermination()
799 Metadata trailers = new Metadata(); in basicStream() local
800 trailers.put(asciiKey, "trailers"); in basicStream()
801 trailers.put(asciiKey, "dupvalue"); in basicStream()
802 trailers.put(asciiKey, "dupvalue"); in basicStream()
[all …]
|
| /external/rust/crates/nix/test/ |
| D | test_sendfile.rs | 54 let trailers: Vec<&[u8]> = trailer_strings.iter().map(|s| s.as_bytes()).collect(); in test_sendfile_freebsd() localVariable
66 Some(trailers.as_slice()), in test_sendfile_freebsd()
101 let trailers: Vec<&[u8]> = trailer_strings.iter().map(|s| s.as_bytes()).collect(); in test_sendfile_darwin() localVariable
113 Some(trailers.as_slice()), in test_sendfile_darwin()
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 97 final Metadata trailers = new Metadata(); in unaryBlockingCallSuccess() local
103 listener.onClose(status, trailers); in unaryBlockingCallSuccess()
115 final Metadata trailers = new Metadata(); in unaryBlockingCallFailed() local
120 listener.onClose(status, trailers); in unaryBlockingCallFailed()
129 assertSame(trailers, e.getTrailers()); in unaryBlockingCallFailed()
177 Metadata trailers = new Metadata(); in unaryFutureCallFailed() local
178 listener.get().onClose(Status.INTERNAL, trailers); in unaryFutureCallFailed()
186 assertSame(trailers, metadata); in unaryFutureCallFailed()
555 Metadata trailers = new Metadata(); in blockingResponseStreamFailed() local
556 listener.get().onClose(Status.INTERNAL, trailers); in blockingResponseStreamFailed()
[all …]
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 523 public void close(Status status, Metadata trailers) {
524 trailers.merge(requestHeaders, keySet);
525 super.close(status, trailers);
551 public void close(Status status, Metadata trailers) {
552 super.close(status, trailers);
577 public void close(Status status, Metadata trailers) {
578 trailers.merge(requestHeaders, keySet);
579 super.close(status, trailers);
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | ClientServerTest.cs | 107 var trailers = new Metadata { {"xyz", "xyz-value"} }; in UnaryCall_ServerHandlerThrowsRpcExceptionWithTrailers()
108 throw new RpcException(new Status(StatusCode.Unauthenticated, ""), trailers); in UnaryCall_ServerHandlerThrowsRpcExceptionWithTrailers()
300 var trailers = call.GetTrailers(); in AsyncUnaryCall_EchoMetadata()
301 Assert.AreEqual(2, trailers.Count); in AsyncUnaryCall_EchoMetadata()
302 Assert.AreEqual(headers[0].Key, trailers[0].Key); in AsyncUnaryCall_EchoMetadata()
303 Assert.AreEqual(headers[0].Value, trailers[0].Value); in AsyncUnaryCall_EchoMetadata()
305 Assert.AreEqual(headers[1].Key, trailers[1].Key); in AsyncUnaryCall_EchoMetadata()
306 CollectionAssert.AreEqual(headers[1].ValueBytes, trailers[1].ValueBytes); in AsyncUnaryCall_EchoMetadata()
|