Mirror/zeek
1
0
Fork 0
mirror of https://github.com/zeek/zeek.git synced 2025-10-02 06:38:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Remote logs are auto-flushed if the last write was longer than a

Browse source 
second ago. Addresses #498.
This commit is contained in:
Robin Sommer 2011-10-06 17:40:35 -07:00
parent 83ff7b65a6
commit f1ae48ea53
1 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/RemoteSerializer.cc
View file

@ -526,6 +526,7 @@ RemoteSerializer::RemoteSerializer()
closed = false;
terminating = false;
in_sync = 0;
last_flush = 0;
}
RemoteSerializer::~RemoteSerializer()
@ -2583,8 +2584,9 @@ bool RemoteSerializer::SendLogWrite(Peer* peer, EnumVal* id, EnumVal* writer, st
assert(len > 10);
// Do we have enough space in the buffer? If not, flush first.
if ( len > (LOG_BUFFER_SIZE - peer->log_buffer_used) )
// Do we have not enough space in the buffer, or was the last flush a
// while ago? If so, flush first.
if ( len > (LOG_BUFFER_SIZE - peer->log_buffer_used) || (network_time - last_flush > 1.0) )
{
if ( ! FlushLogBuffer(peer) )
return false;
@ -2610,6 +2612,8 @@ error:
bool RemoteSerializer::FlushLogBuffer(Peer* p)
{
last_flush = network_time;
if ( p->state == Peer::CLOSING )
return false;