diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-06-25 14:51:52 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-06-25 14:51:52 +0200 |
| commit | 4cc0ce236115054fab2e2d288220199024f5a467 (patch) | |
| tree | dd539a42551cc774b90ee9652ba75f939e79138a /lib/presque/WorkerHandler.pm | |
| parent | alter order for arguments in methods call (diff) | |
| download | presque-4cc0ce236115054fab2e2d288220199024f5a467.tar.gz | |
add POD; fix queue size when null
Diffstat (limited to 'lib/presque/WorkerHandler.pm')
| -rw-r--r-- | lib/presque/WorkerHandler.pm | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/lib/presque/WorkerHandler.pm b/lib/presque/WorkerHandler.pm index 4399ddf..dcb6acf 100644 --- a/lib/presque/WorkerHandler.pm +++ b/lib/presque/WorkerHandler.pm @@ -71,9 +71,10 @@ sub _get_stats_for_worker { 'failed:' . $worker_id, sub { my $res = shift; - my $desc = JSON::decode_json(shift @$res); - $desc->{processed} = shift @$res; - $desc->{failed} = shift @$res; + my $desc = {}; + $desc = JSON::decode_json(shift @$res) if $res->[0]; + $desc->{processed} = $res->[1] || 0; + $desc->{failed} = $res->[2] || 0; $self->entity($desc); } ); |