]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/dird/ua_output.c
- Fix the block listing bug pointed out by Arno.
[bacula/bacula] / bacula / src / dird / ua_output.c
index f3e1916692a24c766029140f56684035e6556d38..c3f1ac1883a37bbb4bd0d8e2c711018d8d063ad7 100644 (file)
@@ -9,7 +9,7 @@
  */
 
 /*
-   Copyright (C) 2000-2005 Kern Sibbald
+   Copyright (C) 2000-2006 Kern Sibbald
 
    This program is free software; you can redistribute it and/or
    modify it under the terms of the GNU General Public License
@@ -55,10 +55,10 @@ int autodisplay_cmd(UAContext *ua, const char *cmd)
 
    switch (find_arg_keyword(ua, kw)) {
    case 0:
-      ua->auto_display_messages = 1;
+      ua->auto_display_messages = true;
       break;
    case 1:
-      ua->auto_display_messages = 0;
+      ua->auto_display_messages = false;
       break;
    default:
       bsendmsg(ua, _("ON or OFF keyword missing.\n"));
@@ -68,7 +68,7 @@ int autodisplay_cmd(UAContext *ua, const char *cmd)
 }
 
 /*
- * Turn batch processing on/off
+ * Turn GUI mode on/off
  */
 int gui_cmd(UAContext *ua, const char *cmd)
 {
@@ -79,12 +79,10 @@ int gui_cmd(UAContext *ua, const char *cmd)
 
    switch (find_arg_keyword(ua, kw)) {
    case 0:
-      ua->batch = true;
-      ua->jcr->gui = true;
+      ua->jcr->gui = ua->gui = true;
       break;
    case 1:
-      ua->batch = false;
-      ua->jcr->gui = false;
+      ua->jcr->gui = ua->gui = false;
       break;
    default:
       bsendmsg(ua, _("ON or OFF keyword missing.\n"));
@@ -268,7 +266,7 @@ static int do_list_cmd(UAContext *ua, const char *cmd, e_list_type llist)
       } else if (strcasecmp(ua->argk[i], N_("jobtotals")) == 0) {
          db_list_job_totals(ua->jcr, ua->db, &jr, prtit, ua);
 
-      /* List JOBID */
+      /* List JOBID=nn */
       } else if (strcasecmp(ua->argk[i], N_("jobid")) == 0) {
          if (ua->argv[i]) {
             jobid = str_to_int64(ua->argv[i]);
@@ -278,12 +276,19 @@ static int do_list_cmd(UAContext *ua, const char *cmd, e_list_type llist)
             }
          }
 
-      /* List JOB */
+      /* List JOB=xxx */
       } else if (strcasecmp(ua->argk[i], N_("job")) == 0 && ua->argv[i]) {
          bstrncpy(jr.Job, ua->argv[i], MAX_NAME_LENGTH);
          jr.JobId = 0;
          db_list_job_records(ua->jcr, ua->db, &jr, prtit, ua, llist);
 
+      /* List JOBNAME=xxx */
+      } else if (strcasecmp(ua->argk[i], N_("job")) == 0 && ua->argv[i]) {
+         bstrncpy(jr.Name, ua->argv[i], MAX_NAME_LENGTH);
+         jr.JobId = 0;
+         db_list_job_records(ua->jcr, ua->db, &jr, prtit, ua, llist);
+
+
       /* List FILES */
       } else if (strcasecmp(ua->argk[i], N_("files")) == 0) {
 
@@ -407,18 +412,18 @@ static int do_list_cmd(UAContext *ua, const char *cmd, e_list_type llist)
       /* List next volume */
       } else if (strcasecmp(ua->argk[i], N_("nextvol")) == 0 ||
                  strcasecmp(ua->argk[i], N_("nextvolume")) == 0) {
-        n = 1;
+         n = 1;
          j = find_arg_with_value(ua, N_("days"));
          if (j >= 0) {
             n = atoi(ua->argv[j]);
-           if ((n < 0) || (n > 50)) {
-             bsendmsg(ua, _("Ignoring illegal value for days.\n"));
-             n = 1;
-           }
+            if ((n < 0) || (n > 50)) {
+              bsendmsg(ua, _("Ignoring illegal value for days.\n"));
+              n = 1;
+            }
          }
          list_nextvol(ua, n);
       } else if (strcasecmp(ua->argk[i], N_("limit")) == 0
-                || strcasecmp(ua->argk[i], N_("days")) == 0) {
+                 || strcasecmp(ua->argk[i], N_("days")) == 0) {
          /* Ignore it */
       } else {
          bsendmsg(ua, _("Unknown list keyword: %s\n"), NPRT(ua->argk[i]));
@@ -458,21 +463,21 @@ static bool list_nextvol(UAContext *ua, int ndays)
       if (!complete_jcr_for_job(jcr, job, pool)) {
          return false;
       }
-      mr.PoolId = jcr->PoolId;
+      mr.PoolId = jcr->jr.PoolId;
       if (run->storage) {
          jcr->store = run->storage;
       }
       memset(&pr, 0, sizeof(pr));
-      pr.PoolId = jcr->PoolId;
+      pr.PoolId = jcr->jr.PoolId;
       if (! db_get_pool_record(ua->jcr, ua->db, &pr)) {
-        strcpy(pr.Name, "*UnknownPool*");
+         strcpy(pr.Name, "*UnknownPool*");
       }
-      if (!find_next_volume_for_append(jcr, &mr, 0)) {
-        bsendmsg(ua, _("Could not find next Volume for Job %s (%s, %s).\n"),
-           job->hdr.name, pr.Name, level_to_str(run->level));
+      if (!find_next_volume_for_append(jcr, &mr, 1, false/*no create*/)) {
+         bsendmsg(ua, _("Could not find next Volume for Job %s (%s, %s).\n"),
+            job->hdr.name, pr.Name, level_to_str(run->level));
       } else {
          bsendmsg(ua,
-           _("The next Volume to be used by Job \"%s\" (%s, %s) will be %s\n"),
+            _("The next Volume to be used by Job \"%s\" (%s, %s) will be %s\n"),
             job->hdr.name, pr.Name, level_to_str(run->level), mr.VolumeName);
          found = true;
       }
@@ -483,7 +488,7 @@ static bool list_nextvol(UAContext *ua, int ndays)
    }
    if (!found) {
       bsendmsg(ua, _("Could not find next Volume for Job %s.\n"),
-        job->hdr.name);
+         job->hdr.name);
       return false;
    }
    return true;
@@ -520,61 +525,62 @@ RUN *find_next_run(RUN *run, JOB *job, time_t &runtime, int ndays)
    }
    for ( ; run; run=run->next) {
       /*
-       * Find runs in next 24 hours
+       * Find runs in next 24 hours.  Day 0 is today, so if
+       *   ndays=1, look at today and tomorrow.
        */
       for (day = 0; day <= ndays; day++) {
-        future = now + (day * 60 * 60 * 24);
+         future = now + (day * 60 * 60 * 24);
 
-        /* Break down the time into components */
-        localtime_r(&future, &tm);
-        mday = tm.tm_mday - 1;
-        wday = tm.tm_wday;
-        month = tm.tm_mon;
-        wom = mday / 7;
-        woy = tm_woy(future);
+         /* Break down the time into components */
+         localtime_r(&future, &tm);
+         mday = tm.tm_mday - 1;
+         wday = tm.tm_wday;
+         month = tm.tm_mon;
+         wom = mday / 7;
+         woy = tm_woy(future);
 
-        is_scheduled = bit_is_set(mday, run->mday) && bit_is_set(wday, run->wday) &&
+         is_scheduled = bit_is_set(mday, run->mday) && bit_is_set(wday, run->wday) &&
             bit_is_set(month, run->month) && bit_is_set(wom, run->wom) &&
             bit_is_set(woy, run->woy);
  
 #ifdef xxx
-        Dmsg2(000, "day=%d is_scheduled=%d\n", day, is_scheduled);
-        Dmsg1(000, "bit_set_mday=%d\n", bit_is_set(mday, run->mday));
-        Dmsg1(000, "bit_set_wday=%d\n", bit_is_set(wday, run->wday));
-        Dmsg1(000, "bit_set_month=%d\n", bit_is_set(month, run->month));
-        Dmsg1(000, "bit_set_wom=%d\n", bit_is_set(wom, run->wom));
-        Dmsg1(000, "bit_set_woy=%d\n", bit_is_set(woy, run->woy));
+         Dmsg2(000, "day=%d is_scheduled=%d\n", day, is_scheduled);
+         Dmsg1(000, "bit_set_mday=%d\n", bit_is_set(mday, run->mday));
+         Dmsg1(000, "bit_set_wday=%d\n", bit_is_set(wday, run->wday));
+         Dmsg1(000, "bit_set_month=%d\n", bit_is_set(month, run->month));
+         Dmsg1(000, "bit_set_wom=%d\n", bit_is_set(wom, run->wom));
+         Dmsg1(000, "bit_set_woy=%d\n", bit_is_set(woy, run->woy));
 #endif
 
-        if (is_scheduled) { /* Jobs scheduled on that day */
+         if (is_scheduled) { /* Jobs scheduled on that day */
 #ifdef xxx
-           char buf[300], num[10];
-           bsnprintf(buf, sizeof(buf), "tm.hour=%d hour=", tm.tm_hour);
-           for (i=0; i<24; i++) {
-              if (bit_is_set(i, run->hour)) {
-                 bsnprintf(num, sizeof(num), "%d ", i);
-                 bstrncat(buf, num, sizeof(buf));
-              }
-           }
-           bstrncat(buf, "\n", sizeof(buf));
-           Dmsg1(000, "%s", buf);
+            char buf[300], num[10];
+            bsnprintf(buf, sizeof(buf), "tm.hour=%d hour=", tm.tm_hour);
+            for (i=0; i<24; i++) {
+               if (bit_is_set(i, run->hour)) {
+                  bsnprintf(num, sizeof(num), "%d ", i);
+                  bstrncat(buf, num, sizeof(buf));
+               }
+            }
+            bstrncat(buf, "\n", sizeof(buf));
+            Dmsg1(000, "%s", buf);
 #endif
-           /* find time (time_t) job is to be run */
-           localtime_r(&future, &runtm);
-           for (i= 0; i < 24; i++) {
-              if (bit_is_set(i, run->hour)) {
-                 runtm.tm_hour = i;
-                 runtm.tm_min = run->minute;
-                 runtm.tm_sec = 0;
-                 runtime = mktime(&runtm);
-                 Dmsg2(200, "now=%d runtime=%d\n", now, runtime);
-                 if ((runtime > now) && (runtime < endtime)) {
-                    Dmsg2(200, "Found it level=%d %c\n", run->level, run->level);
-                    return run;         /* found it, return run resource */
-                 }
-              }
-           }
-        }
+            /* find time (time_t) job is to be run */
+            localtime_r(&future, &runtm);
+            for (i= 0; i < 24; i++) {
+               if (bit_is_set(i, run->hour)) {
+                  runtm.tm_hour = i;
+                  runtm.tm_min = run->minute;
+                  runtm.tm_sec = 0;
+                  runtime = mktime(&runtm);
+                  Dmsg2(200, "now=%d runtime=%d\n", now, runtime);
+                  if ((runtime > now) && (runtime < endtime)) {
+                     Dmsg2(200, "Found it level=%d %c\n", run->level, run->level);
+                     return run;         /* found it, return run resource */
+                  }
+               }
+            }
+         }
       }
    } /* end for loop over runs */
    /* Nothing found */
@@ -620,7 +626,6 @@ int complete_jcr_for_job(JCR *jcr, JOB *job, POOL *pool)
          Jmsg(jcr, M_INFO, 0, _("Pool %s created in database.\n"), pr.Name);
       }
    }
-   jcr->PoolId = pr.PoolId;
    jcr->jr.PoolId = pr.PoolId;
    return 1;
 }
@@ -635,7 +640,7 @@ void do_messages(UAContext *ua, const char *cmd)
 {
    char msg[2000];
    int mlen;
-   int do_truncate = FALSE;
+   bool do_truncate = false;
 
    Pw(con_lock);
    pthread_cleanup_push(con_lock_release, (void *)NULL);
@@ -646,10 +651,10 @@ void do_messages(UAContext *ua, const char *cmd)
       strcpy(ua->UA_sock->msg, msg);
       ua->UA_sock->msglen = mlen;
       bnet_send(ua->UA_sock);
-      do_truncate = TRUE;
+      do_truncate = true;
    }
    if (do_truncate) {
-      ftruncate(fileno(con_fd), 0L);
+      (void)ftruncate(fileno(con_fd), 0L);
    }
    console_msg_pending = FALSE;
    ua->user_notified_msg_pending = FALSE;