Function on_connect

lib_protocol/samples/http_aio2/http_aio.cpp:76–125

}

static int on_connect(const ACL_ASTREAM_CTX *context)
{
	ACL_ASTREAM *stream = acl_astream_get_conn(context);
//	const ACL_SOCKADDR *addr = acl_astream_get_serv_addr(context);

	if (stream == NULL) {
//		int err = acl_last_error();
//		printf("connect %s failed, errno=%d, %s\r\n", addr, err,
//			err < 0 ? acl_dns_serror(err) : acl_last_serror());
		__stop = true;
		return -1;
	}

//	printf(">>>> connect %s ok!\r\n", addr);

	CTX *ctx = (CTX*) acl_mycalloc(1, sizeof(CTX));
	ctx->stream = stream;

	// ���� HTTP ����ͷ
	ctx->hdr_req = http_hdr_req_create("/", "GET", "HTTP/1.1");
	// ���ö�����ģʽ
	http_hdr_entry_replace(&ctx->hdr_req->hdr, "Connection", "Close", 1);
	// ������������
	http_hdr_put_str(&ctx->hdr_req->hdr, "Content-Type", "text/plain");
	// ���������ֶ�
	http_hdr_put_str(&ctx->hdr_req->hdr, "Host", __server_addr);

	// ���ö���ʱ�ص�����
	acl_aio_add_timeo_hook(stream, on_timeout, ctx);
	// ���ùرջص�����
	acl_aio_add_close_hook(stream, on_close, ctx);

	// ������̬�ڴ沢�� HTTP ����ͷ����������
	ACL_VSTRING *buf = acl_vstring_alloc(1024);
	http_hdr_build_request(ctx->hdr_req, buf);

	// ���� HTTP ����
	acl_aio_writen(stream, acl_vstring_str(buf), ACL_VSTRING_LEN(buf));

	// �ͷŶ�̬�ڴ�
	acl_vstring_free(buf);

	// ���� HTTP ��Ӧ����
	ctx->hdr_res = http_hdr_res_new();

	// �첽��ȡ�������Ӧ�� HTTP ͷ
	http_hdr_res_get_async(ctx->hdr_res, stream, on_http_hdr, ctx, 0);

	return 0;
}

static void usage(const char *procname)
{