fix bug in MeterFilter

pull/2/head
weidai 2003-03-20 20:39:22 +00:00
parent 65abe91c8c
commit 067b425053
1 changed files with 15 additions and 11 deletions

View File

@ -133,19 +133,23 @@ bool Filter::OutputMessageSeriesEnd(int outputSite, int propagation, bool blocki
unsigned int MeterFilter::Put2(const byte *begin, unsigned int length, int messageEnd, bool blocking) unsigned int MeterFilter::Put2(const byte *begin, unsigned int length, int messageEnd, bool blocking)
{ {
FILTER_BEGIN; if (m_transparent)
m_currentMessageBytes += length;
m_totalBytes += length;
if (messageEnd)
{ {
m_currentMessageBytes = 0; FILTER_BEGIN;
m_currentSeriesMessages++; m_currentMessageBytes += length;
m_totalMessages++; m_totalBytes += length;
}
FILTER_OUTPUT(1, begin, length, messageEnd); if (messageEnd)
FILTER_END_NO_MESSAGE_END; {
m_currentMessageBytes = 0;
m_currentSeriesMessages++;
m_totalMessages++;
}
FILTER_OUTPUT(1, begin, length, messageEnd);
FILTER_END_NO_MESSAGE_END;
}
return 0;
} }
bool MeterFilter::IsolatedMessageSeriesEnd(bool blocking) bool MeterFilter::IsolatedMessageSeriesEnd(bool blocking)