diff --git a/fpmsyncd/fpmlink.cpp b/fpmsyncd/fpmlink.cpp
index 1ed888d292..6f71f1e70f 100644
--- a/fpmsyncd/fpmlink.cpp
+++ b/fpmsyncd/fpmlink.cpp
@@ -208,7 +208,14 @@ uint64_t FpmLink::readData()
     size_t start = 0, left;
     ssize_t read;
 
+try
+  {
     read = ::read(m_connection_socket, m_messageBuffer + m_pos, m_bufSize - m_pos);
+  }
+catch(const std::exception& e)
+    {
+        std::cerr << e.what() << 'ERROR: exceeding buffer size ...';
+    }
     if (read == 0)
         throw FpmConnectionClosedException();
     if (read < 0)
diff --git a/mclagsyncd/mclaglink.cpp b/mclagsyncd/mclaglink.cpp
index f48a0e1376..088f2e8b79 100644
--- a/mclagsyncd/mclaglink.cpp
+++ b/mclagsyncd/mclaglink.cpp
@@ -1877,8 +1877,14 @@ uint64_t MclagLink::readData()
     size_t start = 0, left = 0;
     ssize_t read = 0;
     char * msg = NULL;
-
+    try{
     read = ::read(m_connection_socket, m_messageBuffer + m_pos, m_bufSize - m_pos);
+    }
+    catch(const std::exception& e)
+    {
+        std::cerr << e.what() << 'ERROR: exceeding buffer size ...';
+    }
+      
     if (read == 0)
         throw MclagConnectionClosedException();
     if (read < 0)