From f85b4e35a70319bcfd6a15e5011cbe0182ff3643 Mon Sep 17 00:00:00 2001 From: Kern Sibbald Date: Thu, 15 Oct 2009 14:36:07 +0200 Subject: [PATCH] Tweak debug and add cancel message --- bacula/src/dird/job.c | 11 ++++++----- bacula/src/dird/jobq.c | 4 ++-- 2 files changed, 8 insertions(+), 7 deletions(-) diff --git a/bacula/src/dird/job.c b/bacula/src/dird/job.c index acb6480d12..05597a6994 100644 --- a/bacula/src/dird/job.c +++ b/bacula/src/dird/job.c @@ -118,7 +118,7 @@ bool setup_job(JCR *jcr) jcr->term_wait_inited = true; create_unique_job_name(jcr, jcr->job->name()); - set_jcr_job_status(jcr, JS_Created); + jcr->setJobStatus(JS_Created); jcr->unlock(); /* @@ -264,18 +264,18 @@ static void *job_thread(void *arg) Dsm_check(1); Dmsg0(200, "=====Start Job=========\n"); - set_jcr_job_status(jcr, JS_Running); /* this will be set only if no error */ + jcr->setJobStatus(JS_Running); /* this will be set only if no error */ jcr->start_time = time(NULL); /* set the real start time */ jcr->jr.StartTime = jcr->start_time; if (jcr->job->MaxStartDelay != 0 && jcr->job->MaxStartDelay < (utime_t)(jcr->start_time - jcr->sched_time)) { - set_jcr_job_status(jcr, JS_Canceled); + jcr->setJobStatus(JS_Canceled); Jmsg(jcr, M_FATAL, 0, _("Job canceled because max start delay time exceeded.\n")); } if (job_check_maxschedruntime(jcr)) { - set_jcr_job_status(jcr, JS_Canceled); + jcr->setJobStatus(JS_Canceled); Jmsg(jcr, M_FATAL, 0, _("Job canceled because max sched run time exceeded.\n")); } @@ -393,7 +393,7 @@ bool cancel_job(UAContext *ua, JCR *jcr) ua->info_msg(_("JobId %s, Job %s marked to be canceled.\n"), edit_uint64(jcr->JobId, ed1), jcr->Job); jobq_remove(&job_queue, jcr); /* attempt to remove it from queue */ - return true; + break; default: /* Cancel File daemon */ @@ -446,6 +446,7 @@ bool cancel_job(UAContext *ua, JCR *jcr) sd->close(); ua->jcr->store_bsock = NULL; } + break; } return true; diff --git a/bacula/src/dird/jobq.c b/bacula/src/dird/jobq.c index e5db9c46d8..baa81469fc 100644 --- a/bacula/src/dird/jobq.c +++ b/bacula/src/dird/jobq.c @@ -445,8 +445,8 @@ void *jobq_server(void *arg) V(jq->mutex); /* Call user's routine here */ - Dmsg2(2300, "Calling user engine for jobid=%d use=%d\n", jcr->JobId, - jcr->use_count()); + Dmsg3(2300, "Calling user engine for jobid=%d use=%d stat=%c\n", jcr->JobId, + jcr->use_count(), jcr->JobStatus); jq->engine(je->jcr); /* Job finished detach from thread */ -- 2.39.5