add reset on num processed blocks value

This commit is contained in:
Muaz Ahmad 2023-12-12 14:56:14 +05:00
parent 5ef9f52d95
commit 58e79cd95e

View file

@ -85,6 +85,7 @@ pub const ThreadManager = struct {
} }
pub fn unblock(self: *Self) void { pub fn unblock(self: *Self) void {
self.signals.eof_block.store(0, .Release); self.signals.eof_block.store(0, .Release);
self.signals.processed.store(0, .Release);
} }
}; };