Method doApp

app/master/tools/master_dispatch/www/http_servlet.cpp:122–172

}

bool http_servlet::doApp(acl::HttpServletRequest& req,
	acl::HttpServletResponse& res)
{
	acl::http_request* conn = (acl::http_request *) conns_->peek();
	if (conn == NULL)
	{
		logger_error("no connection available, addr: %s",
			var_cfg_manager_addr);
		return doReply(req, res, 500, "%s", "no connection");
	}

	acl::http_header& hdr = conn->request_header();
	hdr.set_url(var_cfg_access_url)
		.set_keep_alive(true)
		.set_method(acl::HTTP_METHOD_GET)
		.accept_gzip(true);

	if (conn->request(NULL, 0) == false)
	{
		logger_error("send request to %s error", var_cfg_manager_addr);
		conns_->put(conn, false);
		return doReply(req, res, 505, "%s", "send request error");
	}

	acl::xml1 xml;
	char buf[8192];
	while (true)
	{
		int ret = conn->read_body(buf, sizeof(buf) - 1);
		if (ret == 0)
			break;
		else if (ret < 0)
		{
			conns_->put(conn, false);
			logger_error("read_body error from %s",
				var_cfg_manager_addr);
			return doReply(req, res, 505, "%s", "read_body error");
		}

		buf[ret] = 0;
		xml.update(buf);
	}

	conns_->put(conn, true);

	acl::json json;
	if (xmlToJson(xml, json) == false)
		return doReply(req, res, 505, "%s", "invalid xml data");

	return doReply(req, res, 200, json);
}

bool http_servlet::xmlToJson(acl::xml& xml, acl::json& json)
{