src/java.net.http/share/classes/jdk/internal/net/http/Http2Connection.java
author dfuchs
Mon, 23 Apr 2018 15:45:40 +0100
branchhttp-client-branch
changeset 56474 fe2bf7b369b8
parent 56451 9585061fdb04
child 56500 4a33cb79f71e
permissions -rw-r--r--
http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
     1
/*
48523
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
     2
 * Copyright (c) 2015, 2018, Oracle and/or its affiliates. All rights reserved.
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
     3
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
     4
 *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
     5
 * This code is free software; you can redistribute it and/or modify it
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
     6
 * under the terms of the GNU General Public License version 2 only, as
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
     7
 * published by the Free Software Foundation.  Oracle designates this
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
     8
 * particular file as subject to the "Classpath" exception as provided
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
     9
 * by Oracle in the LICENSE file that accompanied this code.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    10
 *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    11
 * This code is distributed in the hope that it will be useful, but WITHOUT
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    12
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    13
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    14
 * version 2 for more details (a copy is included in the LICENSE file that
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    15
 * accompanied this code).
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    16
 *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    17
 * You should have received a copy of the GNU General Public License version
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    18
 * 2 along with this work; if not, write to the Free Software Foundation,
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    19
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    20
 *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    21
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    22
 * or visit www.oracle.com if you need additional information or have any
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    23
 * questions.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    24
 */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    25
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    26
package jdk.internal.net.http;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    27
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
    28
import java.io.EOFException;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    29
import java.io.IOException;
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    30
import java.io.UncheckedIOException;
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
    31
import java.lang.System.Logger.Level;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    32
import java.net.InetSocketAddress;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    33
import java.net.URI;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    34
import java.nio.ByteBuffer;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    35
import java.nio.charset.StandardCharsets;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    36
import java.util.Iterator;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    37
import java.util.LinkedList;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    38
import java.util.List;
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    39
import java.util.Locale;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    40
import java.util.Map;
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    41
import java.util.Set;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    42
import java.util.concurrent.CompletableFuture;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    43
import java.util.ArrayList;
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
    44
import java.util.Objects;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    45
import java.util.concurrent.ConcurrentHashMap;
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
    46
import java.util.concurrent.ConcurrentLinkedQueue;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
    47
import java.util.concurrent.Flow;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
    48
import java.util.function.Function;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
    49
import java.util.function.Supplier;
44854
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
    50
import javax.net.ssl.SSLEngine;
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    51
import javax.net.ssl.SSLException;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    52
import java.net.http.HttpClient;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    53
import java.net.http.HttpHeaders;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    54
import jdk.internal.net.http.HttpConnection.HttpPublisher;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    55
import jdk.internal.net.http.common.FlowTube;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    56
import jdk.internal.net.http.common.FlowTube.TubeSubscriber;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    57
import jdk.internal.net.http.common.HttpHeadersImpl;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    58
import jdk.internal.net.http.common.Log;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    59
import jdk.internal.net.http.common.Logger;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    60
import jdk.internal.net.http.common.MinimalFuture;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    61
import jdk.internal.net.http.common.SequentialScheduler;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    62
import jdk.internal.net.http.common.Utils;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    63
import jdk.internal.net.http.frame.ContinuationFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    64
import jdk.internal.net.http.frame.DataFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    65
import jdk.internal.net.http.frame.ErrorFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    66
import jdk.internal.net.http.frame.FramesDecoder;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    67
import jdk.internal.net.http.frame.FramesEncoder;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    68
import jdk.internal.net.http.frame.GoAwayFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    69
import jdk.internal.net.http.frame.HeaderFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    70
import jdk.internal.net.http.frame.HeadersFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    71
import jdk.internal.net.http.frame.Http2Frame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    72
import jdk.internal.net.http.frame.MalformedFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    73
import jdk.internal.net.http.frame.OutgoingHeaders;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    74
import jdk.internal.net.http.frame.PingFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    75
import jdk.internal.net.http.frame.PushPromiseFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    76
import jdk.internal.net.http.frame.ResetFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    77
import jdk.internal.net.http.frame.SettingsFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    78
import jdk.internal.net.http.frame.WindowUpdateFrame;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    79
import jdk.internal.net.http.hpack.Encoder;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    80
import jdk.internal.net.http.hpack.Decoder;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    81
import jdk.internal.net.http.hpack.DecodingCallback;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    82
import static java.nio.charset.StandardCharsets.UTF_8;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
    83
import static jdk.internal.net.http.frame.SettingsFrame.*;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    84
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    85
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    86
/**
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    87
 * An Http2Connection. Encapsulates the socket(channel) and any SSLEngine used
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    88
 * over it. Contains an HttpConnection which hides the SocketChannel SSL stuff.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    89
 *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    90
 * Http2Connections belong to a Http2ClientImpl, (one of) which belongs
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    91
 * to a HttpClientImpl.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    92
 *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    93
 * Creation cases:
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    94
 * 1) upgraded HTTP/1.1 plain tcp connection
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    95
 * 2) prior knowledge directly created plain tcp connection
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    96
 * 3) directly created HTTP/2 SSL connection which uses ALPN.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    97
 *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    98
 * Sending is done by writing directly to underlying HttpConnection object which
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
    99
 * is operating in async mode. No flow control applies on output at this level
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   100
 * and all writes are just executed as puts to an output Q belonging to HttpConnection
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   101
 * Flow control is implemented by HTTP/2 protocol itself.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   102
 *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   103
 * Hpack header compression
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   104
 * and outgoing stream creation is also done here, because these operations
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   105
 * must be synchronized at the socket level. Stream objects send frames simply
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   106
 * by placing them on the connection's output Queue. sendFrame() is called
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   107
 * from a higher level (Stream) thread.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   108
 *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   109
 * asyncReceive(ByteBuffer) is always called from the selector thread. It assembles
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   110
 * incoming Http2Frames, and directs them to the appropriate Stream.incoming()
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   111
 * or handles them directly itself. This thread performs hpack decompression
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   112
 * and incoming stream creation (Server push). Incoming frames destined for a
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   113
 * stream are provided by calling Stream.incoming().
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   114
 */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   115
class Http2Connection  {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   116
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   117
    final Logger debug = Utils.getDebugLogger(this::dbgString, Utils.DEBUG);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   118
    final static Logger DEBUG_LOGGER =
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   119
            Utils.getDebugLogger("Http2Connection"::toString, Utils.DEBUG);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   120
    private final Logger debugHpack =
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   121
            Utils.getHpackLogger(this::dbgString, Utils.DEBUG_HPACK);
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   122
    static final ByteBuffer EMPTY_TRIGGER = ByteBuffer.allocate(0);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   123
48376
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   124
    private boolean singleStream; // used only for stream 1, then closed
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   125
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   126
    /*
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   127
     *  ByteBuffer pooling strategy for HTTP/2 protocol:
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   128
     *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   129
     * In general there are 4 points where ByteBuffers are used:
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   130
     *  - incoming/outgoing frames from/to ByteBuffers plus incoming/outgoing encrypted data
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   131
     *    in case of SSL connection.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   132
     *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   133
     * 1. Outgoing frames encoded to ByteBuffers.
56474
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   134
     *    Outgoing ByteBuffers are created with required size and frequently small (except DataFrames, etc)
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   135
     *    At this place no pools at all. All outgoing buffers should be collected by GC.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   136
     *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   137
     * 2. Incoming ByteBuffers (decoded to frames).
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   138
     *    Here, total elimination of BB pool is not a good idea.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   139
     *    We don't know how many bytes we will receive through network.
56474
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   140
     *
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   141
     *    So here is a strategy we could try to implement:
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   142
     *    We allocate buffer of reasonable size. The following life of the BB:
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   143
     *      - If all frames decoded from the BB are other than DataFrame andHeaderFrame
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   144
     *        (and HeaderFrame subclasses) BB is returned to pool,
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   145
     *      - If we decoded DataFrame from the BB. In that case DataFrame refers to subbuffer
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   146
     *        obtained by slice() method. Such BB is never returned to pool and will be GCed.
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   147
     *      - If we decoded HeadersFrame from the BB. Then header decoding is performed
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   148
     *        inside processFrame method and the buffer could be release to pool.
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   149
     *
56474
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   150
     *    At this moment we do not implement this strategy.
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   151
     *    Instead we only use a pool for recycling SSL encrypted buffers read from
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   152
     *    the socket (see 3).
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   153
     *
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   154
     * 3. SSL encrypted buffers. Here another pool was introduced and all net buffers are to/from
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   155
     *    the pool, because of we can't predict size encrypted packets.
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   156
     *
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   157
     *    At the moment we only recycle encrypted buffers read from the socket, and we have
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   158
     *    a pool of maximum 3 (SocketTube.MAX_BUFFERS = 3) direct buffers which are shared by
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   159
     *    all connections on a given client.
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   160
     *    This pool is used by all SSL connections - whether HTTP/1.1 or HTTP/2, but only
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   161
     *    for SSL encrypted buffers that circulate between the SocketTube publisher and
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   162
     *    the SSLFlowDelegate Reader. Limiting the pool to this particular segment allows
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   163
     *    us to use direct buffer and avoid one more copy.
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   164
     *    See HttpClientImpl.SSLDirectBufferSupplier, SocketTube.SSLDirectBufferSource, and
fe2bf7b369b8 http-client-branch: use direct buffer pool for reading off SSL encrypted buffers from the socket + minor test fixes.
dfuchs
parents: 56451
diff changeset
   165
     *    SSLTube.recycler.
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   166
     *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   167
     */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   168
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   169
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   170
    // A small class that allows to control frames with respect to the state of
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   171
    // the connection preface. Any data received before the connection
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   172
    // preface is sent will be buffered.
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   173
    private final class FramesController {
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   174
        volatile boolean prefaceSent;
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   175
        volatile List<ByteBuffer> pending;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   176
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   177
        boolean processReceivedData(FramesDecoder decoder, ByteBuffer buf)
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   178
                throws IOException
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   179
        {
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   180
            // if preface is not sent, buffers data in the pending list
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   181
            if (!prefaceSent) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   182
                if (debug.on())
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   183
                    debug.log("Preface not sent: buffering %d", buf.remaining());
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   184
                synchronized (this) {
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   185
                    if (!prefaceSent) {
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   186
                        if (pending == null) pending = new ArrayList<>();
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   187
                        pending.add(buf);
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   188
                        if (debug.on())
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   189
                            debug.log("there are now %d bytes buffered waiting for preface to be sent"
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   190
                                    + Utils.remaining(pending)
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   191
                            );
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   192
                        return false;
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   193
                    }
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   194
                }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   195
            }
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   196
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   197
            // Preface is sent. Checks for pending data and flush it.
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   198
            // We rely on this method being called from within the Http2TubeSubscriber
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   199
            // scheduler, so we know that no other thread could execute this method
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   200
            // concurrently while we're here.
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   201
            // This ensures that later incoming buffers will not
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   202
            // be processed before we have flushed the pending queue.
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   203
            // No additional synchronization is therefore necessary here.
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   204
            List<ByteBuffer> pending = this.pending;
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   205
            this.pending = null;
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   206
            if (pending != null) {
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   207
                // flush pending data
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   208
                if (debug.on()) debug.log(() -> "Processing buffered data: "
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   209
                      + Utils.remaining(pending));
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   210
                for (ByteBuffer b : pending) {
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   211
                    decoder.decode(b);
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   212
                }
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   213
            }
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   214
            // push the received buffer to the frames decoder.
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   215
            if (buf != EMPTY_TRIGGER) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   216
                if (debug.on()) debug.log("Processing %d", buf.remaining());
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   217
                decoder.decode(buf);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   218
            }
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   219
            return true;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   220
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   221
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   222
        // Mark that the connection preface is sent
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   223
        void markPrefaceSent() {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   224
            assert !prefaceSent;
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   225
            synchronized (this) {
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   226
                prefaceSent = true;
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   227
            }
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   228
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   229
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   230
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   231
    volatile boolean closed;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   232
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   233
    //-------------------------------------
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   234
    final HttpConnection connection;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   235
    private final Http2ClientImpl client2;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   236
    private final Map<Integer,Stream<?>> streams = new ConcurrentHashMap<>();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   237
    private int nextstreamid;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   238
    private int nextPushStream = 2;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   239
    private final Encoder hpackOut;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   240
    private final Decoder hpackIn;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   241
    final SettingsFrame clientSettings;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   242
    private volatile SettingsFrame serverSettings;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   243
    private final String key; // for HttpClientImpl.connections map
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   244
    private final FramesDecoder framesDecoder;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   245
    private final FramesEncoder framesEncoder = new FramesEncoder();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   246
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   247
    /**
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   248
     * Send Window controller for both connection and stream windows.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   249
     * Each of this connection's Streams MUST use this controller.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   250
     */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   251
    private final WindowController windowController = new WindowController();
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   252
    private final FramesController framesController = new FramesController();
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   253
    private final Http2TubeSubscriber subscriber = new Http2TubeSubscriber();
48263
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
   254
    final ConnectionWindowUpdateSender windowUpdater;
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   255
    private volatile Throwable cause;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   256
    private volatile Supplier<ByteBuffer> initial;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   257
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   258
    static final int DEFAULT_FRAME_SIZE = 16 * 1024;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   259
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   260
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   261
    // TODO: need list of control frames from other threads
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   262
    // that need to be sent
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   263
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   264
    private Http2Connection(HttpConnection connection,
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   265
                            Http2ClientImpl client2,
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   266
                            int nextstreamid,
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   267
                            String key) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   268
        this.connection = connection;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   269
        this.client2 = client2;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   270
        this.nextstreamid = nextstreamid;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   271
        this.key = key;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   272
        this.clientSettings = this.client2.getClientSettings();
48263
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
   273
        this.framesDecoder = new FramesDecoder(this::processFrame,
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
   274
                clientSettings.getParameter(SettingsFrame.MAX_FRAME_SIZE));
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   275
        // serverSettings will be updated by server
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   276
        this.serverSettings = SettingsFrame.getDefaultSettings();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   277
        this.hpackOut = new Encoder(serverSettings.getParameter(HEADER_TABLE_SIZE));
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   278
        this.hpackIn = new Decoder(clientSettings.getParameter(HEADER_TABLE_SIZE));
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   279
        if (debugHpack.on()) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   280
            debugHpack.log("For the record:" + super.toString());
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   281
            debugHpack.log("Decoder created: %s", hpackIn);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   282
            debugHpack.log("Encoder created: %s", hpackOut);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   283
        }
48263
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
   284
        this.windowUpdater = new ConnectionWindowUpdateSender(this,
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
   285
                client2.getConnectionWindowSize(clientSettings));
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   286
    }
46157
f3c2dcb8d8fe 8181422: ClassCastException in HTTP Client
dfuchs
parents: 45530
diff changeset
   287
f3c2dcb8d8fe 8181422: ClassCastException in HTTP Client
dfuchs
parents: 45530
diff changeset
   288
    /**
f3c2dcb8d8fe 8181422: ClassCastException in HTTP Client
dfuchs
parents: 45530
diff changeset
   289
     * Case 1) Create from upgraded HTTP/1.1 connection.
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   290
     * Is ready to use. Can be SSL. exchange is the Exchange
46157
f3c2dcb8d8fe 8181422: ClassCastException in HTTP Client
dfuchs
parents: 45530
diff changeset
   291
     * that initiated the connection, whose response will be delivered
f3c2dcb8d8fe 8181422: ClassCastException in HTTP Client
dfuchs
parents: 45530
diff changeset
   292
     * on a Stream.
f3c2dcb8d8fe 8181422: ClassCastException in HTTP Client
dfuchs
parents: 45530
diff changeset
   293
     */
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   294
    private Http2Connection(HttpConnection connection,
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   295
                    Http2ClientImpl client2,
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   296
                    Exchange<?> exchange,
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   297
                    Supplier<ByteBuffer> initial)
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   298
        throws IOException, InterruptedException
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   299
    {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   300
        this(connection,
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   301
                client2,
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   302
                3, // stream 1 is registered during the upgrade
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   303
                keyFor(connection));
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   304
        Log.logTrace("Connection send window size {0} ", windowController.connectionWindowSize());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   305
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   306
        Stream<?> initialStream = createStream(exchange);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   307
        initialStream.registerStream(1);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   308
        windowController.registerStream(1, getInitialSendWindowSize());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   309
        initialStream.requestSent();
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   310
        // Upgrading:
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   311
        //    set callbacks before sending preface - makes sure anything that
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   312
        //    might be sent by the server will come our way.
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   313
        this.initial = initial;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   314
        connectFlows(connection);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   315
        sendConnectionPreface();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   316
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   317
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   318
    // Used when upgrading an HTTP/1.1 connection to HTTP/2 after receiving
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   319
    // agreement from the server. Async style but completes immediately, because
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   320
    // the connection is already connected.
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   321
    static CompletableFuture<Http2Connection> createAsync(HttpConnection connection,
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   322
                                                          Http2ClientImpl client2,
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   323
                                                          Exchange<?> exchange,
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   324
                                                          Supplier<ByteBuffer> initial)
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   325
    {
43984
f33383dcb1fb 8175274: Fix httpclient asynchronous usage
skuksenko
parents: 42460
diff changeset
   326
        return MinimalFuture.supply(() -> new Http2Connection(connection, client2, exchange, initial));
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   327
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   328
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   329
    // Requires TLS handshake. So, is really async
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   330
    static CompletableFuture<Http2Connection> createAsync(HttpRequestImpl request,
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   331
                                                          Http2ClientImpl h2client) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   332
        assert request.secure();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   333
        AbstractAsyncSSLConnection connection = (AbstractAsyncSSLConnection)
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   334
        HttpConnection.getConnection(request.getAddress(),
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   335
                                     h2client.client(),
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   336
                                     request,
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   337
                                     HttpClient.Version.HTTP_2);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   338
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   339
        return connection.connectAsync()
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   340
                  .thenCompose(unused -> checkSSLConfig(connection))
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   341
                  .thenCompose(notused-> {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   342
                      CompletableFuture<Http2Connection> cf = new MinimalFuture<>();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   343
                      try {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   344
                          Http2Connection hc = new Http2Connection(request, h2client, connection);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   345
                          cf.complete(hc);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   346
                      } catch (IOException e) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   347
                          cf.completeExceptionally(e);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   348
                      }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   349
                      return cf; } );
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   350
    }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   351
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   352
    /**
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   353
     * Cases 2) 3)
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   354
     *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   355
     * request is request to be sent.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   356
     */
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   357
    private Http2Connection(HttpRequestImpl request,
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   358
                            Http2ClientImpl h2client,
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   359
                            HttpConnection connection)
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   360
        throws IOException
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   361
    {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   362
        this(connection,
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   363
             h2client,
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   364
             1,
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   365
             keyFor(request.uri(), request.proxy()));
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   366
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   367
        Log.logTrace("Connection send window size {0} ", windowController.connectionWindowSize());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   368
44854
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
   369
        // safe to resume async reading now.
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   370
        connectFlows(connection);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   371
        sendConnectionPreface();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   372
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   373
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   374
    private void connectFlows(HttpConnection connection) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   375
        FlowTube tube =  connection.getConnectionFlow();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   376
        // Connect the flow to our Http2TubeSubscriber:
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   377
        tube.connectFlows(connection.publisher(), subscriber);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   378
    }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   379
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   380
    final HttpClientImpl client() {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   381
        return client2.client();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   382
    }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   383
44854
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
   384
    /**
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
   385
     * Throws an IOException if h2 was not negotiated
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
   386
     */
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   387
    private static CompletableFuture<?> checkSSLConfig(AbstractAsyncSSLConnection aconn) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   388
        assert aconn.isSecure();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   389
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   390
        Function<String, CompletableFuture<Void>> checkAlpnCF = (alpn) -> {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   391
            CompletableFuture<Void> cf = new MinimalFuture<>();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   392
            SSLEngine engine = aconn.getEngine();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   393
            assert Objects.equals(alpn, engine.getApplicationProtocol());
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   394
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   395
            DEBUG_LOGGER.log("checkSSLConfig: alpn: %s", alpn );
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   396
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   397
            if (alpn == null || !alpn.equals("h2")) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   398
                String msg;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   399
                if (alpn == null) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   400
                    Log.logSSL("ALPN not supported");
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   401
                    msg = "ALPN not supported";
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   402
                } else {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   403
                    switch (alpn) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   404
                        case "":
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   405
                            Log.logSSL(msg = "No ALPN negotiated");
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   406
                            break;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   407
                        case "http/1.1":
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   408
                            Log.logSSL( msg = "HTTP/1.1 ALPN returned");
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   409
                            break;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   410
                        default:
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   411
                            Log.logSSL(msg = "Unexpected ALPN: " + alpn);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   412
                            cf.completeExceptionally(new IOException(msg));
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   413
                    }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   414
                }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   415
                cf.completeExceptionally(new ALPNException(msg, aconn));
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   416
                return cf;
44854
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
   417
            }
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   418
            cf.complete(null);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   419
            return cf;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   420
        };
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   421
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   422
        return aconn.getALPN()
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   423
                .whenComplete((r,t) -> {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   424
                    if (t != null && t instanceof SSLException) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   425
                        // something went wrong during the initial handshake
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   426
                        // close the connection
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   427
                        aconn.close();
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   428
                    }
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   429
                })
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   430
                .thenCompose(checkAlpnCF);
44854
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
   431
    }
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
   432
48376
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   433
    synchronized boolean singleStream() {
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   434
        return singleStream;
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   435
    }
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   436
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   437
    synchronized void setSingleStream(boolean use) {
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   438
        singleStream = use;
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   439
    }
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   440
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   441
    static String keyFor(HttpConnection connection) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   442
        boolean isProxy = connection.isProxied(); // tunnel or plain clear connection through proxy
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   443
        boolean isSecure = connection.isSecure();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   444
        InetSocketAddress addr = connection.address();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   445
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   446
        return keyString(isSecure, isProxy, addr.getHostString(), addr.getPort());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   447
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   448
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   449
    static String keyFor(URI uri, InetSocketAddress proxy) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   450
        boolean isSecure = uri.getScheme().equalsIgnoreCase("https");
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   451
        boolean isProxy = proxy != null;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   452
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   453
        String host;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   454
        int port;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   455
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   456
        if (proxy != null && !isSecure) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   457
            // clear connection through proxy: use
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   458
            // proxy host / proxy port
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   459
            host = proxy.getHostString();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   460
            port = proxy.getPort();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   461
        } else {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   462
            // either secure tunnel connection through proxy
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   463
            // or direct connection to host, but in either
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   464
            // case only that host can be reached through
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   465
            // the connection: use target host / target port
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   466
            host = uri.getHost();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   467
            port = uri.getPort();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   468
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   469
        return keyString(isSecure, isProxy, host, port);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   470
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   471
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   472
    // {C,S}:{H:P}:host:port
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   473
    // C indicates clear text connection "http"
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   474
    // S indicates secure "https"
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   475
    // H indicates host (direct) connection
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   476
    // P indicates proxy
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   477
    // Eg: "S:H:foo.com:80"
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   478
    static String keyString(boolean secure, boolean proxy, String host, int port) {
48376
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   479
        if (secure && port == -1)
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   480
            port = 443;
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   481
        else if (!secure && port == -1)
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   482
            port = 80;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   483
        return (secure ? "S:" : "C:") + (proxy ? "P:" : "H:") + host + ":" + port;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   484
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   485
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   486
    String key() {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   487
        return this.key;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   488
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   489
48376
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   490
    boolean offerConnection() {
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   491
        return client2.offerConnection(this);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   492
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   493
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   494
    private HttpPublisher publisher() {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   495
        return connection.publisher();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   496
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   497
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   498
    private void decodeHeaders(HeaderFrame frame, DecodingCallback decoder)
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   499
            throws IOException
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   500
    {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   501
        if (debugHpack.on()) debugHpack.log("decodeHeaders(%s)", decoder);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   502
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   503
        boolean endOfHeaders = frame.getFlag(HeaderFrame.END_HEADERS);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   504
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   505
        List<ByteBuffer> buffers = frame.getHeaderBlock();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   506
        int len = buffers.size();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   507
        for (int i = 0; i < len; i++) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   508
            ByteBuffer b = buffers.get(i);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   509
            hpackIn.decode(b, endOfHeaders && (i == len - 1), decoder);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   510
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   511
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   512
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   513
    final int getInitialSendWindowSize() {
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   514
        return serverSettings.getParameter(INITIAL_WINDOW_SIZE);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   515
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   516
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   517
    void close() {
48376
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   518
        Log.logTrace("Closing HTTP/2 connection: to {0}", connection.address());
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   519
        GoAwayFrame f = new GoAwayFrame(0,
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   520
                                        ErrorFrame.NO_ERROR,
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   521
                                        "Requested by user".getBytes(UTF_8));
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   522
        // TODO: set last stream. For now zero ok.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   523
        sendFrame(f);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   524
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   525
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   526
    long count;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   527
    final void asyncReceive(ByteBuffer buffer) {
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   528
        // We don't need to read anything and
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   529
        // we don't want to send anything back to the server
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   530
        // until the connection preface has been sent.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   531
        // Therefore we're going to wait if needed before reading
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   532
        // (and thus replying) to anything.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   533
        // Starting to reply to something (e.g send an ACK to a
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   534
        // SettingsFrame sent by the server) before the connection
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   535
        // preface is fully sent might result in the server
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   536
        // sending a GOAWAY frame with 'invalid_preface'.
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   537
        //
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   538
        // Note: asyncReceive is only called from the Http2TubeSubscriber
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   539
        //       sequential scheduler.
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   540
        try {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   541
            Supplier<ByteBuffer> bs = initial;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   542
            // ensure that we always handle the initial buffer first,
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   543
            // if any.
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   544
            if (bs != null) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   545
                initial = null;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   546
                ByteBuffer b = bs.get();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   547
                if (b.hasRemaining()) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   548
                    long c = ++count;
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   549
                    if (debug.on())
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   550
                        debug.log(() -> "H2 Receiving Initial(" + c +"): " + b.remaining());
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   551
                    framesController.processReceivedData(framesDecoder, b);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   552
                }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   553
            }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   554
            ByteBuffer b = buffer;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   555
            // the Http2TubeSubscriber scheduler ensures that the order of incoming
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   556
            // buffers is preserved.
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   557
            if (b == EMPTY_TRIGGER) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   558
                if (debug.on()) debug.log("H2 Received EMPTY_TRIGGER");
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   559
                boolean prefaceSent = framesController.prefaceSent;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   560
                assert prefaceSent;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   561
                // call framesController.processReceivedData to potentially
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   562
                // trigger the processing of all the data buffered there.
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   563
                framesController.processReceivedData(framesDecoder, buffer);
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   564
                if (debug.on()) debug.log("H2 processed buffered data");
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   565
            } else {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   566
                long c = ++count;
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   567
                if (debug.on())
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   568
                    debug.log("H2 Receiving(%d): %d", c, b.remaining());
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   569
                framesController.processReceivedData(framesDecoder, buffer);
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   570
                if (debug.on()) debug.log("H2 processed(%d)", c);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   571
            }
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   572
        } catch (Throwable e) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   573
            String msg = Utils.stackTrace(e);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   574
            Log.logTrace(msg);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   575
            shutdown(e);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   576
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   577
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   578
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   579
    Throwable getRecordedCause() {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   580
        return cause;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   581
    }
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   582
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   583
    void shutdown(Throwable t) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   584
        if (debug.on()) debug.log(() -> "Shutting down h2c (closed="+closed+"): " + t);
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   585
        if (closed == true) return;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   586
        synchronized (this) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   587
            if (closed == true) return;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   588
            closed = true;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   589
        }
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   590
        Log.logError(t);
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   591
        Throwable initialCause = this.cause;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   592
        if (initialCause == null) this.cause = t;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   593
        client2.deleteConnection(this);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   594
        List<Stream<?>> c = new LinkedList<>(streams.values());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   595
        for (Stream<?> s : c) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   596
            s.cancelImpl(t);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   597
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   598
        connection.close();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   599
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   600
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   601
    /**
48523
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   602
     * Streams initiated by a client MUST use odd-numbered stream
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   603
     * identifiers; those initiated by the server MUST use even-numbered
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   604
     * stream identifiers.
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   605
     */
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   606
    private static final boolean isServerInitiatedStream(int streamid) {
48523
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   607
        return (streamid & 0x1) == 0;
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   608
    }
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   609
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   610
    /**
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   611
     * Handles stream 0 (common) frames that apply to whole connection and passes
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   612
     * other stream specific frames to that Stream object.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   613
     *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   614
     * Invokes Stream.incoming() which is expected to process frame without
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   615
     * blocking.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   616
     */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   617
    void processFrame(Http2Frame frame) throws IOException {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   618
        Log.logFrames(frame, "IN");
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   619
        int streamid = frame.streamid();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   620
        if (frame instanceof MalformedFrame) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   621
            Log.logError(((MalformedFrame) frame).getMessage());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   622
            if (streamid == 0) {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   623
                framesDecoder.close("Malformed frame on stream 0");
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   624
                protocolError(((MalformedFrame) frame).getErrorCode(),
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   625
                        ((MalformedFrame) frame).getMessage());
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   626
            } else {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   627
                if (debug.on())
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   628
                    debug.log(() -> "Reset stream: " + ((MalformedFrame) frame).getMessage());
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   629
                resetStream(streamid, ((MalformedFrame) frame).getErrorCode());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   630
            }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   631
            return;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   632
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   633
        if (streamid == 0) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   634
            handleConnectionFrame(frame);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   635
        } else {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   636
            if (frame instanceof SettingsFrame) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   637
                // The stream identifier for a SETTINGS frame MUST be zero
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   638
                framesDecoder.close(
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   639
                        "The stream identifier for a SETTINGS frame MUST be zero");
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   640
                protocolError(GoAwayFrame.PROTOCOL_ERROR);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   641
                return;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   642
            }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   643
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   644
            Stream<?> stream = getStream(streamid);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   645
            if (stream == null) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   646
                // Should never receive a frame with unknown stream id
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   647
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   648
                if (frame instanceof HeaderFrame) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   649
                    // always decode the headers as they may affect
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   650
                    // connection-level HPACK decoding state
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   651
                    DecodingCallback decoder = new ValidatingHeadersConsumer();
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   652
                    try {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   653
                        decodeHeaders((HeaderFrame) frame, decoder);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   654
                    } catch (UncheckedIOException e) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   655
                        protocolError(ResetFrame.PROTOCOL_ERROR, e.getMessage());
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   656
                        return;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   657
                    }
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   658
                }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   659
48523
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   660
                if (!(frame instanceof ResetFrame)) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   661
                    if (isServerInitiatedStream(streamid)) {
48523
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   662
                        if (streamid < nextPushStream) {
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   663
                            // trailing data on a cancelled push promise stream,
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   664
                            // reset will already have been sent, ignore
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   665
                            Log.logTrace("Ignoring cancelled push promise frame " + frame);
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   666
                        } else {
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   667
                            resetStream(streamid, ResetFrame.PROTOCOL_ERROR);
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   668
                        }
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   669
                    } else if (streamid >= nextstreamid) {
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   670
                        // otherwise the stream has already been reset/closed
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   671
                        resetStream(streamid, ResetFrame.PROTOCOL_ERROR);
b95b08f3e1a8 8194883: Unhandleable Push Promises should be cancelled
chegar
parents: 48376
diff changeset
   672
                    }
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   673
                }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   674
                return;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   675
            }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   676
            if (frame instanceof PushPromiseFrame) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   677
                PushPromiseFrame pp = (PushPromiseFrame)frame;
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   678
                try {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   679
                    handlePushPromise(stream, pp);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   680
                } catch (UncheckedIOException e) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   681
                    protocolError(ResetFrame.PROTOCOL_ERROR, e.getMessage());
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   682
                    return;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   683
                }
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   684
            } else if (frame instanceof HeaderFrame) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   685
                // decode headers (or continuation)
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   686
                try {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   687
                    decodeHeaders((HeaderFrame) frame, stream.rspHeadersConsumer());
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   688
                } catch (UncheckedIOException e) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   689
                    protocolError(ResetFrame.PROTOCOL_ERROR, e.getMessage());
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   690
                    return;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   691
                }
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   692
                stream.incoming(frame);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   693
            } else {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   694
                stream.incoming(frame);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   695
            }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   696
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   697
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   698
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   699
    private <T> void handlePushPromise(Stream<T> parent, PushPromiseFrame pp)
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   700
        throws IOException
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   701
    {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   702
        // always decode the headers as they may affect connection-level HPACK
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   703
        // decoding state
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   704
        HeaderDecoder decoder = new HeaderDecoder();
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   705
        decodeHeaders(pp, decoder);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   706
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   707
        HttpRequestImpl parentReq = parent.request;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   708
        int promisedStreamid = pp.getPromisedStream();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   709
        if (promisedStreamid != nextPushStream) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   710
            resetStream(promisedStreamid, ResetFrame.PROTOCOL_ERROR);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   711
            return;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   712
        } else {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   713
            nextPushStream += 2;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   714
        }
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   715
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   716
        HttpHeadersImpl headers = decoder.headers();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   717
        HttpRequestImpl pushReq = HttpRequestImpl.createPushRequest(parentReq, headers);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   718
        Exchange<T> pushExch = new Exchange<>(pushReq, parent.exchange.multi);
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   719
        Stream.PushedStream<T> pushStream = createPushStream(parent, pushExch);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   720
        pushExch.exchImpl = pushStream;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   721
        pushStream.registerStream(promisedStreamid);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   722
        parent.incoming_pushPromise(pushReq, pushStream);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   723
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   724
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   725
    private void handleConnectionFrame(Http2Frame frame)
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   726
        throws IOException
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   727
    {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   728
        switch (frame.type()) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   729
          case SettingsFrame.TYPE:
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   730
              handleSettings((SettingsFrame)frame);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   731
              break;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   732
          case PingFrame.TYPE:
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   733
              handlePing((PingFrame)frame);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   734
              break;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   735
          case GoAwayFrame.TYPE:
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   736
              handleGoAway((GoAwayFrame)frame);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   737
              break;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   738
          case WindowUpdateFrame.TYPE:
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   739
              handleWindowUpdate((WindowUpdateFrame)frame);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   740
              break;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   741
          default:
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   742
            protocolError(ErrorFrame.PROTOCOL_ERROR);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   743
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   744
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   745
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   746
    void resetStream(int streamid, int code) throws IOException {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   747
        Log.logError(
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   748
            "Resetting stream {0,number,integer} with error code {1,number,integer}",
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   749
            streamid, code);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   750
        ResetFrame frame = new ResetFrame(streamid, code);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   751
        sendFrame(frame);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   752
        closeStream(streamid);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   753
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   754
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   755
    void closeStream(int streamid) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   756
        if (debug.on()) debug.log("Closed stream %d", streamid);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   757
        Stream<?> s = streams.remove(streamid);
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   758
        if (s != null) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   759
            // decrement the reference count on the HttpClientImpl
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   760
            // to allow the SelectorManager thread to exit if no
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   761
            // other operation is pending and the facade is no
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   762
            // longer referenced.
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   763
            client().streamUnreference();
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   764
        }
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   765
        // ## Remove s != null. It is a hack for delayed cancellation,reset
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   766
        if (s != null && !(s instanceof Stream.PushedStream)) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   767
            // Since PushStreams have no request body, then they have no
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   768
            // corresponding entry in the window controller.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   769
            windowController.removeStream(streamid);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   770
        }
48376
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   771
        if (singleStream() && streams.isEmpty()) {
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   772
            // should be only 1 stream, but there might be more if server push
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   773
            close();
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   774
        }
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   775
    }
48376
41ae5c69b09c 8192966: HttpClient should reuse TCP connection for h2c connections
michaelm
parents: 48263
diff changeset
   776
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   777
    /**
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   778
     * Increments this connection's send Window by the amount in the given frame.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   779
     */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   780
    private void handleWindowUpdate(WindowUpdateFrame f)
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   781
        throws IOException
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   782
    {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   783
        int amount = f.getUpdate();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   784
        if (amount <= 0) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   785
            // ## temporarily disable to workaround a bug in Jetty where it
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   786
            // ## sends Window updates with a 0 update value.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   787
            //protocolError(ErrorFrame.PROTOCOL_ERROR);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   788
        } else {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   789
            boolean success = windowController.increaseConnectionWindow(amount);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   790
            if (!success) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   791
                protocolError(ErrorFrame.FLOW_CONTROL_ERROR);  // overflow
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   792
            }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   793
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   794
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   795
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   796
    private void protocolError(int errorCode)
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   797
        throws IOException
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   798
    {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   799
        protocolError(errorCode, null);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   800
    }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   801
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   802
    private void protocolError(int errorCode, String msg)
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   803
        throws IOException
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   804
    {
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   805
        GoAwayFrame frame = new GoAwayFrame(0, errorCode);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   806
        sendFrame(frame);
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   807
        shutdown(new IOException("protocol error" + (msg == null?"":(": " + msg))));
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   808
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   809
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   810
    private void handleSettings(SettingsFrame frame)
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   811
        throws IOException
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   812
    {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   813
        assert frame.streamid() == 0;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   814
        if (!frame.getFlag(SettingsFrame.ACK)) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   815
            int newWindowSize = frame.getParameter(INITIAL_WINDOW_SIZE);
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   816
            if (newWindowSize != -1) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   817
                int oldWindowSize = serverSettings.getParameter(INITIAL_WINDOW_SIZE);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   818
                int diff = newWindowSize - oldWindowSize;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   819
                if (diff != 0) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   820
                    windowController.adjustActiveStreams(diff);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   821
                }
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   822
            }
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   823
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   824
            serverSettings.update(frame);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   825
            sendFrame(new SettingsFrame(SettingsFrame.ACK));
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   826
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   827
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   828
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   829
    private void handlePing(PingFrame frame)
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   830
        throws IOException
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   831
    {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   832
        frame.setFlag(PingFrame.ACK);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   833
        sendUnorderedFrame(frame);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   834
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   835
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   836
    private void handleGoAway(GoAwayFrame frame)
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   837
        throws IOException
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   838
    {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   839
        shutdown(new IOException(
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   840
                        String.valueOf(connection.channel().getLocalAddress())
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   841
                        +": GOAWAY received"));
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   842
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   843
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   844
    /**
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   845
     * Max frame size we are allowed to send
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   846
     */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   847
    public int getMaxSendFrameSize() {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   848
        int param = serverSettings.getParameter(MAX_FRAME_SIZE);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   849
        if (param == -1) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   850
            param = DEFAULT_FRAME_SIZE;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   851
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   852
        return param;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   853
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   854
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   855
    /**
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   856
     * Max frame size we will receive
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   857
     */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   858
    public int getMaxReceiveFrameSize() {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   859
        return clientSettings.getParameter(MAX_FRAME_SIZE);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   860
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   861
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   862
    private static final String CLIENT_PREFACE = "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n";
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   863
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   864
    private static final byte[] PREFACE_BYTES =
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   865
        CLIENT_PREFACE.getBytes(StandardCharsets.ISO_8859_1);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   866
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   867
    /**
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   868
     * Sends Connection preface and Settings frame with current preferred
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   869
     * values
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   870
     */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   871
    private void sendConnectionPreface() throws IOException {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   872
        Log.logTrace("{0}: start sending connection preface to {1}",
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   873
                     connection.channel().getLocalAddress(),
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   874
                     connection.address());
48263
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
   875
        SettingsFrame sf = new SettingsFrame(clientSettings);
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
   876
        int initialWindowSize = sf.getParameter(INITIAL_WINDOW_SIZE);
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   877
        ByteBuffer buf = framesEncoder.encodeConnectionPreface(PREFACE_BYTES, sf);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   878
        Log.logFrames(sf, "OUT");
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   879
        // send preface bytes and SettingsFrame together
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   880
        HttpPublisher publisher = publisher();
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   881
        publisher.enqueueUnordered(List.of(buf));
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   882
        publisher.signalEnqueued();
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   883
        // mark preface sent.
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   884
        framesController.markPrefaceSent();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   885
        Log.logTrace("PREFACE_BYTES sent");
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   886
        Log.logTrace("Settings Frame sent");
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   887
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   888
        // send a Window update for the receive buffer we are using
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   889
        // minus the initial 64 K specified in protocol
48263
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
   890
        final int len = windowUpdater.initialWindowSize - initialWindowSize;
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
   891
        if (len > 0) {
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
   892
            windowUpdater.sendWindowUpdate(len);
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
   893
        }
45530
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   894
        // there will be an ACK to the windows update - which should
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   895
        // cause any pending data stored before the preface was sent to be
3c98842fddf7 8181430: HTTP/2 client might deadlock when receiving data during the initial handshake
dfuchs
parents: 44854
diff changeset
   896
        // flushed (see PrefaceController).
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   897
        Log.logTrace("finished sending connection preface");
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   898
        if (debug.on())
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   899
            debug.log("Triggering processing of buffered data"
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   900
                      + " after sending connection preface");
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   901
        subscriber.onNext(List.of(EMPTY_TRIGGER));
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   902
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   903
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   904
    /**
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   905
     * Returns an existing Stream with given id, or null if doesn't exist
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   906
     */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   907
    @SuppressWarnings("unchecked")
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   908
    <T> Stream<T> getStream(int streamid) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   909
        return (Stream<T>)streams.get(streamid);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   910
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   911
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   912
    /**
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   913
     * Creates Stream with given id.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   914
     */
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   915
    final <T> Stream<T> createStream(Exchange<T> exchange) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   916
        Stream<T> stream = new Stream<>(this, exchange, windowController);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   917
        return stream;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   918
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   919
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   920
    <T> Stream.PushedStream<T> createPushStream(Stream<T> parent, Exchange<T> pushEx) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   921
        PushGroup<T> pg = parent.exchange.getPushGroup();
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   922
        return new Stream.PushedStream<>(pg, this, pushEx);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   923
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   924
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   925
    <T> void putStream(Stream<T> stream, int streamid) {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   926
        // increment the reference count on the HttpClientImpl
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   927
        // to prevent the SelectorManager thread from exiting until
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   928
        // the stream is closed.
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   929
        client().streamReference();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   930
        streams.put(streamid, stream);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   931
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   932
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   933
    /**
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   934
     * Encode the headers into a List<ByteBuffer> and then create HEADERS
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   935
     * and CONTINUATION frames from the list and return the List<Http2Frame>.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   936
     */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   937
    private List<HeaderFrame> encodeHeaders(OutgoingHeaders<Stream<?>> frame) {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   938
        List<ByteBuffer> buffers = encodeHeadersImpl(
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   939
                getMaxSendFrameSize(),
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   940
                frame.getAttachment().getRequestPseudoHeaders(),
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   941
                frame.getUserHeaders(),
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   942
                frame.getSystemHeaders());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   943
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   944
        List<HeaderFrame> frames = new ArrayList<>(buffers.size());
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   945
        Iterator<ByteBuffer> bufIterator = buffers.iterator();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   946
        HeaderFrame oframe = new HeadersFrame(frame.streamid(), frame.getFlags(), bufIterator.next());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   947
        frames.add(oframe);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   948
        while(bufIterator.hasNext()) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   949
            oframe = new ContinuationFrame(frame.streamid(), bufIterator.next());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   950
            frames.add(oframe);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   951
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   952
        oframe.setFlag(HeaderFrame.END_HEADERS);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   953
        return frames;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   954
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   955
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   956
    // Dedicated cache for headers encoding ByteBuffer.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   957
    // There can be no concurrent access to this  buffer as all access to this buffer
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   958
    // and its content happen within a single critical code block section protected
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   959
    // by the sendLock. / (see sendFrame())
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   960
    // private final ByteBufferPool headerEncodingPool = new ByteBufferPool();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   961
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   962
    private ByteBuffer getHeaderBuffer(int maxFrameSize) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   963
        ByteBuffer buf = ByteBuffer.allocate(maxFrameSize);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   964
        buf.limit(maxFrameSize);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   965
        return buf;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   966
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   967
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   968
    /*
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   969
     * Encodes all the headers from the given HttpHeaders into the given List
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   970
     * of buffers.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   971
     *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   972
     * From https://tools.ietf.org/html/rfc7540#section-8.1.2 :
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   973
     *
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   974
     *     ...Just as in HTTP/1.x, header field names are strings of ASCII
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   975
     *     characters that are compared in a case-insensitive fashion.  However,
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   976
     *     header field names MUST be converted to lowercase prior to their
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   977
     *     encoding in HTTP/2...
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   978
     */
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   979
    private List<ByteBuffer> encodeHeadersImpl(int maxFrameSize, HttpHeaders... headers) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   980
        ByteBuffer buffer = getHeaderBuffer(maxFrameSize);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   981
        List<ByteBuffer> buffers = new ArrayList<>();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   982
        for(HttpHeaders header : headers) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   983
            for (Map.Entry<String, List<String>> e : header.map().entrySet()) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
   984
                String lKey = e.getKey().toLowerCase(Locale.US);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   985
                List<String> values = e.getValue();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   986
                for (String value : values) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   987
                    hpackOut.header(lKey, value);
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   988
                    while (!hpackOut.encode(buffer)) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   989
                        buffer.flip();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   990
                        buffers.add(buffer);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   991
                        buffer =  getHeaderBuffer(maxFrameSize);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   992
                    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   993
                }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   994
            }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   995
        }
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
   996
        buffer.flip();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   997
        buffers.add(buffer);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   998
        return buffers;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
   999
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1000
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1001
    private List<ByteBuffer> encodeHeaders(OutgoingHeaders<Stream<?>> oh, Stream<?> stream) {
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1002
        oh.streamid(stream.streamid);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1003
        if (Log.headers()) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1004
            StringBuilder sb = new StringBuilder("HEADERS FRAME (stream=");
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1005
            sb.append(stream.streamid).append(")\n");
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1006
            Log.dumpHeaders(sb, "    ", oh.getAttachment().getRequestPseudoHeaders());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1007
            Log.dumpHeaders(sb, "    ", oh.getSystemHeaders());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1008
            Log.dumpHeaders(sb, "    ", oh.getUserHeaders());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1009
            Log.logHeaders(sb.toString());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1010
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1011
        List<HeaderFrame> frames = encodeHeaders(oh);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1012
        return encodeFrames(frames);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1013
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1014
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1015
    private List<ByteBuffer> encodeFrames(List<HeaderFrame> frames) {
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1016
        if (Log.frames()) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1017
            frames.forEach(f -> Log.logFrames(f, "OUT"));
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1018
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1019
        return framesEncoder.encodeFrames(frames);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1020
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1021
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1022
    private Stream<?> registerNewStream(OutgoingHeaders<Stream<?>> oh) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1023
        Stream<?> stream = oh.getAttachment();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1024
        int streamid = nextstreamid;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1025
        nextstreamid += 2;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1026
        stream.registerStream(streamid);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1027
        // set outgoing window here. This allows thread sending
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1028
        // body to proceed.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1029
        windowController.registerStream(streamid, getInitialSendWindowSize());
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1030
        return stream;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1031
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1032
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1033
    private final Object sendlock = new Object();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1034
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1035
    void sendFrame(Http2Frame frame) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1036
        try {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1037
            HttpPublisher publisher = publisher();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1038
            synchronized (sendlock) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1039
                if (frame instanceof OutgoingHeaders) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1040
                    @SuppressWarnings("unchecked")
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1041
                    OutgoingHeaders<Stream<?>> oh = (OutgoingHeaders<Stream<?>>) frame;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1042
                    Stream<?> stream = registerNewStream(oh);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1043
                    // provide protection from inserting unordered frames between Headers and Continuation
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1044
                    publisher.enqueue(encodeHeaders(oh, stream));
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1045
                } else {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1046
                    publisher.enqueue(encodeFrame(frame));
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1047
                }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1048
            }
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1049
            publisher.signalEnqueued();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1050
        } catch (IOException e) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1051
            if (!closed) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1052
                Log.logError(e);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1053
                shutdown(e);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1054
            }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1055
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1056
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1057
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1058
    private List<ByteBuffer> encodeFrame(Http2Frame frame) {
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1059
        Log.logFrames(frame, "OUT");
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1060
        return framesEncoder.encodeFrame(frame);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1061
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1062
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1063
    void sendDataFrame(DataFrame frame) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1064
        try {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1065
            HttpPublisher publisher = publisher();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1066
            publisher.enqueue(encodeFrame(frame));
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1067
            publisher.signalEnqueued();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1068
        } catch (IOException e) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1069
            if (!closed) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1070
                Log.logError(e);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1071
                shutdown(e);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1072
            }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1073
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1074
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1075
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1076
    /*
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1077
     * Direct call of the method bypasses synchronization on "sendlock" and
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1078
     * allowed only of control frames: WindowUpdateFrame, PingFrame and etc.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1079
     * prohibited for such frames as DataFrame, HeadersFrame, ContinuationFrame.
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1080
     */
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1081
    void sendUnorderedFrame(Http2Frame frame) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1082
        try {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1083
            HttpPublisher publisher = publisher();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1084
            publisher.enqueueUnordered(encodeFrame(frame));
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1085
            publisher.signalEnqueued();
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1086
        } catch (IOException e) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1087
            if (!closed) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1088
                Log.logError(e);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1089
                shutdown(e);
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1090
            }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1091
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1092
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1093
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1094
    /**
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1095
     * A simple tube subscriber for reading from the connection flow.
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1096
     */
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1097
    final class Http2TubeSubscriber implements TubeSubscriber {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1098
        volatile Flow.Subscription subscription;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1099
        volatile boolean completed;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1100
        volatile boolean dropped;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1101
        volatile Throwable error;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1102
        final ConcurrentLinkedQueue<ByteBuffer> queue
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1103
                = new ConcurrentLinkedQueue<>();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1104
        final SequentialScheduler scheduler =
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1105
                SequentialScheduler.synchronizedScheduler(this::processQueue);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1106
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1107
        final void processQueue() {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1108
            try {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1109
                while (!queue.isEmpty() && !scheduler.isStopped()) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1110
                    ByteBuffer buffer = queue.poll();
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1111
                    if (debug.on())
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1112
                        debug.log("sending %d to Http2Connection.asyncReceive",
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1113
                                  buffer.remaining());
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1114
                    asyncReceive(buffer);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1115
                }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1116
            } catch (Throwable t) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1117
                Throwable x = error;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1118
                if (x == null) error = t;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1119
            } finally {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1120
                Throwable x = error;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1121
                if (x != null) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1122
                    if (debug.on()) debug.log("Stopping scheduler", x);
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1123
                    scheduler.stop();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1124
                    Http2Connection.this.shutdown(x);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1125
                }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1126
            }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1127
        }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1128
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1129
        @Override
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1130
        public void onSubscribe(Flow.Subscription subscription) {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1131
            // supports being called multiple time.
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1132
            // doesn't cancel the previous subscription, since that is
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1133
            // most probably the same as the new subscription.
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1134
            assert this.subscription == null || dropped == false;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1135
            this.subscription = subscription;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1136
            dropped = false;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1137
            // TODO FIXME: request(1) should be done by the delegate.
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1138
            if (!completed) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1139
                if (debug.on())
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1140
                    debug.log("onSubscribe: requesting Long.MAX_VALUE for reading");
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1141
                subscription.request(Long.MAX_VALUE);
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1142
            } else {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1143
                if (debug.on()) debug.log("onSubscribe: already completed");
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1144
            }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1145
        }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1146
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1147
        @Override
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1148
        public void onNext(List<ByteBuffer> item) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1149
            if (debug.on()) debug.log(() -> "onNext: got " + Utils.remaining(item)
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1150
                    + " bytes in " + item.size() + " buffers");
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1151
            queue.addAll(item);
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1152
            scheduler.runOrSchedule(client().theExecutor());
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1153
        }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1154
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1155
        @Override
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1156
        public void onError(Throwable throwable) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1157
            if (debug.on()) debug.log(() -> "onError: " + throwable);
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1158
            error = throwable;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1159
            completed = true;
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1160
            scheduler.runOrSchedule(client().theExecutor());
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1161
        }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1162
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1163
        @Override
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1164
        public void onComplete() {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1165
            if (debug.on()) debug.log("EOF");
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1166
            error = new EOFException("EOF reached while reading");
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1167
            completed = true;
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1168
            scheduler.runOrSchedule(client().theExecutor());
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1169
        }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1170
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1171
        @Override
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1172
        public void dropSubscription() {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1173
            if (debug.on()) debug.log("dropSubscription");
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1174
            // we could probably set subscription to null here...
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1175
            // then we might not need the 'dropped' boolean?
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1176
            dropped = true;
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1177
        }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1178
    }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1179
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1180
    @Override
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1181
    public final String toString() {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1182
        return dbgString();
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1183
    }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1184
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1185
    final String dbgString() {
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1186
        return "Http2Connection("
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1187
                    + connection.getConnectionFlow() + ")";
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1188
    }
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1189
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1190
    static class HeaderDecoder extends ValidatingHeadersConsumer {
48083
b1c1b4ef4be2 8191494: Refresh incubating HTTP Client
chegar
parents: 47216
diff changeset
  1191
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1192
        HttpHeadersImpl headers;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1193
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1194
        HeaderDecoder() {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1195
            this.headers = new HttpHeadersImpl();
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1196
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1197
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1198
        @Override
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1199
        public void onDecoded(CharSequence name, CharSequence value) {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1200
            String n = name.toString();
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1201
            String v = value.toString();
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1202
            super.onDecoded(n, v);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1203
            headers.addHeader(n, v);
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1204
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1205
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1206
        HttpHeadersImpl headers() {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1207
            return headers;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1208
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1209
    }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1210
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1211
    /*
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1212
     * Checks RFC 7540 rules (relaxed) compliance regarding pseudo-headers.
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1213
     */
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1214
    static class ValidatingHeadersConsumer implements DecodingCallback {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1215
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1216
        private static final Set<String> PSEUDO_HEADERS =
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1217
                Set.of(":authority", ":method", ":path", ":scheme", ":status");
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1218
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1219
        /** Used to check that if there are pseudo-headers, they go first */
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1220
        private boolean pseudoHeadersEnded;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1221
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1222
        /**
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1223
         * Called when END_HEADERS was received. This consumer may be invoked
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1224
         * again after reset() is called, but for a whole new set of headers.
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1225
         */
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1226
        void reset() {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1227
            pseudoHeadersEnded = false;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1228
        }
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1229
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1230
        @Override
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1231
        public void onDecoded(CharSequence name, CharSequence value)
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1232
                throws UncheckedIOException
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1233
        {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1234
            String n = name.toString();
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1235
            if (n.startsWith(":")) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1236
                if (pseudoHeadersEnded) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1237
                    throw newException("Unexpected pseudo-header '%s'", n);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1238
                } else if (!PSEUDO_HEADERS.contains(n)) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1239
                    throw newException("Unknown pseudo-header '%s'", n);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1240
                }
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1241
            } else {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1242
                pseudoHeadersEnded = true;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1243
                if (!Utils.isValidName(n)) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1244
                    throw newException("Bad header name '%s'", n);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1245
                }
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1246
            }
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1247
            String v = value.toString();
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1248
            if (!Utils.isValidValue(v)) {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1249
                throw newException("Bad header value '%s'", v);
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1250
            }
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1251
        }
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1252
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1253
        private UncheckedIOException newException(String message, String header)
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1254
        {
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1255
            return new UncheckedIOException(
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1256
                    new IOException(String.format(message, header)));
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1257
        }
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1258
    }
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1259
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1260
    static final class ConnectionWindowUpdateSender extends WindowUpdateSender {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1261
48263
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
  1262
        final int initialWindowSize;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1263
        public ConnectionWindowUpdateSender(Http2Connection connection,
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1264
                                            int initialWindowSize) {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1265
            super(connection, initialWindowSize);
48263
a559b7cd1dea 8193370: Provide more user friendly defaults for HTTP/2 client settings
dfuchs
parents: 48083
diff changeset
  1266
            this.initialWindowSize = initialWindowSize;
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1267
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1268
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1269
        @Override
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1270
        int getStreamId() {
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1271
            return 0;
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1272
        }
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1273
    }
44854
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1274
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1275
    /**
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1276
     * Thrown when https handshake negotiates http/1.1 alpn instead of h2
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1277
     */
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1278
    static final class ALPNException extends IOException {
49765
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1279
        private static final long serialVersionUID = 0L;
ee6f7a61f3a5 8197564: HTTP Client implementation
chegar
parents: 48523
diff changeset
  1280
        final transient AbstractAsyncSSLConnection connection;
44854
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1281
46157
f3c2dcb8d8fe 8181422: ClassCastException in HTTP Client
dfuchs
parents: 45530
diff changeset
  1282
        ALPNException(String msg, AbstractAsyncSSLConnection connection) {
44854
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1283
            super(msg);
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1284
            this.connection = connection;
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1285
        }
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1286
46157
f3c2dcb8d8fe 8181422: ClassCastException in HTTP Client
dfuchs
parents: 45530
diff changeset
  1287
        AbstractAsyncSSLConnection getConnection() {
44854
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1288
            return connection;
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1289
        }
5a486e0acd29 8175814: Update default HttpClient protocol version and optional request version
michaelm
parents: 43984
diff changeset
  1290
    }
42460
7133f144981a 8170648: Move java.net.http package out of Java SE to incubator namespace
michaelm
parents:
diff changeset
  1291
}