Function tcp_write_on_socket

net/tcp_common.c:356–383

}

int tcp_write_on_socket(struct tcp_connection* c, int fd,
		char *buf, int len, int write_timeout, int async_write_timeout)
{
	int n;

	lock_get(&c->write_lock);
	if (fd < 0) {
		n = tcp_async_add_chunk(c, buf, len, 0);
		if (n == 0)
			n = len;
	} else if (c->async) {
		/*
		 * if there is any data pending to write, we have to wait for those chunks
		 * to be sent, otherwise we will completely break the messages' order
		 */
		if (c->async->pending)
			n = tcp_async_add_chunk(c, buf, len, 0);
		else
			n = tsend_stream_async(c,fd,buf,len, async_write_timeout);
	} else {
		n = tsend_stream(fd, buf, len, write_timeout);
	}
	lock_release(&c->write_lock);
	if (fd >= 0 && n > 0)
		tcp_conn_reset_lifetime(c);

	return n;
}

/* returns :
 * 0  - in case of success