Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Fetching contributors…

Cannot retrieve contributors at this time

119 lines (87 sloc) 2.609 kB
package Plack::Loader::Restarter;
use strict;
use warnings;
use parent qw(Plack::Loader);
use Plack::Util;
use Try::Tiny;
sub new {
my($class, $runner) = @_;
bless { watch => [] }, $class;
}
sub preload_app {
my($self, $builder) = @_;
$self->{builder} = $builder;
}
sub watch {
my($self, @dir) = @_;
push @{$self->{watch}}, @dir;
}
sub _fork_and_start {
my($self, $server) = @_;
delete $self->{pid}; # re-init in case it's a restart
my $pid = fork;
die "Can't fork: $!" unless defined $pid;
if ($pid == 0) { # child
return $server->run($self->{builder}->());
} else {
$self->{pid} = $pid;
}
}
sub _kill_child {
my $self = shift;
my $pid = $self->{pid} or return;
warn "Killing the existing server (pid:$pid)\n";
kill 'TERM' => $pid;
waitpid($pid, 0);
}
sub valid_file {
my($self, $file) = @_;
# vim temporary file is 4913 to 5036
# http://www.mail-archive.com/vim_dev@googlegroups.com/msg07518.html
if ( $file->{path} =~ m{(\d+)$} && $1 >= 4913 && $1 <= 5036) {
return 0;
}
$file->{path} !~ m!\.(?:git|svn)[/\\]|\.(?:bak|swp|swpx|swx)$|~$|_flymake\.p[lm]$!;
}
sub run {
my($self, $server, $builder) = @_;
$self->_fork_and_start($server, $builder);
return unless $self->{pid};
require Filesys::Notify::Simple;
my $watcher = Filesys::Notify::Simple->new($self->{watch});
warn "Watching @{$self->{watch}} for file updates.\n";
local $SIG{TERM} = sub { $self->_kill_child; exit(0); };
while (1) {
my @restart;
# this is blocking
$watcher->wait(sub {
my @events = @_;
@events = grep $self->valid_file($_), @events;
return unless @events;
@restart = @events;
});
next unless @restart;
for my $ev (@restart) {
warn "-- $ev->{path} updated.\n";
}
$self->_kill_child;
warn "Successfully killed! Restarting the new server process.\n";
$self->_fork_and_start($server, $builder);
return unless $self->{pid};
}
}
1;
__END__
=head1 NAME
Plack::Loader::Restarter - Restarting loader
=head1 SYNOPSIS
plackup -r -R paths
=head1 DESCRIPTION
Plack::Loader::Restarter is a loader backend that implements C<-r> and
C<-R> option for the L<plackup> script. It forks the server as a child
process and the parent watches the directories for file updates, and
whenever it receives the notification, kills the child server and
restart.
=head1 SEE ALSO
L<Plack::Runner>, L<Catalyst::Restarter>
=cut
Jump to Line
Something went wrong with that request. Please try again.