more logs

Signed-off-by: Nikita Skrynnik <nikita.skrynnik@xored.com>
networkservicemesh · Oct 9, 2023 · 01e4176 · 01e4176
1 parent 948f3cf
commit 01e4176
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/internal/prefixcollector/collector.go b/internal/prefixcollector/collector.go
@@ -112,6 +112,9 @@ func (epc *ExcludedPrefixCollector) Serve(ctx context.Context) {
 	for {
 		select {
 		case <-epc.notifyChan:
+
+			// Можно тут прочитать весь канал
+
 			epc.updateExcludedPrefixes(ctx)
 		case <-ctx.Done():
 			return

diff --git a/internal/prefixcollector/collector_file_output_test.go b/internal/prefixcollector/collector_file_output_test.go
@@ -141,9 +141,10 @@ func (eps *ExcludedPrefixesSuite) watchFile(ctx context.Context, prefixesFilePat
 					close(errorCh)
 					return
 				}
+
 				if event.Op&fsnotify.Write == fsnotify.Write {
 					modifyCount++
-					log.FromContext(ctx).Infof("File is modified. Operation: %s", event.Op.String())
+					log.FromContext(ctx).Infof("File is modified. Event: %v. Operation: %s.", event.String(), event.Op.String())
 					if modifyCount == maxModifyCount {
 						close(errorCh)
 						return

diff --git a/internal/prefixcollector/prefix_writer.go b/internal/prefixcollector/prefix_writer.go
@@ -48,11 +48,9 @@ func fileWriter(filePath string) writePrefixesFunc {
 			return
 		}
 
-		if ctx.Err() == nil {
-			err = os.WriteFile(filePath, data, outputFilePermissions)
-			if err != nil {
-				log.FromContext(ctx).Fatalf("Unable to write into file: %v", err.Error())
-			}
+		err = os.WriteFile(filePath, data, outputFilePermissions)
+		if err != nil {
+			log.FromContext(ctx).Fatalf("Unable to write into file: %v", err.Error())
 		}
 	}
 }