Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 326 for addrI (0.15 sec)

  1. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go

    	res := []model.AddressInfo{}
    	type kindindex struct {
    		k     kind.Kind
    		index int
    	}
    	addrm := map[netip.Addr]kindindex{}
    	for _, wl := range a.workloads.List() {
    		overwrite := -1
    		write := true
    		for _, addr := range wl.Addresses {
    			a := byteIPToAddr(addr)
    			if existing, f := addrm[a]; f {
    				// This address was already found. We want unique addresses in the result.
    				// Pod > WorkloadEntry
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 19 17:19:41 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  2. src/net/lookup_test.go

    	}
    
    	defer dnsWaitGroup.Wait()
    
    	for _, tt := range lookupGoogleHostTests {
    		addrs, err := LookupHost(tt.name)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if len(addrs) == 0 {
    			t.Error("got no record")
    		}
    		for _, addr := range addrs {
    			if ParseIP(addr) == nil {
    				t.Errorf("got %q; want a literal IP address", addr)
    			}
    		}
    	}
    }
    
    func TestLookupLongTXT(t *testing.T) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  3. pilot/pkg/xds/workload.go

    		aliases := addr.Aliases()
    		removed.DeleteAll(aliases...)
    		n := addr.ResourceName()
    		have.Insert(n)
    		haveAliases.InsertAll(aliases...)
    		switch w.TypeUrl {
    		case v3.WorkloadType:
    			if addr.GetWorkload() != nil {
    				resources = append(resources, &discovery.Resource{
    					Name:     n,
    					Aliases:  aliases,
    					Resource: protoconv.MessageToAny(addr.GetWorkload()), // TODO: pre-marshal
    				})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 14:14:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  4. 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
    			ipAddr, ok := netip.AddrFromSlice(ip)
    			if !ok {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  5. src/net/http/serve_test.go

    	}))
    	if _, err := cst.c.Head(cst.ts.URL); err != nil {
    		t.Fatal(err)
    	}
    
    	host := cst.ts.Listener.Addr().String()
    	got := <-ch
    	if addr, ok := got.(net.Addr); !ok {
    		t.Errorf("local addr value = %T; want net.Addr", got)
    	} else if fmt.Sprint(addr) != host {
    		t.Errorf("local addr = %v; want %v", addr, host)
    	}
    }
    
    // https://golang.org/issue/15960
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 202K bytes
    - Viewed (0)
  6. pilot/cmd/pilot-agent/app/cmd.go

    	// Find IP addr of excluded interfaces and add to a map for instant lookup
    	for _, ifaceName := range exclusions {
    		iface, err := net.InterfaceByName(ifaceName)
    		if err != nil {
    			log.Warnf("Unable to get interface %s: %v", ifaceName, err)
    			continue
    		}
    		addrs, err := iface.Addrs()
    		if err != nil {
    			log.Warnf("Unable to get IP addr(s) of interface %s: %v", ifaceName, err)
    			continue
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  7. src/runtime/sema.go

    	}
    	releaseSudog(s)
    }
    
    func semrelease(addr *uint32) {
    	semrelease1(addr, false, 0)
    }
    
    func semrelease1(addr *uint32, handoff bool, skipframes int) {
    	root := semtable.rootFor(addr)
    	atomic.Xadd(addr, 1)
    
    	// Easy case: no waiters?
    	// This check must happen after the xadd, to avoid a missed wakeup
    	// (see loop in semacquire).
    	if root.nwait.Load() == 0 {
    		return
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 19K bytes
    - Viewed (0)
  8. cmd/server-main.go

    		haddrs, err := globalDNSCache.LookupHost(ctx, host)
    		if err == nil {
    			for _, addr := range haddrs {
    				addrs.Add(net.JoinHostPort(addr, globalMinioPort))
    			}
    		} else {
    			// Unable to lookup host in 2-secs, let it fail later anyways.
    			addrs.Add(globalMinioAddr)
    		}
    	} else {
    		addrs.Add(globalMinioAddr)
    	}
    	return addrs.ToSlice()
    }
    
    var globalLoggerOutput io.WriteCloser
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 04 15:12:57 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  9. pkg/kubelet/nodestatus/setters.go

    			if nodeIPSpecified {
    				ipAddr = nodeIP
    			} else if addr := netutils.ParseIPSloppy(hostname); addr != nil {
    				ipAddr = addr
    			} else {
    				var addrs []net.IP
    				addrs, _ = net.LookupIP(node.Name)
    				for _, addr := range addrs {
    					if err = validateNodeIPFunc(addr); err == nil {
    						if isPreferredIPFamily(addr) {
    							ipAddr = addr
    							break
    						} else if ipAddr == nil {
    							ipAddr = addr
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 12:12:04 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  10. cmd/common-main.go

    			if net.ParseIP(endpoint) == nil {
    				// Checking if the IP is a DNS entry.
    				addrs, err := globalDNSCache.LookupHost(GlobalContext, endpoint)
    				if err != nil {
    					logger.FatalIf(err, "Unable to initialize MinIO server with [%s] invalid entry found in MINIO_PUBLIC_IPS", endpoint)
    				}
    				for _, addr := range addrs {
    					domainIPs.Add(addr)
    				}
    			}
    			domainIPs.Add(endpoint)
    		}
    		updateDomainIPs(domainIPs)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 31.5K bytes
    - Viewed (0)
Back to top