| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientStreamTest.java | 141 stream().transportState().setId(STREAM_ID); in closeShouldSucceed()
149 stream().transportState().setId(STREAM_ID); in cancelShouldSendCommand()
160 stream().transportState().setId(STREAM_ID); in deadlineExceededCancelShouldSendCommand()
177 stream().transportState().setId(STREAM_ID); in writeMessageShouldSendRequest()
182 eq(new SendGrpcFrameCommand(stream.transportState(), messageFrame(MESSAGE), false)), in writeMessageShouldSendRequest()
189 stream().transportState().setId(STREAM_ID); in writeMessageShouldSendRequestUnknownLength()
197 stream.transportState(), messageFrame(MESSAGE).slice(0, 5), false)), in writeMessageShouldSendRequestUnknownLength()
201 stream.transportState(), messageFrame(MESSAGE).slice(5, 11), false)), in writeMessageShouldSendRequestUnknownLength()
207 stream().transportState().setId(STREAM_ID); in setStatusWithOkShouldCloseStream()
208 stream().transportState().transportReportStatus(Status.OK, true, new Metadata()); in setStatusWithOkShouldCloseStream()
[all …]
|
| D | NettyServerStreamTest.java | 113 assertThat(sendHeaders.stream()).isSameAs(stream.transportState()); in writeMessageShouldSendResponse()
123 eq(new SendGrpcFrameCommand(stream.transportState(), messageFrame(MESSAGE), false)), in writeMessageShouldSendResponse()
139 assertThat(sendHeaders.stream()).isSameAs(stream.transportState()); in writeHeadersShouldSendHeaders()
159 assertThat(sendHeaders.stream()).isSameAs(stream.transportState()); in closeBeforeClientHalfCloseShouldSucceed()
166 stream().transportState().complete(); in closeBeforeClientHalfCloseShouldSucceed()
187 assertThat(sendHeaders.stream()).isSameAs(stream.transportState()); in closeWithErrorBeforeClientHalfCloseShouldSucceed()
194 stream().transportState().complete(); in closeWithErrorBeforeClientHalfCloseShouldSucceed()
208 stream().transportState() in closeAfterClientHalfCloseShouldSucceed()
221 assertThat(cmd.stream()).isSameAs(stream.transportState()); in closeAfterClientHalfCloseShouldSucceed()
227 stream().transportState().complete(); in closeAfterClientHalfCloseShouldSucceed()
[all …]
|
| D | NettyStreamTestBase.java | 122 ((NettyServerStream) stream).transportState() in inboundMessageShouldCallListener()
125 ((NettyClientStream) stream).transportState() in inboundMessageShouldCallListener()
|
| D | NettyServerHandlerTest.java | 223 new SendGrpcFrameCommand(stream.transportState(), content(), false)); in sendFrameShouldSucceed()
406 enqueue(new CancelServerStreamCommand(stream.transportState(), Status.DEADLINE_EXCEEDED)); in cancelShouldSendRstStream()
407 verifyWrite().writeRstStream(eq(ctx()), eq(stream.transportState().id()), in cancelShouldSendRstStream()
628 SendResponseHeadersCommand.createHeaders(stream.transportState(), headers)); in keepAliveEnforcer_sendingDataResetsCounters()
632 new SendGrpcFrameCommand(stream.transportState(), content().retainedSlice(), false)); in keepAliveEnforcer_sendingDataResetsCounters()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AbstractServerStreamTest.java | 87 stream.transportState().setListener(new ServerStreamListenerBase() { in frameShouldBeIgnoredAfterDeframerClosed()
100 stream.transportState().complete(); in frameShouldBeIgnoredAfterDeframerClosed()
102 stream.transportState().inboundDataReceived(buffer, true); in frameShouldBeIgnoredAfterDeframerClosed()
112 .transportState() in queuedBytesInDeframerShouldNotBlockComplete()
122 stream.transportState().inboundDataReceived(ReadableBuffers.wrap(new byte[] {1}), false); in queuedBytesInDeframerShouldNotBlockComplete()
124 stream.transportState().complete(); in queuedBytesInDeframerShouldNotBlockComplete()
133 .transportState() in queuedBytesInDeframerShouldNotBlockTransportReportStatus()
143 stream.transportState().inboundDataReceived(ReadableBuffers.wrap(new byte[] {1}), false); in queuedBytesInDeframerShouldNotBlockTransportReportStatus()
144 stream.transportState().transportReportStatus(Status.CANCELLED); in queuedBytesInDeframerShouldNotBlockTransportReportStatus()
153 .transportState() in partialMessageAtEndOfStreamShouldFail()
[all …]
|
| D | AbstractClientStreamTest.java | 175 TransportState state = stream.transportState(); in inboundDataReceived_failsOnNullFrame()
188 stream.transportState().inboundHeadersReceived(headers); in inboundHeadersReceived_notifiesListener()
197 stream.transportState().transportReportStatus(Status.CANCELLED, false, new Metadata()); in inboundHeadersReceived_failsIfStatusReported()
199 TransportState state = stream.transportState(); in inboundHeadersReceived_failsIfStatusReported()
214 stream.transportState().inboundHeadersReceived(headers); in inboundHeadersReceived_acceptsGzipContentEncoding()
229 stream.transportState().inboundHeadersReceived(headers); in inboundHeadersReceived_contentEncodingIsCaseInsensitive()
243 stream.transportState().inboundHeadersReceived(headers); in inboundHeadersReceived_failsOnUnrecognizedContentEncoding()
246 Throwable t = ((BaseTransportState) stream.transportState()).getDeframeFailedCause(); in inboundHeadersReceived_failsOnUnrecognizedContentEncoding()
265 stream.transportState().inboundHeadersReceived(headers); in inboundHeadersReceived_disallowsContentAndMessageEncoding()
268 Throwable t = ((BaseTransportState) stream.transportState()).getDeframeFailedCause(); in inboundHeadersReceived_disallowsContentAndMessageEncoding()
[all …]
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientStream.java | 90 protected TransportState transportState() { in transportState() method in NettyClientStream
145 Status s = transportState().handler.getLifecycleManager().getShutdownStatus(); in writeHeaders()
147 s = transportState().statusFromFailedFuture(future); in writeHeaders()
149 transportState().transportReportStatus(s, true, new Metadata()); in writeHeaders()
155 writeQueue.enqueue(new CreateStreamCommand(http2Headers, transportState(), get), in writeHeaders()
168 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, endOfStream), flush) in writeFrame()
174 if (future.isSuccess() && transportState().http2Stream() != null) { in writeFrame()
177 transportState().onSentBytes(numBytes); in writeFrame()
184 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, endOfStream), flush); in writeFrame()
192 transportState().requestMessagesFromDeframer(numMessages); in request()
[all …]
|
| D | NettyServerStream.java | 71 protected TransportState transportState() { in transportState() method in NettyServerStream
95 transportState().requestMessagesFromDeframer(numMessages); in request()
100 transportState().requestMessagesFromDeframer(numMessages); in request()
110 transportState(), in writeHeaders()
126 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, false), flush) in writeFrame()
132 transportState().onSentBytes(numBytes); in writeFrame()
144 SendResponseHeadersCommand.createTrailers(transportState(), http2Trailers, status), in writeTrailers()
150 writeQueue.enqueue(new CancelServerStreamCommand(transportState(), status), true); in cancel()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AbstractClientStream.java | 138 transportState().setMaxInboundMessageSize(maxSize); in setMaxInboundMessageSize()
143 transportState().setFullStreamDecompression(fullStreamDecompression); in setFullStreamDecompression()
148 transportState().setDecompressorRegistry(decompressorRegistry); in setDecompressorRegistry()
153 protected abstract TransportState transportState(); in transportState() method in AbstractClientStream
157 transportState().setListener(listener); in start()
189 if (!transportState().isOutboundClosed()) { in halfClose()
190 transportState().setOutboundClosed(); in halfClose()
|
| D | AbstractServerStream.java | 91 protected abstract TransportState transportState(); in transportState() method in AbstractServerStream
136 transportState().setClosedStatus(status); in close()
162 transportState().setDecompressor(Preconditions.checkNotNull(decompressor, "decompressor")); in setDecompressor()
176 transportState().setListener(serverStreamListener); in setListener()
|
| D | AbstractStream.java | 41 protected abstract TransportState transportState(); in transportState() method in AbstractStream
85 return transportState().isReady(); in isReady()
95 transportState().onSendingBytes(numBytes); in onSendingBytes()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientStreamTest.java | 121 stream.transportState().start(1234); in cancel_started()
141 stream.transportState().start(1234); in start_alreadyCancelled()
154 stream.transportState().start(3); in start_userAgentRemoved()
169 stream.transportState().start(3); in start_headerFieldOrder()
207 stream.transportState().start(3); in getUnaryRequest()
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientTransport.java | 129 clientStream.transportState().transportReportStatus(goAwayStatus, true, new Metadata()); in newStream()
145 stream.transportState().start(streamFactory); in startStream()
256 stream.transportState().transportReportStatus(status, isCancelled, new Metadata());
|
| D | CronetClientStream.java | 116 protected TransportState transportState() { in transportState() method in CronetClientStream
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 356 clientStream.transportState().transportReportStatus( in streamReadyToStart()
372 stream.transportState().start(nextStreamId); in startStream()
691 entry.getValue().transportState().transportReportStatus(reason, false, new Metadata()); in shutdownNow()
695 stream.transportState().transportReportStatus(reason, true, new Metadata()); in shutdownNow()
765 entry.getValue().transportState().transportReportStatus( in startGoAway()
771 stream.transportState().transportReportStatus( in startGoAway()
811 .transportState() in finishStream()
1020 stream.transportState().transportDataReceived(buf, inFinished); in data()
1052 stream.transportState().transportHeadersReceived(headerBlock, inFinished); in headers()
|
| D | OutboundFlowController.java | 392 stream.transportState().onSentBytes(bytesToWrite); in write()
|
| D | OkHttpClientStream.java | 96 protected TransportState transportState() { in transportState() method in OkHttpClientStream
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 99 stream.transportState().start(factory); in run()
393 clientStream.transportState().transportReportStatus(Status.UNAVAILABLE, false, new Metadata()); in streamFailed()
421 clientStream.transportState().transportReportStatus(Status.UNAVAILABLE, false, new Metadata()); in streamFailedAfterResponseHeaderReceived()
452 clientStream.transportState().transportReportStatus(Status.UNAVAILABLE, false, new Metadata()); in streamFailedAfterTrailerReceived()
485 clientStream.transportState().transportReportStatus(Status.UNAVAILABLE, false, new Metadata()); in streamFailedAfterTrailerAndEndOfStreamReceived()
|