X-Git-Url: http://git.ieval.ro/?p=gruntmaster-daemon.git;a=blobdiff_plain;f=lib%2FGruntmaster%2FDaemon.pm;h=7b41d66131bd76b0933457c02ae7e19910aedf5d;hp=3a836924afebea26ff627c55c4fa342365332fcd;hb=19f0465bd8ca1792390c55b97d558a8b7fc0c908;hpb=ee638edb8ce97aeb5b6e76921cf63a0cc995f786 diff --git a/lib/Gruntmaster/Daemon.pm b/lib/Gruntmaster/Daemon.pm index 3a83692..7b41d66 100644 --- a/lib/Gruntmaster/Daemon.pm +++ b/lib/Gruntmaster/Daemon.pm @@ -144,14 +144,13 @@ sub got_job{ my $id = $job->id; get_logger->debug("Taking job $id..."); my $daemon = hostname . ":$$"; - $job->update({daemon => $daemon}); - #if (set_job_daemon $job, hostname . ":$$") { - if (1) { + $job->update({daemon => $daemon}, {where => {daemon => undef}})->discard_changes; + if ($job->daemon eq $daemon) { get_logger->debug("Succesfully taken job $id"); process_job $job; get_logger->debug("Job $id done"); } else { - get_logger->debug("Job $id already taken"); + get_logger->debug("Job $id already taken by " . $job->daemon); } }