Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 350 for adir (0.07 sec)

  1. pilot/pkg/networking/util/util.go

    func ConvertAddressToCidr(addr string) *core.CidrRange {
    	cidr, err := AddrStrToCidrRange(addr)
    	if err != nil {
    		log.Errorf("failed to convert address %s to CidrRange: %v", addr, err)
    		return nil
    	}
    
    	return cidr
    }
    
    // AddrStrToCidrRange converts from string to CIDR prefix
    func AddrStrToPrefix(addr string) (netip.Prefix, error) {
    	if len(addr) == 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  2. src/net/http/transport_test.go

    		t.Fatalf("after first response, expected %d idle conn cache keys; got %d", e, g)
    	}
    	addr := ts.Listener.Addr().String()
    	cacheKey := "|http|" + addr
    	if keys[0] != cacheKey {
    		t.Fatalf("Expected idle cache key %q; got %q", cacheKey, keys[0])
    	}
    	if e, g := 1, tr.IdleConnCountForTesting("http", addr); e != g {
    		t.Errorf("after first response, expected %d idle conns; got %d", e, g)
    	}
    
    	resch <- "res2"
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  3. src/cmd/vendor/github.com/google/pprof/driver/driver.go

    	// with the leaf function first.
    	SourceLine(addr uint64) ([]Frame, error)
    
    	// Symbols returns a list of symbols in the object file.
    	// If r is not nil, Symbols restricts the list to symbols
    	// with names matching the regular expression.
    	// If addr is not zero, Symbols restricts the list to symbols
    	// containing that address.
    	Symbols(r *regexp.Regexp, addr uint64) ([]*Sym, error)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  4. cni/pkg/repair/netns.go

    		return false, fmt.Errorf("failed to get interfaces")
    	}
    
    	for _, ief := range interfaces {
    		var addrs []net.Addr
    		if addrs, err = ief.Addrs(); err != nil {
    			return
    		}
    		for _, addr := range addrs {
    			switch v := addr.(type) {
    			case *net.IPNet:
    				if v.IP.Equal(targetAddr) {
    					return true, nil
    				}
    			}
    		}
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 04:07:10 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  5. src/net/lookup_test.go

    					}
    
    					var v4Addrs []netip.Addr
    					var v6Addrs []netip.Addr
    					for _, ip := range ips {
    						if addr, ok := netip.AddrFromSlice(ip); ok {
    							if addr.Is4() {
    								v4Addrs = append(v4Addrs, addr)
    							} else {
    								v6Addrs = append(v6Addrs, addr)
    							}
    						} else {
    							t.Fatalf("IP=%q is neither IPv4 nor IPv6", ip)
    						}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  6. src/runtime/lock_futex.go

    )
    
    // This implementation depends on OS-specific implementations of
    //
    //	futexsleep(addr *uint32, val uint32, ns int64)
    //		Atomically,
    //			if *addr == val { sleep }
    //		Might be woken up spuriously; that's allowed.
    //		Don't sleep longer than ns; ns < 0 means forever.
    //
    //	futexwakeup(addr *uint32, cnt uint32)
    //		If any procs are sleeping on addr, wake up at most cnt.
    
    const (
    	mutex_unlocked = 0
    	mutex_locked   = 1
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:34 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  7. tools/istio-iptables/pkg/config/config.go

    )
    
    // getLocalIP returns one of the local IP address and it should support IPv6 or not
    func getLocalIP(dualStack bool) (netip.Addr, bool, error) {
    	var isIPv6 bool
    	var ipAddrs []netip.Addr
    	addrs, err := LocalIPAddrs()
    	if err != nil {
    		return netip.Addr{}, isIPv6, err
    	}
    
    	for _, a := range addrs {
    		if ipnet, ok := a.(*net.IPNet); ok {
    			ip := ipnet.IP
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  8. internal/kms/config.go

    				cert := certificate.Get()
    				return &cert, nil
    			}
    		}
    
    		var caDir string
    		if opts != nil {
    			caDir = opts.CADir
    		}
    		conf.RootCAs, err = certs.GetRootCAs(env.Get(EnvKESServerCA, caDir))
    		if err != nil {
    			return nil, err
    		}
    
    		client := kes.NewClientWithConfig("", conf)
    		client.Endpoints = endpoints
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Jun 12 14:31:26 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/kube/controller/network.go

    	}
    	newGateways := model.NetworkGatewaySet{}
    	for _, addr := range gw.Spec.Addresses {
    		if addr.Type == nil {
    			continue
    		}
    		if addrType := *addr.Type; addrType != v1beta1.IPAddressType && addrType != v1beta1.HostnameAddressType {
    			continue
    		}
    		for _, l := range slices.Filter(gw.Spec.Listeners, autoPassthrough) {
    			networkGateway := base
    			networkGateway.Addr = addr.Value
    			networkGateway.Port = uint32(l.Port)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 22:23:22 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  10. internal/http/dial_others.go

    func NewInternodeDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext {
    	return func(ctx context.Context, network, addr string) (net.Conn, error) {
    		dialer := &net.Dialer{
    			Timeout: dialTimeout,
    		}
    		return dialer.DialContext(ctx, network, addr)
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Apr 24 04:08:47 UTC 2024
    - 1.6K bytes
    - Viewed (0)
Back to top