diff --git a/pkg/memlogd/cmd/logread/main.go b/pkg/memlogd/cmd/logread/main.go index ff1d2ee90..8eab0e3ec 100644 --- a/pkg/memlogd/cmd/logread/main.go +++ b/pkg/memlogd/cmd/logread/main.go @@ -2,8 +2,10 @@ package main import ( "encoding/json" + "errors" "flag" "fmt" + "io" "net" "strings" "time" @@ -65,6 +67,9 @@ func main() { decoder := json.NewDecoder(conn) for { if err := decoder.Decode(&entry); err != nil { + if errors.Is(err, net.ErrClosed) || errors.Is(err, io.EOF) { + return + } panic(err) }