]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/dird/ua_output.c
This commit was manufactured by cvs2svn to create tag
[bacula/bacula] / bacula / src / dird / ua_output.c
index 2c97d1cb32dc75cea0146d13f9071bfab725140e..e4a4c07bd234b90d05090340de15597d4ac607ef 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
@@ -41,7 +41,7 @@ extern brwlock_t con_lock;
 
 /* Forward referenced functions */
 static int do_list_cmd(UAContext *ua, const char *cmd, e_list_type llist);
-static bool list_nextvol(UAContext *ua);
+static bool list_nextvol(UAContext *ua, int ndays);
 
 /*
  * Turn auto display of console messages on/off
@@ -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"));
@@ -204,7 +202,9 @@ bail_out:
  *
  *  list jobs           - lists all jobs run
  *  list jobid=nnn      - list job data for jobid
- *  list job=name       - list job data for job
+ *  list ujobid=uname   - list job data for unique jobid
+ *  list job=name       - list all jobs with "name"   
+ *  list jobname=name   - same as above 
  *  list jobmedia jobid=<nn>
  *  list jobmedia job=name
  *  list files jobid=<nn> - list files saved for job nn
@@ -268,7 +268,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,8 +278,15 @@ static int do_list_cmd(UAContext *ua, const char *cmd, e_list_type llist)
             }
          }
 
-      /* List JOB */
-      } else if (strcasecmp(ua->argk[i], N_("job")) == 0 && ua->argv[i]) {
+      /* List JOB=xxx */
+      } else if ((strcasecmp(ua->argk[i], N_("job")) == 0 ||
+                  strcasecmp(ua->argk[i], N_("jobname")) == 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 UJOBID=xxx */
+      } else if (strcasecmp(ua->argk[i], N_("ujobid")) == 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);
@@ -288,7 +295,7 @@ static int do_list_cmd(UAContext *ua, const char *cmd, e_list_type llist)
       } else if (strcasecmp(ua->argk[i], N_("files")) == 0) {
 
          for (j=i+1; j<ua->argc; j++) {
-            if (strcasecmp(ua->argk[j], N_("job")) == 0 && ua->argv[j]) {
+            if (strcasecmp(ua->argk[j], N_("ujobid")) == 0 && ua->argv[j]) {
                bstrncpy(jr.Job, ua->argv[j], MAX_NAME_LENGTH);
                jr.JobId = 0;
                db_get_job_record(ua->jcr, ua->db, &jr);
@@ -307,7 +314,7 @@ static int do_list_cmd(UAContext *ua, const char *cmd, e_list_type llist)
       } else if (strcasecmp(ua->argk[i], N_("jobmedia")) == 0) {
          int done = FALSE;
          for (j=i+1; j<ua->argc; j++) {
-            if (strcasecmp(ua->argk[j], N_("job")) == 0 && ua->argv[j]) {
+            if (strcasecmp(ua->argk[j], N_("ujobid")) == 0 && ua->argv[j]) {
                bstrncpy(jr.Job, ua->argv[j], MAX_NAME_LENGTH);
                jr.JobId = 0;
                db_get_job_record(ua->jcr, ua->db, &jr);
@@ -326,7 +333,8 @@ static int do_list_cmd(UAContext *ua, const char *cmd, e_list_type llist)
          }
 
       /* List POOLS */
-      } else if (strcasecmp(ua->argk[i], N_("pool")) == 0) {
+      } else if (strcasecmp(ua->argk[i], N_("pool")) == 0 ||
+                 strcasecmp(ua->argk[i], N_("pools")) == 0) {
          POOL_DBR pr;
          memset(&pr, 0, sizeof(pr));
          if (ua->argv[i]) {
@@ -344,7 +352,7 @@ static int do_list_cmd(UAContext *ua, const char *cmd, e_list_type llist)
                  strcasecmp(ua->argk[i], N_("volumes")) == 0) {
          bool done = false;
          for (j=i+1; j<ua->argc; j++) {
-            if (strcasecmp(ua->argk[j], N_("job")) == 0 && ua->argv[j]) {
+            if (strcasecmp(ua->argk[j], N_("ujobid")) == 0 && ua->argv[j]) {
                bstrncpy(jr.Job, ua->argv[j], MAX_NAME_LENGTH);
                jr.JobId = 0;
                db_get_job_record(ua->jcr, ua->db, &jr);
@@ -406,8 +414,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) {
-         list_nextvol(ua);
-      } else if (strcasecmp(ua->argk[i], N_("limit")) == 0) {
+         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;
+            }
+         }
+         list_nextvol(ua, n);
+      } else if (strcasecmp(ua->argk[i], N_("limit")) == 0
+                 || strcasecmp(ua->argk[i], N_("days")) == 0) {
          /* Ignore it */
       } else {
          bsendmsg(ua, _("Unknown list keyword: %s\n"), NPRT(ua->argk[i]));
@@ -416,7 +434,7 @@ static int do_list_cmd(UAContext *ua, const char *cmd, e_list_type llist)
    return 1;
 }
 
-static bool list_nextvol(UAContext *ua)
+static bool list_nextvol(UAContext *ua, int ndays)
 {
    JOB *job;
    JCR *jcr = ua->jcr;
@@ -425,6 +443,7 @@ static bool list_nextvol(UAContext *ua)
    time_t runtime;
    bool found = false;
    MEDIA_DBR mr;
+   POOL_DBR pr;
 
    memset(&mr, 0, sizeof(mr));
    int i = find_arg_with_value(ua, "job");
@@ -441,20 +460,30 @@ static bool list_nextvol(UAContext *ua)
          }
       }
    }
-   for (run=NULL; (run = find_next_run(run, job, runtime)); ) {
+   for (run=NULL; (run = find_next_run(run, job, runtime, ndays)); ) {
       pool = run->pool ? run->pool : NULL;
       if (!complete_jcr_for_job(jcr, job, pool)) {
          return false;
       }
+      memset(&pr, 0, sizeof(pr));
+      pr.PoolId = jcr->PoolId;
+      if (! db_get_pool_record(ua->jcr, ua->db, &pr)) {
+         strcpy(pr.Name, "*UnknownPool*");
+      }
       mr.PoolId = jcr->PoolId;
       if (run->storage) {
          jcr->store = run->storage;
+      } else {
+         jcr->store = (STORE *)job->storage->first();
       }
-      if (!find_next_volume_for_append(jcr, &mr, 0)) {
-         bsendmsg(ua, _("Could not find next Volume.\n"));
+      mr.StorageId = jcr->store->StorageId;
+      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\" will be %s\n"),
-            job->hdr.name, mr.VolumeName);
+         bsendmsg(ua,
+            _("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;
       }
       if (jcr->db && jcr->db != ua->db) {
@@ -463,7 +492,8 @@ static bool list_nextvol(UAContext *ua)
       }
    }
    if (!found) {
-      bsendmsg(ua, _("Could not find next Volume.\n"));
+      bsendmsg(ua, _("Could not find next Volume for Job %s.\n"),
+         job->hdr.name);
       return false;
    }
    return true;
@@ -474,36 +504,24 @@ static bool list_nextvol(UAContext *ua)
  * For a given job, we examine all his run records
  *  to see if it is scheduled today or tomorrow.
  */
-RUN *find_next_run(RUN *run, JOB *job, time_t &runtime)
+RUN *find_next_run(RUN *run, JOB *job, time_t &runtime, int ndays)
 {
-   time_t now, tomorrow;
+   time_t now, future, endtime;
    SCHED *sched;
-   struct tm tm;
-   int mday, wday, month, wom, tmday, twday, tmonth, twom, i;
-   int woy, twoy;
-   int tod, tom;
+   struct tm tm, runtm;
+   int mday, wday, month, wom, i;
+   int woy;
+   int day;
+   int is_scheduled;
 
    sched = job->schedule;
    if (sched == NULL) {            /* scheduled? */
       return NULL;                 /* no nothing to report */
    }
-   /* Break down current time into components */
+
+   /* Break down the time into components */
    now = time(NULL);
-   localtime_r(&now, &tm);
-   mday = tm.tm_mday - 1;
-   wday = tm.tm_wday;
-   month = tm.tm_mon;
-   wom = mday / 7;
-   woy = tm_woy(now);
-
-   /* Break down tomorrow into components */
-   tomorrow = now + 60 * 60 * 24;
-   localtime_r(&tomorrow, &tm);
-   tmday = tm.tm_mday - 1;
-   twday = tm.tm_wday;
-   tmonth = tm.tm_mon;
-   twom = tmday / 7;
-   twoy  = tm_woy(tomorrow);
+   endtime = now + (ndays * 60 * 60 * 24);
 
    if (run == NULL) {
       run = sched->run;
@@ -512,67 +530,59 @@ RUN *find_next_run(RUN *run, JOB *job, time_t &runtime)
    }
    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.
        */
-      tod = bit_is_set(mday, run->mday) && bit_is_set(wday, run->wday) &&
+      for (day = 0; day <= ndays; day++) {
+         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);
+
+         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);
-
-      tom = bit_is_set(tmday, run->mday) && bit_is_set(twday, run->wday) &&
-            bit_is_set(tmonth, run->month) && bit_is_set(twom, run->wom) &&
-            bit_is_set(twoy, run->woy);
-
 #ifdef xxx
-      Dmsg2(000, "tod=%d tom=%d\n", tod, tom);
-      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 (tod) {                   /* Jobs scheduled today (next 24 hours) */
+
+         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);
-#endif
-         /* find time (time_t) job is to be run */
-         localtime_r(&now, &tm);
-         for (i=tm.tm_hour; i < 24; i++) {
-            if (bit_is_set(i, run->hour)) {
-               tm.tm_hour = i;
-               tm.tm_min = run->minute;
-               tm.tm_sec = 0;
-               runtime = mktime(&tm);
-               Dmsg2(200, "now=%d runtime=%d\n", now, runtime);
-               if (runtime > now) {
-                  Dmsg2(200, "Found it level=%d %c\n", run->level, run->level);
-                  return run;         /* found it, return run resource */
+            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));
                }
             }
-         }
-      }
-
-//    Dmsg2(200, "runtime=%d now=%d\n", runtime, now);
-      if (tom) {                /* look at jobs scheduled tomorrow */
-         localtime_r(&tomorrow, &tm);
-         for (i=0; i < 24; i++) {
-            if (bit_is_set(i, run->hour)) {
-               tm.tm_hour = i;
-               tm.tm_min = run->minute;
-               tm.tm_sec = 0;
-               runtime = mktime(&tm);
-               Dmsg2(200, "now=%d runtime=%d\n", now, runtime);
-               if (runtime < tomorrow) {
-                  Dmsg2(200, "Found it level=%d %c\n", run->level, run->level);
-                  return run;         /* found it, return run resource */
+            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 */
+                  }
                }
             }
          }
@@ -636,7 +646,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);
@@ -647,10 +657,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;