Class SocketSelector

classpath/java/nio/channels/SocketSelector.java:17–133

import java.net.Socket;

class SocketSelector extends Selector {
  protected volatile long state;
  protected final Object lock = new Object();
  protected boolean woken = false;

  public SocketSelector() throws IOException {
    Socket.init();

    state = natInit();
  }

  public boolean isOpen() {
    return state != 0;
  }

  public Selector wakeup() {
    synchronized (lock) {
      if (isOpen() && (! woken)) {
        woken = true;

        natWakeup(state);
      }
    }
    return this;
  }

  private boolean clearWoken() {
    synchronized (lock) {
      if (woken) {
        woken = false;
        return true;
      } else {
        return false;
      }
    }
  }

  public synchronized int selectNow() throws IOException {
    return doSelect(-1);
  }

  public synchronized int select() throws IOException {
    return doSelect(0);
  }

  public synchronized int select(long interval) throws IOException {
    if (interval < 0) throw new IllegalArgumentException();

    return doSelect(interval);
  }

  public int doSelect(long interval) throws IOException {
    if (! isOpen()) {
      throw new ClosedSelectorException();
    }

    selectedKeys.clear();