Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for Justen (0.13 sec)

  1. cni/pkg/pluginlistener/listener.go

    		log.Warnf("Failed to create directory for %v: %v", path, err)
    	}
    
    	var err error
    	listener, err := net.Listen("unix", path)
    	if err != nil {
    		return nil, fmt.Errorf("failed to listen on unix socket %q: %v", path, err)
    	}
    
    	// Update file permission so that cni plugin has permission to access it.
    	if _, err := os.Stat(path); err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  2. cni/pkg/monitoring/monitoring.go

    	if port <= 0 {
    		return
    	}
    	mux := http.NewServeMux()
    	var listener net.Listener
    	var err error
    	if listener, err = net.Listen("tcp", fmt.Sprintf(":%d", port)); err != nil {
    		log.Errorf("unable to listen on socket: %v", err)
    		return
    	}
    	exporter, err := monitoring.RegisterPrometheusExporter(nil, nil)
    	if err != nil {
    		log.Errorf("could not set up prometheus exporter: %v", err)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jun 09 07:54:01 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/cni-watcher.go

    		}
    	}()
    
    	context.AfterFunc(s.ctx, func() {
    		if err := s.cniListenServer.Close(); err != nil {
    			log.Errorf("CNI listen server terminated with error: %v", err)
    		} else {
    			log.Debug("CNI listen server terminated")
    		}
    	})
    	return nil
    }
    
    func (s *CniPluginServer) handleAddEvent(w http.ResponseWriter, req *http.Request) {
    	if req.Body == nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 6.1K bytes
    - Viewed (0)
Back to top