Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NetnsDo (0.52 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top