aboutsummaryrefslogtreecommitdiff
path: root/std/event.zig
diff options
context:
space:
mode:
authorAndrew Kelley <superjoe30@gmail.com>2018-05-29 03:22:52 -0400
committerAndrew Kelley <superjoe30@gmail.com>2018-05-29 03:22:52 -0400
commitcb042c8343eb94a8d149fe1f5d69aa2746aa85d0 (patch)
tree36b9711c480b61c372c86bc47dd20a635d624d3a /std/event.zig
parent7fa97b752e167de6df9a8a76999456d2c199b345 (diff)
parenteda6898c5b253367174172db909ee23013f32733 (diff)
downloadzig-cb042c8343eb94a8d149fe1f5d69aa2746aa85d0.tar.gz
zig-cb042c8343eb94a8d149fe1f5d69aa2746aa85d0.zip
Merge remote-tracking branch 'origin/master' into llvm7
Diffstat (limited to 'std/event.zig')
-rw-r--r--std/event.zig13
1 files changed, 2 insertions, 11 deletions
diff --git a/std/event.zig b/std/event.zig
index 558bd2a188..6ee8ab35f1 100644
--- a/std/event.zig
+++ b/std/event.zig
@@ -76,19 +76,14 @@ pub const TcpServer = struct {
}
continue;
},
- error.ConnectionAborted,
- error.FileDescriptorClosed => continue,
+ error.ConnectionAborted, error.FileDescriptorClosed => continue,
error.PageFault => unreachable,
error.InvalidSyscall => unreachable,
error.FileDescriptorNotASocket => unreachable,
error.OperationNotSupported => unreachable,
- error.SystemFdQuotaExceeded,
- error.SystemResources,
- error.ProtocolFailure,
- error.BlockedByFirewall,
- error.Unexpected => {
+ error.SystemFdQuotaExceeded, error.SystemResources, error.ProtocolFailure, error.BlockedByFirewall, error.Unexpected => {
@panic("TODO handle this error");
},
}
@@ -121,7 +116,6 @@ pub const Loop = struct {
pub fn removeFd(self: &Loop, fd: i32) void {
std.os.linuxEpollCtl(self.epollfd, std.os.linux.EPOLL_CTL_DEL, fd, undefined) catch {};
}
-
async fn waitFd(self: &Loop, fd: i32) !void {
defer self.removeFd(fd);
suspend |p| {
@@ -169,7 +163,6 @@ test "listen on a port, send bytes, receive bytes" {
tcp_server: TcpServer,
const Self = this;
-
async<&mem.Allocator> fn handler(tcp_server: &TcpServer, _addr: &const std.net.Address, _socket: &const std.os.File) void {
const self = @fieldParentPtr(Self, "tcp_server", tcp_server);
var socket = _socket.*; // TODO https://github.com/ziglang/zig/issues/733
@@ -184,7 +177,6 @@ test "listen on a port, send bytes, receive bytes" {
cancel p;
}
}
-
async fn errorableHandler(self: &Self, _addr: &const std.net.Address, _socket: &const std.os.File) !void {
const addr = _addr.*; // TODO https://github.com/ziglang/zig/issues/733
var socket = _socket.*; // TODO https://github.com/ziglang/zig/issues/733
@@ -207,7 +199,6 @@ test "listen on a port, send bytes, receive bytes" {
defer cancel p;
loop.run();
}
-
async fn doAsyncTest(loop: &Loop, address: &const std.net.Address) void {
errdefer @panic("test failure");