]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/dird/ua_select.c
Backport from Bacula Enterprise
[bacula/bacula] / bacula / src / dird / ua_select.c
index aebdaa0b8be6ec3b4b0d66ce38bc8cff86f1635c..343dbbead877a025e22ecf856dee41b13c8f43be 100644 (file)
@@ -1,29 +1,21 @@
 /*
-   Bacula® - The Network Backup Solution
-
-   Copyright (C) 2001-2009 Free Software Foundation Europe e.V.
-
-   The main author of Bacula is Kern Sibbald, with contributions from
-   many others, a complete list can be found in the file AUTHORS.
-   This program is Free Software; you can redistribute it and/or
-   modify it under the terms of version two of the GNU General Public
-   License as published by the Free Software Foundation and included
-   in the file LICENSE.
-
-   This program is distributed in the hope that it will be useful, but
-   WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-   General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
-   02110-1301, USA.
-
-   Bacula® is a registered trademark of Kern Sibbald.
-   The licensor of Bacula is the Free Software Foundation Europe
-   (FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich,
-   Switzerland, email:ftf@fsfeurope.org.
+   Bacula(R) - The Network Backup Solution
+
+   Copyright (C) 2000-2015 Kern Sibbald
+   Copyright (C) 2001-2014 Free Software Foundation Europe e.V.
+
+   The original author of Bacula is Kern Sibbald, with contributions
+   from many others, a complete list can be found in the file AUTHORS.
+
+   You may use this file and others of this release according to the
+   license defined in the LICENSE file, which includes the Affero General
+   Public License, v3.0 ("AGPLv3") and some additional permissions and
+   terms pursuant to its AGPLv3 Section 7.
+
+   This notice must be preserved when any source code is 
+   conveyed and/or propagated.
+
+   Bacula(R) is a registered trademark of Kern Sibbald.
 */
 /*
  *
@@ -31,7 +23,6 @@
  *
  *     Kern Sibbald, October MMI
  *
- *   Version  $Id$
  */
 
 #include "bacula.h"
 /* Imported variables */
 extern struct s_jl joblevels[];
 
+int confirm_retention_yesno(UAContext *ua, utime_t ret, const char *msg)
+{
+   char ed1[100];
+   int val;
+
+   /* Look for "yes" in command line */
+   if (find_arg(ua, NT_("yes")) != -1) {
+      return 1;
+   }
+
+   for ( ;; ) {
+       ua->info_msg(_("The current %s retention period is: %s\n"),
+          msg, edit_utime(ret, ed1, sizeof(ed1)));
+       if (!get_cmd(ua, _("Continue? (yes/no): "))) {
+          return 0;
+       }
+       if (is_yesno(ua->cmd, &val)) {
+          return val;           /* is 1 for yes, 0 for no */
+       }
+    }
+    return 1;
+}
 
 /*
  * Confirm a retention period
@@ -49,14 +62,15 @@ int confirm_retention(UAContext *ua, utime_t *ret, const char *msg)
    char ed1[100];
    int val;
 
-   int yes_in_arg = find_arg(ua, NT_("yes"));
+   /* Look for "yes" in command line */
+   if (find_arg(ua, NT_("yes")) != -1) {
+      return 1;
+   }
 
    for ( ;; ) {
        ua->info_msg(_("The current %s retention period is: %s\n"),
           msg, edit_utime(*ret, ed1, sizeof(ed1)));
-       if (yes_in_arg != -1) {
-          return 1;
-       }
+
        if (!get_cmd(ua, _("Continue? (yes/mod/no): "))) {
           return 0;
        }
@@ -151,17 +165,28 @@ int do_keyword_prompt(UAContext *ua, const char *msg, const char **list)
 
 /*
  * Select a Storage resource from prompt list
+ *  If unique is set storage resources that have the main address are
+ *   combined into one (i.e. they are all part of the same)
+ *   storage.  Note, not all commands want this.
  */
-STORE *select_storage_resource(UAContext *ua)
+STORE *select_storage_resource(UAContext *ua, bool unique)
 {
    char name[MAX_NAME_LENGTH];
    STORE *store;
 
+   /* Does user want a full selection? */
+   if (unique && find_arg(ua, NT_("select")) > 0) {
+      unique = false;
+   }
    start_prompt(ua, _("The defined Storage resources are:\n"));
    LockRes();
    foreach_res(store, R_STORAGE) {
       if (acl_access_ok(ua, Storage_ACL, store->name())) {
-         add_prompt(ua, store->name());
+         if (unique) {
+            add_prompt(ua, store->name(), store->address);
+         } else {
+            add_prompt(ua, store->name());
+         }
       }
    }
    UnlockRes();
@@ -245,7 +270,7 @@ CAT *get_catalog_resource(UAContext *ua)
 
 
 /*
- * Select a job to enable or disable   
+ * Select a job to enable or disable
  */
 JOB *select_enable_disable_job_resource(UAContext *ua, bool enable)
 {
@@ -253,7 +278,11 @@ JOB *select_enable_disable_job_resource(UAContext *ua, bool enable)
    JOB *job;
 
    LockRes();
-   start_prompt(ua, _("The defined Job resources are:\n"));
+   if (enable) {
+      start_prompt(ua, _("The disabled Job resources are:\n"));
+   } else {
+      start_prompt(ua, _("The enabled Job resources are:\n"));
+   }
    foreach_res(job, R_JOB) {
       if (!acl_access_ok(ua, Job_ACL, job->name())) {
          continue;
@@ -294,6 +323,24 @@ JOB *select_job_resource(UAContext *ua)
    return job;
 }
 
+/*
+ * Select a Restore Job resource from argument or prompt
+ */
+JOB *get_restore_job(UAContext *ua)
+{
+   JOB *job;
+   int i = find_arg_with_value(ua, "restorejob");
+   if (i >= 0 && acl_access_ok(ua, Job_ACL, ua->argv[i])) {
+      job = (JOB *)GetResWithName(R_JOB, ua->argv[i]);
+      if (job && job->JobType == JT_RESTORE) {
+         return job;
+      }
+      ua->error_msg(_("Error: Restore Job resource \"%s\" does not exist.\n"),
+                    ua->argv[i]);
+   }
+   return select_restore_job_resource(ua);
+}
+
 /*
  * Select a Restore Job resource from prompt list
  */
@@ -317,6 +364,32 @@ JOB *select_restore_job_resource(UAContext *ua)
    return job;
 }
 
+/*
+ * Select a client to enable or disable
+ */
+CLIENT *select_enable_disable_client_resource(UAContext *ua, bool enable)
+{
+   char name[MAX_NAME_LENGTH];
+   CLIENT *client;
+
+   LockRes();
+   start_prompt(ua, _("The defined Client resources are:\n"));
+   foreach_res(client, R_CLIENT) {
+      if (!acl_access_ok(ua, Client_ACL, client->name())) {
+         continue;
+      }
+      if (client->enabled == enable) {   /* Already enabled/disabled? */
+         continue;                       /* yes, skip */
+      }
+      add_prompt(ua, client->name());
+   }
+   UnlockRes();
+   if (do_prompt(ua, _("Client"), _("Select Client resource"), name, sizeof(name)) < 0) {
+      return NULL;
+   }
+   client = (CLIENT *)GetResWithName(R_CLIENT, name);
+   return client;
+}
 
 
 /*
@@ -369,6 +442,34 @@ CLIENT *get_client_resource(UAContext *ua)
    return select_client_resource(ua);
 }
 
+/*
+ * Select a schedule to enable or disable
+ */
+SCHED *select_enable_disable_schedule_resource(UAContext *ua, bool enable)
+{
+   char name[MAX_NAME_LENGTH];
+   SCHED *sched;
+
+   LockRes();
+   start_prompt(ua, _("The defined Schedule resources are:\n"));
+   foreach_res(sched, R_SCHEDULE) {
+      if (!acl_access_ok(ua, Schedule_ACL, sched->name())) {
+         continue;
+      }
+      if (sched->enabled == enable) {   /* Already enabled/disabled? */
+         continue;                      /* yes, skip */
+      }
+      add_prompt(ua, sched->name());
+   }
+   UnlockRes();
+   if (do_prompt(ua, _("Schedule"), _("Select Schedule resource"), name, sizeof(name)) < 0) {
+      return NULL;
+   }
+   sched = (SCHED *)GetResWithName(R_SCHEDULE, name);
+   return sched;
+}
+
+
 /* Scan what the user has entered looking for:
  *
  *  client=<client-name>
@@ -473,7 +574,7 @@ bool select_client_dbr(UAContext *ua, CLIENT_DBR *cr)
 bool get_pool_dbr(UAContext *ua, POOL_DBR *pr, const char *argk)
 {
    if (pr->Name[0]) {                 /* If name already supplied */
-      if (db_get_pool_record(ua->jcr, ua->db, pr) &&
+      if (db_get_pool_numvols(ua->jcr, ua->db, pr) &&
           acl_access_ok(ua, Pool_ACL, pr->Name)) {
          return true;
       }
@@ -500,7 +601,7 @@ bool select_pool_dbr(UAContext *ua, POOL_DBR *pr, const char *argk)
       if (strcasecmp(ua->argk[i], argk) == 0 && ua->argv[i] &&
           acl_access_ok(ua, Pool_ACL, ua->argv[i])) {
          bstrncpy(pr->Name, ua->argv[i], sizeof(pr->Name));
-         if (!db_get_pool_record(ua->jcr, ua->db, pr)) {
+         if (!db_get_pool_numvols(ua->jcr, ua->db, pr)) {
             ua->error_msg(_("Could not find Pool \"%s\": ERR=%s"), ua->argv[i],
                      db_strerror(ua->db));
             pr->PoolId = 0;
@@ -526,7 +627,7 @@ bool select_pool_dbr(UAContext *ua, POOL_DBR *pr, const char *argk)
    }
    for (i=0; i < num_pools; i++) {
       opr.PoolId = ids[i];
-      if (!db_get_pool_record(ua->jcr, ua->db, &opr) ||
+      if (!db_get_pool_numvols(ua->jcr, ua->db, &opr) ||
           !acl_access_ok(ua, Pool_ACL, opr.Name)) {
          continue;
       }
@@ -545,7 +646,7 @@ bool select_pool_dbr(UAContext *ua, POOL_DBR *pr, const char *argk)
    if (!bstrcmp(name, _("*None*"))) {
      bstrncpy(opr.Name, name, sizeof(opr.Name));
 
-     if (!db_get_pool_record(ua->jcr, ua->db, &opr)) {
+     if (!db_get_pool_numvols(ua->jcr, ua->db, &opr)) {
         ua->error_msg(_("Could not find Pool \"%s\": ERR=%s"), name, db_strerror(ua->db));
         return false;
      }
@@ -581,37 +682,52 @@ int select_pool_and_media_dbr(UAContext *ua, POOL_DBR *pr, MEDIA_DBR *mr)
 int select_media_dbr(UAContext *ua, MEDIA_DBR *mr)
 {
    int i;
+   int ret = 0;
+   POOLMEM *err = get_pool_memory(PM_FNAME);
+   *err=0;
 
-   memset(mr, 0, sizeof(MEDIA_DBR));
-
+   mr->clear();
    i = find_arg_with_value(ua, "volume");
    if (i >= 0) {
-      bstrncpy(mr->VolumeName, ua->argv[i], sizeof(mr->VolumeName));
+      if (is_name_valid(ua->argv[i], &err)) {
+         bstrncpy(mr->VolumeName, ua->argv[i], sizeof(mr->VolumeName));
+      } else {
+         goto bail_out;
+      }
    }
    if (mr->VolumeName[0] == 0) {
       POOL_DBR pr;
       memset(&pr, 0, sizeof(pr));
       /* Get the pool from pool=<pool-name> */
       if (!get_pool_dbr(ua, &pr)) {
-         return 0;
+         goto bail_out;
       }
       mr->PoolId = pr.PoolId;
       db_list_media_records(ua->jcr, ua->db, mr, prtit, ua, HORZ_LIST);
-      if (!get_cmd(ua, _("Enter *MediaId or Volume name: "))) {
-         return 0;
+      if (!get_cmd(ua, _("Enter a Volume name or *MediaId: "))) {
+         goto bail_out;
       }
       if (ua->cmd[0] == '*' && is_a_number(ua->cmd+1)) {
          mr->MediaId = str_to_int64(ua->cmd+1);
-      } else {
+      } else if (is_name_valid(ua->cmd, &err)) {
          bstrncpy(mr->VolumeName, ua->cmd, sizeof(mr->VolumeName));
+      } else {
+         goto bail_out;
       }
    }
 
    if (!db_get_media_record(ua->jcr, ua->db, mr)) {
-      ua->error_msg("%s", db_strerror(ua->db));
-      return 0;
+      pm_strcpy(err, db_strerror(ua->db));
+      goto bail_out;
    }
-   return 1;
+   ret = 1;
+
+bail_out:
+   if (!ret && *err) {
+      ua->error_msg("%s", err);
+   }
+   free_pool_memory(err);
+   return ret;
 }
 
 
@@ -663,7 +779,7 @@ POOL *get_pool_resource(UAContext *ua)
 /*
  * List all jobs and ask user to select one
  */
-int select_job_dbr(UAContext *ua, JOB_DBR *jr)
+static int select_job_dbr(UAContext *ua, JOB_DBR *jr)
 {
    db_list_job_records(ua->jcr, ua->db, jr, prtit, ua, HORZ_LIST);
    if (!get_pint(ua, _("Enter the JobId to select: "))) {
@@ -737,28 +853,39 @@ void start_prompt(UAContext *ua, const char *msg)
   if (ua->max_prompts == 0) {
      ua->max_prompts = 10;
      ua->prompt = (char **)bmalloc(sizeof(char *) * ua->max_prompts);
+     ua->unique = (char **)bmalloc(sizeof(char *) * ua->max_prompts);
   }
   ua->num_prompts = 1;
   ua->prompt[0] = bstrdup(msg);
+  ua->unique[0] = NULL;
 }
 
 /*
- * Add to prompts -- keeping them unique
+ * Add to prompts -- keeping them unique by name
  */
-void add_prompt(UAContext *ua, const char *prompt)
+void add_prompt(UAContext *ua, const char *prompt, char *unique)
 {
    int i;
    if (ua->num_prompts == ua->max_prompts) {
       ua->max_prompts *= 2;
       ua->prompt = (char **)brealloc(ua->prompt, sizeof(char *) *
          ua->max_prompts);
+      ua->unique = (char **)brealloc(ua->unique, sizeof(char *) *
+         ua->max_prompts);
     }
     for (i=1; i < ua->num_prompts; i++) {
        if (strcmp(ua->prompt[i], prompt) == 0) {
           return;
+       } else if (unique && strcmp(ua->unique[i], unique) == 0) {
+          return;
        }
     }
-    ua->prompt[ua->num_prompts++] = bstrdup(prompt);
+    ua->prompt[ua->num_prompts] = bstrdup(prompt);
+    if (unique) {
+       ua->unique[ua->num_prompts++] = bstrdup(unique);
+    } else {
+       ua->unique[ua->num_prompts++] = NULL;
+    }
 }
 
 /*
@@ -769,7 +896,7 @@ void add_prompt(UAContext *ua, const char *prompt)
  *               is copied to prompt if not NULL
  *             prompt is set to the chosen prompt item string
  */
-int do_prompt(UAContext *ua, const char *automsg, const char *msg, 
+int do_prompt(UAContext *ua, const char *automsg, const char *msg,
               char *prompt, int max_prompt)
 {
    int i, item;
@@ -848,11 +975,105 @@ int do_prompt(UAContext *ua, const char *automsg, const char *msg,
 done:
    for (i=0; i < ua->num_prompts; i++) {
       free(ua->prompt[i]);
+      if (ua->unique[i]) free(ua->unique[i]);
    }
    ua->num_prompts = 0;
    return item>0 ? item-1 : item;
 }
 
+/*
+ * Display prompts and get user's choice
+ *
+ *  Returns: -1 on error
+ *            number of items selected and the choices are
+ *               copied to selected if not NULL
+ *            selected is an alist of the prompts chosen
+ *              Note! selected must already be initialized.
+ */
+int do_alist_prompt(UAContext *ua, const char *automsg, const char *msg,
+              alist *selected)
+{
+   int i, item;
+   char pmsg[MAXSTRING];
+   BSOCK *user = ua->UA_sock;
+   sellist sl;
+
+   /* First item is the prompt string, not the items */
+   if (ua->num_prompts == 1) {
+      ua->error_msg(_("Selection list for \"%s\" is empty!\n"), automsg);
+      item = -1;                    /* list is empty ! */
+      goto done;
+   }
+   if (ua->num_prompts == 2) {
+      item = 1;
+      selected->append(bstrdup(ua->prompt[1]));
+      ua->send_msg(_("Automatically selected %s: %s\n"), automsg, ua->prompt[1]);
+      goto done;
+   }
+   /* If running non-interactive, bail out */
+   if (ua->batch) {
+      /* First print the choices he wanted to make */
+      ua->send_msg(ua->prompt[0]);
+      for (i=1; i < ua->num_prompts; i++) {
+         ua->send_msg("%6d: %s\n", i, ua->prompt[i]);
+      }
+      /* Now print error message */
+      ua->send_msg(_("Your request has multiple choices for \"%s\". Selection is not possible in batch mode.\n"), automsg);
+      item = -1;
+      goto done;
+   }
+   if (ua->api) user->signal(BNET_START_SELECT);
+   ua->send_msg(ua->prompt[0]);
+   for (i=1; i < ua->num_prompts; i++) {
+      if (ua->api) {
+         ua->send_msg("%s", ua->prompt[i]);
+      } else {
+         ua->send_msg("%6d: %s\n", i, ua->prompt[i]);
+      }
+   }
+   if (ua->api) user->signal(BNET_END_SELECT);
+
+   sprintf(pmsg, "%s (1-%d): ", msg, ua->num_prompts-1);
+
+   for ( ;; ) {
+      bool ok = true;
+      /* Either a . or an @ will get you out of the loop */
+      if (ua->api) user->signal(BNET_SELECT_INPUT);
+
+      if (!get_selection_list(ua, sl, pmsg, false)) {
+         item = -1;
+         break;
+      }
+
+      if (sl.is_all()) {
+         for (i=1; i < ua->num_prompts; i++) {
+            selected->append(bstrdup(ua->prompt[i]));
+         }
+      } else {
+         while ( (item = sl.next()) > 0) {
+            if (item < 1 || item >= ua->num_prompts) {
+               ua->warning_msg(_("Please enter a number between 1 and %d\n"), ua->num_prompts-1);
+               ok = false;
+               break;
+            }
+            selected->append(bstrdup(ua->prompt[item]));
+         }
+      }
+      if (ok) {
+         item = selected->size();
+         break;
+      }
+   }
+
+done:
+   for (i=0; i < ua->num_prompts; i++) {
+      free(ua->prompt[i]);
+      if (ua->unique[i]) free(ua->unique[i]);
+   }
+   ua->num_prompts = 0;
+   return item;
+}
+
 
 /*
  * We scan what the user has entered looking for
@@ -865,7 +1086,7 @@ done:
  * If use_default is set, we assume that any keyword without a value
  *   is the name of the Storage resource wanted.
  */
-STORE *get_storage_resource(UAContext *ua, bool use_default)
+STORE *get_storage_resource(UAContext *ua, bool use_default, bool unique)
 {
    char *store_name = NULL;
    STORE *store = NULL;
@@ -931,14 +1152,15 @@ STORE *get_storage_resource(UAContext *ua, bool use_default)
                ua->error_msg(_("Expecting ujobid=xxx, got: %s.\n"), ua->argk[i]);
                return NULL;
             }
-            if (!(jcr=get_jcr_by_full_name(ua->argv[i]))) {
-               ua->error_msg(_("Job \"%s\" is not running.\n"), ua->argv[i]);
-               return NULL;
+            if ((jcr=get_jcr_by_full_name(ua->argv[i]))) {
+               store = jcr->wstore;
+               free_jcr(jcr);
+               /* The job might not be running, so we try to see other keywords */
+               if (store) {
+                  break;
+               }
             }
-            store = jcr->wstore;
-            free_jcr(jcr);
-            break;
-        }
+         }
       }
    }
    if (store && !acl_access_ok(ua, Storage_ACL, store->name())) {
@@ -956,7 +1178,7 @@ STORE *get_storage_resource(UAContext *ua, bool use_default)
    }
    /* No keywords found, so present a selection list */
    if (!store) {
-      store = select_storage_resource(ua);
+      store = select_storage_resource(ua, unique);
    }
    return store;
 }
@@ -1040,16 +1262,228 @@ int get_media_type(UAContext *ua, char *MediaType, int max_media)
    return (do_prompt(ua, _("Media Type"), _("Select the Media Type"), MediaType, max_media) < 0) ? 0 : 1;
 }
 
+
 bool get_level_from_name(JCR *jcr, const char *level_name)
 {
    /* Look up level name and pull code */
    bool found = false;
    for (int i=0; joblevels[i].level_name; i++) {
       if (strcasecmp(level_name, joblevels[i].level_name) == 0) {
-         jcr->set_JobLevel(joblevels[i].level);
+         jcr->setJobLevel(joblevels[i].level);
          found = true;
          break;
       }
    }
    return found;
 }
+
+static int count_running_jobs(UAContext *ua)
+{
+   int tjobs = 0;                  /* total # number jobs */
+   int njobs = 0;
+   JCR *jcr;
+   /* Count Jobs running */
+   foreach_jcr(jcr) {
+      if (jcr->JobId == 0) {      /* this is us */
+         continue;
+      }
+      tjobs++;                    /* count of all jobs */
+      if (!acl_access_ok(ua, Job_ACL, jcr->job->name())) {
+         continue;               /* skip not authorized */
+      }
+      njobs++;                   /* count of authorized jobs */
+   }
+   endeach_jcr(jcr);
+
+   if (njobs == 0) {            /* no authorized */
+      if (tjobs == 0) {
+         ua->send_msg(_("No Jobs running.\n"));
+      } else {
+         ua->send_msg(_("None of your jobs are running.\n"));
+      }
+   }
+   return njobs;
+}
+
+
+/* Get a list of running jobs
+ * "reason" is used in user messages
+ * can be: cancel, limit, ...
+ *  Returns: -1 on error
+ *           nb of JCR on success (should be free_jcr() after)
+ */
+int select_running_jobs(UAContext *ua, alist *jcrs, const char *reason)
+{
+   int i;
+   JCR *jcr = NULL;
+   int njobs = 0;
+   char JobName[MAX_NAME_LENGTH];
+   char temp[256];
+   alist *selected = NULL;
+
+   for (i=1; i<ua->argc; i++) {
+      if (strcasecmp(ua->argk[i], NT_("jobid")) == 0) {
+         sellist sl;
+         int32_t JobId;
+
+         if (!ua->argv[i]) {
+            ua->error_msg(_("No value given for \"jobid\".\n"));
+            goto bail_out;
+         }
+         if (!sl.set_string(ua->argv[i], true)) {
+            ua->send_msg("%s", sl.get_errmsg());
+            goto bail_out;
+         }
+         foreach_sellist(JobId, &sl) {
+            jcr = get_jcr_by_id(JobId);
+            if (jcr && jcr->job && acl_access_ok(ua, Job_ACL, jcr->job->name())) {
+               jcrs->append(jcr);
+            } else if (jcr) {
+               ua->error_msg(_("Unauthorized command from this console "
+                               "for JobId=%d.\n"), JobId);
+               free_jcr(jcr);
+            } else {
+               ua->warning_msg(_("Warning Job JobId=%d is not running.\n"), JobId);
+            }
+         }
+         if (jcrs->size() == 0) {
+            goto bail_out;               /* If we did not find specified jobid, get out */
+         }
+         break;
+
+      /* TODO: might want to implement filters (client, status, etc...) */
+      } else if (strcasecmp(ua->argk[i], NT_("all")) == 0) {
+         foreach_jcr(jcr) {
+            if (jcr->JobId == 0) {      /* Do not cancel consoles */
+               continue;
+            }
+            if (!acl_access_ok(ua, Job_ACL, jcr->job->name())) {
+               continue;               /* skip not authorized */
+            }
+            jcr->inc_use_count();
+            jcrs->append(jcr);
+         }
+         endeach_jcr(jcr);
+
+         /* If we have something and no "yes" on command line, get confirmation */
+         if (jcrs->size() > 0 && find_arg(ua, NT_("yes")) < 0) {
+            char nbuf[1000];
+            bsnprintf(nbuf, sizeof(nbuf),  _("Confirm %s of %d Job%s (yes/no): "),
+                      reason, jcrs->size(), jcrs->size()>1?"s":"");
+            if (!get_yesno(ua, nbuf) || ua->pint32_val == 0) {
+               goto bail_out;
+            }
+         }
+         if (jcrs->size() == 0) {
+            goto bail_out;               /* If we did not find specified jobid, get out */
+         }
+         break;
+
+      } else if (strcasecmp(ua->argk[i], NT_("job")) == 0) {
+         if (!ua->argv[i]) {
+            ua->error_msg(_("No value given for \"job\".\n"));
+            goto bail_out;
+         }
+         jcr = get_jcr_by_partial_name(ua->argv[i]);
+
+         if (jcr && jcr->job && acl_access_ok(ua, Job_ACL, jcr->job->name())) {
+            jcrs->append(jcr);
+
+         } else if (jcr) {
+            if (jcr->job) {
+               ua->error_msg(_("Unauthorized command from this console "
+                               "for job=%s.\n"), ua->argv[i]);
+            }
+            free_jcr(jcr);
+
+         } else {
+            ua->warning_msg(_("Warning Job %s is not running.\n"), ua->argv[i]);
+         }
+         if (jcrs->size() == 0) {
+            goto bail_out;               /* If we did not find specified jobid, get out */
+         }
+         break;
+
+      } else if (strcasecmp(ua->argk[i], NT_("ujobid")) == 0) {
+         if (!ua->argv[i]) {
+            ua->error_msg(_("No value given for \"ujobid\".\n"));
+            goto bail_out;
+         }
+         jcr = get_jcr_by_full_name(ua->argv[i]);
+
+         if (jcr && jcr->job && acl_access_ok(ua, Job_ACL, jcr->job->name())) {
+            jcrs->append(jcr);
+
+         } else if (jcr) {
+            if (jcr->job) {
+               ua->error_msg(_("Unauthorized command from this console "
+                               "for ujobid=%s.\n"), ua->argv[i]);
+            }
+            free_jcr(jcr);
+
+         } else {
+            ua->warning_msg(_("Warning Job %s is not running.\n"), ua->argv[i]);
+         }
+         if (jcrs->size() == 0) {
+            goto bail_out;               /* If we did not find specified jobid, get out */
+         }
+         break;
+      }
+   }
+
+   if (jcrs->size() == 0) {
+      /*
+       * If we still do not have a jcr,
+       *   throw up a list and ask the user to select one.
+       */
+      char *item;
+      char buf[1000];
+      njobs = count_running_jobs(ua);
+      if (njobs == 0) {
+         goto bail_out;
+      }
+      start_prompt(ua, _("Select Job(s):\n"));
+      foreach_jcr(jcr) {
+         char ed1[50];
+         if (jcr->JobId == 0) {      /* this is us */
+            continue;
+         }
+         bsnprintf(buf, sizeof(buf), _("JobId=%s Job=%s"), edit_int64(jcr->JobId, ed1), jcr->Job);
+         add_prompt(ua, buf);
+      }
+      endeach_jcr(jcr);
+      bsnprintf(temp, sizeof(temp), _("Choose Job list to %s"), _(reason));
+      selected = New(alist(5, owned_by_alist));
+      if (do_alist_prompt(ua, _("Job"), temp, selected) < 0) {
+         goto bail_out;
+      }
+      /* Possibly ask for confirmation */
+      if (selected->size() > 0 && find_arg(ua, NT_("yes")) < 0) {
+         char nbuf[1000];
+         foreach_alist(item, selected) {
+            ua->send_msg("%s\n", item);
+         }
+         bsnprintf(nbuf, sizeof(nbuf),  _("Confirm %s of %d Job%s (yes/no): "),
+                   reason, selected->size(), selected->size()>1?"s":"");
+         if (!get_yesno(ua, nbuf) || ua->pint32_val == 0) {
+            goto bail_out;
+         }
+      }
+
+      foreach_alist(item, selected) {
+         if (sscanf(item, "JobId=%d Job=%127s", &njobs, JobName) != 2) {
+            ua->warning_msg(_("Job \"%s\" not found.\n"), item);
+            continue;
+         }
+         jcr = get_jcr_by_full_name(JobName);
+         if (jcr) {
+            jcrs->append(jcr);
+         } else {
+            ua->warning_msg(_("Job \"%s\" not found.\n"), JobName);
+         }
+      }
+   }
+bail_out:
+   if (selected) delete selected;
+   return jcrs->size();
+}