Skip to content

Commit

Permalink
close the channel for component status updates to avoid blocking
Browse files Browse the repository at this point in the history
Signed-off-by: Florian Bacher <[email protected]>
  • Loading branch information
bacherfl committed Dec 11, 2024
1 parent c511562 commit da5f159
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions extension/opampextension/opamp_agent.go
Original file line number Diff line number Diff line change
Expand Up @@ -162,6 +162,9 @@ func (o *opampAgent) Shutdown(ctx context.Context) error {

o.statusSubscriptionWg.Wait()
o.componentHealthWg.Wait()
if o.componentStatusCh != nil {
close(o.componentStatusCh)
}

o.logger.Debug("OpAMP agent shutting down...")
if o.opampClient == nil {
Expand Down

0 comments on commit da5f159

Please sign in to comment.