| ... | @@ -62,9 +62,9 @@ pub const Loop = struct { | ... | @@ -62,9 +62,9 @@ pub const Loop = struct { |
| 62 | pub const Overlapped = @TypeOf(overlapped_init); | 62 | pub const Overlapped = @TypeOf(overlapped_init); |
| 63 | | 63 | |
| 64 | pub const Id = enum { | 64 | pub const Id = enum { |
| 65 | Basic, | 65 | basic, |
| 66 | Stop, | 66 | stop, |
| 67 | EventFd, | 67 | event_fd, |
| 68 | }; | 68 | }; |
| 69 | | 69 | |
| 70 | pub const EventFd = switch (builtin.os.tag) { | 70 | pub const EventFd = switch (builtin.os.tag) { |
| ... | @@ -165,7 +165,7 @@ pub const Loop = struct { | ... | @@ -165,7 +165,7 @@ pub const Loop = struct { |
| 165 | .available_eventfd_resume_nodes = std.atomic.Stack(ResumeNode.EventFd).init(), | 165 | .available_eventfd_resume_nodes = std.atomic.Stack(ResumeNode.EventFd).init(), |
| 166 | .eventfd_resume_nodes = undefined, | 166 | .eventfd_resume_nodes = undefined, |
| 167 | .final_resume_node = ResumeNode{ | 167 | .final_resume_node = ResumeNode{ |
| 168 | .id = ResumeNode.Id.Stop, | 168 | .id = .stop, |
| 169 | .handle = undefined, | 169 | .handle = undefined, |
| 170 | .overlapped = ResumeNode.overlapped_init, | 170 | .overlapped = ResumeNode.overlapped_init, |
| 171 | }, | 171 | }, |
| ... | @@ -224,7 +224,7 @@ pub const Loop = struct { | ... | @@ -224,7 +224,7 @@ pub const Loop = struct { |
| 224 | eventfd_node.* = std.atomic.Stack(ResumeNode.EventFd).Node{ | 224 | eventfd_node.* = std.atomic.Stack(ResumeNode.EventFd).Node{ |
| 225 | .data = ResumeNode.EventFd{ | 225 | .data = ResumeNode.EventFd{ |
| 226 | .base = ResumeNode{ | 226 | .base = ResumeNode{ |
| 227 | .id = .EventFd, | 227 | .id = .event_fd, |
| 228 | .handle = undefined, | 228 | .handle = undefined, |
| 229 | .overlapped = ResumeNode.overlapped_init, | 229 | .overlapped = ResumeNode.overlapped_init, |
| 230 | }, | 230 | }, |
| ... | @@ -282,7 +282,7 @@ pub const Loop = struct { | ... | @@ -282,7 +282,7 @@ pub const Loop = struct { |
| 282 | eventfd_node.* = std.atomic.Stack(ResumeNode.EventFd).Node{ | 282 | eventfd_node.* = std.atomic.Stack(ResumeNode.EventFd).Node{ |
| 283 | .data = ResumeNode.EventFd{ | 283 | .data = ResumeNode.EventFd{ |
| 284 | .base = ResumeNode{ | 284 | .base = ResumeNode{ |
| 285 | .id = ResumeNode.Id.EventFd, | 285 | .id = .event_fd, |
| 286 | .handle = undefined, | 286 | .handle = undefined, |
| 287 | .overlapped = ResumeNode.overlapped_init, | 287 | .overlapped = ResumeNode.overlapped_init, |
| 288 | }, | 288 | }, |
| ... | @@ -347,7 +347,7 @@ pub const Loop = struct { | ... | @@ -347,7 +347,7 @@ pub const Loop = struct { |
| 347 | eventfd_node.* = std.atomic.Stack(ResumeNode.EventFd).Node{ | 347 | eventfd_node.* = std.atomic.Stack(ResumeNode.EventFd).Node{ |
| 348 | .data = ResumeNode.EventFd{ | 348 | .data = ResumeNode.EventFd{ |
| 349 | .base = ResumeNode{ | 349 | .base = ResumeNode{ |
| 350 | .id = ResumeNode.Id.EventFd, | 350 | .id = .event_fd, |
| 351 | .handle = undefined, | 351 | .handle = undefined, |
| 352 | .overlapped = ResumeNode.overlapped_init, | 352 | .overlapped = ResumeNode.overlapped_init, |
| 353 | }, | 353 | }, |
| ... | @@ -413,7 +413,7 @@ pub const Loop = struct { | ... | @@ -413,7 +413,7 @@ pub const Loop = struct { |
| 413 | eventfd_node.* = std.atomic.Stack(ResumeNode.EventFd).Node{ | 413 | eventfd_node.* = std.atomic.Stack(ResumeNode.EventFd).Node{ |
| 414 | .data = ResumeNode.EventFd{ | 414 | .data = ResumeNode.EventFd{ |
| 415 | .base = ResumeNode{ | 415 | .base = ResumeNode{ |
| 416 | .id = ResumeNode.Id.EventFd, | 416 | .id = .event_fd, |
| 417 | .handle = undefined, | 417 | .handle = undefined, |
| 418 | .overlapped = ResumeNode.overlapped_init, | 418 | .overlapped = ResumeNode.overlapped_init, |
| 419 | }, | 419 | }, |
| ... | @@ -503,7 +503,7 @@ pub const Loop = struct { | ... | @@ -503,7 +503,7 @@ pub const Loop = struct { |
| 503 | assert(flags & os.linux.EPOLL.ONESHOT == os.linux.EPOLL.ONESHOT); | 503 | assert(flags & os.linux.EPOLL.ONESHOT == os.linux.EPOLL.ONESHOT); |
| 504 | var resume_node = ResumeNode.Basic{ | 504 | var resume_node = ResumeNode.Basic{ |
| 505 | .base = ResumeNode{ | 505 | .base = ResumeNode{ |
| 506 | .id = .Basic, | 506 | .id = .basic, |
| 507 | .handle = @frame(), | 507 | .handle = @frame(), |
| 508 | .overlapped = ResumeNode.overlapped_init, | 508 | .overlapped = ResumeNode.overlapped_init, |
| 509 | }, | 509 | }, |
| ... | @@ -590,7 +590,7 @@ pub const Loop = struct { | ... | @@ -590,7 +590,7 @@ pub const Loop = struct { |
| 590 | pub fn bsdWaitKev(self: *Loop, ident: usize, filter: i16, flags: u16) void { | 590 | pub fn bsdWaitKev(self: *Loop, ident: usize, filter: i16, flags: u16) void { |
| 591 | var resume_node = ResumeNode.Basic{ | 591 | var resume_node = ResumeNode.Basic{ |
| 592 | .base = ResumeNode{ | 592 | .base = ResumeNode{ |
| 593 | .id = ResumeNode.Id.Basic, | 593 | .id = .basic, |
| 594 | .handle = @frame(), | 594 | .handle = @frame(), |
| 595 | .overlapped = ResumeNode.overlapped_init, | 595 | .overlapped = ResumeNode.overlapped_init, |
| 596 | }, | 596 | }, |
| ... | @@ -1419,9 +1419,9 @@ pub const Loop = struct { | ... | @@ -1419,9 +1419,9 @@ pub const Loop = struct { |
| 1419 | const handle = resume_node.handle; | 1419 | const handle = resume_node.handle; |
| 1420 | const resume_node_id = resume_node.id; | 1420 | const resume_node_id = resume_node.id; |
| 1421 | switch (resume_node_id) { | 1421 | switch (resume_node_id) { |
| 1422 | .Basic => {}, | 1422 | .basic => {}, |
| 1423 | .Stop => return, | 1423 | .stop => return, |
| 1424 | .EventFd => { | 1424 | .event_fd => { |
| 1425 | const event_fd_node = @fieldParentPtr(ResumeNode.EventFd, "base", resume_node); | 1425 | const event_fd_node = @fieldParentPtr(ResumeNode.EventFd, "base", resume_node); |
| 1426 | event_fd_node.epoll_op = os.linux.EPOLL.CTL_MOD; | 1426 | event_fd_node.epoll_op = os.linux.EPOLL.CTL_MOD; |
| 1427 | const stack_node = @fieldParentPtr(std.atomic.Stack(ResumeNode.EventFd).Node, "data", event_fd_node); | 1427 | const stack_node = @fieldParentPtr(std.atomic.Stack(ResumeNode.EventFd).Node, "data", event_fd_node); |
| ... | @@ -1429,7 +1429,7 @@ pub const Loop = struct { | ... | @@ -1429,7 +1429,7 @@ pub const Loop = struct { |
| 1429 | }, | 1429 | }, |
| 1430 | } | 1430 | } |
| 1431 | resume handle; | 1431 | resume handle; |
| 1432 | if (resume_node_id == ResumeNode.Id.EventFd) { | 1432 | if (resume_node_id == .event_fd) { |
| 1433 | self.finishOneEvent(); | 1433 | self.finishOneEvent(); |
| 1434 | } | 1434 | } |
| 1435 | } | 1435 | } |
| ... | @@ -1443,19 +1443,19 @@ pub const Loop = struct { | ... | @@ -1443,19 +1443,19 @@ pub const Loop = struct { |
| 1443 | const handle = resume_node.handle; | 1443 | const handle = resume_node.handle; |
| 1444 | const resume_node_id = resume_node.id; | 1444 | const resume_node_id = resume_node.id; |
| 1445 | switch (resume_node_id) { | 1445 | switch (resume_node_id) { |
| 1446 | .Basic => { | 1446 | .basic => { |
| 1447 | const basic_node = @fieldParentPtr(ResumeNode.Basic, "base", resume_node); | 1447 | const basic_node = @fieldParentPtr(ResumeNode.Basic, "base", resume_node); |
| 1448 | basic_node.kev = ev; | 1448 | basic_node.kev = ev; |
| 1449 | }, | 1449 | }, |
| 1450 | .Stop => return, | 1450 | .stop => return, |
| 1451 | .EventFd => { | 1451 | .event_fd => { |
| 1452 | const event_fd_node = @fieldParentPtr(ResumeNode.EventFd, "base", resume_node); | 1452 | const event_fd_node = @fieldParentPtr(ResumeNode.EventFd, "base", resume_node); |
| 1453 | const stack_node = @fieldParentPtr(std.atomic.Stack(ResumeNode.EventFd).Node, "data", event_fd_node); | 1453 | const stack_node = @fieldParentPtr(std.atomic.Stack(ResumeNode.EventFd).Node, "data", event_fd_node); |
| 1454 | self.available_eventfd_resume_nodes.push(stack_node); | 1454 | self.available_eventfd_resume_nodes.push(stack_node); |
| 1455 | }, | 1455 | }, |
| 1456 | } | 1456 | } |
| 1457 | resume handle; | 1457 | resume handle; |
| 1458 | if (resume_node_id == ResumeNode.Id.EventFd) { | 1458 | if (resume_node_id == .event_fd) { |
| 1459 | self.finishOneEvent(); | 1459 | self.finishOneEvent(); |
| 1460 | } | 1460 | } |
| 1461 | } | 1461 | } |
| ... | @@ -1477,9 +1477,9 @@ pub const Loop = struct { | ... | @@ -1477,9 +1477,9 @@ pub const Loop = struct { |
| 1477 | const handle = resume_node.handle; | 1477 | const handle = resume_node.handle; |
| 1478 | const resume_node_id = resume_node.id; | 1478 | const resume_node_id = resume_node.id; |
| 1479 | switch (resume_node_id) { | 1479 | switch (resume_node_id) { |
| 1480 | .Basic => {}, | 1480 | .basic => {}, |
| 1481 | .Stop => return, | 1481 | .stop => return, |
| 1482 | .EventFd => { | 1482 | .event_fd => { |
| 1483 | const event_fd_node = @fieldParentPtr(ResumeNode.EventFd, "base", resume_node); | 1483 | const event_fd_node = @fieldParentPtr(ResumeNode.EventFd, "base", resume_node); |
| 1484 | const stack_node = @fieldParentPtr(std.atomic.Stack(ResumeNode.EventFd).Node, "data", event_fd_node); | 1484 | const stack_node = @fieldParentPtr(std.atomic.Stack(ResumeNode.EventFd).Node, "data", event_fd_node); |
| 1485 | self.available_eventfd_resume_nodes.push(stack_node); | 1485 | self.available_eventfd_resume_nodes.push(stack_node); |