adds EOF check

bmeg · Dec 6, 2023 · 650fb83 · 650fb83
1 parent 43ab6e5
commit 650fb83
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/extractors/plugin_load.go b/extractors/plugin_load.go
@@ -3,6 +3,7 @@ package extractors
 import (
 	"bufio"
 	"encoding/json"
+	"io"
 	"log"
 	"os"
 	"os/exec"
@@ -52,7 +53,7 @@ func (ml *PluginLoadStep) Start(task task.RuntimeTask) (chan map[string]interfac
 
 			for err == nil {
 				line, isPrefix, err = reader.ReadLine()
-				if err != nil {
+				if err != nil && err != io.EOF {
 					log.Printf("plugin (%s) input error: %s", ml.CommandLine, err)
 				}
 				ln = append(ln, line...)

diff --git a/transform/plugin.go b/transform/plugin.go
@@ -3,6 +3,7 @@ package transform
 import (
 	"bufio"
 	"encoding/json"
+	"io"
 	"log"
 	"os"
 	"os/exec"
@@ -61,7 +62,7 @@ func (ps *pluginProcess) Process(in chan map[string]any, out chan map[string]any
 
 			for err == nil {
 				line, isPrefix, err = reader.ReadLine()
-				if err != nil {
+				if err != nil && err != io.EOF {
 					log.Printf("plugin (%s) input error: %s", ps.config.CommandLine, err)
 				}
 				ln = append(ln, line...)