Function tcp_drain

net/proxy_protocol.c:394–425

}

static int tcp_drain(struct tcp_connection *c, char *buf, int len)
{
	int bytes_read, total = 0;
	int retries = 0;
	int fd = c->fd;
again:
	bytes_read = read(fd, buf + total, len - total);
	if (bytes_read < 0) {
		if (errno == EINTR) {
			goto again;
		} else if (errno == EAGAIN || errno == EWOULDBLOCK) {
			if (++retries > 100) {
				LM_ERR("failed consuming proxy_protocol header due to repeated EAGAIN\n");
				return -1;
			}
			goto again;
		} else {
			LM_ERR("error consuming proxy_protocol header: %s\n", strerror(errno));
			return -1;
		}
	} else if (bytes_read == 0) {
		c->state = S_CONN_EOF;
		LM_DBG("EOF on %p, FD %d while consuming proxy_protocol header\n", c, fd);
		return -1;
	}
	total += bytes_read;
	retries = 0;
	if (total < len)
		goto again;

	return total;
}

int check_tcp_proxy_protocol(struct tcp_connection *c)
{