From 37c6033371f5ae7fb4bc618712cbba48fa018666 Mon Sep 17 00:00:00 2001 From: Amir Raminfar Date: Mon, 16 Oct 2023 09:26:27 -0700 Subject: [PATCH] fix: cleans up reading messages when headers are invalid (#2424) --- docker/event_generator.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/docker/event_generator.go b/docker/event_generator.go index 21ec7146..497b8bcd 100644 --- a/docker/event_generator.go +++ b/docker/event_generator.go @@ -125,7 +125,8 @@ func readEvent(reader *bufio.Reader, tty bool) (string, StdType, error) { return "", streamType, err } if n != 8 { - return "", streamType, ErrBadHeader + message, _ := reader.ReadString('\n') + return message, streamType, ErrBadHeader } switch header[0] { @@ -134,7 +135,8 @@ func readEvent(reader *bufio.Reader, tty bool) (string, StdType, error) { case 2: streamType = STDERR default: - return "", streamType, ErrBadHeader + message, _ := reader.ReadString('\n') + return message, streamType, ErrBadHeader } count := binary.BigEndian.Uint32(header[4:])