Method Client

src/test/msgr/test_async_networkstack.cc:689–695

   public:
    Client(StressFactory *f, EventCenter *cen, ConnectedSocket s, size_t c)
        : factory(f), center(cen), socket(std::move(s)), left(c), homeless_message(factory->rs, -1, 1024),
          read_ctxt(this), write_ctxt(this) {
      center->create_file_event(
              socket.fd(), EVENT_READABLE, &read_ctxt);
      center->dispatch_event_external(&read_ctxt);
    }
    void close() {
      ASSERT_FALSE(write_enabled);
      dead = true;