1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
# Monitor a given watcher for changes on a periodic interval.
class Puppet::Util::Watcher::PeriodicWatcher
# @param watcher [Puppet::Util::Watcher::ChangeWatcher] a watcher for the value to watch
# @param timer [Puppet::Util::Watcher::Timer] A timer to determine when to
# recheck the watcher. If the timeout of the timer is negative, then the
# watched value is always considered to be changed
def initialize(watcher, timer)
@watcher = watcher
@timer = timer
@timer.start
end
# @return [true, false] If the file has changed since it was last checked.
def changed?
return true if always_consider_changed?
@watcher = examine_watched_info(@watcher)
@watcher.changed?
end
private
def always_consider_changed?
@timer.timeout < 0
end
def examine_watched_info(known)
if @timer.expired?
@timer.start
known.next_reading
else
known
end
end
end
|
