Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for bagian (0.14 sec)

  1. cni/pkg/nodeagent/net.go

    	// in that case, try finding the netns using procfs.
    	if err := s.rescanPod(pod); err != nil {
    		log.Errorf("error scanning proc: error was %s", err)
    		return nil, err
    	}
    	// try again. we can still get here if the pod is in the process of being created.
    	// in this case the CNI will be invoked soon and provide us with the netns.
    	openNetns = s.currentPodSnapshot.Get(string(pod.UID))
    	if openNetns == nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  2. istioctl/pkg/multixds/gather.go

    		responses, err = queryEachShard(all, dr, istioNamespace, kubeClient, centralOpts)
    	}
    	if err != nil {
    		if _, ok := err.(ControlPlaneNotFoundError); ok {
    			// Attempt to get the XDS address from the webhook and try again
    			addr, err := getXdsAddressFromWebhooks(kubeClient)
    			if err == nil {
    				centralOpts.Xds = addr.host
    				centralOpts.GCPProject = addr.gcpProject
    				centralOpts.IstiodAddr = addr.istiod
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 08 08:38:19 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/ztunnelserver.go

    	we may need to ztunnel to send its (uid, bootid / boot time) to us
    	so that we can remove stale entries when the ztunnel pod is deleted
    	or when the ztunnel pod is restarted in the same pod (remove old entries when the same uid connects again, but with different boot id?)
    
    	save a queue of what needs to be sent to the ztunnel pod and send it one by one when it connects.
    
    	when a new ztunnel connects with different uid, only propagate deletes to older ztunnels.
    */
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  4. cni/pkg/iptables/iptables.go

    		{"-t", iptablesconstants.NAT, "-D", iptablesconstants.POSTROUTING, "-j", ChainHostPostrouting},
    		// flush-then-delete our created chains
    		// these sometimes fail due to "Device or resource busy" - again NBD.
    		{"-t", iptablesconstants.NAT, "-F", ChainHostPostrouting},
    		{"-t", iptablesconstants.NAT, "-X", ChainHostPostrouting},
    	}
    
    	// iptablei seems like a reasonable pluralization of iptables
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  5. cni/pkg/install/install.go

    		// We had a watch error - that's no good
    		return err
    	case <-ctx.Done():
    		return ctx.Err()
    	default:
    		// Valid configuration; set isReady to true and wait for modifications before checking again
    		setReady(in.isReady)
    		cniInstalls.With(resultLabel.Value(resultSuccess)).Increment()
    		// Pod set to "NotReady" before termination
    		return watcher.Wait(ctx)
    	}
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 10.8K bytes
    - Viewed (0)
Back to top