diff --git a/cts/corosync.py b/cts/corosync.py
index 89b08088..b8c4edbf 100644
--- a/cts/corosync.py
+++ b/cts/corosync.py
@@ -558,7 +558,11 @@ class TestAgent(object):
 
     def read (self):
 
-        msg = self.sock.recv (4096)
+        try:
+            msg = self.sock.recv (4096)
+        except socket.error, msg:
+            raise RuntimeError(msg)
+
         if msg == '':
             raise RuntimeError("socket connection broken")
         return msg