From 16930cbb1905afc954ece36bb485e3289ea77223 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Nuno=20S=C3=A1?= <nuno.sa@analog.com>
Date: Wed, 5 Feb 2025 11:30:37 +0000
Subject: [PATCH] test_3

---
 iiod-responder.c | 3 ---
 iiod/rw.c        | 9 +++++++--
 2 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/iiod-responder.c b/iiod-responder.c
index 337c91343..5cd00d24d 100644
--- a/iiod-responder.c
+++ b/iiod-responder.c
@@ -13,7 +13,6 @@
 #include <iio/iio.h>
 #include <iio/iio-backend.h>
 #include <iio/iio-lock.h>
-#include <pthread.h>
 #include <string.h>
 #ifdef _WIN32
 #include <Windows.h>
@@ -160,8 +159,6 @@ static ssize_t iiod_rw_all(struct iiod_responder *priv,
 		else
 			ret = priv->ops->write(priv->d, curr, nb);
 		if (ret <= 0) {
-			printf("Got an error or stop event(%zd) (%lu)\n", ret,
-			       pthread_self());
 			return ret;
 		}
 		while (ret && (size_t) ret >= curr->size) {
diff --git a/iiod/rw.c b/iiod/rw.c
index 3796a4e89..86ef6562f 100644
--- a/iiod/rw.c
+++ b/iiod/rw.c
@@ -7,6 +7,7 @@
  */
 
 #include "ops.h"
+#include <pthread.h>
 
 ssize_t write_all(struct parser_pdata *pdata, const void *src, size_t len)
 {
@@ -31,10 +32,14 @@ ssize_t read_all(struct parser_pdata *pdata, void *dst, size_t len)
 
 	while (len) {
 		ssize_t ret = pdata->readfd(pdata, (void *) ptr, len);
-		if (ret < 0)
+		if (ret < 0) {
+			printf("Got an error(%zd) (%lu)\n", ret, pthread_self());
 			return ret;
-		if (!ret)
+		}
+		if (!ret) {
+			printf("Connection closed(%lu)\n", pthread_self());
 			return -EPIPE;
+		}
 		ptr += ret;
 		len -= ret;
 	}