/*
- Bacula® - The Network Backup Solution
-
- Copyright (C) 2000-2012 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 three of the GNU Affero 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 Affero 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) 2000-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.
*/
/*
*
* I.e. messages, listing database, showing resources, ...
*
* Kern Sibbald, September MM
- *
- * Version $Id$
*/
#include "bacula.h"
return 1;
}
-/*
- * Enter with Resources locked
+/*
+ * Enter with Resources locked
*/
static void show_disabled_jobs(UAContext *ua)
{
JOB *job;
bool first = true;
- foreach_res(job, R_JOB) {
+ foreach_res(job, R_JOB) {
if (!acl_access_ok(ua, Job_ACL, job->name())) {
continue;
}
LockRes();
for (i=1; i<ua->argc; i++) {
- if (strcasecmp(ua->argk[i], _("disabled")) == 0) {
+ if (strcasecmp(ua->argk[i], NT_("disabled")) == 0) {
show_disabled_jobs(ua);
goto bail_out;
}
+
type = 0;
+
res_name = ua->argk[i];
if (!ua->argv[i]) { /* was a name given? */
/* No name, dump all resources of specified type */
recurse = 1;
len = strlen(res_name);
for (j=0; reses[j].res_name; j++) {
- if (strncasecmp(res_name, _(reses[j].res_name), len) == 0) {
+ if (strncasecmp(res_name, reses[j].res_name, len) == 0) {
type = reses[j].type;
if (type > 0) {
res = res_head[type-r_first];
recurse = 0;
len = strlen(res_name);
for (j=0; reses[j].res_name; j++) {
- if (strncasecmp(res_name, _(reses[j].res_name), len) == 0) {
+ if (strncasecmp(res_name, reses[j].res_name, len) == 0) {
type = reses[j].type;
res = (RES *)GetResWithName(type, ua->argv[i]);
if (!res) {
}
switch (type) {
- case -1: /* all */
+ /* All resources */
+ case -1:
for (j=r_first; j<=r_last; j++) {
- dump_resource(j, res_head[j-r_first], bsendmsg, ua);
+ /* Skip R_DEVICE since it is really not used or updated */
+ if (j != R_DEVICE) {
+ dump_resource(j, res_head[j-r_first], bsendmsg, ua);
+ }
}
break;
+ /* Help */
case -2:
ua->send_msg(_("Keywords for the show command are:\n"));
for (j=0; reses[j].res_name; j++) {
- ua->error_msg("%s\n", _(reses[j].res_name));
+ ua->error_msg("%s\n", reses[j].res_name);
}
goto bail_out;
+ /* Resource not found */
case -3:
ua->error_msg(_("%s resource %s not found.\n"), res_name, ua->argv[i]);
goto bail_out;
+ /* Resource not found */
case 0:
ua->error_msg(_("Resource %s not found\n"), res_name);
goto bail_out;
+ /* Dump a specific type */
default:
dump_resource(recurse?type:-type, res, bsendmsg, ua);
break;
return 1;
}
+/*
+ * Check if the access is permitted for a list of jobids
+ *
+ * Not in ua_acl.c because it's using db access, and tools such
+ * as bdirjson are not linked with cats.
+ */
+bool acl_access_jobid_ok(UAContext *ua, const char *jobids)
+{
+ char *tmp=NULL, *p;
+ bool ret=false;
+ JOB_DBR jr;
+ uint32_t jid;
+
+ if (!jobids) {
+ return false;
+ }
+
+ if (!is_a_number_list(jobids)) {
+ return false;
+ }
+
+ /* If no console resource => default console and all is permitted */
+ if (!ua || !ua->cons) {
+ Dmsg0(1400, "Root cons access OK.\n");
+ return true; /* No cons resource -> root console OK for everything */
+ }
+
+ alist *list = ua->cons->ACL_lists[Job_ACL];
+ if (!list) { /* empty list */
+ return false; /* List empty, reject everything */
+ }
+
+ /* Special case *all* gives full access */
+ if (list->size() == 1 && strcasecmp("*all*", (char *)list->get(0)) == 0) {
+ return true;
+ }
+
+ /* If we can't open the database, just say no */
+ if (!open_new_client_db(ua)) {
+ return false;
+ }
+
+ p = tmp = bstrdup(jobids);
+ while (get_next_jobid_from_list(&p, &jid) > 0) {
+ memset(&jr, 0, sizeof(jr));
+ jr.JobId = jid;
+ if (db_get_job_record(ua->jcr, ua->db, &jr)) {
+ for (int i=0; i<list->size(); i++) {
+ if (strcasecmp(jr.Name, (char *)list->get(i)) == 0) {
+ Dmsg3(1400, "ACL found %s in %d %s\n", jr.Name,
+ Job_ACL, (char *)list->get(i));
+ ret = true;
+ goto bail_out;
+ }
+ }
+ }
+ }
+
+bail_out:
+ if (tmp) {
+ free(tmp);
+ }
+ return ret;
+}
/*
* List contents of database
* list jobs - lists all jobs run
* list jobid=nnn - list job data for jobid
* list ujobid=uname - list job data for unique jobid
- * list job=name - list all jobs with "name"
- * list jobname=name - same as above
+ * list job=name - list all jobs with "name"
+ * list jobname=name - same as above
* list jobmedia jobid=<nn>
* list jobmedia job=name
* list joblog jobid=<nn>
POOL_DBR pr;
MEDIA_DBR mr;
- if (!open_client_db(ua))
+ if (!open_new_client_db(ua))
return 1;
memset(&jr, 0, sizeof(jr));
if (!ua->db) {
ua->error_msg(_("Hey! DB is NULL\n"));
}
-
/* Apply any limit */
- j = find_arg_with_value(ua, NT_("limit"));
- if (j >= 0) {
- jr.limit = atoi(ua->argv[j]);
+ for (j = 1; j < ua->argc ; j++) {
+ if (strcasecmp(ua->argk[j], NT_("joberrors")) == 0) {
+ jr.JobErrors = 1;
+ } else if (!ua->argv[j]) {
+ /* skip */
+ } else if (strcasecmp(ua->argk[j], NT_("order")) == 0) {
+ if (strcasecmp(ua->argv[j], NT_("desc")) == 0) {
+ jr.order = 1;
+ } else if (strcasecmp(ua->argv[j], NT_("asc")) == 0) {
+ jr.order = 0;
+ } else {
+ ua->error_msg(_("Unknown order type %s\n"), ua->argv[j]);
+ return 1;
+ }
+ } else if (strcasecmp(ua->argk[j], NT_("limit")) == 0) {
+ jr.limit = atoi(ua->argv[j]);
+
+ } else if (strcasecmp(ua->argk[j], NT_("jobstatus")) == 0) {
+ if (B_ISALPHA(ua->argv[j][0])) {
+ jr.JobStatus = ua->argv[j][0];
+ }
+ } else if (strcasecmp(ua->argk[j], NT_("client")) == 0) {
+ if (is_name_valid(ua->argv[j], NULL)) {
+ CLIENT_DBR cr;
+ memset(&cr, 0, sizeof(cr));
+ if(get_client_dbr(ua, &cr)) {
+ jr.ClientId = cr.ClientId;
+ }
+ }
+ }
}
/* Scan arguments looking for things to do */
db_list_base_files_for_job(ua->jcr, ua->db, jobid, prtit, ua);
}
}
-
+
/* List FILES */
} else if (strcasecmp(ua->argk[i], NT_("files")) == 0) {
} else if (strcasecmp(ua->argk[i], NT_("clients")) == 0) {
db_list_client_records(ua->jcr, ua->db, prtit, ua, llist);
-
/* List MEDIA or VOLUMES */
} else if (strcasecmp(ua->argk[i], NT_("media")) == 0 ||
strcasecmp(ua->argk[i], NT_("volume")) == 0 ||
free_pool_memory(VolumeName);
done = true;
}
+
/* if no job or jobid keyword found, then we list all media */
if (!done) {
int num_pools;
uint32_t *ids;
/* List a specific volume? */
- if (ua->argv[i]) {
+ if (ua->argv[i] && *ua->argv[i]) {
bstrncpy(mr.VolumeName, ua->argv[i], sizeof(mr.VolumeName));
db_list_media_records(ua->jcr, ua->db, &mr, prtit, ua, llist);
return 1;
}
} else if (strcasecmp(ua->argk[j], NT_("limit")) == 0 && ua->argv[j]) {
limit = atoi(ua->argv[j]);
- }
+ }
}
db_list_copies_records(ua->jcr,ua->db,limit,jobids,prtit,ua,llist);
} else if (strcasecmp(ua->argk[i], NT_("limit")) == 0
- || strcasecmp(ua->argk[i], NT_("days")) == 0) {
+ || strcasecmp(ua->argk[i], NT_("days")) == 0
+ || strcasecmp(ua->argk[i], NT_("joberrors")) == 0
+ || strcasecmp(ua->argk[i], NT_("order")) == 0
+ || strcasecmp(ua->argk[i], NT_("jobstatus")) == 0
+ || strcasecmp(ua->argk[i], NT_("client")) == 0
+ ) {
/* Ignore it */
+ } else if (strcasecmp(ua->argk[i], NT_("snapshot")) == 0 ||
+ strcasecmp(ua->argk[i], NT_("snapshots")) == 0)
+ {
+ snapshot_list(ua, i, prtit, llist);
+ return 1;
+
} else {
ua->error_msg(_("Unknown list keyword: %s\n"), NPRT(ua->argk[i]));
}
static bool list_nextvol(UAContext *ua, int ndays)
{
JOB *job;
- JCR *jcr;
+ JCR *jcr;
USTORE store;
RUN *run;
utime_t runtime;
}
get_out:
- if (jcr->db) {
- db_close_database(jcr, jcr->db);
- jcr->db = NULL;
- }
+ if (jcr->db) db_close_database(jcr, jcr->db);
+ jcr->db = NULL;
free_jcr(jcr);
if (!found) {
ua->error_msg(_("Could not find next Volume for Job %s.\n"),
SCHED *sched;
struct tm tm, runtm;
int mday, wday, month, wom, i;
- int woy;
+ int woy, ldom;
int day;
- int is_scheduled;
+ bool is_scheduled;
sched = job->schedule;
- if (sched == NULL) { /* scheduled? */
+ if (!sched || !job->enabled || (sched && !sched->enabled) ||
+ (job->client && !job->client->enabled)) {
return NULL; /* no nothing to report */
}
month = tm.tm_mon;
wom = mday / 7;
woy = tm_woy(future);
+ ldom = tm_ldom(month, tm.tm_year + 1900);
+
+ 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)) ||
+ (bit_is_set(month, run->month) &&
+ bit_is_set(31, run->mday) && mday == ldom);
- 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
Pmsg2(000, "day=%d is_scheduled=%d\n", day, is_scheduled);
Pmsg1(000, "bit_set_mday=%d\n", bit_is_set(mday, run->mday));
}
Dmsg0(100, "complete_jcr open db\n");
- jcr->db = db_init_database(jcr, jcr->catalog->db_driver, jcr->catalog->db_name,
- jcr->catalog->db_user,
- jcr->catalog->db_password, jcr->catalog->db_address,
- jcr->catalog->db_port, jcr->catalog->db_socket,
- jcr->catalog->mult_db_connections,
- jcr->catalog->disable_batch_insert);
+ jcr->db = db_init_database(jcr, jcr->catalog->db_driver, jcr->catalog->db_name,
+ jcr->catalog->db_user,
+ jcr->catalog->db_password, jcr->catalog->db_address,
+ jcr->catalog->db_port, jcr->catalog->db_socket,
+ jcr->catalog->mult_db_connections,
+ jcr->catalog->disable_batch_insert);
if (!jcr->db || !db_open_database(jcr, jcr->db)) {
Jmsg(jcr, M_FATAL, 0, _("Could not open database \"%s\".\n"),
jcr->catalog->db_name);
int mlen;
bool do_truncate = false;
+ if (ua->jcr) {
+ dequeue_messages(ua->jcr);
+ }
Pw(con_lock);
pthread_cleanup_push(con_lock_release, (void *)NULL);
rewind(con_fd);
{
UAContext *ua = (UAContext *)ctx;
- ua->UA_sock->fsend("%s", msg);
+ if (ua) ua->send_msg("%s", msg);
}
/*
}
#endif
-
+
void bsendmsg(void *ctx, const char *fmt, ...)
{
va_list arg_ptr;
* programs
*/
/*
- * This is a message that should be displayed on the user's
+ * This is a message that should be displayed on the user's
* console.
*/
void UAContext::send_msg(const char *fmt, ...)
va_end(arg_ptr);
}
-/*
+/*
* This is a warning message, that should bring up a warning
* dialog box on the GUI. The command is not aborted, but something
* went wrong.
va_end(arg_ptr);
}
-/*
+/*
* This is an information message that should probably be put
* into the status line of a GUI program.
*/
projects / bacula / bacula / blobdiff