Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for GetAddr (0.13 sec)

  1. src/net/lookup_windows.go

    	var family int32 = syscall.AF_UNSPEC
    	switch ipVersion(network) {
    	case '4':
    		family = syscall.AF_INET
    	case '6':
    		family = syscall.AF_INET6
    	}
    
    	getaddr := func() ([]IPAddr, error) {
    		if err := acquireThread(ctx); err != nil {
    			return nil, &DNSError{
    				Name:      name,
    				Err:       mapErr(err).Error(),
    				IsTimeout: ctx.Err() == context.DeadlineExceeded,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:23:45 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  2. cmd/admin-handlers.go

    		return addr
    	}
    
    	// anonymizedAddr - Updated the addr of the node info with anonymized one
    	anonymizeAddr := func(info madmin.NodeInfo) {
    		info.SetAddr(anonAddr(info.GetAddr()))
    	}
    
    	partialWrite := func(oinfo madmin.HealthInfo) {
    		select {
    		case healthInfoCh <- oinfo:
    		case <-healthCtx.Done():
    		}
    	}
    
    	getAndWritePlatformInfo := func() {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 98K bytes
    - Viewed (0)
  3. src/net/netip/slow_test.go

    		if zone == "" {
    			return Addr{}, fmt.Errorf("netaddr.ParseIP(%q): no zone after zone specifier", s)
    		}
    	default:
    		return Addr{}, fmt.Errorf("netaddr.ParseIP(%q): too many zone specifiers", s) // TODO: less specific?
    	}
    
    	// IPv4 by itself is easy to do in a helper.
    	if strings.Count(s, ":") == 0 {
    		if zone != "" {
    			return Addr{}, fmt.Errorf("netaddr.ParseIP(%q): IPv4 addresses cannot have a zone", s)
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 11 19:54:31 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. src/net/sock_posix.go

    	// 3) the one passed to us as the raddr parameter.
    	lsa, _ = syscall.Getsockname(fd.pfd.Sysfd)
    	if crsa != nil {
    		fd.setAddr(fd.addrFunc()(lsa), fd.addrFunc()(crsa))
    	} else if rsa, _ = syscall.Getpeername(fd.pfd.Sysfd); rsa != nil {
    		fd.setAddr(fd.addrFunc()(lsa), fd.addrFunc()(rsa))
    	} else {
    		fd.setAddr(fd.addrFunc()(lsa), raddr)
    	}
    	return nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go

    		if waypointAddress == nil {
    			return nil
    		}
    
    		ip := waypointAddress.GetAddress()
    		netip, _ := netip.AddrFromSlice(ip)
    		netaddr := networkAddress{
    			network: waypointAddress.GetNetwork(),
    			ip:      netip.String(),
    		}
    		return append(make([]networkAddress, 1), netaddr)
    	})
    	WorkloadServices.RegisterBatch(krt.BatchedEventFilter(
    		func(a model.ServiceInfo) *workloadapi.Service {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 19 17:19:41 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  6. src/net/file_unix.go

    		poll.CloseFunc(s)
    		return nil, err
    	}
    	laddr := fd.addrFunc()(lsa)
    	raddr := fd.addrFunc()(rsa)
    	fd.net = laddr.Network()
    	if err := fd.init(); err != nil {
    		fd.Close()
    		return nil, err
    	}
    	fd.setAddr(laddr, raddr)
    	return fd, nil
    }
    
    func fileConn(f *os.File) (Conn, error) {
    	fd, err := newFileFD(f)
    	if err != nil {
    		return nil, err
    	}
    	switch fd.laddr.(type) {
    	case *TCPAddr:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  7. src/net/fd_posix.go

    	// immutable until Close
    	family      int
    	sotype      int
    	isConnected bool // handshake completed or use of association with peer
    	net         string
    	laddr       Addr
    	raddr       Addr
    }
    
    func (fd *netFD) setAddr(laddr, raddr Addr) {
    	fd.laddr = laddr
    	fd.raddr = raddr
    	runtime.SetFinalizer(fd, (*netFD).Close)
    }
    
    func (fd *netFD) Close() error {
    	runtime.SetFinalizer(fd, nil)
    	return fd.pfd.Close()
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 29 16:24:51 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  8. src/net/fd_fake.go

    		}
    		return nil, err
    	}
    	netfd = newFD("tcp", d)
    	if err = netfd.init(); err != nil {
    		netfd.Close()
    		return nil, err
    	}
    	return netfd, nil
    }
    
    func (fd *netFD) setAddr(laddr, raddr Addr) {
    	fd.laddr = laddr
    	fd.raddr = raddr
    	runtime.SetFinalizer(fd, (*netFD).Close)
    }
    
    func (fd *netFD) Close() error {
    	if fd.fakeNetFD != nil {
    		return fd.fakeNetFD.Close()
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Nov 20 15:56:08 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  9. src/net/fd_unix.go

    		poll.CloseFunc(d)
    		return nil, err
    	}
    	if err = netfd.init(); err != nil {
    		netfd.Close()
    		return nil, err
    	}
    	lsa, _ := syscall.Getsockname(netfd.pfd.Sysfd)
    	netfd.setAddr(netfd.addrFunc()(lsa), netfd.addrFunc()(rsa))
    	return netfd, nil
    }
    
    // Defined in os package.
    func newUnixFile(fd int, name string) *os.File
    
    func (fd *netFD) dup() (f *os.File, err error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 24 20:19:46 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  10. src/net/fd_windows.go

    	var llen, rlen int32
    	syscall.GetAcceptExSockaddrs((*byte)(unsafe.Pointer(&rawsa[0])),
    		0, rsan, rsan, &lrsa, &llen, &rrsa, &rlen)
    	lsa, _ := lrsa.Sockaddr()
    	rsa, _ := rrsa.Sockaddr()
    
    	netfd.setAddr(netfd.addrFunc()(lsa), netfd.addrFunc()(rsa))
    	return netfd, nil
    }
    
    // Unimplemented functions.
    
    func (fd *netFD) dup() (*os.File, error) {
    	// TODO: Implement this, perhaps using internal/poll.DupCloseOnExec.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 16:46:10 UTC 2024
    - 6.2K bytes
    - Viewed (0)
Back to top