We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e3cde12 commit 61ac792Copy full SHA for 61ac792
server.go
@@ -196,6 +196,10 @@ func (s *ExtensionManagerServer) Start() error {
196
err := func() error {
197
s.mutex.Lock()
198
defer s.mutex.Unlock()
199
+ // check after the lock the serverClient is present. It could have gone away on very short restart loops
200
+ if s.serverClient == nil {
201
+ return errors.New("cannot start, shutdown in progress")
202
+ }
203
registry := s.genRegistry()
204
205
stat, err := s.serverClient.RegisterExtension(
@@ -278,9 +282,7 @@ func (s *ExtensionManagerServer) Run() error {
278
282
}()
279
283
280
284
err := <-errc
281
- if err := s.Shutdown(context.Background()); err != nil {
- return err
- }
285
+ _ = s.Shutdown(context.Background())
286
return err
287
}
288
0 commit comments