Commitb7e88f0

committed

fix: remove closed check when starting notification manager

1 parentcba69f3 commitb7e88f0Copy full SHA for b7e88f0

File tree

-11

lines changed

-11

lines changed

Lines changed: 0 additions & 11 deletions

Original file line number	Diff line number	Diff line change
`@@ -53,7 +53,6 @@ type Manager struct {`
`53`	`53`	`success,failurechandispatchResult`
`54`	`54`
`55`	`55`	`mu sync.Mutex// Protects following.`
`56`		`-closedbool`
`57`	`56`	`notifier*notifier`
`58`	`57`
`59`	`58`	`runOnce sync.Once`
`@@ -161,11 +160,6 @@ func (m *Manager) loop(ctx context.Context) error {`
`161`	`160`	`}()`
`162`	`161`
`163`	`162`	`m.mu.Lock()`
`164`		`-ifm.closed {`
`165`		`-m.mu.Unlock()`
`166`		`-returnxerrors.New("manager already closed")`
`167`		`-}`
`168`		`-`
`169`	`163`	`vareg errgroup.Group`
`170`	`164`
`171`	`165`	`m.notifier=newNotifier(ctx,m.cfg,uuid.New(),m.log,m.store,m.handlers,m.helpers,m.metrics,m.clock)`
`@@ -354,11 +348,6 @@ func (m *Manager) Stop(ctx context.Context) error {`
`354`	`348`	`m.mu.Lock()`
`355`	`349`	`deferm.mu.Unlock()`
`356`	`350`
`357`		`-ifm.closed {`
`358`		`-returnnil`
`359`		`-}`
`360`		`-m.closed=true`
`361`		`-`
`362`	`351`	`m.log.Debug(context.Background(),"graceful stop requested")`
`363`	`352`
`364`	`353`	`// If the notifier hasn't been started, we don't need to wait for anything.`

Comments

(0)