diff --git a/cmd/ipfswatch/main.go b/cmd/ipfswatch/main.go
index 87570e35643..c133039eb3d 100644
--- a/cmd/ipfswatch/main.go
+++ b/cmd/ipfswatch/main.go
@@ -121,12 +121,7 @@ func run(ipfsPath, watchPath string) error {
 					}
 				}
 				proc.Go(func(p process.Process) {
-					file, err := os.Open(e.Name)
-					if err != nil {
-						log.Println(err)
-					}
-					defer file.Close()
-					k, err := coreunix.Add(node, file)
+					k, err := coreunix.AddR(node, e.Name)
 					if err != nil {
 						log.Println(err)
 					}