lib/Stem/Event/Signal.pm

   1 package Stem::Event::Signal ;
   2
   3 use Stem::Event::Queue ;
   4
   5 use strict ;
   6 use warnings ;
   7
   8 use base 'Exporter' ;
   9 our @EXPORT = qw( process_signal_queue ) ;
  10
  11 # this generic signal event code needs the safe signals of perl 5.8+
  12
  13 use 5.008 ;
  14
  15 my %signal2event ;
  16
  17 my @signal_queue ;
  18 my %cached_handlers ;
  19
  20 # this sub will cache the handler closures so we can reuse them.
  21
  22 sub _build {
  23
  24         my( $self ) = @_ ;
  25
  26         my $signal = $self->{'signal'} ;
  27
  28         $self->{'method'} ||= "sig_\L${signal}_handler" ;
  29
  30 # create the signal event handler and cache it.
  31 # we cache them so we can reuse these closures and never leak
  32
  33         $SIG{ $signal } = $cached_handlers{$signal} ||=
  34                 sub {
  35         Stem::Event::Queue::queue_has_event() ;
  36
  37 #print "HIT $signal\n";
  38                         push @signal_queue, $signal
  39                 } ;
  40
  41 # track the event object for this signal
  42
  43         $signal2event{$signal} = $self ;
  44
  45 #print "$signal = $SIG{ $signal }\n" ;
  46
  47 # make sure the event queue is set up so we can handle signals in the
  48 # event loop
  49
  50         Stem::Event::Queue::_init_event_queue() ;
  51
  52         return ;
  53 }
  54
  55 sub _cancel {
  56
  57         my( $self ) = @_ ;
  58
  59         $SIG{ $self->{'signal'} } = 'DEFAULT' ;
  60
  61         return ;
  62 }
  63
  64 sub process_signal_queue {
  65
  66         my $sig_count = @signal_queue ;
  67
  68 #print "PROCESS SIGNAL Q $sig_count\n" ;
  69
  70 # return if we have no pending signals
  71
  72         return $sig_count unless $sig_count ;
  73
  74         while( my $signal = shift @signal_queue ) {
  75
  76                 my $event = $signal2event{ $signal } ;
  77
  78                 next unless $event ;
  79                 next unless $event->{'active'} ;
  80
  81                 $event->trigger() ;
  82         }
  83
  84         return $sig_count ;
  85 }
  86
  87 1 ;