- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for listenerStoppedCh (0.21 sec)
-
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
// Shutdown server gracefully. serverShutdownCh, listenerStoppedCh := make(chan struct{}), make(chan struct{}) go func() { defer close(serverShutdownCh) <-stopCh ctx, cancel := context.WithTimeout(context.Background(), shutDownTimeout) server.Shutdown(ctx) cancel() }() go func() { defer utilruntime.HandleCrash() defer close(listenerStoppedCh) var listener net.Listener
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
return fmt.Errorf("failed to run the audit backend: %v", err) } } stoppedCh, listenerStoppedCh, err := s.NonBlockingRunWithContext(stopHTTPServerCtx, shutdownTimeout) if err != nil { return err } httpServerStoppedListeningCh := s.lifecycleSignals.HTTPServerStoppedListening go func() { <-listenerStoppedCh httpServerStoppedListeningCh.Signal()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0) -
cmd/kube-scheduler/app/server.go
handler := buildHandlerChain(newHealthEndpointsAndMetricsHandler(&cc.ComponentConfig, cc.InformerFactory, isLeader, checks, readyzChecks), cc.Authentication.Authenticator, cc.Authorization.Authorizer) // TODO: handle stoppedCh and listenerStoppedCh returned by c.SecureServing.Serve if _, _, err := cc.SecureServing.Serve(handler, 0, ctx.Done()); err != nil { // fail early for secure handlers, removing the old error loop from above
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
// | stoppedCh is closed // | // | // <-drainedCh.Signaled() // | // s.AuditBackend.Shutdown() // | // <-listenerStoppedCh // | // <-stoppedCh // | // return nil func TestGracefulTerminationWithKeepListeningDuringGracefulTerminationDisabled(t *testing.T) { fakeAudit := &fakeAudit{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
slis.SLIMetricsWithReset{}.Install(unsecuredMux) handler := genericcontrollermanager.BuildHandlerChain(unsecuredMux, &c.Authorization, &c.Authentication) // TODO: handle stoppedCh and listenerStoppedCh returned by c.SecureServing.Serve if _, _, err := c.SecureServing.Serve(handler, 0, stopCh); err != nil { return err } } clientBuilder, rootClientBuilder := createClientBuilders(logger, c)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0)