Method read_response_head

lib_acl_cpp/src/http/http_client.cpp:487–568

}

bool http_client::read_response_head(void)
{
	// �Է���һ����������ܵ��ϴ�����IJ������м����ݶ���
	reset();

	if (stream_ == NULL) {
		logger_error("connect stream not open yet");
		disconnected_ = true;
		return false;
	}
	ACL_VSTREAM* vstream = stream_->get_vstream();
	if (vstream == NULL) {
		logger_error("connect stream null");
		disconnected_ = true;
		return false;
	}

	hdr_res_ = http_hdr_res_new();
	int ret = http_hdr_res_get_sync(hdr_res_, vstream, vstream->rw_timeout);
	if (ret == -1) {
		http_hdr_res_free(hdr_res_);
		hdr_res_      = NULL;
		disconnected_ = true;
		return false;
	}

	if (http_hdr_res_parse(hdr_res_) < 0) {
		logger_error("parse response header error");
		http_hdr_res_free(hdr_res_);
		hdr_res_      = NULL;
		disconnected_ = true;
		return false;
	}

	// �鴫������ȼ����
	if (!hdr_res_->hdr.chunked) {
		// �����������Ӧʱ��ȷָ���˳���Ϊ 0 ���ʾ��û��������
		if (hdr_res_->hdr.content_length == 0) {
			body_finish_ = true;
			return true;
		}
	}

	if (!unzip_) {
		return true;
	}

#define	EQ(x, y) !strcasecmp((x), (y))

	bool gzipped = false;
	const char* ptr = http_hdr_entry_value(&hdr_res_->hdr, "Content-Encoding");
	if (ptr) {
		if (EQ(ptr, "gzip") || EQ(ptr, "x-gzip")) {
			gzipped = true;
		} else {
			logger_warn("unknown compress format: %s", ptr);
		}
	}