| 826 | |
| 827 | public: |
| 828 | Server(StressFactory *f, EventCenter *c, ConnectedSocket s): |
| 829 | factory(f), center(c), socket(std::move(s)), read_ctxt(this), write_ctxt(this) { |
| 830 | center->create_file_event(socket.fd(), EVENT_READABLE, &read_ctxt); |
| 831 | center->dispatch_event_external(&read_ctxt); |
| 832 | } |
| 833 | void close() { |
| 834 | ASSERT_FALSE(write_enabled); |
| 835 | socket.shutdown(); |
nothing calls this directly
no test coverage detected