Method write_await

lib_acl_cpp/src/stream/aio_ostream.cpp:228–258

}

void aio_ostream::write_await(const void* data, int len,
	acl_int64 delay /* = 0 */, aio_timer_writer* callback /* = NULL */)
{
	if (delay > 0) {
		disable_write();

		aio_timer_writer* timer_writer;

		if (callback != NULL) {
			timer_writer= callback;
		} else {
			timer_writer = NEW aio_timer_writer();
		}

		// ���� timer_writer_ ����ij�Ա����
		timer_writer->out_ = this;
		timer_writer->buf_.copy(data, len);

		// ����д���������ӳ��첽д�Ķ�����
		if (timer_writers_ == NULL) {
			timer_writers_ = NEW std::list<aio_timer_writer*>;
		}
		timer_writers_->push_back(timer_writer);
		// ���ö�ʱ��
		handle_->set_timer(timer_writer, delay);
		return;
	}

	acl_assert(stream_);
	acl_aio_writen(stream_, (const char*) data, len);
}

int aio_ostream::sendto(const void* data, int len, const char* dest_addr, int flags)
{