Function check_tcp_proxy_protocol

net/proxy_protocol.c:427–480

}

int check_tcp_proxy_protocol(struct tcp_connection *c)
{
	static char pp_buf[PROXY_PROTOCOL_BUF_MAX];
	char *p;
	int len;

	if (c->flags & F_CONN_DATA_READY)
		return 1;

	if (!c->rcv.bind_address ||
			(c->rcv.bind_address->flags & SI_PROXY_IN) == 0) {
		c->flags |= F_CONN_DATA_READY;
		return 1;
	}

	len = tcp_peek(c, pp_buf, PROXY_PROTOCOL_BUF_MAX);
	if (len < 0)
		return -1;

	switch (is_net_proxy_protocol(pp_buf, len)) {
		case -1:
			return 0;
		case 0:
			c->flags |= F_CONN_DATA_READY;
			return 1;
		default:
			/* parse proxy_protocol fields */
			break;
	}

	p = parse_net_proxy_protocol(pp_buf, len, &c->rcv.real_ep);
	if (!p) {
		if (c->rcv.real_ep.flags == PP_ERROR) {
			LM_ERR("could not parse proxy_protocol header\n");
			return -1;
		}
		return 0;
	}
	if (c->rcv.real_ep.flags == PP_OK) {
		LM_DBG("message proxy_protocol %s:%hu -> %s:%hu\n",
				ip_addr2a(&c->rcv.real_ep.src_ip), c->rcv.real_ep.src_port,
				ip_addr2a(&c->rcv.real_ep.dst_ip), c->rcv.real_ep.dst_port);
	} else {
		LM_DBG("message proxy_protocol UNKNOWN\n");
	}

	if (tcp_drain(c, pp_buf, p - pp_buf) < 0) {
		LM_ERR("could not consume PROXY header\n");
		return -1;
	}

	c->flags |= F_CONN_DATA_READY;
	return 1;
}

int check_udp_proxy_protocol(char **buf, int *size, struct receive_info *ri)
{