| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155 | 
							- package net
 
- import (
 
- 	"net"
 
- 	"strings"
 
- )
 
- // Destination represents a network destination including address and protocol (tcp / udp).
 
- type Destination struct {
 
- 	Address Address
 
- 	Port    Port
 
- 	Network Network
 
- }
 
- // DestinationFromAddr generates a Destination from a net address.
 
- func DestinationFromAddr(addr net.Addr) Destination {
 
- 	switch addr := addr.(type) {
 
- 	case *net.TCPAddr:
 
- 		return TCPDestination(IPAddress(addr.IP), Port(addr.Port))
 
- 	case *net.UDPAddr:
 
- 		return UDPDestination(IPAddress(addr.IP), Port(addr.Port))
 
- 	case *net.UnixAddr:
 
- 		return UnixDestination(DomainAddress(addr.Name))
 
- 	default:
 
- 		panic("Net: Unknown address type.")
 
- 	}
 
- }
 
- // ParseDestination converts a destination from its string presentation.
 
- func ParseDestination(dest string) (Destination, error) {
 
- 	d := Destination{
 
- 		Address: AnyIP,
 
- 		Port:    Port(0),
 
- 	}
 
- 	if strings.HasPrefix(dest, "tcp:") {
 
- 		d.Network = Network_TCP
 
- 		dest = dest[4:]
 
- 	} else if strings.HasPrefix(dest, "udp:") {
 
- 		d.Network = Network_UDP
 
- 		dest = dest[4:]
 
- 	} else if strings.HasPrefix(dest, "unix:") {
 
- 		d = UnixDestination(DomainAddress(dest[5:]))
 
- 		return d, nil
 
- 	}
 
- 	hstr, pstr, err := SplitHostPort(dest)
 
- 	if err != nil {
 
- 		return d, err
 
- 	}
 
- 	if len(hstr) > 0 {
 
- 		d.Address = ParseAddress(hstr)
 
- 	}
 
- 	if len(pstr) > 0 {
 
- 		port, err := PortFromString(pstr)
 
- 		if err != nil {
 
- 			return d, err
 
- 		}
 
- 		d.Port = port
 
- 	}
 
- 	return d, nil
 
- }
 
- // TCPDestination creates a TCP destination with given address
 
- func TCPDestination(address Address, port Port) Destination {
 
- 	return Destination{
 
- 		Network: Network_TCP,
 
- 		Address: address,
 
- 		Port:    port,
 
- 	}
 
- }
 
- // UDPDestination creates a UDP destination with given address
 
- func UDPDestination(address Address, port Port) Destination {
 
- 	return Destination{
 
- 		Network: Network_UDP,
 
- 		Address: address,
 
- 		Port:    port,
 
- 	}
 
- }
 
- // UnixDestination creates a Unix destination with given address
 
- func UnixDestination(address Address) Destination {
 
- 	return Destination{
 
- 		Network: Network_UNIX,
 
- 		Address: address,
 
- 	}
 
- }
 
- // NetAddr returns the network address in this Destination in string form.
 
- func (d Destination) NetAddr() string {
 
- 	addr := ""
 
- 	if d.Network == Network_TCP || d.Network == Network_UDP {
 
- 		addr = d.Address.String() + ":" + d.Port.String()
 
- 	} else if d.Network == Network_UNIX {
 
- 		addr = d.Address.String()
 
- 	}
 
- 	return addr
 
- }
 
- // RawNetAddr converts a net.Addr from its Destination presentation.
 
- func (d Destination) RawNetAddr() net.Addr {
 
- 	var addr net.Addr
 
- 	switch d.Network {
 
- 	case Network_TCP:
 
- 		if d.Address.Family().IsIP() {
 
- 			addr = &net.TCPAddr{
 
- 				IP:   d.Address.IP(),
 
- 				Port: int(d.Port),
 
- 			}
 
- 		}
 
- 	case Network_UDP:
 
- 		if d.Address.Family().IsIP() {
 
- 			addr = &net.UDPAddr{
 
- 				IP:   d.Address.IP(),
 
- 				Port: int(d.Port),
 
- 			}
 
- 		}
 
- 	case Network_UNIX:
 
- 		if d.Address.Family().IsDomain() {
 
- 			addr = &net.UnixAddr{
 
- 				Name: d.Address.String(),
 
- 				Net:  d.Network.SystemString(),
 
- 			}
 
- 		}
 
- 	}
 
- 	return addr
 
- }
 
- // String returns the strings form of this Destination.
 
- func (d Destination) String() string {
 
- 	prefix := "unknown:"
 
- 	switch d.Network {
 
- 	case Network_TCP:
 
- 		prefix = "tcp:"
 
- 	case Network_UDP:
 
- 		prefix = "udp:"
 
- 	case Network_UNIX:
 
- 		prefix = "unix:"
 
- 	}
 
- 	return prefix + d.NetAddr()
 
- }
 
- // IsValid returns true if this Destination is valid.
 
- func (d Destination) IsValid() bool {
 
- 	return d.Network != Network_Unknown
 
- }
 
- // AsDestination converts current Endpoint into Destination.
 
- func (p *Endpoint) AsDestination() Destination {
 
- 	return Destination{
 
- 		Network: p.Network,
 
- 		Address: p.Address.AsAddress(),
 
- 		Port:    Port(p.Port),
 
- 	}
 
- }
 
 
  |