fx: 增加walk 函数的错误检查

fileSync.go

@@ -12,8 +12,8 @@ import (
 )
 
 const (
-	SendDur  = 1111			// 发送时间间隔毫秒
-	SleepDur = 86400000		// 定期器初始睡眠时间
+	SendDur  = 1111     // 发送时间间隔毫秒
+	SleepDur = 86400000 // 定期器初始睡眠时间
 )
 
 var CollectFiles map[string]struct{}
@@ -25,17 +25,17 @@ var DelDirs []string
 var LenBuff []byte
 
 const (
-	hrl  = ".hrl"
-	erl  = ".erl"
-	beam = ".beam"
-	dtl  = ".dtl"
-	lfe  = "lfe"
-	ex   = "ex"
-	idea = ".idea"
-	svn = ".svn"
-	git = ".git"
-	lock = ".lock"
-	bea = ".bea"
+	hrl    = ".hrl"
+	erl    = ".erl"
+	beam   = ".beam"
+	dtl    = ".dtl"
+	lfe    = "lfe"
+	ex     = "ex"
+	idea   = ".idea"
+	svn    = ".svn"
+	git    = ".git"
+	lock   = ".lock"
+	bea    = ".bea"
 	config = ".config"
 )
 
@@ -97,7 +97,7 @@ func isDelDir(dirs []string, curDirs string) bool {
 
 // 判断所给路径文件/文件夹是否存在
 func existPath(path string) bool {
-	_, err := os.Stat(path)    //os.Stat获取文件信息
+	_, err := os.Stat(path) //os.Stat获取文件信息
 	if err != nil {
 		if os.IsNotExist(err) {
 			return false
@@ -112,7 +112,7 @@ func (w *Watch) watchDir(dir string) {
 	//通过Walk来遍历目录下的所有子目录
 	filepath.Walk(dir, func(path string, info os.FileInfo, err error) error {
 		//这里判断是否为目录，只需监控目录即可 目录下的文件也在监控范围内，不需要我们一个一个加
-		if info.IsDir() {
+		if err == nil && info.IsDir() {
 			path, err := filepath.Abs(path)
 			if err != nil {
 				return err
@@ -131,7 +131,7 @@ func (w *Watch) watchDir(dir string) {
 			//通过Walk来遍历目录下的所有子目录
 			filepath.Walk(v, func(path string, info os.FileInfo, err error) error {
 				//这里判断是否为目录，只需监控目录即可 目录下的文件也在监控范围内，不需要我们一个一个加
-				if info.IsDir() {
+				if err == nil && info.IsDir() {
 					path, err := filepath.Abs(path)
 					if err != nil {
 						return err
@@ -245,6 +245,7 @@ func SendToErl() {
 	Write(Str.Bytes())
 	Str.Reset()
 }
+
 //********************************************** port end   ************************************************************
 
 func main() {
@@ -252,7 +253,7 @@ func main() {
 	SendTimer = time.NewTimer(time.Millisecond * SleepDur)
 	defer SendTimer.Stop()
 	LenBuff = make([]byte, 4)
-	
+
 	Write([]byte("init"))
 	data, err := Read()
 	if err == io.EOF || err != nil {