diff options
Diffstat (limited to 'pkg/stream/message.go')
| -rw-r--r-- | pkg/stream/message.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/pkg/stream/message.go b/pkg/stream/message.go index fbaae6ce4..18df19a60 100644 --- a/pkg/stream/message.go +++ b/pkg/stream/message.go @@ -23,6 +23,8 @@ import ( "io" "k8s.io/klog/v2" + + "github.com/kubeedge/kubeedge/common/constants" ) type MessageType uint64 @@ -89,7 +91,7 @@ func ReadMessageFromTunnel(r io.Reader) (*Message, error) { if err != nil { return nil, err } - data, err := io.ReadAll(buf) + data, err := io.ReadAll(io.LimitReader(buf, constants.MaxRespBodyLength)) if err != nil { return nil, err } |