Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for retHandlers (0.17 sec)

  1. pkg/kubelet/kuberuntime/helpers.go

    			Reason:  c.Reason,
    			Message: c.Message,
    		})
    	}
    	retHandlers := make([]kubecontainer.RuntimeHandler, len(handlers))
    	for i, h := range handlers {
    		supportsRRO := false
    		supportsUserns := false
    		if h.Features != nil {
    			supportsRRO = h.Features.RecursiveReadOnlyMounts
    			supportsUserns = h.Features.UserNamespaces
    		}
    		retHandlers[i] = kubecontainer.RuntimeHandler{
    			Name:                            h.Name,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 12K bytes
    - Viewed (0)
  2. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SecuredHandlerCollection.groovy

        SecuredHandlerCollection() {
        }
    
        HandlerCollection getHandlers() {
            handlers
        }
    
        void reset() {
            realm = null
            securityHandler?.stop()
            securityHandler = null
            handlers.stop()
            delegate = handlers
            handlers.setHandlers(new Handler[0])
            handlers.start()
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  3. pkg/kubelet/runtime.go

    	s.Lock()
    	defer s.Unlock()
    	s.runtimeError = err
    }
    
    func (s *runtimeState) setRuntimeHandlers(rtHandlers []kubecontainer.RuntimeHandler) {
    	s.Lock()
    	defer s.Unlock()
    	s.rtHandlers = rtHandlers
    }
    
    func (s *runtimeState) runtimeHandlers() []kubecontainer.RuntimeHandler {
    	s.RLock()
    	defer s.RUnlock()
    	return s.rtHandlers
    }
    
    func (s *runtimeState) setStorageState(err error) {
    	s.Lock()
    	defer s.Unlock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 00:48:07 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  4. pkg/kubelet/pluginmanager/reconciler/reconciler.go

    		stopCh)
    }
    
    func (rc *reconciler) AddHandler(pluginType string, pluginHandler cache.PluginHandler) {
    	rc.Lock()
    	defer rc.Unlock()
    
    	rc.handlers[pluginType] = pluginHandler
    }
    
    func (rc *reconciler) getHandlers() map[string]cache.PluginHandler {
    	rc.RLock()
    	defer rc.RUnlock()
    
    	var copyHandlers = make(map[string]cache.PluginHandler)
    	for pluginType, handler := range rc.handlers {
    		copyHandlers[pluginType] = handler
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 18 04:27:38 UTC 2022
    - 6.2K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractorTest.java

                server = new Server(port);
    
                final RequestHandlerImpl request_handler = new RequestHandlerImpl();
                final HandlerList handlers = new HandlerList();
                handlers.setHandlers(new Handler[] { request_handler, new DefaultHandler() });
                server.setHandler(handlers);
            }
    
            public void start() {
                try {
                    server.start();
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_getters.go

    // user namespaces.
    func (kl *Kubelet) HandlerSupportsUserNamespaces(rtHandler string) (bool, error) {
    	rtHandlers := kl.runtimeState.runtimeHandlers()
    	if rtHandlers == nil {
    		return false, fmt.Errorf("runtime handlers are not set")
    	}
    	for _, h := range rtHandlers {
    		if h.Name == rtHandler {
    			return h.SupportsUserNamespaces, nil
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 00:48:07 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  7. fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java

            resource_handler.setResourceBase(docRoot.getAbsolutePath());
            Log.info("serving " + resource_handler.getBaseResource());
            final HandlerList handlers = new HandlerList();
            handlers.setHandlers(new Handler[] { resource_handler, new DefaultHandler() });
            server.setHandler(handlers);
        }
    
        public void start() {
            try {
                server.start();
            } catch (final Exception e) {
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  8. fess-crawler-es/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java

            resource_handler.setResourceBase(docRoot.getAbsolutePath());
            Log.info("serving " + resource_handler.getBaseResource());
            final HandlerList handlers = new HandlerList();
            handlers.setHandlers(new Handler[] { resource_handler, new DefaultHandler() });
            server.setHandler(handlers);
        }
    
        public void start() {
            try {
                server.start();
            } catch (final Exception e) {
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 5K bytes
    - Viewed (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java

            resource_handler.setResourceBase(docRoot.getAbsolutePath());
            Log.info("serving " + resource_handler.getBaseResource());
            final HandlerList handlers = new HandlerList();
            handlers.setHandlers(new Handler[] { resource_handler, new DefaultHandler() });
            server.setHandler(handlers);
        }
    
        public void start() {
            try {
                server.start();
            } catch (final Exception e) {
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 6.3K bytes
    - Viewed (0)
Back to top