- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for toRun (0.04 sec)
-
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) -
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) -
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) -
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) -
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)