Method Pipe

classpath/java-nio.cpp:730–765

The Windows socket API only accepts socket file descriptors, not pipe descriptors or others. Thus, to implement Selector.wakeup(), we make a socket connection via the loopback interface and use it as a pipe.

  // Selector.wakeup(), we make a socket connection via the loopback
  // interface and use it as a pipe.
  Pipe(JNIEnv* e) : connected_(false), listener_(-1), reader_(-1), writer_(-1)
  {
    sockaddr_in address;
    address.sin_family = AF_INET;
    address.sin_port = 0;
    address.sin_addr.s_addr = inet_addr("127.0.0.1");  // INADDR_LOOPBACK;

    listener_ = makeSocket(e);
    if (e->ExceptionCheck())
      return;

    setBlocking(e, listener_, false);

    ::doBind(e, listener_, &address);
    if (e->ExceptionCheck())
      return;

    ::doListen(e, listener_);
    if (e->ExceptionCheck())
      return;

    socklen_t length = sizeof(sockaddr_in);
    int r = getsockname(
        listener_, reinterpret_cast<sockaddr*>(&address), &length);
    if (r) {
      throwIOException(e);
      return;
    }

    writer_ = makeSocket(e);
    if (e->ExceptionCheck())
      return;

    setBlocking(e, writer_, true);
    connected_ = ::doConnect(e, writer_, &address);
  }

  void dispose()
  {