diff options
| author | Kazuki Yamaguchi <k@rhe.jp> | 2015-05-12 14:30:01 +0900 |
|---|---|---|
| committer | Kazuki Yamaguchi <k@rhe.jp> | 2015-05-12 14:30:01 +0900 |
| commit | e4d1686cbd1e59ab968675166ae25a7891b39f1a (patch) | |
| tree | 9d21d701d77f05ba9ab6c5e097fe55043a4a2db6 /lib/collector/event_queue.rb | |
| parent | f1051e1e7e70aa9c9864b3826060397ec508260b (diff) | |
| download | aclog-e4d1686cbd1e59ab968675166ae25a7891b39f1a.tar.gz | |
worker_node/collctor: cache with timestamp
Diffstat (limited to 'lib/collector/event_queue.rb')
| -rw-r--r-- | lib/collector/event_queue.rb | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/lib/collector/event_queue.rb b/lib/collector/event_queue.rb index 3851d82..936263b 100644 --- a/lib/collector/event_queue.rb +++ b/lib/collector/event_queue.rb @@ -93,8 +93,10 @@ module Collector private def cache(object) if id = object[:identifier] - unless @dalli.get(id) - @dalli.set(id, true) + key, val = id.split("#", 2) + cur = @dalli.get(id) + if !cur || (val && (cur <=> val) == -1) # not found or new + @dalli.set(key, true || value) yield end else |