X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=include%2Fbabeltrace%2Fcommon-internal.h;fp=include%2Fbabeltrace%2Fcommon-internal.h;h=19594fe3c347f4345788befe9078df3dac13bcf2;hp=0e84e8fa49007b706e1214195cb1507e14a34eb1;hb=282b829b5df579f26e8506f58b6e7cb2a7a928b8;hpb=2c2a5bf944c7d0e3f5e2595a92b448b57bd625cf

diff --git a/include/babeltrace/common-internal.h b/include/babeltrace/common-internal.h
index 0e84e8fa..19594fe3 100644
--- a/include/babeltrace/common-internal.h
+++ b/include/babeltrace/common-internal.h
@@ -32,9 +32,10 @@
 #include <babeltrace/trace-ir/event-class-const.h>
 #include <babeltrace/graph/self-message-iterator.h>
 #include <babeltrace/value.h>
-#include <stdarg.h>
 #include <inttypes.h>
+#include <stdarg.h>
 #include <stdint.h>
+#include <unistd.h>
 #include <glib.h>
 
 #define BT_COMMON_COLOR_RESET              "\033[0m"
@@ -305,6 +306,55 @@ void bt_common_custom_snprintf(char *buf, size_t buf_size,
 BT_HIDDEN
 size_t bt_common_get_page_size(void);
 
+/*
+ * Wraps read() function to handle EINTR and partial reads.
+ * On success, it returns `count` received as parameter. On error, it returns a
+ * value smaller than the requested `count`.
+ */
+static inline
+ssize_t bt_common_read(int fd, void *buf, size_t count)
+{
+	size_t i = 0;
+	ssize_t ret;
+
+	BT_ASSERT(buf);
+
+	/* Never return an overflow value. */
+	BT_ASSERT(count <= SSIZE_MAX);
+
+	do {
+		ret = read(fd, buf + i, count - i);
+		if (ret < 0) {
+			if (errno == EINTR) {
+#ifdef BT_LOGD_STR
+				BT_LOGD_STR("read() call interrupted. Retrying...");
+#endif
+				/* retry operation */
+				continue;
+			} else {
+#ifdef BT_LOGE_ERRNO
+				BT_LOGE_ERRNO("Error while reading", ": fd=%d",
+					fd);
+#endif
+				goto end;
+			}
+		}
+		i += ret;
+		BT_ASSERT(i <= count);
+	} while (count - i > 0 && ret > 0);
+
+end:
+	if (ret >= 0) {
+		if (i == 0) {
+			ret = -1;
+		} else {
+			ret = i;
+		}
+	}
+
+	return ret;
+}
+
 static inline
 const char *bt_common_field_class_type_string(enum bt_field_class_type class_type)
 {