src/java.base/share/classes/java/net/HttpConnectSocketImpl.java
branchniosocketimpl-branch
changeset 57172 63ab5af5d009
parent 57171 d8ed7335dadd
child 57212 28b0946d3b81
--- a/src/java.base/share/classes/java/net/HttpConnectSocketImpl.java	Sat Feb 09 19:16:30 2019 +0000
+++ b/src/java.base/share/classes/java/net/HttpConnectSocketImpl.java	Sun Feb 10 09:54:31 2019 +0000
@@ -46,7 +46,7 @@
  * @since 1.8
  */
 
-/*package*/ class HttpConnectSocketImpl extends SocketImpl implements SocketImpl.DelegatingImpl {
+/*package*/ class HttpConnectSocketImpl extends DelegatingSocketImpl {
 
     private static final String httpURLClazzStr =
                                   "sun.net.www.protocol.http.HttpURLConnection";
@@ -59,7 +59,6 @@
     private final String server;
     private InetSocketAddress external_address;
     private HashMap<Integer, Object> optionsMap = new HashMap<>();
-    private final SocketImpl delegate;
 
     static  {
         try {
@@ -82,13 +81,13 @@
         }
     }
     HttpConnectSocketImpl(SocketImpl delegate) {
-        this.delegate = delegate;
+        super(delegate);
         this.server = null;
         throw new InternalError();
     }
 
     HttpConnectSocketImpl(Proxy proxy, SocketImpl delegate) {
-        this.delegate = delegate;
+        super(delegate);
         SocketAddress a = proxy.address();
         if ( !(a instanceof InetSocketAddress) )
             throw new IllegalArgumentException("Unsupported address type");
@@ -99,11 +98,6 @@
     }
 
     @Override
-    protected void create(boolean stream) throws IOException {
-        delegate.create(stream);
-    }
-
-    @Override
     protected void connect(String host, int port) throws IOException {
         connect(new InetSocketAddress(host, port), 0);
     }
@@ -121,8 +115,7 @@
 
     @Override
     void setServerSocket(ServerSocket socket) {
-        delegate.serverSocket = socket;
-        super.setServerSocket(socket);
+        throw new InternalError("should not get here");
     }
 
     @Override
@@ -163,49 +156,15 @@
         } catch (IOException x) {  /* gulp! */  }
     }
 
-    @Override
-    protected void bind(InetAddress host, int port) throws IOException {
-        delegate.bind(host, port);
-    }
 
     @Override
-    protected void listen(int backlog) throws IOException {
-        throw new IllegalStateException();
-    }
-
-    @Override
-    protected void accept(SocketImpl s) throws IOException {
-        throw new IllegalStateException();
-    }
-
-    @Override
-    protected InputStream getInputStream() throws IOException {
-        return delegate.getInputStream();
+    protected void listen(int backlog) {
+        throw new InternalError("should not get here");
     }
 
     @Override
-    protected OutputStream getOutputStream() throws IOException {
-        return delegate.getOutputStream();
-    }
-
-    @Override
-    protected int available() throws IOException {
-        return delegate.available();
-    }
-
-    @Override
-    protected void close() throws IOException {
-        delegate.close();
-    }
-
-    @Override
-    protected <T> void setOption(SocketOption<T> name, T value) throws IOException {
-        delegate.setOption(name, value);
-    }
-
-    @Override
-    protected <T> T getOption(SocketOption<T> name) throws IOException {
-        return delegate.getOption(name);
+    protected void accept(SocketImpl s) {
+        throw new InternalError("should not get here");
     }
 
     @Override
@@ -214,16 +173,6 @@
     }
 
     @Override
-    protected Set<SocketOption<?>> supportedOptions() {
-        return delegate.supportedOptions();
-    }
-
-    @Override
-    protected boolean supportsUrgentData () {
-        return delegate.supportsUrgentData();
-    }
-
-    @Override
     public void setOption(int opt, Object val) throws SocketException {
         delegate.setOption(opt, val);
 
@@ -234,11 +183,6 @@
         optionsMap.put(opt, val);
     }
 
-    @Override
-    public Object getOption(int optID) throws SocketException {
-        return delegate.getOption(optID);
-    }
-
     private Socket privilegedDoTunnel(final String urlString,
                                       final int timeout)
         throws IOException
@@ -299,35 +243,4 @@
         else
             return delegate.getPort();
     }
-
-
-    @Override
-    protected FileDescriptor getFileDescriptor() {
-        return delegate.getFileDescriptor();
-    }
-
-    @Override
-    protected void shutdownInput() throws IOException {
-        delegate.shutdownInput();
-    }
-
-    @Override
-    protected void shutdownOutput() throws IOException {
-        delegate.shutdownOutput();
-    }
-
-    @Override
-    protected int getLocalPort() {
-        return delegate.getLocalPort();
-    }
-
-    @Override
-    protected void sendUrgentData(int data) throws IOException {
-        delegate.sendUrgentData(data);
-    }
-
-    @Override
-    public SocketImpl delegate() {
-        return delegate;
-    }
 }