watch_poll.go RawHistoryFolder

1package kvconf
2
3import "time"
4
5// poller reports every watched directory at each tick; the file stamps tell
6// what changed. It works everywhere.
7type poller struct {
8	every   time.Duration
9	targets []*target
10	woken   chan struct{}
11	timer   *time.Timer
12}
13
14func newPoller(every time.Duration) *poller {
15	t := time.NewTimer(time.Hour)
16	t.Stop()
17	return &poller{every: every, woken: make(chan struct{}, 1), timer: t}
18}
19
20func (p *poller) set(targets []*target) (bool, error) {
21	p.targets = targets
22	return false, nil
23}
24
25func (p *poller) wait(timeout time.Duration, evs []event) ([]event, error) {
26	d := p.every
27	if timeout >= 0 && timeout < d {
28		d = timeout
29	}
30	p.timer.Reset(d)
31	select {
32	case <-p.timer.C:
33	case <-p.woken:
34		p.timer.Stop()
35		return evs, nil
36	}
37	for _, t := range p.targets {
38		evs = append(evs, event{dir: t.dir})
39	}
40	return evs, nil
41}
42
43func (p *poller) wake() {
44	select {
45	case p.woken <- struct{}{}:
46	default:
47	}
48}
49
50func (p *poller) close() error { return nil }