Method add_read_callback

lib_acl_cpp/src/stream/aio_istream.cpp:80–112

}

void aio_istream::add_read_callback(aio_callback* callback)
{
	acl_assert(callback);

	// �Ȳ�ѯ�ûص������Ѿ�����
	std::list<AIO_CALLBACK*>::iterator it = read_callbacks_.begin();
	for (; it != read_callbacks_.end(); ++it) {
		if ((*it)->callback == callback) {
			if ((*it)->enable == false) {
				(*it)->enable = true;
			}
			return;
		}
	}

	// ��һ����λ
	it = read_callbacks_.begin();
	for (; it != read_callbacks_.end(); ++it) {
		if ((*it)->callback == NULL) {
			(*it)->enable = true;
			(*it)->callback = callback;
			return;
		}
	}

	// ����һ���µ�λ��
	AIO_CALLBACK* ac = (AIO_CALLBACK*) acl_mycalloc(1, sizeof(AIO_CALLBACK));
	ac->enable   = true;
	ac->callback = callback;

	// ���ӽ��ص����������
	read_callbacks_.push_back(ac);
}

int aio_istream::del_read_callback(aio_callback* callback /* = NULL */)
{