From dba0989c54740b8b9a221869ef2462756f0b4b3e Mon Sep 17 00:00:00 2001 From: Alexey Khit Date: Fri, 13 Jan 2023 13:37:36 +0300 Subject: [PATCH] Fix empty streams json on stream lock --- cmd/streams/stream.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/cmd/streams/stream.go b/cmd/streams/stream.go index 0a675b1f..2c175913 100644 --- a/cmd/streams/stream.go +++ b/cmd/streams/stream.go @@ -198,8 +198,12 @@ producers: //} func (s *Stream) MarshalJSON() ([]byte, error) { + if !s.mu.TryLock() { + log.Warn().Msgf("[streams] json locked") + return []byte(`null`), nil + } + var v []interface{} - s.mu.Lock() for _, prod := range s.producers { if prod.element != nil { v = append(v, prod.element)