| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/http/ |
| D | Http2Stream.java | 15 public class Http2Stream extends HttpStreamBase { class
17 protected Http2Stream(long ptr) { in Http2Stream() method in Http2Stream
|
| D | Http2ClientConnection.java | 188 …public Http2Stream makeRequest(HttpRequestBase request, HttpStreamBaseResponseHandler streamHandle… in makeRequest()
194 … Http2Stream stream = http2ClientConnectionMakeRequest(getNativeHandle(), request.marshalForJni(), in makeRequest()
206 …private static native Http2Stream http2ClientConnectionMakeRequest(long connectionBinding, byte[] … in http2ClientConnectionMakeRequest()
|
| D | Http2StreamManager.java | 146 public CompletableFuture<Http2Stream> acquireStream(Http2Request request, in acquireStream()
152 public CompletableFuture<Http2Stream> acquireStream(HttpRequest request, in acquireStream()
158 private CompletableFuture<Http2Stream> acquireStream(HttpRequestBase request, in acquireStream()
161 CompletableFuture<Http2Stream> completionFuture = new CompletableFuture<>(); in acquireStream()
|
| /external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/ |
| D | Http2ClientLocalHostTest.java | 25 import software.amazon.awssdk.crt.http.Http2Stream;
144 List<CompletableFuture<Http2Stream>> acquireCompleteFutures = new ArrayList<>(); in testParallelRequestsStress()
168 for (CompletableFuture<Http2Stream> f : acquireCompleteFutures) { in testParallelRequestsStress()
200 List<CompletableFuture<Http2Stream>> acquireCompleteFutures = new ArrayList<>(); in testParallelRequestsStressWithBody()
239 for (CompletableFuture<Http2Stream> f : acquireCompleteFutures) { in testParallelRequestsStressWithBody()
275 …CompletableFuture<Http2Stream> acquireCompleteFuture = streamManager.acquireStream(request, new H… in testRequestsUploadStress()
320 …CompletableFuture<Http2Stream> acquireCompleteFuture = streamManager.acquireStream(request, new H… in testRequestsDownloadStress()
|
| D | Http2RequestResponseTest.java | 17 import software.amazon.awssdk.crt.http.Http2Stream;
191 Http2Stream h2Stream = (Http2Stream) stream; in testHttp2ResetStream()
206 try (Http2Stream h2Stream = conn.makeRequest(request, streamHandler)) { in testHttp2ResetStream()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientHandler.java | 75 import io.netty.handler.codec.http2.Http2Stream;
117 private final InUseStateAggregator<Http2Stream> inUseState =
118 new InUseStateAggregator<Http2Stream>() {
297 public void onStreamActive(Http2Stream stream) { in NettyClientHandler()
305 public void onStreamClosed(Http2Stream stream) { in NettyClientHandler()
366 void returnProcessedBytes(Http2Stream stream, int bytes) { in returnProcessedBytes()
450 public boolean visit(Http2Stream stream) throws Http2Exception { in channelInactive()
621 Http2Stream http2Stream = connection().stream(streamId); in createStreamTraced()
780 public boolean visit(Http2Stream stream) throws Http2Exception { in forcefulClose()
837 public boolean visit(Http2Stream stream) throws Http2Exception { in goingAway()
[all …]
|
| D | NettyClientStream.java | 45 import io.netty.handler.codec.http2.Http2Stream;
231 private Http2Stream http2Stream;
278 public void setHttp2Stream(Http2Stream http2Stream) { in setHttp2Stream()
293 public Http2Stream http2Stream() { in http2Stream()
|
| D | NettyServerStream.java | 35 import io.netty.handler.codec.http2.Http2Stream;
155 private final Http2Stream http2Stream;
163 Http2Stream http2Stream, in TransportState()
|
| D | NettyServerHandler.java | 88 import io.netty.handler.codec.http2.Http2Stream;
303 public void onStreamActive(Http2Stream stream) { in NettyServerHandler()
313 public void onStreamClosed(Http2Stream stream) { in NettyServerHandler()
462 Http2Stream http2Stream = requireHttp2Stream(streamId); in onHeadersRead()
621 public boolean visit(Http2Stream stream) throws Http2Exception { in channelInactive()
672 void returnProcessedBytes(Http2Stream http2Stream, int bytes) { in returnProcessedBytes()
717 Http2Stream stream = connection().stream(streamId); in sendResponseHeaders()
761 public boolean visit(Http2Stream stream) throws Http2Exception { in forcefulClose()
795 private Http2Stream requireHttp2Stream(int streamId) { in requireHttp2Stream()
796 Http2Stream stream = connection().stream(streamId); in requireHttp2Stream()
[all …]
|
| D | AbstractNettyHandler.java | 33 import io.netty.handler.codec.http2.Http2Stream;
114 Http2Stream connectionStream = connection().connectionStream(); in sendInitialConnectionWindow()
|
| D | Utils.java | 55 import io.netty.handler.codec.http2.Http2Stream;
464 private final Http2Stream connectionStream;
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/ |
| D | NettyRequestMetrics.java | 20 import io.netty.handler.codec.http2.Http2Stream;
80 Http2Stream stream = http2Connection.stream(streamId); in writeHttp2RequestMetrics()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyStreamTestBase.java | 42 import io.netty.handler.codec.http2.Http2Stream;
84 protected Http2Stream http2Stream;
|
| D | NettyHandlerTestBase.java | 63 import io.netty.handler.codec.http2.Http2Stream;
418 Http2Stream connectionStream = connection().connectionStream(); in windowUpdateMatchesTarget()
447 Http2Stream connectionStream = connection().connectionStream(); in windowShouldNotExceedMaxWindowSize()
|
| D | NettyClientHandlerTest.java | 89 import io.netty.handler.codec.http2.Http2Stream;
640 Http2Stream connectionStream = connection().connectionStream(); in connectionWindowShouldBeOverridden()
925 Http2Stream stream = connection.local().createStream(streamId - 2, true); in newHandler()
|
| D | NettyServerHandlerTest.java | 85 import io.netty.handler.codec.http2.Http2Stream;
455 Http2Stream connectionStream = connection().connectionStream(); in connectionWindowShouldBeOverridden()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | NettyFlowControlTest.java | 40 import io.netty.handler.codec.http2.Http2Stream;
207 Http2Stream connectionStream = grpcHandler.connection().connectionStream(); in onNext()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/http2/ |
| D | Http2MultiplexedChannelPoolTest.java | 35 import io.netty.handler.codec.http2.Http2Stream;
241 Http2Stream connectionStream = http2Connection.stream(0); in acquire_shouldExpandConnectionWindowSizeProportionally()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/http2/ |
| D | Http2MultiplexedChannelPool.java | 36 import io.netty.handler.codec.http2.Http2Stream;
238 Http2Stream connectionStream = http2Connection.connectionStream(); in tryExpandConnectionWindow()
|