net #

Description:

net provides networking functions. It is mostly a wrapper to BSD sockets, so you can listen on a port, connect to remote TCP/UDP services, and communicate with them.

fn addr_from_socket_handle(handle int) Addr

fn dial_tcp(address string) ?&TcpConn

fn dial_tcp_with_bind(saddr string, laddr string) ?&TcpConn

bind local address and dial.

fn dial_udp(raddr string) ?&UdpConn

fn listen_tcp(family AddrFamily, saddr string) ?&TcpListener

fn listen_udp(laddr string) ?&UdpConn

fn resolve_addrs(addr string, family AddrFamily, @type SocketType) ?[]Addr

fn resolve_addrs_fuzzy(addr string, @type SocketType) ?[]Addr

fn resolve_ipaddrs(addr string, family AddrFamily, typ SocketType) ?[]Addr

fn socket_error(potential_code int) ?int

fn socket_error_message(potential_code int, s string) ?int

fn split_address(addr string) ?(string, u16)

split address splits an address into its host name and its port

fn validate_port(port int) ?u16

validate_port checks whether a port is valid and returns the port or an error

fn wrap_error(error_code int) ?

fn (mut s TcpSocket) set_option_bool(opt SocketOption, value bool) ?

fn (mut s TcpSocket) set_dualstack(on bool) ?

fn (mut s TcpSocket) set_option_int(opt SocketOption, value int) ?

fn (mut s TcpSocket) bind(addr string) ?

bind a local rddress for TcpSocket

fn (mut s UdpSocket) set_option_bool(opt SocketOption, value bool) ?

fn (mut s UdpSocket) set_dualstack(on bool) ?

enum AddrFamily {
	unix = C.AF_UNIX
	ip = C.AF_INET
	ip6 = C.AF_INET6
	unspec = C.AF_UNSPEC
}

AddrFamily are the available address families

enum SocketOption {
// TODO: SO_ACCEPT_CONN is not here becuase windows doesnt support it
// and there is no easy way to define it
	broadcast = C.SO_BROADCAST
	debug = C.SO_DEBUG
	dont_route = C.SO_DONTROUTE
	error = C.SO_ERROR
	keep_alive = C.SO_KEEPALIVE
	linger = C.SO_LINGER
	oob_inline = C.SO_OOBINLINE
	reuse_addr = C.SO_REUSEADDR
	recieve_buf_size = C.SO_RCVBUF
	recieve_low_size = C.SO_RCVLOWAT
	recieve_timeout = C.SO_RCVTIMEO
	send_buf_size = C.SO_SNDBUF
	send_low_size = C.SO_SNDLOWAT
	send_timeout = C.SO_SNDTIMEO
	socket_type = C.SO_TYPE
	ipv6_only = C.IPV6_V6ONLY
}

enum SocketType {
	udp = C.SOCK_DGRAM
	tcp = C.SOCK_STREAM
	seqpacket = C.SOCK_SEQPACKET
}

SocketType are the available sockets

struct Addr {
pub:
	f    u16
	addr AddrData
}

fn (a Addr) family() AddrFamily

struct C.addrinfo {
mut:
	ai_family    int
	ai_socktype  int
	ai_flags     int
	ai_protocol  int
	ai_addrlen   int
	ai_addr      voidptr
	ai_canonname voidptr
	ai_next      voidptr
}

struct C.fd_set {}

struct C.sockaddr_in {
mut:
	sin_family u16
	sin_port   u16
	sin_addr   u32
}

struct C.sockaddr_in6 {
mut:
	sin6_family u16
	sin6_port   u16
	sin6_addr   [4]u32
}

struct C.sockaddr_un {
mut:
	sun_family u16
	sun_path   [max_unix_path]char
}

struct Ip {
	port u16
	addr [4]u8
// Pad to size so that socket functions
// dont complain to us (see  in.h and bind())
// TODO(emily): I would really like to use
// some constant calculations here
// so that this doesnt have to be hardcoded
	sin_pad [8]u8
}

struct Ip6 {
	port      u16
	flow_info u32
	addr      [16]u8
	scope_id  u32
}

struct Socket {
pub:
	handle int
}

fn (s &Socket) address() ?Addr

address gets the address of a socket

struct TcpConn {
pub mut:
	sock TcpSocket
mut:
	write_deadline time.Time
	read_deadline  time.Time
	read_timeout   time.Duration
	write_timeout  time.Duration
	is_blocking    bool
}

fn (c &TcpConn) addr() ?Addr

fn (mut c TcpConn) close() ?

fn (mut con TcpConn) get_blocking() bool

get_blocking returns whether the connection is in a blocking state, that is calls to .read_line, C.recv etc will block till there is new data arrived, instead of returning immediately.

fn (c &TcpConn) peer_addr() ?Addr

fn (c &TcpConn) peer_ip() ?string

fn (c TcpConn) read(mut buf []u8) !int

fn (mut c TcpConn) read_deadline() ?time.Time

fn (mut con TcpConn) read_line() string

read_line is a simple, non customizable, blocking line reader.
It will return a line, ending with LF, or just '', on EOF.
Note: if you want more control over the buffer, please use a buffered IO reader instead: io.new_buffered_reader({reader: io.make_reader(con)})

fn (mut con TcpConn) read_line_max(max_line_len int) string

read_line_max is a simple, non customizable, blocking line reader.
It will return a line, ending with LF, '' on EOF.
It stops reading, when the result line length exceeds max_line_len.

fn (c TcpConn) read_ptr(buf_ptr &u8, len int) ?int

fn (c &TcpConn) read_timeout() time.Duration

fn (mut con TcpConn) set_blocking(state bool) ?

set_blocking will change the state of the connection to either blocking, when state is true, or non blocking (false).
The default for net tcp connections is the non blocking mode.
Calling .read_line will set the connection to blocking mode.

fn (mut c TcpConn) set_read_deadline(deadline time.Time)

fn (mut c TcpConn) set_read_timeout(t time.Duration)

fn (mut c TcpConn) set_write_deadline(deadline time.Time)

fn (mut c TcpConn) set_write_timeout(t time.Duration)

fn (c TcpConn) str() string

fn (c TcpConn) wait_for_read() ?

fn (mut c TcpConn) wait_for_write() ?

fn (mut c TcpConn) write(bytes []u8) ?int

write blocks and attempts to write all data

fn (mut c TcpConn) write_deadline() ?time.Time

fn (mut c TcpConn) write_ptr(b &u8, len int) ?int

write_ptr blocks and attempts to write all data

fn (mut c TcpConn) write_string(s string) ?int

write_string blocks and attempts to write all data

fn (c &TcpConn) write_timeout() time.Duration

struct TcpListener {
pub mut:
	sock TcpSocket
mut:
	accept_timeout  time.Duration
	accept_deadline time.Time
}

fn (mut l TcpListener) accept() ?&TcpConn

fn (c &TcpListener) accept_deadline() ?time.Time

fn (mut c TcpListener) set_accept_deadline(deadline time.Time)

fn (c &TcpListener) accept_timeout() time.Duration

fn (mut c TcpListener) set_accept_timeout(t time.Duration)

fn (mut c TcpListener) wait_for_accept() ?

fn (mut c TcpListener) close() ?

fn (c &TcpListener) addr() ?Addr

struct UdpConn {
pub mut:
	sock UdpSocket
mut:
	write_deadline time.Time
	read_deadline  time.Time
	read_timeout   time.Duration
	write_timeout  time.Duration
}

fn (mut c UdpConn) write_ptr(b &u8, len int) ?int

sock := UdpSocket{ 		handle: sbase.handle 		l: local 		r: resolve_wrapper(raddr) 	} }

fn (mut c UdpConn) write(buf []u8) ?int

fn (mut c UdpConn) write_string(s string) ?int

fn (mut c UdpConn) write_to_ptr(addr Addr, b &u8, len int) ?int

fn (mut c UdpConn) write_to(addr Addr, buf []u8) ?int

write_to blocks and writes the buf to the remote addr specified

fn (mut c UdpConn) write_to_string(addr Addr, s string) ?int

write_to_string blocks and writes the buf to the remote addr specified

fn (mut c UdpConn) read(mut buf []u8) ?(int, Addr)

read reads from the socket into buf up to buf.len returning the number of bytes read

fn (c &UdpConn) read_deadline() ?time.Time

fn (mut c UdpConn) set_read_deadline(deadline time.Time)

fn (c &UdpConn) write_deadline() ?time.Time

fn (mut c UdpConn) set_write_deadline(deadline time.Time)

fn (c &UdpConn) read_timeout() time.Duration

fn (mut c UdpConn) set_read_timeout(t time.Duration)

fn (c &UdpConn) write_timeout() time.Duration

fn (mut c UdpConn) set_write_timeout(t time.Duration)

fn (mut c UdpConn) wait_for_read() ?

fn (mut c UdpConn) wait_for_write() ?

fn (c &UdpConn) str() string

fn (mut c UdpConn) close() ?

struct Unix {
	path [max_unix_path]u8
}