oqapi/webgui
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Forward porting spectre stop fix. Moved from IKC to interrupt based.

Browse source
This commit is contained in:
Colin Kuskie 2009-07-29 23:30:52 +00:00
parent 10755c3b83
commit f8b8f9da37
5 changed files with 59 additions and 28 deletions
Download patch file Download diff file Expand all files Collapse all files

34
lib/Spectre/Admin.pm
View file

@ -26,6 +26,21 @@ use Spectre::Cron;
use Spectre::Workflow;
#-------------------------------------------------------------------
=head2 _safe_shutdown ( )
Stops the kernel when TERM signal is received
=cut
sub _safe_shutdown {
my ($obj) = @_[ OBJECT ];
$obj->error('Spectre shut down');
POE::Kernel->stop;
}
#-------------------------------------------------------------------
=head2 _start ( )
@ -41,22 +56,9 @@ sub _start {
$kernel->alias_set($serviceName);
$kernel->call( IKC => publish => $serviceName, $publicEvents );
$kernel->delay_set("loadSiteData",3);
$kernel->sig( TERM => '_safe_shutdown' );
}
#-------------------------------------------------------------------
=head2 _stop ( )
Gracefully shuts down the admin interface.
=cut
sub _stop {
my ($kernel, $self) = @_[KERNEL, OBJECT];
$self->debug("Stopping Spectre administrative manager.");
undef $self;
$kernel->stop;
}
#-------------------------------------------------------------------
@ -204,8 +206,8 @@ sub new {
name => 'Spectre'
);
POE::Session->create(
object_states => [ $self => {_start=>"_start", _stop=>"_stop", "shutdown"=>"_stop", "ping"=>"ping", "loadSiteData"=>"loadSiteData"} ],
args=>[["shutdown","ping"]]
object_states => [ $self => {_start=>"_start", "ping"=>"ping", "loadSiteData"=>"loadSiteData", "_safe_shutdown" => "_safe_shutdown"} ],
args=>[["ping"]]
);
Spectre::Workflow->new($config, $logger, $debug);
Spectre::Cron->new($config, $logger, $debug);