Function request_header_ready

app/jaws/module/mod_http/http_proxy.c:1155–1226

* �ɹ�����HTTP����ͷ��Ļص����� */

 * �ɹ�����HTTP����ͷ��Ļص�����
 */
static int request_header_ready(int status, void *arg)
{
	const char *myname = "request_header_ready";
	HTTP_CLIENT_REQ *req = (HTTP_CLIENT_REQ *) arg;
	HTTP_CLIENT *http_client = req->http_client;
	const char *via;
	static char *via_static = NULL;
	static int   via_max = 256;

	/* ȡ���ͻ�����������״̬ */
	http_client->flag &= ~HTTP_FLAG_CLIENT_LOCKED;

	if (status != HTTP_CHAT_OK) {
		http_proxy_complete(http_client, -1);
		return (0);
	}

	if (http_hdr_req_parse3(req->hdr_req, 0 , 0) < 0) {
		acl_msg_error("%s: parse hdr_req error", myname);
		http_proxy_complete(http_client, -1);
		return (0);
	}

#ifdef WIN32
#define snprintf _snprintf
#endif

	if (via_static == NULL) {
		via_static = (char*) acl_mycalloc(1, via_max);
		snprintf(via_static, via_max, "jaws-%d", getpid());
	}

	/* ����Ƿ������·���� */

	via = http_hdr_entry_value(&req->hdr_req->hdr, "x-via-jaws");
	if (via == NULL) {
		http_hdr_put_str(&req->hdr_req->hdr, "x-via-jaws", via_static);
	} else if (strcasecmp(via, via_static) == 0) {
		acl_msg_warn("%s(%d): loop tested, via(%s), url(http://%s%s)",
			myname, __LINE__, via, req->hdr_req->host,
			acl_vstring_str(req->hdr_req->url_part));

		/* �����ͻ����� */
		http_client->flag |= HTTP_FLAG_CLIENT_LOCKED;

		acl_aio_writen(http_client->entry.client,
			HTTP_REQUEST_LOOP,
			(int) strlen(HTTP_REQUEST_LOOP));

		/* ȡ���ͻ�����������״̬ */
		http_client->flag &= ~HTTP_FLAG_CLIENT_LOCKED;
		http_proxy_complete(http_client, -1);
		return (0);
	}

	/* �������Ѿ���ɣ�ȡ����ȴ�״̬ */
	req->flag &= ~CLIENT_READ_WAIT;