- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NetnsDo (0.52 sec)
-
cni/pkg/nodeagent/netns_other.go
return errors.New("not implemented") } 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")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Mar 14 09:32:25 GMT 2024 - 1K bytes - Viewed (0) -
cni/pkg/nodeagent/netns_linux.go
if err := unix.Setns(int(n.Fd()), unix.CLONE_NEWNET); err != nil { 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) }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Jan 31 10:05:36 GMT 2024 - 2.7K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
) *NetServer { return &NetServer{ ztunnelServer: ztunnelServer, currentPodSnapshot: podNsMap, podNs: podNs, iptablesConfigurator: iptablesConfigurator, netnsRunner: NetnsDo, hostsideProbeIPSet: probeSet, } } func (s *NetServer) Start(ctx context.Context) { log.Debug("starting ztunnel server") go s.ztunnelServer.Run(ctx) } func (s *NetServer) Stop() {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1)