1 files changed, 6 insertions, 5 deletions

diff --git a/src/socket.cpp b/src/socket.cpp
index e206bb5..c4f914b 100644
--- a/src/socket.cpp
+++ b/src/socket.cpp
@@ -181,11 +181,12 @@ void Bu::Socket::read()
 
 size_t Bu::Socket::read( void *pBuf, size_t nBytes )
 {
-        read();
-
-
-
-        return sReadBuf.getSize();
+        int nRead = TEMP_FAILURE_RETRY( ::read( nSocket, pBuf, nBytes ) );
+        if( nRead < 0 )
+        {
+                throw ConnectionException( excodeReadError, strerror(errno) );
+        }
+        return nRead;
 }
 
 size_t Bu::Socket::write( const void *pBuf, size_t nBytes )