1
1
package watch
2
2
3
3
import (
4
- "fmt"
5
4
"io/ioutil"
6
5
"log"
7
6
"os"
8
7
"path/filepath"
9
8
"strconv"
10
9
"strings"
11
10
11
+ "github.com/pkg/errors"
12
12
"github.com/windmilleng/fsnotify"
13
13
"google.golang.org/grpc"
14
14
"google.golang.org/grpc/codes"
@@ -29,27 +29,27 @@ type linuxNotify struct {
29
29
func (d * linuxNotify ) Add (name string ) error {
30
30
fi , err := os .Stat (name )
31
31
if err != nil && ! os .IsNotExist (err ) {
32
- return fmt . Errorf ( "notify.Add(%q): %v " , name , err )
32
+ return errors . Wrapf ( err , "notify.Add(%q)" , name )
33
33
}
34
34
35
- // if it's a file that doesn't exist watch it's parent
35
+ // if it's a file that doesn't exist, watch its parent
36
36
if os .IsNotExist (err ) {
37
37
parent := filepath .Join (name , ".." )
38
38
err = d .watcher .Add (parent )
39
39
if err != nil {
40
- return fmt . Errorf ( "notify.Add(%q): %v " , name , err )
40
+ return errors . Wrapf ( err , "notify.Add(%q)" , name )
41
41
}
42
42
d .watchList [parent ] = true
43
43
} else if fi .IsDir () {
44
44
err = d .watchRecursively (name )
45
45
if err != nil {
46
- return fmt . Errorf ( "notify.Add(%q): %v " , name , err )
46
+ return errors . Wrapf ( err , "notify.Add(%q)" , name )
47
47
}
48
48
d .watchList [name ] = true
49
49
} else {
50
50
err = d .watcher .Add (name )
51
51
if err != nil {
52
- return fmt . Errorf ( "notify.Add(%q): %v " , name , err )
52
+ return errors . Wrapf ( err , "notify.Add(%q)" , name )
53
53
}
54
54
d .watchList [name ] = true
55
55
}
@@ -68,7 +68,7 @@ func (d *linuxNotify) watchRecursively(dir string) error {
68
68
if os .IsNotExist (err ) {
69
69
return nil
70
70
}
71
- return fmt . Errorf ( "watcher.Add(%q): %v " , path , err )
71
+ return errors . Wrapf ( err , "watcher.Add(%q)" , path )
72
72
}
73
73
return nil
74
74
})
0 commit comments