changes in step clearing of receive buffer

This commit is contained in:
vivek-shankar 2017-01-29 04:55:04 -05:00
parent 79e0ee04ed
commit ff1b3a0bcb
1 changed files with 2 additions and 2 deletions

View File

@ -373,9 +373,9 @@ inline void CommunicationManager::Check_In_Messages_and_Transfer_To_Topics()
if (size_in_messages > 0) if (size_in_messages > 0)
{ {
if(!multi_msgs_receive.empty()) steps++; if(!multi_msgs_receive.empty()) steps++;
if(steps>1000){ if(steps>500){
steps=0; steps=0;
//multi_msgs_receive.clear(); multi_msgs_receive.clear();
receiver_cur_checksum=0; receiver_cur_checksum=0;
} }
uint64_t current_int64 = 0; uint64_t current_int64 = 0;