From b83ccc00ec28a5b3cbe9b3d70d84e2007f2bfc3e Mon Sep 17 00:00:00 2001
From: vivek-shankar <robovivek@gmail.com>
Date: Thu, 26 Jan 2017 23:22:07 -0500
Subject: [PATCH] debugging

---
 src/CommunicationManager.cpp | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/CommunicationManager.cpp b/src/CommunicationManager.cpp
index fa245f4..29589b0 100644
--- a/src/CommunicationManager.cpp
+++ b/src/CommunicationManager.cpp
@@ -355,8 +355,12 @@ inline void CommunicationManager::Check_In_Messages_and_Transfer_To_Topics()
 	uint16_t* header;
 	if (size_in_messages > 0)
 	{
-		steps++;
-		if(steps==100) steps=0;
+		if(!multi_msgs.empty()) steps++;
+		if(steps==10){ 
+			steps=0;
+			multi_msgs.clear();
+			cur_checksum=0;
+		}
 		uint64_t current_int64 = 0;
 		for (std::size_t j = 0; j < size_in_messages; j++)
 		{