blob: 04ac8c37be3259953488fbeb141c74aa7cae9a71 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
package presque::worker::Role::Dispatcher;
use Moose::Role;
use Try::Tiny;
has fork_dispatcher => (
is => 'ro',
isa => 'Bool',
default => 0,
);
around work => sub {
my ($orig, $self, $job) = @_;
try {
if ($self->fork_dispatcher) {
$self->_fork_and_work($orig, $job);
}
else {
$self->$orig($job);
}
}catch{
$self->_job_failure($job, $_);
};
};
sub _fork_and_work {
my ($self, $orig, $job) = @_;
my $pid = fork();
if ($pid == 0) {
$self->$orig($job);
exit;
}
elsif ($pid > 0) {
return;
}
else {
# failure
}
}
1;
|