()
| 79 | } |
| 80 | |
| 81 | func (d *fseventNotify) Start() error { |
| 82 | if len(d.stream.Paths) == 0 { |
| 83 | return nil |
| 84 | } |
| 85 | |
| 86 | d.closeOnce = sync.Once{} |
| 87 | |
| 88 | numberOfWatches.Add(int64(len(d.stream.Paths))) |
| 89 | |
| 90 | err := d.stream.Start() |
| 91 | if err != nil { |
| 92 | return err |
| 93 | } |
| 94 | go d.loop() |
| 95 | return nil |
| 96 | } |
| 97 | |
| 98 | func (d *fseventNotify) Close() error { |
| 99 | d.closeOnce.Do(func() { |