Function pv_get_proxy_protocol

pvar.c:2646–2694

}

static int pv_get_proxy_protocol(struct sip_msg *msg, pv_param_t *param,
															pv_value_t *res)
{
	if(msg==NULL || res==NULL)
		return -1;

	if (msg->rcv.real_ep.flags != PP_OK)
		return pv_get_null(msg, NULL, res);

	switch (param->pvn.u.isname.name.n) {
		case PROXY_PROTOCOL_SRC_IP_ID:
			res->rs.s = ip_addr2a(&msg->rcv.real_ep.src_ip);
			res->rs.len = strlen(res->rs.s);
			res->flags = PV_VAL_STR;
			break;
		case PROXY_PROTOCOL_SRC_PORT_ID:
			res->ri = msg->rcv.real_ep.src_port;
			res->rs.s = int2str((uint64_t)msg->rcv.real_ep.src_port, &res->rs.len);
			res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;
			break;
		case PROXY_PROTOCOL_DST_IP_ID:
			res->rs.s = ip_addr2a(&msg->rcv.real_ep.dst_ip);
			res->rs.len = strlen(res->rs.s);
			res->flags = PV_VAL_STR;
			break;
		case PROXY_PROTOCOL_DST_PORT_ID:
			res->ri = msg->rcv.real_ep.dst_port;
			res->rs.s = int2str((uint64_t)msg->rcv.real_ep.dst_port, &res->rs.len);
			res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;
			break;
		case PROXY_PROTOCOL_AF_ID:
			if (msg->rcv.real_ep.src_ip.af == AF_INET) {
				res->rs.s = "INET";
				res->rs.len = 4;
			} else if (msg->rcv.real_ep.src_ip.af == AF_INET6) {
				res->rs.s = "INET6";
				res->rs.len = 5;
			} else {
				return pv_get_null(msg, NULL, res);
			}
			res->flags = PV_VAL_STR;
			break;
		default:
			LM_CRIT("BUG - unsupported proxy_protocol ID %d\n",
					param->pvn.u.isname.name.n);
			return pv_get_null(NULL, NULL, res);
	}
	return 0;
}