Function send_stream_proxy_protocol_v1

net/proxy_protocol.c:155–213

}

int send_stream_proxy_protocol_v1(struct tcp_connection *c, int fd,
		int write_timeout, int lock, const struct receive_info *ri,
		const char *proto_name)
{
	char pp_hdr[PROXY_PROTOCOL_BUF_MAX];
	int pp_len, rc, dbg_len;
	const char *action;

	if (!should_send_stream_proxy_protocol(c))
		return 0;

	if (fd < 0 && ((c->flags & F_CONN_INIT) == 0 || c->fd < 0))
		return 0;

	pp_len = build_outbound_proxy_protocol_v1_hdr(ri,
			&c->rcv.dst_ip, c->rcv.dst_port,
			&c->rcv.src_ip, c->rcv.src_port,
			pp_hdr, sizeof(pp_hdr));
	if (pp_len < 0) {
		LM_ERR("failed to build outbound PROXY header\n");
		return -1;
	}

	dbg_len = pp_len;
	if (dbg_len >= 2 && pp_hdr[dbg_len - 2] == '\r' &&
			pp_hdr[dbg_len - 1] == '\n')
		dbg_len -= 2;

	action = (fd < 0) ? "queueing" : "sending";
	LM_DBG("%s outbound PROXY header on %s conn %u: %.*s\n",
			action, proto_name ? proto_name : "stream", c->id,
			dbg_len, pp_hdr);

	if (fd < 0) {
		rc = tcp_async_add_chunk(c, pp_hdr, pp_len, lock);
	} else {
		if (lock)
			lock_get(&c->write_lock);
		rc = tsend_stream(fd, pp_hdr, pp_len, write_timeout);
		if (lock)
			lock_release(&c->write_lock);
		if (rc != pp_len) {
			LM_ERR("failed to send outbound PROXY header on %s\n",
					proto_name ? proto_name : "stream");
			return -1;
		}
		tcp_conn_reset_lifetime(c);
		rc = 0;
	}

	if (rc < 0) {
		LM_ERR("failed to send outbound PROXY header on %s\n",
				proto_name ? proto_name : "stream");
		return -1;
	}

	c->flags |= F_CONN_PROXY_OUT_SENT;
	return 0;