src/java.base/share/classes/java/net/HttpConnectSocketImpl.java
author alanb
Fri, 01 Mar 2019 18:28:44 +0000
branchniosocketimpl-branch
changeset 57238 b145b1b04106
parent 57212 28b0946d3b81
child 57240 f0e45a80ab8f
permissions -rw-r--r--
HttpURLConnection.doTunneling can fail with IOE
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
     1
/*
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
     2
 * Copyright (c) 2010, 2013, Oracle and/or its affiliates. All rights reserved.
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
     3
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
     4
 *
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
     5
 * This code is free software; you can redistribute it and/or modify it
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
     6
 * under the terms of the GNU General Public License version 2 only, as
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
     7
 * published by the Free Software Foundation.  Oracle designates this
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
     8
 * particular file as subject to the "Classpath" exception as provided
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
     9
 * by Oracle in the LICENSE file that accompanied this code.
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    10
 *
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    11
 * This code is distributed in the hope that it will be useful, but WITHOUT
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    12
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    13
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    14
 * version 2 for more details (a copy is included in the LICENSE file that
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    15
 * accompanied this code).
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    16
 *
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    17
 * You should have received a copy of the GNU General Public License version
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    18
 * 2 along with this work; if not, write to the Free Software Foundation,
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    19
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    20
 *
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    21
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    22
 * or visit www.oracle.com if you need additional information or have any
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    23
 * questions.
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    24
 */
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    25
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    26
package java.net;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    27
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    28
import java.io.IOException;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    29
import java.lang.reflect.Field;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    30
import java.lang.reflect.Method;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    31
import java.util.HashMap;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    32
import java.util.Map;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    33
import java.util.Set;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    34
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    35
/**
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    36
 * Basic SocketImpl that relies on the internal HTTP protocol handler
57212
28b0946d3b81 Cleanup/comments
alanb
parents: 57172
diff changeset
    37
 * implementation to perform the HTTP tunneling and authentication. Once
28b0946d3b81 Cleanup/comments
alanb
parents: 57172
diff changeset
    38
 * connected, all socket operations delegate to a platform SocketImpl.
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    39
 *
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    40
 * @since 1.8
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    41
 */
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    42
57172
63ab5af5d009 Moving delegating SocketImpl to its own class
alanb
parents: 57171
diff changeset
    43
/*package*/ class HttpConnectSocketImpl extends DelegatingSocketImpl {
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    44
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    45
    private static final String httpURLClazzStr =
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    46
                                  "sun.net.www.protocol.http.HttpURLConnection";
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    47
    private static final String netClientClazzStr = "sun.net.NetworkClient";
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    48
    private static final String doTunnelingStr = "doTunneling";
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    49
    private static final Field httpField;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    50
    private static final Field serverSocketField;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    51
    private static final Method doTunneling;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    52
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    53
    private final String server;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    54
    private InetSocketAddress external_address;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    55
    private HashMap<Integer, Object> optionsMap = new HashMap<>();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    56
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    57
    static  {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    58
        try {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    59
            Class<?> httpClazz = Class.forName(httpURLClazzStr, true, null);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    60
            httpField = httpClazz.getDeclaredField("http");
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    61
            doTunneling = httpClazz.getDeclaredMethod(doTunnelingStr);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    62
            Class<?> netClientClazz = Class.forName(netClientClazzStr, true, null);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    63
            serverSocketField = netClientClazz.getDeclaredField("serverSocket");
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    64
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    65
            java.security.AccessController.doPrivileged(
29986
97167d851fc4 8078467: Update core libraries to use diamond with anonymous classes
darcy
parents: 25859
diff changeset
    66
                new java.security.PrivilegedAction<>() {
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    67
                    public Void run() {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    68
                        httpField.setAccessible(true);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    69
                        serverSocketField.setAccessible(true);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    70
                        return null;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    71
                }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    72
            });
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    73
        } catch (ReflectiveOperationException x) {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    74
            throw new InternalError("Should not reach here", x);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    75
        }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    76
    }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    77
57167
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
    78
    HttpConnectSocketImpl(Proxy proxy, SocketImpl delegate) {
57172
63ab5af5d009 Moving delegating SocketImpl to its own class
alanb
parents: 57171
diff changeset
    79
        super(delegate);
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    80
        SocketAddress a = proxy.address();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    81
        if ( !(a instanceof InetSocketAddress) )
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    82
            throw new IllegalArgumentException("Unsupported address type");
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    83
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    84
        InetSocketAddress ad = (InetSocketAddress) a;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    85
        server = ad.getHostString();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    86
        port = ad.getPort();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    87
    }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    88
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
    89
    @Override
57110
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
    90
    protected void connect(String host, int port) throws IOException {
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
    91
        connect(new InetSocketAddress(host, port), 0);
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
    92
    }
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
    93
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
    94
    @Override
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
    95
    protected void connect(InetAddress address, int port) throws IOException {
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
    96
        connect(new InetSocketAddress(address, port), 0);
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
    97
    }
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
    98
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
    99
    @Override
57167
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   100
    void setSocket(Socket socket) {
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   101
        delegate.socket = socket;
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   102
        super.setSocket(socket);
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   103
    }
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   104
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   105
    @Override
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   106
    void setServerSocket(ServerSocket socket) {
57172
63ab5af5d009 Moving delegating SocketImpl to its own class
alanb
parents: 57171
diff changeset
   107
        throw new InternalError("should not get here");
57167
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   108
    }
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   109
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   110
    @Override
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   111
    protected void connect(SocketAddress endpoint, int timeout)
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   112
        throws IOException
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   113
    {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   114
        if (endpoint == null || !(endpoint instanceof InetSocketAddress))
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   115
            throw new IllegalArgumentException("Unsupported address type");
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   116
        final InetSocketAddress epoint = (InetSocketAddress)endpoint;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   117
        final String destHost = epoint.isUnresolved() ? epoint.getHostName()
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   118
                                                      : epoint.getAddress().getHostAddress();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   119
        final int destPort = epoint.getPort();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   120
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   121
        SecurityManager security = System.getSecurityManager();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   122
        if (security != null)
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   123
            security.checkConnect(destHost, destPort);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   124
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   125
        // Connect to the HTTP proxy server
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   126
        String urlString = "http://" + destHost + ":" + destPort;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   127
        Socket httpSocket = privilegedDoTunnel(urlString, timeout);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   128
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   129
        // Success!
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   130
        external_address = epoint;
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   131
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   132
        // close the original socket impl and release its descriptor
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   133
        close();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   134
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   135
        // update the Sockets impl to the impl from the http Socket
57110
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
   136
        SocketImpl si = httpSocket.impl;
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
   137
        ((SocketImpl) this).getSocket().setImpl(si);
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   138
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   139
        // best effort is made to try and reset options previously set
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   140
        Set<Map.Entry<Integer,Object>> options = optionsMap.entrySet();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   141
        try {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   142
            for(Map.Entry<Integer,Object> entry : options) {
57110
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
   143
                si.setOption(entry.getKey(), entry.getValue());
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   144
            }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   145
        } catch (IOException x) {  /* gulp! */  }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   146
    }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   147
57167
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   148
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   149
    @Override
57172
63ab5af5d009 Moving delegating SocketImpl to its own class
alanb
parents: 57171
diff changeset
   150
    protected void listen(int backlog) {
63ab5af5d009 Moving delegating SocketImpl to its own class
alanb
parents: 57171
diff changeset
   151
        throw new InternalError("should not get here");
57167
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   152
    }
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   153
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   154
    @Override
57172
63ab5af5d009 Moving delegating SocketImpl to its own class
alanb
parents: 57171
diff changeset
   155
    protected void accept(SocketImpl s) {
63ab5af5d009 Moving delegating SocketImpl to its own class
alanb
parents: 57171
diff changeset
   156
        throw new InternalError("should not get here");
57167
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   157
    }
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   158
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   159
    @Override
57212
28b0946d3b81 Cleanup/comments
alanb
parents: 57172
diff changeset
   160
    void reset() {
28b0946d3b81 Cleanup/comments
alanb
parents: 57172
diff changeset
   161
        throw new InternalError("should not get here");
57167
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   162
    }
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   163
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   164
    @Override
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   165
    public void setOption(int opt, Object val) throws SocketException {
57167
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   166
        delegate.setOption(opt, val);
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   167
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   168
        if (external_address != null)
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   169
            return;  // we're connected, just return
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   170
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   171
        // store options so that they can be re-applied to the impl after connect
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   172
        optionsMap.put(opt, val);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   173
    }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   174
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   175
    private Socket privilegedDoTunnel(final String urlString,
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   176
                                      final int timeout)
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   177
        throws IOException
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   178
    {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   179
        try {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   180
            return java.security.AccessController.doPrivileged(
29986
97167d851fc4 8078467: Update core libraries to use diamond with anonymous classes
darcy
parents: 25859
diff changeset
   181
                new java.security.PrivilegedExceptionAction<>() {
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   182
                    public Socket run() throws IOException {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   183
                        return doTunnel(urlString, timeout);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   184
                }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   185
            });
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   186
        } catch (java.security.PrivilegedActionException pae) {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   187
            throw (IOException) pae.getException();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   188
        }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   189
    }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   190
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   191
    private Socket doTunnel(String urlString, int connectTimeout)
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   192
        throws IOException
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   193
    {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   194
        Proxy proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress(server, port));
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   195
        URL destURL = new URL(urlString);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   196
        HttpURLConnection conn = (HttpURLConnection) destURL.openConnection(proxy);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   197
        conn.setConnectTimeout(connectTimeout);
57112
alanb
parents: 57110 53473
diff changeset
   198
        int timeout = (int) getOption(SocketOptions.SO_TIMEOUT);
alanb
parents: 57110 53473
diff changeset
   199
        if (timeout > 0) {
57110
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
   200
            conn.setReadTimeout(timeout);
b848ca1ef778 Prototype of NIO based SocketImpl
alanb
parents: 47216
diff changeset
   201
        }
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   202
        conn.connect();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   203
        doTunneling(conn);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   204
        try {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   205
            Object httpClient = httpField.get(conn);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   206
            return (Socket) serverSocketField.get(httpClient);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   207
        } catch (IllegalAccessException x) {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   208
            throw new InternalError("Should not reach here", x);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   209
        }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   210
    }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   211
57238
b145b1b04106 HttpURLConnection.doTunneling can fail with IOE
alanb
parents: 57212
diff changeset
   212
    private void doTunneling(HttpURLConnection conn) throws IOException {
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   213
        try {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   214
            doTunneling.invoke(conn);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   215
        } catch (ReflectiveOperationException x) {
57238
b145b1b04106 HttpURLConnection.doTunneling can fail with IOE
alanb
parents: 57212
diff changeset
   216
            Throwable cause = x.getCause();
b145b1b04106 HttpURLConnection.doTunneling can fail with IOE
alanb
parents: 57212
diff changeset
   217
            if (cause instanceof IOException) {
b145b1b04106 HttpURLConnection.doTunneling can fail with IOE
alanb
parents: 57212
diff changeset
   218
                throw (IOException) cause;
b145b1b04106 HttpURLConnection.doTunneling can fail with IOE
alanb
parents: 57212
diff changeset
   219
            }
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   220
            throw new InternalError("Should not reach here", x);
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   221
        }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   222
    }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   223
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   224
    @Override
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   225
    protected InetAddress getInetAddress() {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   226
        if (external_address != null)
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   227
            return external_address.getAddress();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   228
        else
57167
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   229
            return delegate.getInetAddress();
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   230
    }
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   231
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   232
    @Override
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   233
    protected int getPort() {
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   234
        if (external_address != null)
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   235
            return external_address.getPort();
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   236
        else
57167
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   237
            return delegate.getPort();
82874527373e Socket changes to support both NioSocketImpl and PlainSocketImpl switchable by net property
michaelm
parents: 57112
diff changeset
   238
    }
16061
c80133bafef0 6370908: Add support for HTTP_CONNECT proxy in Socket class
chegar
parents:
diff changeset
   239
}