jdk-sandbox: comparison src/java.base/share/classes/sun/nio/ch/Net.java

equal deleted inserted replaced

-:eb491334113f
+:119ac9128c1b
 import java.net.UnknownHostException;
 import java.nio.channels.AlreadyBoundException;
 import java.nio.channels.ClosedChannelException;
 import java.nio.channels.NotYetBoundException;
 import java.nio.channels.NotYetConnectedException;
+import java.nio.channels.UnixDomainSocketAddress;
 import java.nio.channels.UnresolvedAddressException;
 import java.nio.channels.UnsupportedAddressTypeException;
 import java.security.AccessController;
 import java.security.PrivilegedAction;
 import java.util.Enumeration;
 import sun.net.ext.ExtendedSocketOptions;
 import sun.net.util.IPAddressUtil;
 import sun.security.action.GetPropertyAction;
 public class Net {
-private Net() { }
+public Net() { }
+private static final boolean unixDomainSupported;
+//private static final boolean abstractNamesSupported;
 // unspecified protocol family
-static final ProtocolFamily UNSPEC = new ProtocolFamily() {
+public static final ProtocolFamily UNSPEC = new ProtocolFamily() {
 public String name() {
 return "UNSPEC";
 }
 };
+static {
+unixDomainSupported = unixDomainSocketSupported();
+String name = GetPropertyAction.privilegedGetProperty("os.name")
+.toLowerCase();
+// Windows claims to support it but doesn't. Disable for now
+//abstractNamesSupported = name.startsWith("linux");
+//  || name.startsWith("windows");
+}
 // set to true if exclusive binding is on for Windows
 private static final boolean exclusiveBind;
 // set to true if the fast tcp loopback should be enabled on Windows
 }
 /**
 * Returns true if exclusive binding is on
 */
-static boolean useExclusiveBind() {
+public static boolean useExclusiveBind() {
 return exclusiveBind;
 }
 /**
 * Tells whether IPv6 sockets can join IPv4 multicast groups
 // -- Socket options
 static final ExtendedSocketOptions extendedOptions =
 ExtendedSocketOptions.getInstance();
-static void setSocketOption(FileDescriptor fd, SocketOption<?> name, Object value)
+public static void setSocketOption(FileDescriptor fd, SocketOption<?> name, Object value)
 throws IOException
 {
 setSocketOption(fd, Net.UNSPEC, name, value);
 }
-static void setSocketOption(FileDescriptor fd, ProtocolFamily family,
+public static void setSocketOption(FileDescriptor fd, ProtocolFamily family,
 SocketOption<?> name, Object value)
 throws IOException
 {
 if (value == null)
 throw new IllegalArgumentException("Invalid option value");
 boolean mayNeedConversion = (family == UNSPEC);
 boolean isIPv6 = (family == StandardProtocolFamily.INET6);
 setIntOption0(fd, mayNeedConversion, key.level(), key.name(), arg, isIPv6);
 }
-static Object getSocketOption(FileDescriptor fd, SocketOption<?> name)
+public static Object getSocketOption(FileDescriptor fd, SocketOption<?> name)
 throws IOException
 {
 return getSocketOption(fd, Net.UNSPEC, name);
 }
-static Object getSocketOption(FileDescriptor fd, ProtocolFamily family, SocketOption<?> name)
+public static Object getSocketOption(FileDescriptor fd, ProtocolFamily family, SocketOption<?> name)
 throws IOException
 {
 Class<?> type = name.type();
 if (extendedOptions.isOptionSupported(name)) {
 boolean preferIPv6 = isIPv6Available() &&
 (family != StandardProtocolFamily.INET);
 return IOUtil.newFD(socket0(preferIPv6, stream, false, fastLoopback));
 }
-static FileDescriptor serverSocket(boolean stream) {
+public static FileDescriptor serverSocket(boolean stream) {
 return IOUtil.newFD(socket0(isIPv6Available(), stream, true, fastLoopback));
 }
 // Due to oddities SO_REUSEADDR on windows reuse is ignored
 private static native int socket0(boolean preferIPv6, boolean stream, boolean reuse,
 private static native void bind0(FileDescriptor fd, boolean preferIPv6,
 boolean useExclBind, InetAddress addr,
 int port)
 throws IOException;
-static native void listen(FileDescriptor fd, int backlog) throws IOException;
+public static native void listen(FileDescriptor fd, int backlog) throws IOException;
 static int connect(FileDescriptor fd, InetAddress remote, int remotePort)
 throws IOException
 {
 return connect(UNSPEC, fd, remote, remotePort);
 public static final int SHUT_RD = 0;
 public static final int SHUT_WR = 1;
 public static final int SHUT_RDWR = 2;
-static native void shutdown(FileDescriptor fd, int how) throws IOException;
+public static native void shutdown(FileDescriptor fd, int how) throws IOException;
 private static native int localPort(FileDescriptor fd)
 throws IOException;
 private static native InetAddress localInetAddress(FileDescriptor fd)
 * Performs a non-blocking poll of a connecting socket to test if the
 * connection has been established.
 *
 * @return true if connected
 */
-static boolean pollConnectNow(FileDescriptor fd) throws IOException {
+public static boolean pollConnectNow(FileDescriptor fd) throws IOException {
 return pollConnect(fd, 0);
 }
 /**
 * Return the number of bytes in the socket input buffer.
 */
-static native int available(FileDescriptor fd) throws IOException;
+public static native int available(FileDescriptor fd) throws IOException;
 /**
 * Send one byte of urgent data (MSG_OOB) on the socket.
 */
 static native int sendOOB(FileDescriptor fd, byte data) throws IOException;
 * Event masks for the various poll system calls.
 * They will be set platform dependent in the static initializer below.
 */
 public static final short POLLIN;
 public static final short POLLOUT;
+public static boolean isUnixDomainSupported() {
+return unixDomainSupported;
+}
+public static UnixDomainSocketAddress checkUnixAddress(SocketAddress sa) {
+if (sa == null)
+throw new NullPointerException();
+if (!(sa instanceof UnixDomainSocketAddress))
+throw new UnsupportedAddressTypeException();
+UnixDomainSocketAddress usa = (UnixDomainSocketAddress)sa;
+//if (usa.isAbstract() && !abstractNamesSupported())
+//throw new UnsupportedAddressTypeException();
+return usa;
+}
+/**
+* 2 methods to be implemented if fine-grained security to be used
+*/
+static UnixDomainSocketAddress getRevealedLocalAddress(UnixDomainSocketAddress addr) {
+return addr;
+}
+static String getRevealedLocalAddressAsString(UnixDomainSocketAddress addr) {
+return addr.toString();
+}
+// -- Socket operations --
+public static FileDescriptor unixDomainSocket() throws IOException {
+return IOUtil.newFD(unixDomainSocket0());
+}
+public static native boolean unixDomainSocketSupported();
+private static native int unixDomainSocket0();
+static native void unixDomainBind(FileDescriptor fd, UnixDomainSocketAddress addr)
+throws IOException;
+static native int unixDomainConnect(FileDescriptor fd, UnixDomainSocketAddress remote)
+throws IOException;
+static native int unixDomainAccept(FileDescriptor fd,
+FileDescriptor newfd,
+SocketAddress[] isaa)
+throws IOException;
+public static native UnixDomainSocketAddress localUnixAddress(FileDescriptor fd)
+throws IOException;
 public static final short POLLERR;
 public static final short POLLHUP;
 public static final short POLLNVAL;
 public static final short POLLCONN;
 exclusiveBind = false;
 }
 fastLoopback = isFastTcpLoopbackRequested();
 }
 }

branch	unixdomainchannels
changeset 58801	119ac9128c1b
parent 55375	96c7427456f9
child 58847	692de65ab293