Skip to content
Snippets Groups Projects
Unverified Commit 273f8af5 authored by Giuseppe Carboni's avatar Giuseppe Carboni Committed by GitHub
Browse files

Porting latest hotfix onto master

parents c0bdaddc 5f52c09a
No related branches found
No related tags found
No related merge requests found
...@@ -41,11 +41,13 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p) ...@@ -41,11 +41,13 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p)
char *buffer; char *buffer;
DDWORD headerSize=sizeof(Backends::TDumpHeader);*/ DDWORD headerSize=sizeof(Backends::TDumpHeader);*/
Backends::TDumpHeader *dumpH; Backends::TDumpHeader *dumpH;
DDWORD totalBytes;
if (flowNumber_m==1) { if (flowNumber_m==1) {
if (m_buffer==NULL) { if (m_buffer==NULL) {
m_buffer=new char[frame_p->total_length()]; m_buffer=new char[frame_p->total_length()];
m_bufferLen=frame_p->total_length(); m_bufferLen=frame_p->total_length();
totalBytes=frame_p->total_length();
m_bufferPointer=0; m_bufferPointer=0;
} }
else { else {
...@@ -53,6 +55,7 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p) ...@@ -53,6 +55,7 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p)
memcpy(newBuff,m_buffer,m_bufferPointer); // save the old buffer; memcpy(newBuff,m_buffer,m_bufferPointer); // save the old buffer;
delete []m_buffer; //get rid of the old buffer; delete []m_buffer; //get rid of the old buffer;
m_bufferLen+=frame_p->total_length(); //update the buffer length; m_bufferLen+=frame_p->total_length(); //update the buffer length;
totalBytes=frame_p->total_length();
m_buffer=newBuff; // now keep track of the buffer pointer; m_buffer=newBuff; // now keep track of the buffer pointer;
} }
while (frame_p!=NULL) { while (frame_p!=NULL) {
...@@ -74,7 +77,7 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p) ...@@ -74,7 +77,7 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p)
m_bufferLen=0; m_bufferLen=0;
m_bufferPointer=0; m_bufferPointer=0;
} }
m_receivedBytes+=frame_p->total_length(); m_receivedBytes+=totalBytes;
} }
return 0; return 0;
} }
......
...@@ -44,11 +44,13 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p) ...@@ -44,11 +44,13 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p)
char *buffer; char *buffer;
DDWORD headerSize=sizeof(Backends::TDumpHeader);*/ DDWORD headerSize=sizeof(Backends::TDumpHeader);*/
Backends::TDumpHeader *dumpH; Backends::TDumpHeader *dumpH;
DDWORD totalBytes;
if (flowNumber_m==1) { if (flowNumber_m==1) {
if (m_buffer==NULL) { if (m_buffer==NULL) {
m_buffer=new char[frame_p->total_length()]; m_buffer=new char[frame_p->total_length()];
m_bufferLen=frame_p->total_length(); m_bufferLen=frame_p->total_length();
totalBytes=frame_p->total_length();
m_bufferPointer=0; m_bufferPointer=0;
} }
else { else {
...@@ -56,6 +58,7 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p) ...@@ -56,6 +58,7 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p)
memcpy(newBuff,m_buffer,m_bufferPointer); // save the old buffer; memcpy(newBuff,m_buffer,m_bufferPointer); // save the old buffer;
delete []m_buffer; //get rid of the old buffer; delete []m_buffer; //get rid of the old buffer;
m_bufferLen+=frame_p->total_length(); //update the buffer length; m_bufferLen+=frame_p->total_length(); //update the buffer length;
totalBytes=frame_p->total_length();
m_buffer=newBuff; // now keep track of the buffer pointer; m_buffer=newBuff; // now keep track of the buffer pointer;
} }
while (frame_p!=NULL) { while (frame_p!=NULL) {
...@@ -76,7 +79,7 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p) ...@@ -76,7 +79,7 @@ int ReceiverCallback::cbReceive(ACE_Message_Block * frame_p)
m_bufferLen=0; m_bufferLen=0;
m_bufferPointer=0; m_bufferPointer=0;
} }
m_receivedBytes+=frame_p->total_length(); m_receivedBytes+=totalBytes;
} }
return 0; return 0;
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment