Spiri
/
services-ros1-xbee_mav
12
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

changes in step for clearing receiver buffer for multi msg

This commit is contained in:
vivek-shankar 2017-01-29 04:24:14 -05:00
parent edd2677d11
commit 79e0ee04ed
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/CommunicationManager.cpp
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>10){ if(steps>1000){
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;
@ -414,7 +414,6 @@ inline void CommunicationManager::Check_In_Messages_and_Transfer_To_Topics()
char temporary_buffer[20]; char temporary_buffer[20];
std::string frame; std::string frame;
std::cout << "Multi msg Received header " <<header[0]<<" "<<header[1]<<" "<<header[2]<<" "<<header[3]<<" "<< std::endl; std::cout << "Multi msg Received header " <<header[0]<<" "<<header[1]<<" "<<header[2]<<" "<<header[3]<<" "<< std::endl;
if (multi_msgs_receive.empty()){ if (multi_msgs_receive.empty()){
//std::cout << "first message" << std::endl; //std::cout << "first message" << std::endl;
multi_msgs_receive.insert(make_pair(header[2], in_message)); multi_msgs_receive.insert(make_pair(header[2], in_message));