Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for listenerStoppedCh (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top