Method handle_res_hdr

lib_acl_cpp/src/http/http_aclient.cpp:609–680

}

bool http_aclient::handle_res_hdr(int status)
{
	if (status != HTTP_CHAT_OK) {
		logger_error("http response head error, status=%d", status);
		return false;
	}

	// ���� HTTP ��Ӧͷ
	http_hdr_res_parse(hdr_res_);

	// �� C HTTP ��Ӧͷת���� C++ HTTP ��Ӧͷ�����ص����෽��
	http_header header(*hdr_res_);
	if (!this->on_http_res_hdr(header)) {
		return false;
	}

	keep_alive_ = header.get_keep_alive();

	// ����� websocket ͨ�ŷ�ʽ����ת�� websocket ��������
	if (status_ == HTTP_ACLIENT_STATUS_WS_HANDSHAKE) {
		acl_assert(ws_in_ && ws_out_);

		// HTTP ��Ӧ״̬������ 101��������� websocket ����ʧ��
		if (hdr_res_->reply_status != 101) {
			logger_error("invalid status=%d for websocket",
				hdr_res_->reply_status);
			this->on_ws_handshake_failed(hdr_res_->reply_status);
			return false;
		}

		// �ص����෽����֪ͨ WS �������
		if (!this->on_ws_handshake()) {
			return false;
		}
		return true;
	}

	// ������������ HTTP ��������

	if (http_res_) {
		http_res_free(http_res_);
	}
	http_res_ = http_res_new(hdr_res_);

	// �����Ӧ����Ϊ GZIP ѹ�����ݣ����û��������Զ���ѹ���ܣ�����Ҫ����
	// ��ѹ�����������Ӧ���ݽ��н�ѹ
	if (unzip_ && header.is_transfer_gzip() && zlib_stream::zlib_load_once()) {
		zstream_ = NEW zlib_stream();
		if (!zstream_->unzip_begin(false)) {
			logger_error("unzip_begin error");
			delete zstream_;
			zstream_ = NULL;
		} else {
			// gzip ��Ӧ������ǰ���� 10 �ֽڵ�ͷ���ֶ�
			gzip_header_left_ = 10;
		}
	}