diff --git a/service/ocm/service_websocket.go b/service/ocm/service_websocket.go index 4c552cbf5..4f76179ef 100644 --- a/service/ocm/service_websocket.go +++ b/service/ocm/service_websocket.go @@ -570,8 +570,11 @@ func (s *Service) pushWebSocketAggregatedStatus(ctx context.Context, clientConn } defer s.statusObserver.UnSubscribe(subscription) - var last aggregatedStatus - hasLast := false + last := s.computeAggregatedUtilization(provider, userConfig) + err = writeWebSocketAggregatedStatus(clientConn, clientWriteAccess, last) + if err != nil { + return + } for { select { @@ -582,13 +585,6 @@ func (s *Service) pushWebSocketAggregatedStatus(ctx context.Context, clientConn case <-sessionClosed: return case <-firstRealRequest: - current := s.computeAggregatedUtilization(provider, userConfig) - err = writeWebSocketAggregatedStatus(clientConn, clientWriteAccess, current) - if err != nil { - return - } - last = current - hasLast = true firstRealRequest = nil case <-subscription: for { @@ -599,9 +595,6 @@ func (s *Service) pushWebSocketAggregatedStatus(ctx context.Context, clientConn } } drained: - if !hasLast { - continue - } current := s.computeAggregatedUtilization(provider, userConfig) if current.equal(last) { continue