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     protected <T> T getOption(SocketOption<T> name) throws IOException {
  74         if (!name.equals(ExtendedSocketOptions.SO_FLOW_SLA)) {
  75             return super.getOption(name);
  76         }
  77         if (isClosedOrPending()) {
  78             throw new SocketException("Socket closed");
  79         }
  80         checkGetOptionPermission(name);
  81         SocketFlow flow = SocketFlow.create();
  82         getFlowOption(getFileDescriptor(), flow);
  83         return (T)flow;
  84     }
  85 
  86     native void socketCreate(boolean isServer) throws IOException;
  87 
  88     native void socketConnect(InetAddress address, int port, int timeout)
  89         throws IOException;
  90 
  91     native void socketBind(InetAddress address, int port)
  92         throws IOException;
  93 
  94     native void socketListen(int count) throws IOException;
  95 
  96     native void socketAccept(SocketImpl s) throws IOException;
  97 
  98     native int socketAvailable() throws IOException;
  99 
 100     native void socketClose0(boolean useDeferredClose) throws IOException;
 101 
 102     native void socketShutdown(int howto) throws IOException;
 103 
 104     static native void initProto();
 105 
 106     native void socketSetOption(int cmd, boolean on, Object value)
 107         throws SocketException;
 108 
 109     native int socketGetOption(int opt, Object iaContainerObj) throws SocketException;
 110 
 111     native void socketSendUrgentData(int data) throws IOException;
 112 }