| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| CancelClientStreamCommand.java | 27 private final NettyClientStream.TransportState stream;
30 CancelClientStreamCommand(NettyClientStream.TransportState stream, Status reason) {
37 NettyClientStream.TransportState stream() {
|
| CreateStreamCommand.java | 28 private final NettyClientStream.TransportState stream;
32 NettyClientStream.TransportState stream) {
37 NettyClientStream.TransportState stream, boolean get) {
43 NettyClientStream.TransportState stream() {
|
| CancelServerStreamCommand.java | 28 private final NettyServerStream.TransportState stream;
31 CancelServerStreamCommand(NettyServerStream.TransportState stream, Status reason) {
36 NettyServerStream.TransportState stream() {
|
| NettyServerStream.java | 47 private final TransportState state;
56 TransportState state,
62 this.state = checkNotNull(state, "transportState");
71 protected TransportState transportState() {
95 transportState().requestMessagesFromDeframer(numMessages);
100 transportState().requestMessagesFromDeframer(numMessages);
110 transportState(),
126 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, false), flush)
132 transportState().onSentBytes(numBytes)
[all...] |
| NettyClientStream.java | 56 private final TransportState state;
65 TransportState state,
80 this.state = checkNotNull(state, "transportState");
90 protected TransportState transportState() {
145 Status s = transportState().handler.getLifecycleManager().getShutdownStatus();
147 s = transportState().statusFromFailedFuture(future);
149 transportState().transportReportStatus(s, true, new Metadata());
155 writeQueue.enqueue(new CreateStreamCommand(http2Headers, transportState(), get),
168 writeQueue.enqueue(new SendGrpcFrameCommand(transportState(), bytebuf, endOfStream), flush
[all...] |
| NettyClientHandler.java | 342 NettyClientStream.TransportState stream = clientStream(requireHttp2Stream(streamId));
354 NettyClientStream.TransportState stream = clientStream(requireHttp2Stream(streamId));
366 NettyClientStream.TransportState stream = clientStream(connection().stream(streamId));
407 NettyClientStream.TransportState clientStream = clientStream(stream);
463 NettyClientStream.TransportState stream = clientStream(connection().stream(http2Ex.streamId()));
514 final NettyClientStream.TransportState stream = command.stream();
563 NettyClientStream.TransportState stream = cmd.stream();
654 NettyClientStream.TransportState clientStream = clientStream(stream);
679 NettyClientStream.TransportState clientStream = clientStream(stream);
715 private NettyClientStream.TransportState clientStream(Http2Stream stream)
[all...] |
| NettyServerHandler.java | 422 NettyServerStream.TransportState state = new NettyServerStream.TransportState(
463 NettyServerStream.TransportState stream = serverStream(requireHttp2Stream(streamId));
474 NettyServerStream.TransportState stream = serverStream(connection().stream(streamId));
498 NettyServerStream.TransportState serverStream = serverStream(
550 NettyServerStream.TransportState serverStream = serverStream(stream);
601 final NettyServerStream.TransportState stream = serverStream(requireHttp2Stream(streamId));
655 NettyServerStream.TransportState serverStream = serverStream(stream);
696 private NettyServerStream.TransportState serverStream(Http2Stream stream) {
697 return stream == null ? null : (NettyServerStream.TransportState) stream.getProperty(streamKey)
[all...] |
| NettyClientTransport.java | 159 new NettyClientStream.TransportState(
|
| /art/dt_fd_forward/ |
| dt_fd_forward.h | 66 enum class TransportState {
106 bool ChangeState(TransportState old_state, TransportState new_state); // REQUIRES(state_mutex_);
142 TransportState state_; // GUARDED_BY(state_mutex_);
|
| dt_fd_forward.cc | 81 state_(TransportState::kClosed),
86 bool FdForwardTransport::ChangeState(TransportState old_state, TransportState new_state) {
121 if (!ChangeState(TransportState::kClosed, TransportState::kListenSetup)) {
126 CHECK(ChangeState(TransportState::kListenSetup, TransportState::kListening));
141 if (ChangeState(TransportState::kListening, TransportState::kClosed) ||
142 state_ == TransportState::kOpen)
[all...] |
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| AbstractServerStreamTest.java | 34 import io.grpc.internal.AbstractServerStream.TransportState;
78 new AbstractServerStreamBase.TransportState(MAX_MESSAGE_SIZE, transportTracer));
87 stream.transportState().setListener(new ServerStreamListenerBase() {
100 stream.transportState().complete();
102 stream.transportState().inboundDataReceived(buffer, true);
112 .transportState()
122 stream.transportState().inboundDataReceived(ReadableBuffers.wrap(new byte[] {1}), false);
124 stream.transportState().complete();
133 .transportState()
143 stream.transportState().inboundDataReceived(ReadableBuffers.wrap(new byte[] {1}), false)
[all...] |
| AbstractClientStreamTest.java | 43 import io.grpc.internal.AbstractClientStream.TransportState;
175 TransportState state = stream.transportState();
188 stream.transportState().inboundHeadersReceived(headers);
197 stream.transportState().transportReportStatus(Status.CANCELLED, false, new Metadata());
199 TransportState state = stream.transportState();
214 stream.transportState().inboundHeadersReceived(headers);
229 stream.transportState().inboundHeadersReceived(headers);
243 stream.transportState().inboundHeadersReceived(headers)
[all...] |
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| AbstractStream.java | 41 protected abstract TransportState transportState();
85 return transportState().isReady();
95 transportState().onSendingBytes(numBytes);
102 public abstract static class TransportState
135 protected TransportState(
|
| AbstractServerStream.java | 29 * implement {@link #transportState()} and {@link #abstractServerStreamSink()}. Must only be called
66 * triggering {@link TransportState#requestMessagesFromDeframer(int)} on the transport thread.
91 protected abstract TransportState transportState();
136 transportState().setClosedStatus(status);
162 transportState().setDecompressor(Preconditions.checkNotNull(decompressor, "decompressor"));
176 transportState().setListener(serverStreamListener);
188 protected abstract static class TransportState extends AbstractStream.TransportState {
202 protected TransportState(
[all...] |
| AbstractClientStream.java | 44 * implement {@link #transportState()} and {@link #abstractClientStreamSink()}. Must only be called
81 * should end up triggering {@link TransportState#requestMessagesFromDeframer(int)} on the
138 transportState().setMaxInboundMessageSize(maxSize);
143 transportState().setFullStreamDecompression(fullStreamDecompression);
148 transportState().setDecompressorRegistry(decompressorRegistry);
153 protected abstract TransportState transportState();
157 transportState().setListener(listener);
189 if (!transportState().isOutboundClosed()) {
190 transportState().setOutboundClosed()
[all...] |
| Http2ClientStreamTransportState.java | 31 public abstract class Http2ClientStreamTransportState extends AbstractClientStream.TransportState {
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| OkHttpClientStream.java | 59 private final TransportState state;
91 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, frameWriter, outboundFlow,
96 protected TransportState transportState() {
183 class TransportState extends Http2ClientStreamTransportState {
206 public TransportState(
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| CronetClientStream.java | 79 private final TransportState state;
112 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, transportTracer);
116 protected TransportState transportState() {
212 class TransportState extends Http2ClientStreamTransportState {
229 public TransportState(
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| NettyServerStreamTest.java | 113 assertThat(sendHeaders.stream()).isSameAs(stream.transportState());
123 eq(new SendGrpcFrameCommand(stream.transportState(), messageFrame(MESSAGE), false)),
139 assertThat(sendHeaders.stream()).isSameAs(stream.transportState());
159 assertThat(sendHeaders.stream()).isSameAs(stream.transportState());
166 stream().transportState().complete();
187 assertThat(sendHeaders.stream()).isSameAs(stream.transportState());
194 stream().transportState().complete();
208 stream().transportState()
221 assertThat(cmd.stream()).isSameAs(stream.transportState());
227 stream().transportState().complete()
[all...] |
| NettyClientHandlerTest.java | 110 private NettyClientStream.TransportState streamTransportState;
757 private static class TransportStateImpl extends NettyClientStream.TransportState {
|
| NettyClientStreamTest.java | 141 stream().transportState().setId(STREAM_ID);
149 stream().transportState().setId(STREAM_ID);
160 stream().transportState().setId(STREAM_ID);
177 stream().transportState().setId(STREAM_ID);
182 eq(new SendGrpcFrameCommand(stream.transportState(), messageFrame(MESSAGE), false)),
189 stream().transportState().setId(STREAM_ID);
197 stream.transportState(), messageFrame(MESSAGE).slice(0, 5), false)),
201 stream.transportState(), messageFrame(MESSAGE).slice(5, 11), false)),
207 stream().transportState().setId(STREAM_ID);
208 stream().transportState().transportReportStatus(Status.OK, true, new Metadata())
[all...] |
| /external/grpc-grpc-java/core/ |
| grpc-core-1.14.0.jar | |
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| OkHttpClientTransportTest.java | [all...] |
| /external/grpc-grpc-java/netty/shaded/ |
| grpc-netty-shaded-1.14.0.jar | |
