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

Give log buffer the correct name.

Browse source
This commit is contained in:
Matthias Vallentin 2012-12-24 23:06:56 -08:00
parent 7ff15f4599
commit 32a0ead698
1 changed files with 13 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

28
scripts/base/protocols/ssl/main.bro
View file

@ -131,15 +131,13 @@ redef likely_server_ports += {
989/tcp, 990/tcp, 992/tcp, 993/tcp, 995/tcp, 5223/tcp 989/tcp, 990/tcp, 992/tcp, 993/tcp, 995/tcp, 5223/tcp
}; };
# A double-ended queue that determines the log record order in which logs have # A queue that buffers log records.
# to written out to disk. global queue: table[count] of Info;
global deque: table[count] of Info;
# The top-most deque index. # The top queue index where records are added.
global head = 0; global head = 0;
# The bottom deque index that points to the next record to be flushed as soon # The bottom queue index that points to the next record to be flushed.
# as the notary response arrives.
global tail = 0; global tail = 0;
function set_session(c: connection) function set_session(c: connection)
@ -154,7 +152,7 @@ function delay_record(info: Info, token: string)
info$delay_tokens = set(); info$delay_tokens = set();
add info$delay_tokens[token]; add info$delay_tokens[token];
deque[head] = info; queue[head] = info;
++head; ++head;
} }
@ -173,11 +171,11 @@ event delay_logging(info: Info)
function log_record(info: Info) function log_record(info: Info)
{ {
for ( unused_index in deque ) for ( unused_index in queue )
{ {
if ( head == tail ) if ( head == tail )
return; return;
if ( |deque[tail]$delay_tokens| > 0 ) if ( |queue[tail]$delay_tokens| > 0 )
{ {
if ( info$ts + max_log_delay > network_time() ) if ( info$ts + max_log_delay > network_time() )
{ {
@ -193,8 +191,8 @@ function log_record(info: Info)
""); "");
} }
} }
Log::write(SSL::LOG, deque[tail]); Log::write(SSL::LOG, queue[tail]);
delete deque[tail]; delete queue[tail];
++tail; ++tail;
} }
} }
@ -307,12 +305,12 @@ event protocol_violation(c: connection, atype: count, aid: count,
event bro_done() event bro_done()
{ {
if ( |deque| == 0 ) if ( |queue| == 0 )
return; return;
for ( unused_index in deque ) for ( unused_index in queue )
{ {
Log::write(SSL::LOG, deque[tail]); Log::write(SSL::LOG, queue[tail]);
delete deque[tail]; delete queue[tail];
++tail; ++tail;
} }
} }