1 /*
   2  * Copyright (c) 2007, 2008, Oracle and/or its affiliates. All rights reserved.
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * This code is free software; you can redistribute it and/or modify it
   6  * under the terms of the GNU General Public License version 2 only, as
   7  * published by the Free Software Foundation.  Oracle designates this
   8  * particular file as subject to the "Classpath" exception as provided
   9  * by Oracle in the LICENSE file that accompanied this code.
  10  *
  11  * This code is distributed in the hope that it will be useful, but WITHOUT
  12  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  13  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
  14  * version 2 for more details (a copy is included in the LICENSE file that
  15  * accompanied this code).
  16  *
  17  * You should have received a copy of the GNU General Public License version
  18  * 2 along with this work; if not, write to the Free Software Foundation,
  19  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
  20  *
  21  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
  22  * or visit www.oracle.com if you need additional information or have any
  23  * questions.
  24  */
  25 package java.net;
  26 
  27 import java.io.IOException;
  28 import java.io.FileDescriptor;
  29 import java.util.Set;
  30 import java.util.HashSet;
  31 import java.util.Collections;
  32 import jdk.net.*;
  33 
  34 import static sun.net.ExtendedOptionsImpl.*;
  35 
  36 /*
  37  * On Unix systems we simply delegate to native methods.
  38  *
  39  * @author Chris Hegarty
  40  */
  41 
  42 class PlainSocketImpl extends AbstractPlainSocketImpl
  43 {
  44     static {
  45         initProto();
  46     }
  47 
  48     /**
  49      * Constructs an empty instance.
  50      */
  51     PlainSocketImpl() { }
  52 
  53     /**
  54      * Constructs an instance with the given file descriptor.
  55      */
  56     PlainSocketImpl(FileDescriptor fd) {
  57         this.fd = fd;
  58     }
  59 
  60     protected <T> void setOption(SocketOption<T> name, T value) throws IOException {
  61         if (!name.equals(ExtendedSocketOptions.SO_FLOW_SLA)) {
  62             super.setOption(name, value);
  63         } else {
  64             if (isClosedOrPending()) {
  65                 throw new SocketException("Socket closed");
  66             }
  67             checkSetOptionPermission(name);
  68             checkValueType(value, SocketFlow.class);
  69             setFlowOption(getFileDescriptor(), (SocketFlow)value);
  70         }
  71     }
  72 
  73     @SuppressWarnings("unchecked")
  74     protected <T> T getOption(SocketOption<T> name) throws IOException {
  75         if (!name.equals(ExtendedSocketOptions.SO_FLOW_SLA)) {
  76             return super.getOption(name);
  77         }
  78         if (isClosedOrPending()) {
  79             throw new SocketException("Socket closed");
  80         }
  81         checkGetOptionPermission(name);
  82         SocketFlow flow = SocketFlow.create();
  83         getFlowOption(getFileDescriptor(), flow);
  84         return (T)flow;
  85     }
  86 
  87     protected Set<SocketOption<?>> supportedOptions() {
  88         HashSet<SocketOption<?>> options = new HashSet<>(
  89             super.supportedOptions());
  90 
  91         if (getSocket() != null && flowSupported()) {
  92             options.add(ExtendedSocketOptions.SO_FLOW_SLA);
  93         }
  94         return options;
  95     }
  96 
  97     protected void socketSetOption(int opt, boolean b, Object val) throws SocketException {
  98         try {
  99             socketSetOption0(opt, b, val);
 100         } catch (SocketException se) {
 101             if (socket == null || !socket.isConnected())
 102                 throw se;
 103         }
 104     }
 105 
 106     native void socketCreate(boolean isServer) throws IOException;
 107 
 108     native void socketConnect(InetAddress address, int port, int timeout)
 109         throws IOException;
 110 
 111     native void socketBind(InetAddress address, int port)
 112         throws IOException;
 113 
 114     native void socketListen(int count) throws IOException;
 115 
 116     native void socketAccept(SocketImpl s) throws IOException;
 117 
 118     native int socketAvailable() throws IOException;
 119 
 120     native void socketClose0(boolean useDeferredClose) throws IOException;
 121 
 122     native void socketShutdown(int howto) throws IOException;
 123 
 124     static native void initProto();
 125 
 126     native void socketSetOption0(int cmd, boolean on, Object value)
 127         throws SocketException;
 128 
 129     native int socketGetOption(int opt, Object iaContainerObj) throws SocketException;
 130 
 131     native void socketSendUrgentData(int data) throws IOException;
 132 }