2 files changed, 9 insertions, 9 deletions
diff --git a/lib/base/console.cpp b/lib/base/console.cpp
index c923da52..0a01094b 100644
--- a/lib/base/console.cpp
+++ b/lib/base/console.cpp
@@ -371,18 +371,17 @@ void eConsoleAppContainer::readyWrite(int what)
 	if (what&eSocketNotifier::Write && outbuf.size() )
 	{
 		queue_data d = outbuf.front();
-		outbuf.pop();
-		if ( ::write( fd[1], d.data, d.len ) != d.len )
-		{
-			/* emit */ dataSent(-1);
-//			eDebug("writeError");
-		}
+		int wr = ::write( fd[1], d.data+d.dataSent, d.len-d.dataSent );
+		if (wr < 0)
+			eDebug("eConsoleAppContainer write failed (%m)");
 		else
+			d.dataSent += wr;
+		if (d.dataSent == d.len)
 		{
+			outbuf.pop();
+			delete [] d.data;
 			/* emit */ dataSent(0);
-//			eDebug("write ok");
 		}
-		delete [] d.data;
 	}
 	if ( !outbuf.size() )
 		out->stop();
diff --git a/lib/base/console.h b/lib/base/console.h
index 7c807699..3aa180e4 100644
--- a/lib/base/console.h
+++ b/lib/base/console.h
@@ -11,11 +11,12 @@
 struct queue_data
 {
 	queue_data( char *data, int len )
-		:data(data), len(len)
+		:data(data), len(len), dataSent(0)
 	{
 	}
 	char *data;
 	int len;
+	int dataSent;
 };
 #endif