Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for disconnectClient (0.38 sec)

  1. pkg/kubelet/cm/devicemanager/plugin/v1beta1/handler.go

    }
    
    func (s *server) DeRegisterPlugin(pluginName string) {
    	klog.V(2).InfoS("Deregistering plugin", "plugin", pluginName)
    	client := s.getClient(pluginName)
    	if client != nil {
    		s.disconnectClient(pluginName, client)
    	}
    }
    
    func (s *server) ValidatePlugin(pluginName string, endpoint string, versions []string) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:21:15 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/devicemanager/plugin/v1beta1/server.go

    	go func() {
    		defer s.wg.Done()
    		s.grpc.Serve(ln)
    	}()
    
    	return nil
    }
    
    func (s *server) Stop() error {
    	s.visitClients(func(r string, c Client) {
    		if err := s.disconnectClient(r, c); err != nil {
    			klog.InfoS("Error disconnecting device plugin client", "resourceName", r, "err", err)
    		}
    	})
    
    	s.mutex.Lock()
    	defer s.mutex.Unlock()
    
    	if s.grpc == nil {
    		return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jan 27 02:10:25 UTC 2024
    - 5.4K bytes
    - Viewed (0)
Back to top