POSIX & Networking Support

[kristate]

Tracking issue for building-out std.os.posix.* and friends.

OS Support

• Darwin (macOS, iOS, tvOS)
  tracking PR: More Socket Defines for Darwin #1272
• Windows
• BSD?

Async API

• Berkeley Sockets
• TCP
• UDP
  tracking PR: [WIP] UDP Networking #1331

Memos

zig/std/event/tcp.zig

Line 127 in b6eb404

// TODO build abstractions for other operating systems

[ghost]

looks like sockets are already available?

zig/lib/std/net.zig

Lines 219 to 247 in 5026db1

	pub fn connectUnixSocket(path: []const u8) !std.fs.File {
	const opt_non_block = if (std.event.Loop.instance != null) os.SOCK_NONBLOCK else 0;
	const sockfd = try os.socket(
	os.AF_UNIX,
	os.SOCK_STREAM | os.SOCK_CLOEXEC | opt_non_block,
	0,
	);
	errdefer os.close(sockfd);
	var sock_addr = os.sockaddr{
	.un = os.sockaddr_un{
	.family = os.AF_UNIX,
	.path = undefined,
	},
	};
	if (path.len > @typeOf(sock_addr.un.path).len) return error.NameTooLong;
	mem.copy(u8, sock_addr.un.path[0..], path);
	const size = @intCast(u32, @sizeOf(os.sa_family_t) + path.len);
	if (std.event.Loop.instance) |loop| {
	try os.connect_async(sockfd, &sock_addr, size);
	try loop.linuxWaitFd(sockfd, os.EPOLLIN | os.EPOLLOUT | os.EPOLLET);
	try os.getsockoptError(sockfd);
	} else {
	try os.connect(sockfd, &sock_addr, size);
	}
	return std.fs.File.openHandle(sockfd);
	}

[shawnl]

@cup But that is not asynchronous.

[ghost]

@shawnl yeah, it is:

zig/lib/std/net.zig

Line 239 in 5026db1

try os.connect_async(sockfd, &sock_addr, size);

zig/lib/std/os.zig

Lines 1752 to 1776 in 5026db1

	pub fn connect_async(sockfd: i32, sock_addr: *sockaddr, len: socklen_t) ConnectError!void {
	while (true) {
	switch (errno(system.connect(sockfd, sock_addr, len))) {
	EINVAL => unreachable,
	EINTR => continue,
	0, EINPROGRESS => return,
	EACCES => return error.PermissionDenied,
	EPERM => return error.PermissionDenied,
	EADDRINUSE => return error.AddressInUse,
	EADDRNOTAVAIL => return error.AddressNotAvailable,
	EAFNOSUPPORT => return error.AddressFamilyNotSupported,
	EAGAIN => return error.SystemResources,
	EALREADY => unreachable, // The socket is nonblocking and a previous connection attempt has not yet been completed.
	EBADF => unreachable, // sockfd is not a valid open file descriptor.
	ECONNREFUSED => return error.ConnectionRefused,
	EFAULT => unreachable, // The socket structure address is outside the user's address space.
	EISCONN => unreachable, // The socket is already connected.
	ENETUNREACH => return error.NetworkUnreachable,
	ENOTSOCK => unreachable, // The file descriptor sockfd does not refer to a socket.
	EPROTOTYPE => unreachable, // The socket type does not support the requested communications protocol.
	ETIMEDOUT => return error.ConnectionTimedOut,
	else => |err| return unexpectedErrno(err),
	}
	}
	}