| 327 | } |
| 328 | |
| 329 | void aio_istream::readable_await(int timeout /* = 0 */) |
| 330 | { |
| 331 | // ���������첽����ʱʱ�� |
| 332 | if (timeout >= 0) { |
| 333 | ACL_AIO_SET_TIMEOUT(stream_, timeout); |
| 334 | } |
| 335 | acl_aio_enable_read(stream_, read_wakeup, this); |
| 336 | } |
| 337 | |
| 338 | int aio_istream::read_callback(ACL_ASTREAM* stream acl_unused, void* ctx, |
| 339 | char* data, int len) |
no test coverage detected