From: Jonathan Rockway <jon@jrock.us>
Date: Tue, 12 May 2009 00:11:26 +0000 (-0500)
Subject: add framework for implementing auto-restarters as plugins
X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=commitdiff_plain;h=d69f95ab3681e6eb1ae1e96f9d66fa6bf783c09c;p=gitmo%2FMooseX-Runnable.git

add framework for implementing auto-restarters as plugins
---

diff --git a/lib/MooseX/Runnable/Invocation/Plugin/Restart/Base.pm b/lib/MooseX/Runnable/Invocation/Plugin/Restart/Base.pm
new file mode 100644
index 0000000..13c8175
--- /dev/null
+++ b/lib/MooseX/Runnable/Invocation/Plugin/Restart/Base.pm
@@ -0,0 +1,84 @@
+package MooseX::Runnable::Invocation::Plugin::Restart::Base;
+use Moose::Role;
+use MooseX::Types::Moose qw(Int);
+use namespace::autoclean;
+
+has 'child_pid' => (
+    is        => 'rw',
+    isa       => Int,
+    clearer   => 'clear_child_pid',
+    predicate => 'has_child_pid',
+);
+
+requires 'run_parent_loop';
+
+my $is_debug = sub { return 1;
+    $_[0]->meta->does_role('MooseX::Runnable::Invocation::Plugin::Debug');
+};
+
+sub _restart_parent_setup {
+    my $self = shift;
+}
+
+sub restart {
+    my $self = shift;
+    return unless $self->has_child_pid;
+    eval { $self->_debug_message("Restarting...") };
+    kill 'HUP', $self->child_pid;
+}
+
+sub kill_child {
+    my $self = shift;
+    return unless $self->has_child_pid;
+    eval { $self->_debug_message("Killing ", $self->child_pid) };
+
+    kill 'KILL', $self->child_pid;
+    $self->clear_child_pid;
+}
+
+around 'run' => sub {
+    my ($next, $self, @args) = @_;
+    my $pid = fork();
+    if($pid){
+        local $SIG{CHLD} = 'IGNORE';
+
+        # parent
+        $self->child_pid( $pid );
+        $self->_restart_parent_setup;
+
+        my $code = $self->run_parent_loop;
+        eval { $self->_debug_message("Shutting down.") };
+
+        $self->kill_child;
+        return $code;
+    }
+    else {
+        # we go to all this effort so that the child process is always
+        # free of any "infection" by the parent (like the event loop,
+        # used by the parent to receive filesystem events or signals,
+        # which can't be cancelled by the child)
+
+        my $child_body; $child_body = sub {
+            while(1){
+                my $pid2 = fork;
+                if($pid2){
+                    # parent? wait for kid to die
+                    local $SIG{HUP} = sub {
+                        kill 'KILL', $pid2;
+                    };
+                    waitpid $pid2, 0;
+                    $child_body->();
+                }
+                else {
+                    # child? actually do the work
+                    exit $self->$next(@args);
+
+                }
+            }
+        };
+
+        $child_body->();
+    }
+};
+
+1;