diff options
| author | rhenium <rhenium@rhe.jp> | 2014-05-18 20:34:49 +0900 |
|---|---|---|
| committer | rhenium <rhenium@rhe.jp> | 2014-05-18 20:34:49 +0900 |
| commit | 05164521262d016740bce860c28744f497a2c5b5 (patch) | |
| tree | 363670c1d95e26c8453614a354a25a3dc820534e /lib | |
| parent | 0a1ecd7cc18506a0fdedc14c4362cbb61cdac63a (diff) | |
| download | aclog-05164521262d016740bce860c28744f497a2c5b5.tar.gz | |
collector: don't defer
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/collector/daemon.rb | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/collector/daemon.rb b/lib/collector/daemon.rb index 876cf97..2363874 100644 --- a/lib/collector/daemon.rb +++ b/lib/collector/daemon.rb @@ -18,7 +18,7 @@ module Collector event_queue = Collector::EventQueue.new EM.add_periodic_timer(Settings.collector.flush_interval) do - EM.defer { event_queue.flush } + event_queue.flush end nodes = EM.start_server("0.0.0.0", Settings.collector.server_port, Collector::NodeConnection, event_queue) |