X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=fd.c;h=48e2faf97c6d3e2bcb1616ebef04db48e2003d9e;hp=8f506ff83044dd23ec098961d9607908bc7ce402;hb=63b57e3e60923cea4e3e1808e3133789db2dc83a;hpb=ac4c4bfa02e9d8adfcc561dfd2377d7c138ce82f

diff --git a/fd.c b/fd.c
index 8f506ff8..48e2faf9 100644
--- a/fd.c
+++ b/fd.c
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2006-2007 Andre Noll <maan@systemlinux.org>
+ * Copyright (C) 2006-2008 Andre Noll <maan@systemlinux.org>
  *
  * Licensed under the GPL v2. For licencing details see COPYING.
  */
@@ -15,6 +15,31 @@
 #include "para.h"
 #include "error.h"
 
+/*
+ * Write a buffer to a file descriptor, re-write on short writes.
+ *
+ * \param fd The file descriptor.
+ * \param buf The buffer to be sent.
+ * \param len The length of \a buf.
+ *
+ * \return Standard. In any case, the number of bytes that have been written is
+ * stored in \a len.
+ */
+int write_all(int fd, const char *buf, size_t *len)
+{
+	size_t total = *len;
+
+	assert(total);
+	*len = 0;
+	while (*len < total) {
+		int ret = write(fd, buf + *len, total - *len);
+		if (ret == -1)
+			return -ERRNO_TO_PARA_ERROR(errno);
+		*len += ret;
+	}
+	return 1;
+}
+
 /**
  * Check whether a file exists.
  *
@@ -67,7 +92,7 @@ int para_select(int n, fd_set *readfds, fd_set *writefds,
  *
  * \return Standard.
  */
-int mark_fd_blocking(int fd)
+__must_check int mark_fd_blocking(int fd)
 {
 	int flags = fcntl(fd, F_GETFL);
 	if (flags < 0)
@@ -85,7 +110,7 @@ int mark_fd_blocking(int fd)
  *
  * \return Standard.
  */
-int mark_fd_nonblocking(int fd)
+__must_check int mark_fd_nonblocking(int fd)
 {
 	int flags = fcntl(fd, F_GETFL);
 	if (flags < 0)