| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AbstractServerStreamTest.java | 34 import io.grpc.internal.AbstractServerStream.TransportState;
78 new AbstractServerStreamBase.TransportState(MAX_MESSAGE_SIZE, transportTracer)); in setUp()
184 TransportState state = stream.transportState(); in setListener_setOnlyOnce()
196 TransportState state = stream.transportState(); in listenerReady_onlyOnce()
213 TransportState state = stream.transportState(); in setListener_failsOnNull()
358 private final AbstractServerStream.TransportState state;
361 AbstractServerStream.TransportState state) { in AbstractServerStreamBase()
373 protected AbstractServerStream.TransportState transportState() { in transportState()
377 static class TransportState extends AbstractServerStream.TransportState { class in AbstractServerStreamTest.AbstractServerStreamBase
378 protected TransportState(int maxMessageSize, TransportTracer transportTracer) { in TransportState() method in AbstractServerStreamTest.AbstractServerStreamBase.TransportState
|
| D | AbstractClientStreamTest.java | 43 import io.grpc.internal.AbstractClientStream.TransportState;
175 TransportState state = stream.transportState(); in inboundDataReceived_failsOnNullFrame()
199 TransportState state = stream.transportState(); in inboundHeadersReceived_failsIfStatusReported()
451 private final TransportState state;
468 TransportState state, in BaseAbstractClientStream()
477 TransportState state, in BaseAbstractClientStream()
493 public TransportState transportState() { in transportState()
527 private static class BaseTransportState extends AbstractClientStream.TransportState {
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | CreateStreamCommand.java | 28 private final NettyClientStream.TransportState stream;
32 NettyClientStream.TransportState stream) { in CreateStreamCommand()
37 NettyClientStream.TransportState stream, boolean get) { in CreateStreamCommand()
43 NettyClientStream.TransportState stream() { in stream()
|
| D | NettyServerStream.java | 47 private final TransportState state;
56 TransportState state, in NettyServerStream()
71 protected TransportState transportState() { in transportState()
155 public static class TransportState extends AbstractServerStream.TransportState class in NettyServerStream
161 public TransportState( in TransportState() method in NettyServerStream.TransportState
|
| D | CancelClientStreamCommand.java | 27 private final NettyClientStream.TransportState stream;
30 CancelClientStreamCommand(NettyClientStream.TransportState stream, Status reason) { in CancelClientStreamCommand()
37 NettyClientStream.TransportState stream() { in stream()
|
| D | CancelServerStreamCommand.java | 28 private final NettyServerStream.TransportState stream;
31 CancelServerStreamCommand(NettyServerStream.TransportState stream, Status reason) { in CancelServerStreamCommand()
36 NettyServerStream.TransportState stream() { in stream()
|
| D | NettyClientHandler.java | 342 NettyClientStream.TransportState stream = clientStream(requireHttp2Stream(streamId)); in onHeadersRead()
354 NettyClientStream.TransportState stream = clientStream(requireHttp2Stream(streamId)); in onDataRead()
366 NettyClientStream.TransportState stream = clientStream(connection().stream(streamId)); in onRstStreamRead()
407 NettyClientStream.TransportState clientStream = clientStream(stream); in channelInactive()
463 NettyClientStream.TransportState stream = clientStream(connection().stream(http2Ex.streamId())); in onStreamError()
514 final NettyClientStream.TransportState stream = command.stream(); in createStream()
563 NettyClientStream.TransportState stream = cmd.stream(); in cancelStream()
654 NettyClientStream.TransportState clientStream = clientStream(stream); in forcefulClose()
679 NettyClientStream.TransportState clientStream = clientStream(stream); in goingAway()
715 private NettyClientStream.TransportState clientStream(Http2Stream stream) { in clientStream()
[all …]
|
| D | NettyClientStream.java | 56 private final TransportState state;
65 TransportState state, in NettyClientStream()
90 protected TransportState transportState() { in transportState()
210 public abstract static class TransportState extends Http2ClientStreamTransportState class in NettyClientStream
217 public TransportState( in TransportState() method in NettyClientStream.TransportState
|
| D | NettyServerHandler.java | 422 NettyServerStream.TransportState state = new NettyServerStream.TransportState( in onHeadersRead()
463 NettyServerStream.TransportState stream = serverStream(requireHttp2Stream(streamId)); in onDataRead()
474 NettyServerStream.TransportState stream = serverStream(connection().stream(streamId)); in onRstStreamRead()
498 NettyServerStream.TransportState serverStream = serverStream( in onStreamError()
550 NettyServerStream.TransportState serverStream = serverStream(stream); in channelInactive()
601 final NettyServerStream.TransportState stream = serverStream(requireHttp2Stream(streamId)); in closeStreamWhenDone()
655 NettyServerStream.TransportState serverStream = serverStream(stream); in forcefulClose()
696 private NettyServerStream.TransportState serverStream(Http2Stream stream) { in serverStream()
697 return stream == null ? null : (NettyServerStream.TransportState) stream.getProperty(streamKey); in serverStream()
|
| D | NettyClientTransport.java | 159 new NettyClientStream.TransportState( in newStream()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AbstractServerStream.java | 91 protected abstract TransportState transportState(); in transportState()
188 protected abstract static class TransportState extends AbstractStream.TransportState { class in AbstractServerStream
202 protected TransportState( in TransportState() method in AbstractServerStream.TransportState
|
| D | AbstractStream.java | 41 protected abstract TransportState transportState(); in transportState()
102 public abstract static class TransportState class in AbstractStream
135 protected TransportState( in TransportState() method in AbstractStream.TransportState
|
| D | AbstractClientStream.java | 153 protected abstract TransportState transportState(); in transportState()
212 protected abstract static class TransportState extends AbstractStream.TransportState { class in AbstractClientStream
234 protected TransportState( in TransportState() method in AbstractClientStream.TransportState
|
| D | Http2ClientStreamTransportState.java | 31 public abstract class Http2ClientStreamTransportState extends AbstractClientStream.TransportState {
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 59 private final TransportState state;
91 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, frameWriter, outboundFlow, in OkHttpClientStream()
96 protected TransportState transportState() { in transportState()
183 class TransportState extends Http2ClientStreamTransportState { class in OkHttpClientStream
206 public TransportState( in TransportState() method in OkHttpClientStream.TransportState
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientStream.java | 79 private final TransportState state;
112 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, transportTracer); in CronetClientStream()
116 protected TransportState transportState() { in transportState()
212 class TransportState extends Http2ClientStreamTransportState { class in CronetClientStream
229 public TransportState( in TransportState() method in CronetClientStream.TransportState
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerStreamTest.java | 288 NettyServerStream.TransportState state = new NettyServerStream.TransportState( in createStream()
|
| D | NettyClientHandlerTest.java | 110 private NettyClientStream.TransportState streamTransportState;
757 private static class TransportStateImpl extends NettyClientStream.TransportState {
|
| D | NettyClientStreamTest.java | 547 private class TransportStateImpl extends NettyClientStream.TransportState {
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 1268 AbstractStream.TransportState.DEFAULT_ONREADY_THRESHOLD - HEADER_LENGTH - 1; in notifyOnReady()
|