Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Warnf (0.03 sec)

  1. cni/pkg/nodeagent/net.go

    	ingressMode := false
    	if a, f := pod.Annotations[annotation.AmbientBypassInboundCapture.Name]; f {
    		var err error
    		ingressMode, err = strconv.ParseBool(a)
    		if err != nil {
    			log.Warnf("annotation %v=%q found, but only '*' is supported", annotation.AmbientBypassInboundCapture.Name, a)
    		}
    	}
    
    	log.Debug("calling CreateInpodRules")
    	if err := s.netnsRunner(openNetns, func() error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    	s.kubeClient.RunAndWait(s.ctx.Done())
    	log.Info("CNI ambient server kubeclient started")
    	pods := s.handlers.GetActiveAmbientPodSnapshot()
    	err := s.dataplane.ConstructInitialSnapshot(pods)
    	if err != nil {
    		log.Warnf("failed to construct initial snapshot: %v", err)
    	}
    
    	log.Info("CNI ambient server marking ready")
    	s.Ready()
    	s.dataplane.Start(s.ctx)
    	s.handlers.Start()
    }
    
    func (s *Server) Stop() {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/informers.go

    	var pods []*corev1.Pod
    	for _, pod := range s.pods.List(metav1.NamespaceAll, klabels.Everything()) {
    		ns := s.namespaces.Get(pod.Namespace, "")
    		if ns == nil {
    			log.Warnf("failed to find namespace %s for pod %s", pod.Namespace, pod.Name)
    		}
    
    		// Exclude ztunnels, and terminated daemonset pods
    		// from the snapshot.
    		if !util.IsZtunnelPod(s.systemNamespace, pod) &&
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  4. cni/pkg/iptables/iptables_linux.go

    		// IPv6 may be enabled, but only partially
    		v, err := ReadSysctl(ipv6DisabledLo)
    		if v != "1" {
    			// If we got an error, we will proceed. Maybe it will work anyways
    			if err != nil {
    				log.Warnf("attempted to read %q got error: %v; attemping to continue", ipv6DisabledLo, err)
    			}
    			cidrs = append(cidrs, "0::0/0")
    		} else {
    			log.Debugf("IPv6 is enabled, but the loopback interface has IPv6 disabled; skipping")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Sep 06 09:44:28 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. istioctl/pkg/proxyconfig/proxyconfig.go

    				levelString, _ := getLogLevelFromConfigMap(ctx)
    				level, ok := stringToLevel[levelString]
    				if ok {
    					destLoggerLevels[defaultLoggerName] = level
    				} else {
    					log.Warnf("unable to get logLevel from ConfigMap istio-sidecar-injector, using default value %q for envoy proxies",
    						levelToString[defaultEnvoyOutputLevel])
    					destLoggerLevels[defaultLoggerName] = defaultEnvoyOutputLevel
    				}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  6. cni/pkg/iptables/iptables.go

    	redirectDNS := cfg.cfg.RedirectDNS
    	if ingressMode && cfg.cfg.TPROXYRedirection {
    		ingressMode = false
    		// We could support this, but TPROXYRedirection is deprecated and will be removed soon, so we can just test less.
    		log.Warnf("ignoring ingressMode due to TPROXYRedirection being enabled. These are mutually exclusive")
    	}
    
    	inpodMark := fmt.Sprintf("0x%x", InpodMark) + "/" + fmt.Sprintf("0x%x", InpodMask)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 15 15:39:28 UTC 2024
    - 23.3K bytes
    - Viewed (0)
Back to top