Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for toRun (0.03 sec)

  1. src/runtime/netpoll_solaris.go

    			// scanning error reporting once we are sure
    			// about the event port on SmartOS.
    			//
    			// See golang.org/x/issue/30840.
    			delta += netpollready(&toRun, pd, mode)
    		}
    	}
    
    	return toRun, delta
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  2. 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: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Feb 10 00:31:55 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. src/runtime/netpoll.go

    //
    //go:nowritebarrier
    func netpollready(toRun *gList, pd *pollDesc, mode int32) int32 {
    	delta := int32(0)
    	var rg, wg *g
    	if mode == 'r' || mode == 'r'+'w' {
    		rg = netpollunblock(pd, 'r', true, &delta)
    	}
    	if mode == 'w' || mode == 'r'+'w' {
    		wg = netpollunblock(pd, 'w', true, &delta)
    	}
    	if rg != nil {
    		toRun.push(rg)
    	}
    	if wg != nil {
    		toRun.push(wg)
    	}
    	return delta
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net_test.go

    	netServer := newNetServer(ztunnelServer, podNsMap, iptablesConfigurator, NewPodNetnsProcFinder(fakeFs()), set)
    
    	netServer.netnsRunner = func(fdable NetnsFd, toRun func() error) error {
    		return toRun()
    	}
    	netServer.Start(ctx)
    	return netTestFixture{
    		netServer:            netServer,
    		podNsMap:             podNsMap,
    		ztunnelServer:        ztunnelServer,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/net.go

    	currentPodSnapshot   *podNetnsCache
    	iptablesConfigurator *iptables.IptablesConfigurator
    	podNs                PodNetnsFinder
    	// allow overriding for tests
    	netnsRunner        func(fdable NetnsFd, toRun func() error) error
    	hostsideProbeIPSet ipset.IPSet
    }
    
    var _ MeshDataplane = &NetServer{}
    
    func newNetServer(ztunnelServer ZtunnelServer, podNsMap *podNetnsCache,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 13.4K bytes
    - Viewed (0)
Back to top