Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for toRun (0.08 sec)

  1. cni/pkg/nodeagent/netns_linux.go

    		return fmt.Errorf("Error switching to ns fd %v: %v", n.Fd(), err)
    	}
    	return nil
    }
    
    // inspired by netns.Do() but with an existing fd.
    func NetnsDo(fdable NetnsFd, toRun func() error) error {
    	containedCall := func() error {
    		threadNS, err := netns.GetCurrentNS()
    		if err != nil {
    			return fmt.Errorf("failed to open current netns: %v", err)
    		}
    		defer threadNS.Close()
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jan 31 10:05:36 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/netns_other.go

    }
    
    func OpenNetns(nspath string) (NetnsCloser, error) {
    	return nil, errors.New("not implemented")
    }
    
    // inspired by netns.Do() but with an existing fd.
    func NetnsDo(fdable NetnsFd, toRun func() error) error {
    	return errors.New("not implemented")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Mar 14 09:32:25 UTC 2024
    - 1K bytes
    - Viewed (0)
  3. cni/pkg/plugin/plugin_dryrun_test.go

    	"istio.io/istio/tools/istio-iptables/pkg/cmd"
    	"istio.io/istio/tools/istio-iptables/pkg/dependencies"
    )
    
    type mockNetNs struct {
    	path string
    }
    
    func (ns *mockNetNs) Do(toRun func(ns.NetNS) error) error {
    	return toRun(ns)
    }
    
    func (*mockNetNs) Set() error {
    	return nil
    }
    
    func (ns *mockNetNs) Path() string {
    	return ns.path
    }
    
    func (*mockNetNs) Fd() uintptr {
    	return 0
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Aug 27 16:44:45 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net_test.go

    	ztunnelServer := &fakeZtunnel{}
    
    	netServer := newNetServer(ztunnelServer, podNsMap, iptablesConfigurator, NewPodNetnsProcFinder(fakeFs()))
    
    	netServer.netnsRunner = func(fdable NetnsFd, toRun func() error) error {
    		return toRun()
    	}
    	netServer.Start(ctx)
    	return netTestFixture{
    		netServer:            netServer,
    		podNsMap:             podNsMap,
    		ztunnelServer:        ztunnelServer,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/net.go

    	ztunnelServer      ZtunnelServer
    	currentPodSnapshot *podNetnsCache
    	podIptables        *iptables.IptablesConfigurator
    	podNs              PodNetnsFinder
    	// allow overriding for tests
    	netnsRunner func(fdable NetnsFd, toRun func() error) error
    }
    
    var _ MeshDataplane = &NetServer{}
    
    func newNetServer(ztunnelServer ZtunnelServer, podNsMap *podNetnsCache, podIptables *iptables.IptablesConfigurator, podNs PodNetnsFinder) *NetServer {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
Back to top