From cc374a5ea8f0f69e936cbf2def66080c5d805bf7 Mon Sep 17 00:00:00 2001 From: Christoph Ostarek Date: Mon, 18 Dec 2023 14:01:24 +0100 Subject: [PATCH] logread: do not close socket too early only close socket once reading is finished Signed-off-by: Christoph Ostarek --- pkg/memlogd/cmd/logread/main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/memlogd/cmd/logread/main.go b/pkg/memlogd/cmd/logread/main.go index 6f6b5a85b..78571971b 100644 --- a/pkg/memlogd/cmd/logread/main.go +++ b/pkg/memlogd/cmd/logread/main.go @@ -67,7 +67,6 @@ func StreamLogs(socketPath string, follow, dump bool) (<-chan LogEntry, error) { if err != nil { return nil, err } - defer conn.Close() var n int switch { @@ -85,6 +84,7 @@ func StreamLogs(socketPath string, follow, dump bool) (<-chan LogEntry, error) { c := make(chan LogEntry) go func(c chan<- LogEntry) { + defer conn.Close() var ( entry LogEntry decoder = json.NewDecoder(conn)