| 225 | } |
| 226 | |
| 227 | void master_aio::service_main(ACL_SOCKET fd, void* ctx) |
| 228 | { |
| 229 | master_aio* ma = (master_aio *) ctx; |
| 230 | acl_assert(ma->handle_); |
| 231 | acl_assert(ma); |
| 232 | |
| 233 | aio_socket_stream* stream = NEW aio_socket_stream(ma->handle_, fd); |
| 234 | |
| 235 | aio_close_callback* callback = NEW aio_close_callback(stream); |
| 236 | stream->add_close_callback(callback); |
| 237 | |
| 238 | ma->on_accept(stream); |
| 239 | } |
| 240 | |
| 241 | void master_aio::service_on_listen(void* ctx, ACL_VSTREAM *sstream) |
| 242 | { |
nothing calls this directly
no test coverage detected