Method read_await

lib_acl_cpp/src/stream/aio_istream.cpp:283–327

}

void aio_istream::read_await(int count /* = 0 */, int timeout /* = 0 */,
	acl_int64 delay /* = 0 */, aio_timer_reader* callback /* = NULL */)
{
	if (delay > 0) {
		// �����µĻ����ö��ӳٶ�ʱ��

		disable_read();

		if (callback != NULL) {
			if (timer_reader_ != NULL) {
				handle_->del_timer(timer_reader_);
				timer_reader_->destroy();
			}
			timer_reader_= callback;
		}

		if (timer_reader_ == NULL) {
			timer_reader_ = NEW aio_timer_reader();
		}
		// ���� timer_reader_ ����ij�Ա����
		timer_reader_->in_            = this;
		timer_reader_->delay_gets_    = false;
		timer_reader_->delay_timeout_ = timeout;
		timer_reader_->delay_count_   = count;

		// �����첽����ʱ��
		handle_->set_timer(timer_reader_, delay);
		return;
	} else if (timer_reader_ != NULL) {
		// ����ȡ��֮ǰ���õ��첽����ʱ��
		handle_->del_timer(timer_reader_);
		timer_reader_->destroy();
		timer_reader_ = NULL;
	}

	// ���������첽����ʱʱ��
	if (timeout >= 0) {
		ACL_AIO_SET_TIMEOUT(stream_, timeout);
	}
	if (count > 0) {
		acl_aio_readn(stream_, count);
	} else {
		acl_aio_read(stream_);
	}
}

void aio_istream::readable_await(int timeout /* = 0 */)
{