| 255 | } |
| 256 | |
| 257 | void aio_socket_stream::enable_open() |
| 258 | { |
| 259 | acl_assert(stream_); |
| 260 | |
| 261 | if ((status_ & STATUS_HOOKED_OPEN)) { |
| 262 | return; |
| 263 | } |
| 264 | status_ |= STATUS_HOOKED_OPEN; |
| 265 | |
| 266 | acl_aio_ctl(stream_, |
| 267 | ACL_AIO_CTL_CONNECT_HOOK_ADD, open_callback, this, |
| 268 | ACL_AIO_CTL_END); |
| 269 | } |
| 270 | |
| 271 | int aio_socket_stream::open_callback(ACL_ASTREAM* stream acl_unused, void* ctx) |
| 272 | { |