- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 360 for addrI (0.04 sec)
-
src/net/lookup.go
if err != nil { return nil, err } addrs := addrsi.([]IPAddr) if shared { clone := make([]IPAddr, len(addrs)) copy(clone, addrs) addrs = clone } return addrs, nil } // ipAddrsEface returns an empty interface slice of addrs. func ipAddrsEface(addrs []IPAddr) []any { s := make([]any, len(addrs)) for i, v := range addrs { s[i] = v } return s }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 28.6K bytes - Viewed (0) -
cni/pkg/repair/netns.go
if interfaces, err = net.Interfaces(); err != nil { 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) -
src/net/interface.go
s = "0" } return s } // Addrs returns a list of unicast interface addresses for a specific // interface. func (ifi *Interface) Addrs() ([]Addr, error) { if ifi == nil { return nil, &OpError{Op: "route", Net: "ip+net", Source: nil, Addr: nil, Err: errInvalidInterface} } ifat, err := interfaceAddrTable(ifi) if err != nil { err = &OpError{Op: "route", Net: "ip+net", Source: nil, Addr: nil, Err: err} } return ifat, err
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/ctrlz/ctrlz.go
router.PathPrefix("/debug/pprof/").HandlerFunc(pprof.Index) } registerHome(router, mainLayout) addr := o.Address if addr == "*" { addr = "" } // Canonicalize the address and resolve a dynamic port if necessary listener, err := net.Listen("tcp", fmt.Sprintf("%s:%d", addr, o.Port)) if err != nil { log.Errorf("Unable to start ControlZ: %v", err) return nil, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 21:22:53 UTC 2024 - 5.9K bytes - Viewed (0) -
pkg/proxy/util/utils.go
func AppendPortIfNeeded(addr string, port int32) string { // Return if address is already in "ipv4:port" or "[ipv6]:port" format. if _, _, err := net.SplitHostPort(addr); err == nil { return addr } // Simply return for invalid case. This should be caught by validation instead. ip := netutils.ParseIPSloppy(addr) if ip == nil { return addr } // Append port to address.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 7.4K bytes - Viewed (0) -
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) -
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) -
pkg/proxy/util/nodeport_addresses.go
func (npa *NodePortAddresses) GetNodeIPs(nw NetworkInterfacer) ([]net.IP, error) { addrs, err := nw.InterfaceAddrs() if err != nil { return nil, fmt.Errorf("error listing all interfaceAddrs from host, error: %v", err) } // Use a map to dedup matches addresses := make(map[string]net.IP) for _, cidr := range npa.cidrs { for _, addr := range addrs { var ip net.IP
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 3.6K bytes - Viewed (0) -
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) -
src/net/tcpsock.go
func TCPAddrFromAddrPort(addr netip.AddrPort) *TCPAddr { return &TCPAddr{ IP: addr.Addr().AsSlice(), Zone: addr.Addr().Zone(), Port: int(addr.Port()), } } // TCPConn is an implementation of the [Conn] interface for TCP network // connections. type TCPConn struct { conn } // KeepAliveConfig contains TCP keep-alive options. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 13.7K bytes - Viewed (0)