Function on_accept

src/tests/test_linkee.cpp:54–82

Handler for the server socket. NOTE: This keeps all incoming sockets open forever because the link tests need "half-open" connections for some tests. A connection becomes "half-open" when either the read or write direction of the socket is closed via a `::shutdown()`. Normally, the peer will discover a "half-open" connection if a read/write returns data of length zero. The test-linkee does not a

// The test-linkee does not act on this information in order to give
// the link tests full control over the lifetime of sockets.
void on_accept(const Future<Socket>& incoming)
{
  if (incoming.isReady()) {
    // NOTE: We copy and explicitly leak the socket here.
    // `Socket` is a shared pointer that closes itself after the
    // reference count goes to zero. By leaking the socket here, we
    // ensure that each incoming socket is never closed by the linkee.
    new Socket(incoming.get());

    const size_t size = 1024;
    char* data = new char[size];

    incoming->recv(data, size)
      .then([data](const size_t size) -> Future<Nothing> {
        delete[] data;

        // If there was any content at all, assume this is a message
        // telling the linkee to terminate.
        if (size > 0) {
          EXIT(EXIT_SUCCESS);
        }

        return Nothing();
      });
  }

  __s__->accept()
    .onAny(lambda::bind(&on_accept, lambda::_1));
}


/**