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

Fix a unit test.

Browse source
This commit is contained in:
Jon Siwek 2013-08-15 15:53:00 -05:00
parent 57b193593d
commit e202500f5f
1 changed files with 10 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

13
testing/btest/scripts/base/frameworks/input/raw/stderr.bro
View file

@ -3,6 +3,7 @@
# @TEST-EXEC: btest-diff out # @TEST-EXEC: btest-diff out
redef exit_only_after_terminate = T; redef exit_only_after_terminate = T;
@load base/frameworks/communication # let network-time run. otherwise there are no heartbeats...
type Val: record { type Val: record {
s: string; s: string;
@ -37,12 +38,15 @@ event line(description: Input::EventDescription, tpe: Input::Event, s: string, i
} }
} }
global n = 0;
event Input::end_of_data(name: string, source:string) event Input::end_of_data(name: string, source:string)
{ {
print outfile, "End of Data event"; print outfile, "End of Data event";
print outfile, name; print outfile, name;
terminate(); # due to the current design, end_of_data will be called after process_finshed and all line events. ++n;
# this could potentially change if ( n == 2 )
terminate();
} }
event InputRaw::process_finished(name: string, source:string, exit_code:count, signal_exit:bool) event InputRaw::process_finished(name: string, source:string, exit_code:count, signal_exit:bool)
@ -51,6 +55,9 @@ event InputRaw::process_finished(name: string, source:string, exit_code:count, s
print outfile, name; print outfile, name;
if ( exit_code != 0 ) if ( exit_code != 0 )
print outfile, "Exit code != 0"; print outfile, "Exit code != 0";
++n;
if ( n == 2 )
terminate();
} }
event bro_init() event bro_init()
@ -62,5 +69,5 @@ event bro_init()
outfile = open("../out"); outfile = open("../out");
try = 0; try = 0;
Input::add_event([$source="ls .. ../nonexistant ../nonexistant2 ../nonexistant3 |", $reader=Input::READER_RAW, $name="input", $fields=Val, $ev=line, $want_record=F, $config=config_strings]); Input::add_event([$source="ls .. ../nonexistant ../nonexistant2 ../nonexistant3 |", $reader=Input::READER_RAW, $name="input", $fields=Val, $ev=line, $want_record=F, $config=config_strings, $mode=Input::STREAM]);
} }