github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 11:50:44 +00:00
Code Issues Projects Releases Wiki Activity

genericapiserver library must wait for server.Shutdown

Browse Source
This commit is contained in:
Lukasz Szaszkiewicz 2020-06-10 14:05:24 +02:00
parent b6bdd64b10
commit 4362d613f2
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
View File

@ -330,7 +330,7 @@ func (s preparedGenericAPIServer) Run(stopCh <-chan struct{}) error {
}() }()
// close socket after delayed stopCh // close socket after delayed stopCh
err := s.NonBlockingRun(delayedStopCh) stoppedCh, err := s.NonBlockingRun(delayedStopCh)
if err != nil { if err != nil {
return err return err
} }
@ -345,6 +345,8 @@ func (s preparedGenericAPIServer) Run(stopCh <-chan struct{}) error {
// wait for the delayed stopCh before closing the handler chain (it rejects everything after Wait has been called). // wait for the delayed stopCh before closing the handler chain (it rejects everything after Wait has been called).
<-delayedStopCh <-delayedStopCh
// wait for stoppedCh that is closed when the graceful termination (server.Shutdown) is finished.
<-stoppedCh
// Wait for all requests to finish, which are bounded by the RequestTimeout variable. // Wait for all requests to finish, which are bounded by the RequestTimeout variable.
s.HandlerChainWaitGroup.Wait() s.HandlerChainWaitGroup.Wait()
@ -354,7 +356,8 @@ func (s preparedGenericAPIServer) Run(stopCh <-chan struct{}) error {
// NonBlockingRun spawns the secure http server. An error is // NonBlockingRun spawns the secure http server. An error is
// returned if the secure port cannot be listened on. // returned if the secure port cannot be listened on.
func (s preparedGenericAPIServer) NonBlockingRun(stopCh <-chan struct{}) error { // The returned channel is closed when the (asynchronous) termination is finished.
func (s preparedGenericAPIServer) NonBlockingRun(stopCh <-chan struct{}) (<-chan struct{}, error) {
// Use an stop channel to allow graceful shutdown without dropping audit events // Use an stop channel to allow graceful shutdown without dropping audit events
// after http server shutdown. // after http server shutdown.
auditStopCh := make(chan struct{}) auditStopCh := make(chan struct{})
@ -363,7 +366,7 @@ func (s preparedGenericAPIServer) NonBlockingRun(stopCh <-chan struct{}) error {
// before http server start serving. Otherwise the Backend.ProcessEvents call might block. // before http server start serving. Otherwise the Backend.ProcessEvents call might block.
if s.AuditBackend != nil { if s.AuditBackend != nil {
if err := s.AuditBackend.Run(auditStopCh); err != nil { if err := s.AuditBackend.Run(auditStopCh); err != nil {
return fmt.Errorf("failed to run the audit backend: %v", err) return nil, fmt.Errorf("failed to run the audit backend: %v", err)
} }
} }
@ -376,7 +379,7 @@ func (s preparedGenericAPIServer) NonBlockingRun(stopCh <-chan struct{}) error {
if err != nil { if err != nil {
close(internalStopCh) close(internalStopCh)
close(auditStopCh) close(auditStopCh)
return err return nil, err
} }
} }
@ -399,7 +402,7 @@ func (s preparedGenericAPIServer) NonBlockingRun(stopCh <-chan struct{}) error {
klog.Errorf("Unable to send systemd daemon successful start message: %v\n", err) klog.Errorf("Unable to send systemd daemon successful start message: %v\n", err)
} }
return nil return stoppedCh, nil
} }
// installAPIResources is a private method for installing the REST storage backing each api groupversionresource // installAPIResources is a private method for installing the REST storage backing each api groupversionresource