| ... | @@ -792,7 +792,7 @@ pub const Loop = struct { | ... | @@ -792,7 +792,7 @@ pub const Loop = struct { |
| 792 | .waiters = DelayQueue.Waiters{ | 792 | .waiters = DelayQueue.Waiters{ |
| 793 | .entries = std.atomic.Queue(anyframe).init(), | 793 | .entries = std.atomic.Queue(anyframe).init(), |
| 794 | }, | 794 | }, |
| 795 | .thread = try std.Thread.spawn(&self.delay_queue, DelayQueue.run), | 795 | .thread = try std.Thread.spawn(self, DelayQueue.run), |
| 796 | .event = std.AutoResetEvent{}, | 796 | .event = std.AutoResetEvent{}, |
| 797 | .is_running = true, | 797 | .is_running = true, |
| 798 | }; | 798 | }; |
| ... | @@ -858,7 +858,7 @@ pub const Loop = struct { | ... | @@ -858,7 +858,7 @@ pub const Loop = struct { |
| 858 | return entry.expires; | 858 | return entry.expires; |
| 859 | } | 859 | } |
| 860 | | 860 | |
| 861 | fn peekExpiringEntry() ?*Entry { | 861 | fn peekExpiringEntry(self: *Waiters) ?*Entry { |
| 862 | const held = self.entries.mutex.acquire(); | 862 | const held = self.entries.mutex.acquire(); |
| 863 | defer held.release(); | 863 | defer held.release(); |
| 864 | | 864 | |