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

equal deleted inserted replaced

-:eb491334113f
+:119ac9128c1b
 /**
 * An implementation of ServerSocketChannels
 */
-class ServerSocketChannelImpl
+public abstract class ServerSocketChannelImpl
 extends ServerSocketChannel
 implements SelChImpl
 {
 // Used to make native close and configure calls
-private static final NativeDispatcher nd = new SocketDispatcher();
+static final NativeDispatcher nd = new SocketDispatcher();
 // Our file descriptor
-private final FileDescriptor fd;
+final FileDescriptor fd;
-private final int fdVal;
+final int fdVal;
 // Lock held by thread currently blocked on this channel
-private final ReentrantLock acceptLock = new ReentrantLock();
+final ReentrantLock acceptLock = new ReentrantLock();
 // Lock held by any thread that modifies the state fields declared below
 // DO NOT invoke a blocking I/O operation while holding this lock!
-private final Object stateLock = new Object();
+final Object stateLock = new Object();
 // -- The following fields are protected by stateLock
 // Channel state, increases monotonically
-private static final int ST_INUSE = 0;
+static final int ST_INUSE = 0;
-private static final int ST_CLOSING = 1;
+static final int ST_CLOSING = 1;
-private static final int ST_CLOSED = 2;
+static final int ST_CLOSED = 2;
-private int state;
+int state;
 // ID of native thread currently blocked in this channel, for signalling
-private long thread;
+long thread;
 // Binding
-private InetSocketAddress localAddress; // null => unbound
+SocketAddress localAddress; // null => unbound
-// set true when exclusive binding is on and SO_REUSEADDR is emulated
-private boolean isReuseAddress;
-// Our socket adaptor, if any
-private ServerSocket socket;
 // -- End of fields protected by stateLock
+ServerSocketChannelImpl(SelectorProvider sp, FileDescriptor fd)
-ServerSocketChannelImpl(SelectorProvider sp) {
-super(sp);
-this.fd = Net.serverSocket(true);
-this.fdVal = IOUtil.fdVal(fd);
-}
-ServerSocketChannelImpl(SelectorProvider sp, FileDescriptor fd, boolean bound)
 throws IOException
 {
 super(sp);
 this.fd =  fd;
 this.fdVal = IOUtil.fdVal(fd);
-if (bound) {
-synchronized (stateLock) {
-localAddress = Net.localAddress(fd);
-}
-}
 }
 // @throws ClosedChannelException if channel is closed
-private void ensureOpen() throws ClosedChannelException {
+void ensureOpen() throws ClosedChannelException {
 if (!isOpen())
 throw new ClosedChannelException();
 }
-@Override
+abstract SocketAddress getRevealedLocalAddress(SocketAddress addr);
-public ServerSocket socket() {
-synchronized (stateLock) {
+abstract String getRevealedLocalAddressAsString(SocketAddress addr);
-if (socket == null)
-socket = ServerSocketAdaptor.create(this);
-return socket;
-}
-}
 @Override
 public SocketAddress getLocalAddress() throws IOException {
 synchronized (stateLock) {
 ensureOpen();
 return (localAddress == null)
 ? null
-: Net.getRevealedLocalAddress(localAddress);
+: getRevealedLocalAddress(localAddress);
 }
 }
-@Override
-public <T> ServerSocketChannel setOption(SocketOption<T> name, T value)
-throws IOException
-{
-Objects.requireNonNull(name);
-if (!supportedOptions().contains(name))
-throw new UnsupportedOperationException("'" + name + "' not supported");
-if (!name.type().isInstance(value))
-throw new IllegalArgumentException("Invalid value '" + value + "'");
-synchronized (stateLock) {
-ensureOpen();
-if (name == StandardSocketOptions.SO_REUSEADDR && Net.useExclusiveBind()) {
-// SO_REUSEADDR emulated when using exclusive bind
-isReuseAddress = (Boolean)value;
-} else {
-// no options that require special handling
-Net.setSocketOption(fd, Net.UNSPEC, name, value);
-}
-return this;
-}
-}
-@Override
-@SuppressWarnings("unchecked")
-public <T> T getOption(SocketOption<T> name)
-throws IOException
-{
-Objects.requireNonNull(name);
-if (!supportedOptions().contains(name))
-throw new UnsupportedOperationException("'" + name + "' not supported");
-synchronized (stateLock) {
-ensureOpen();
-if (name == StandardSocketOptions.SO_REUSEADDR && Net.useExclusiveBind()) {
-// SO_REUSEADDR emulated when using exclusive bind
-return (T)Boolean.valueOf(isReuseAddress);
-}
-// no options that require special handling
-return (T) Net.getSocketOption(fd, Net.UNSPEC, name);
-}
-}
-private static class DefaultOptionsHolder {
-static final Set<SocketOption<?>> defaultOptions = defaultOptions();
-private static Set<SocketOption<?>> defaultOptions() {
-HashSet<SocketOption<?>> set = new HashSet<>();
-set.add(StandardSocketOptions.SO_RCVBUF);
-set.add(StandardSocketOptions.SO_REUSEADDR);
-if (Net.isReusePortAvailable()) {
-set.add(StandardSocketOptions.SO_REUSEPORT);
-}
-set.addAll(ExtendedSocketOptions.serverSocketOptions());
-return Collections.unmodifiableSet(set);
-}
-}
-@Override
-public final Set<SocketOption<?>> supportedOptions() {
-return DefaultOptionsHolder.defaultOptions;
-}
-@Override
-public ServerSocketChannel bind(SocketAddress local, int backlog) throws IOException {
-synchronized (stateLock) {
-ensureOpen();
-if (localAddress != null)
-throw new AlreadyBoundException();
-InetSocketAddress isa = (local == null)
-? new InetSocketAddress(0)
-: Net.checkAddress(local);
-SecurityManager sm = System.getSecurityManager();
-if (sm != null)
-sm.checkListen(isa.getPort());
-NetHooks.beforeTcpBind(fd, isa.getAddress(), isa.getPort());
-Net.bind(fd, isa.getAddress(), isa.getPort());
-Net.listen(fd, backlog < 1 ? 50 : backlog);
-localAddress = Net.localAddress(fd);
-}
-return this;
-}
 /**
 * Marks the beginning of an I/O operation that might block.
 *
 * @throws ClosedChannelException if the channel is closed
 }
 end(completed);
 }
 }
+abstract int implAccept(FileDescriptor fd, FileDescriptor newfd, SocketAddress[] sa)
+throws IOException;
 @Override
 public SocketChannel accept() throws IOException {
 int n = 0;
 FileDescriptor newfd = new FileDescriptor();
-InetSocketAddress[] isaa = new InetSocketAddress[1];
+SocketAddress[] isaa = new SocketAddress[1];
 acceptLock.lock();
 try {
 boolean blocking = isBlocking();
 try {
 begin(blocking);
-n = Net.accept(this.fd, newfd, isaa);
+n = implAccept(this.fd, newfd, isaa);
 if (blocking) {
 while (IOStatus.okayToRetry(n) && isOpen()) {
 park(Net.POLLIN);
-n = Net.accept(this.fd, newfd, isaa);
+n = implAccept(this.fd, newfd, isaa);
 }
 }
 } finally {
 end(blocking, n > 0);
 assert IOStatus.check(n);
 * @throws SocketTimeoutException if the timeout expires
 */
 SocketChannel blockingAccept(long nanos) throws IOException {
 int n = 0;
 FileDescriptor newfd = new FileDescriptor();
-InetSocketAddress[] isaa = new InetSocketAddress[1];
+SocketAddress[] isaa = new SocketAddress[1];
 acceptLock.lock();
 try {
 // check that channel is configured blocking
 if (!isBlocking())
 begin(true);
 // change socket to non-blocking
 lockedConfigureBlocking(false);
 try {
 long startNanos = System.nanoTime();
-n = Net.accept(fd, newfd, isaa);
+n = implAccept(fd, newfd, isaa);
 while (n == IOStatus.UNAVAILABLE && isOpen()) {
 long remainingNanos = nanos - (System.nanoTime() - startNanos);
 if (remainingNanos <= 0) {
 throw new SocketTimeoutException("Accept timed out");
 }
 park(Net.POLLIN, remainingNanos);
-n = Net.accept(fd, newfd, isaa);
+n = implAccept(fd, newfd, isaa);
 }
 } finally {
 // restore socket to blocking mode
 lockedConfigureBlocking(true);
 }
 assert n > 0;
 return finishAccept(newfd, isaa[0]);
 }
-private SocketChannel finishAccept(FileDescriptor newfd, InetSocketAddress isa)
+abstract SocketChannel finishAccept(FileDescriptor newfd, SocketAddress isa)
-throws IOException
+throws IOException;
-{
-try {
-// newly accepted socket is initially in blocking mode
-IOUtil.configureBlocking(newfd, true);
-// check permitted to accept connections from the remote address
-SecurityManager sm = System.getSecurityManager();
-if (sm != null) {
-sm.checkAccept(isa.getAddress().getHostAddress(), isa.getPort());
-}
-return new SocketChannelImpl(provider(), newfd, isa);
-} catch (Exception e) {
-nd.close(newfd);
-throw e;
-}
-}
 @Override
 protected void implConfigureBlocking(boolean block) throws IOException {
 acceptLock.lock();
 try {
 }
 /**
 * Returns the local address, or null if not bound
 */
-InetSocketAddress localAddress() {
+SocketAddress localAddress() {
 synchronized (stateLock) {
 return localAddress;
 }
 }
 sb.append('[');
 if (!isOpen()) {
 sb.append("closed");
 } else {
 synchronized (stateLock) {
-InetSocketAddress addr = localAddress;
+SocketAddress addr = localAddress;
 if (addr == null) {
 sb.append("unbound");
 } else {
-sb.append(Net.getRevealedLocalAddressAsString(addr));
+sb.append(getRevealedLocalAddressAsString(addr));
 }
 }
 }
 sb.append(']');
 return sb.toString();

branch	unixdomainchannels
changeset 58801	119ac9128c1b
parent 55081	dd321e3596c0
child 58847	692de65ab293