Method rpc_request

lib_rpc/src/http_stream.cpp:64–138

}

bool http_request::rpc_request(const MessageLite& in, MessageLite* out)
{
	if (request_ == NULL)
	{
		if (addr_ == NULL)
			return false;
		request_inner_ = new acl::http_request(addr_,
			conn_timeout_, rw_timeout_);
		request_ = request_inner_;
	}

	std::string buf;

#ifdef	DEBUG
	struct timeval begin, end;
	gettimeofday(&begin, NULL);
#endif

	in.SerializeToString(&buf);

#ifdef	DEBUG
	gettimeofday(&end, NULL);
	build_spent_ = stamp_sub(&end, &begin);

	gettimeofday(&begin, NULL);
#endif
	acl::http_header& header = request_->request_header();
	header.set_content_length(buf.length());
	header.set_keep_alive(true);

	if (request_->request(buf.c_str(), buf.length()) == false)
		return false;

#ifdef	DEBUG
	gettimeofday(&end, NULL);
	request_spent_ = stamp_sub(&end, &begin);
#endif

	if (out == NULL)
		return true;

	buf.clear();
	acl::string tmp;
	int   ret;

#ifdef	DEBUG
	gettimeofday(&begin, NULL);
#endif
	while (true)
	{
		ret = request_->read_body(tmp, true);
		if (ret < 0)
			return false;
		else if (ret == 0)
			break;
		buf.append(tmp.c_str(), (size_t) ret);
	}