aboutsummaryrefslogtreecommitdiff
path: root/std/event/tcp.zig
diff options
context:
space:
mode:
authorAndrew Kelley <superjoe30@gmail.com>2018-08-02 17:29:31 -0400
committerAndrew Kelley <superjoe30@gmail.com>2018-08-02 17:29:31 -0400
commit65140b2fba4e55d713de506f2bed259ca9410cbf (patch)
treee52660c1726caabc730c8869499e5801f027f1b1 /std/event/tcp.zig
parent951124e1772c7013c2b1a674cf98a0b638c36262 (diff)
parentfb05b96492f4fb1476106bf735788ac16f69c7ef (diff)
downloadzig-65140b2fba4e55d713de506f2bed259ca9410cbf.tar.gz
zig-65140b2fba4e55d713de506f2bed259ca9410cbf.zip
Merge remote-tracking branch 'origin/master' into async-fs
Diffstat (limited to 'std/event/tcp.zig')
-rw-r--r--std/event/tcp.zig8
1 files changed, 4 insertions, 4 deletions
diff --git a/std/event/tcp.zig b/std/event/tcp.zig
index 6757d8cc09..19cce4a5e5 100644
--- a/std/event/tcp.zig
+++ b/std/event/tcp.zig
@@ -88,8 +88,8 @@ pub const Server = struct {
},
error.ProcessFdQuotaExceeded => {
errdefer std.os.emfile_promise_queue.remove(&self.waiting_for_emfile_node);
- suspend |p| {
- self.waiting_for_emfile_node = PromiseNode.init(p);
+ suspend {
+ self.waiting_for_emfile_node = PromiseNode.init( @handle() );
std.os.emfile_promise_queue.append(&self.waiting_for_emfile_node);
}
continue;
@@ -141,8 +141,8 @@ test "listen on a port, send bytes, receive bytes" {
(await next_handler) catch |err| {
std.debug.panic("unable to handle connection: {}\n", err);
};
- suspend |p| {
- cancel p;
+ suspend {
+ cancel @handle();
}
}
async fn errorableHandler(self: *Self, _addr: *const std.net.Address, _socket: *const std.os.File) !void {