Consume the self-pipe's signal when we get it
1 files changed, 2 insertions(+), 1 deletions(-) M lib/cztop/reactor/signal_handling.rb
M lib/cztop/reactor/signal_handling.rb +2 -1
@@ 118,7 118,8 @@ module CZTop::Reactor::SignalHandling ### Look for any signals that arrived and handle them. - def handle_queued_signals( _event ) + def handle_queued_signals( event ) + event.socket.wait while sig = Thread.main[ SIGNAL_QUEUE_KEY ].shift self.log.debug " got a queued signal: %p" % [ sig ] self.handle_signal( sig )