sub init_loop {
+ Stem::Event::Queue::_init_queue() if defined &Stem::Event::Queue::_init_queue ;
+
$loop_class->_init_loop() ;
++<<<<<<< HEAD:lib/Stem/Event.pm
+#Stem::Event::Queue::_init_queue() if defined &Stem::Event::Queue::_init_queue ;
++=======
++>>>>>>> master:lib/Stem/Event.pm
}
############################################################################
package Stem::Event::Plain ;
++<<<<<<< HEAD:lib/Stem/Event.pm
+
++=======
++>>>>>>> master:lib/Stem/Event.pm
our @ISA = qw( Stem::Event ) ;
=head2 Stem::Event::Plain::new
############################################################################
package Stem::Event::Signal ;
++<<<<<<< HEAD:lib/Stem/Event.pm
+
++=======
++>>>>>>> master:lib/Stem/Event.pm
our @ISA = qw( Stem::Event ) ;
=head2 Stem::Event::Signal::new
############################################################################
package Stem::Event::Timer ;
++<<<<<<< HEAD:lib/Stem/Event.pm
+
++=======
++>>>>>>> master:lib/Stem/Event.pm
our @ISA = qw( Stem::Event ) ;
=head2 Stem::Event::Timer::new
# these override Stem::Event's methods and then call those via SUPER::
package Stem::Event::IO ;
++<<<<<<< HEAD:lib/Stem/Event.pm
+
++=======
++>>>>>>> master:lib/Stem/Event.pm
our @ISA = qw( Stem::Event ) ;
sub init_io_timeout {
#######################################################
package Stem::Event::Read ;
+ our @ISA = qw( Stem::Event::IO ) ;
+ print "B @ISA\n" ;
++<<<<<<< HEAD:lib/Stem/Event.pm
+our @ISA = qw( Stem::Event::IO ) ;
++=======
++>>>>>>> master:lib/Stem/Event.pm
=head2 Stem::Event::Read::new
############################################################################
package Stem::Event::Write ;
++<<<<<<< HEAD:lib/Stem/Event.pm
+
++=======
++>>>>>>> master:lib/Stem/Event.pm
our @ISA = qw( Stem::Event::IO ) ;
=head2 Stem::Event::Write::new
use Socket;
use IO::Handle ;
++<<<<<<< HEAD:lib/Stem/Event/Queue.pm
+my( $self, $queue_read, $queue_write, $queue_read_event, $queue_has_event ) ;
++=======
+ use base 'Exporter' ;
+ our @EXPORT = qw( mark_not_empty ) ;
++>>>>>>> master:lib/Stem/Event/Queue.pm
-my( $queue_read, $queue_write, $queue_read_event ) ;
+sub _init_event_queue {
-my $self ;
+ return if $self ;
-sub _init_queue {
+ $self = bless {} ;
socketpair( $queue_read, $queue_write,
AF_UNIX, SOCK_STREAM, PF_UNSPEC ) || die <<DIE ;
my( $self ) = @_ ;
++<<<<<<< HEAD:t/event/event_test.pl
+ ok( 1, 'plain - event triggered' ) ;
++=======
+ ok( 1, 'plain event triggered' ) ;
+ Stem::Event::stop_loop() ;
++>>>>>>> master:t/event/event_test.pl
}
sub test_signal_events {
my( $self ) = @_ ;
++<<<<<<< HEAD:t/event/event_test.pl
+ ok( 1, 'hard timer - event triggered' ) ;
++=======
+ send_int_signal() ;
+
+ ok( 1, 'hard timer event triggered' ) ;
++>>>>>>> master:t/event/event_test.pl
if ( --$self->{'hard_timer_count'} > 0 ) {