Function http_request_reforward

app/jaws/module/mod_http/http_proxy.c:964–1013

/* ���ͻ��������������������������������� */

static int http_request_reforward(HTTP_CLIENT *http_client)
{
	const char *myname = "http_request_reforward";
	ACL_ASTREAM *server = http_client->entry.server;

	/* ������Ǵ����ӳ���ȡ�õ����������Դ����� 1 */
	if (!http_client->entry.flag_conn_reuse)
		http_client->entry.nretry_on_error++;

	if (http_client->hdr_res) {
		http_hdr_res_free(http_client->hdr_res);
		http_client->hdr_res = NULL;
	}

	/* �Ͽ������˵����ӣ���������������˵����� */
	if (server) {
		/* ʹ��������ûỰ���� */
		client_entry_detach(&http_client->entry, acl_aio_vstream(server));
		/* ȡ�� HTTP ��Ӧͷ�Ļص����� */
		acl_aio_clean_hooks(server);
		/* only for test */
		if (acl_aio_iswset(server)) {
			acl_msg_info("%s(%d): defer free(%d)\n", myname, __LINE__, ACL_VSTREAM_SOCK(server->stream));
                } else
			acl_msg_info("%s(%d): not defer free(%d)\n", myname, __LINE__, ACL_VSTREAM_SOCK(server->stream));
		/* ���첽�رշ������ */
		acl_aio_iocp_close(server);
	}

	/* ������Դ�����������������Ӧ��IP���������򷵻ش��󣬲������� */
	if (http_client->entry.nretry_on_error > http_client->entry.dns_ctx.ip_cnt) {
		acl_msg_error("%s(%d): has retried before(%d,%d), reuse connecion %s",
			myname, __LINE__, http_client->entry.nretry_on_error,
			http_client->entry.dns_ctx.ip_cnt,
			http_client->entry.flag_conn_reuse ? "yes" : "no");
		return (-1);
	}

	/* ������Դ���������ֵ����������ֱ�ӷ��ش��� */
	if (http_client->entry.nretry_on_error >= MAX_RETRIED) {
		acl_msg_error("%s(%d): has retried before(%d,%d)",
			myname, __LINE__, http_client->entry.nretry_on_error,
			MAX_RETRIED);
		return (-1);
	}

	/* ��ʼ����������һ��IP */
	forward_start((CLIENT_ENTRY*) http_client);
	return (0);
}

/*----------------------------------------------------------------------------*/