29 lines
554 B
Plaintext
29 lines
554 B
Plaintext
redef exit_only_after_terminate = T;
|
|
|
|
global value = 0;
|
|
|
|
global event_1: event(val: count);
|
|
|
|
event bye_bye()
|
|
{
|
|
print "received bye-bye event";
|
|
terminate();
|
|
}
|
|
|
|
event publish_next()
|
|
{
|
|
Broker::publish("benchmark/events", event_1, value);
|
|
++value;
|
|
schedule 1msec { publish_next() };
|
|
}
|
|
|
|
event zeek_init()
|
|
{
|
|
local broker_port = to_port(getenv("BROKER_PORT"));
|
|
print fmt("trying to connect to port %s", broker_port);
|
|
Broker::subscribe("benchmark/terminate");
|
|
Broker::peer("127.0.0.1", broker_port);
|
|
schedule 250usec { publish_next() };
|
|
}
|
|
|