+++ /dev/null
-/*
- * Bacula message handling routines
- *
- * Kern Sibbald, April 2000
- *
- * Version $Id$
- *
- */
-
-/*
- Copyright (C) 2000-2003 Kern Sibbald and John Walker
-
- This program is free software; you can redistribute it and/or
- modify it under the terms of the GNU General Public License as
- published by the Free Software Foundation; either version 2 of
- the License, or (at your option) any later version.
-
- 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., 59 Temple Place - Suite 330, Boston,
- MA 02111-1307, USA.
-
- */
-
-
-#include "bacula.h"
-#include "jcr.h"
-
-#define FULL_LOCATION 1 /* set for file:line in Debug messages */
-
-/*
- * This is where we define "Globals" because all the
- * daemons include this file.
- */
-char *working_directory = NULL; /* working directory path stored here */
-int verbose = 0; /* increase User messages */
-int debug_level = 0; /* debug level */
-time_t daemon_start_time = 0; /* Daemon start time */
-const char *version = VERSION " (" BDATE ")";
-char my_name[30]; /* daemon name is stored here */
-char *exepath = (char *)NULL;
-char *exename = (char *)NULL;
-int console_msg_pending = 0;
-char con_fname[500]; /* Console filename */
-FILE *con_fd = NULL; /* Console file descriptor */
-brwlock_t con_lock; /* Console lock structure */
-
-#ifdef HAVE_POSTGRESQL
-char catalog_db[] = "PostgreSQL";
-#else
-#ifdef HAVE_MYSQL
-char catalog_db[] = "MySQL";
-#else
-#ifdef HAVE_SQLITE
-char catalog_db[] = "SQLite";
-#else
-char catalog_db[] = "Internal";
-#endif
-#endif
-#endif
-
-const char *host_os = HOST_OS;
-const char *distname = DISTNAME;
-const char *distver = DISTVER;
-static FILE *trace_fd = NULL;
-#ifdef HAVE_WIN32
-static bool trace = true;
-#else
-static bool trace = false;
-#endif
-
-/* Forward referenced functions */
-
-/* Imported functions */
-
-
-/* Static storage */
-
-static MSGS *daemon_msgs; /* global messages */
-
-/*
- * Set daemon name. Also, find canonical execution
- * path. Note, exepath has spare room for tacking on
- * the exename so that we can reconstruct the full name.
- *
- * Note, this routine can get called multiple times
- * The second time is to put the name as found in the
- * Resource record. On the second call, generally,
- * argv is NULL to avoid doing the path code twice.
- */
-#define BTRACE_EXTRA 20
-void my_name_is(int argc, char *argv[], const char *name)
-{
- char *l, *p, *q;
- char cpath[400], npath[400];
- int len;
-
- bstrncpy(my_name, name, sizeof(my_name));
- if (argc>0 && argv && argv[0]) {
- /* strip trailing filename and save exepath */
- for (l=p=argv[0]; *p; p++) {
- if (*p == '/') {
- l = p; /* set pos of last slash */
- }
- }
- if (*l == '/') {
- l++;
- } else {
- l = argv[0];
-#if defined(HAVE_CYGWIN) || defined(HAVE_WIN32)
- /* On Windows allow c: junk */
- if (l[1] == ':') {
- l += 2;
- }
-#endif
- }
- len = strlen(l) + 1;
- if (exename) {
- free(exename);
- }
- exename = (char *)malloc(len);
- strcpy(exename, l);
-
- if (exepath) {
- free(exepath);
- }
- exepath = (char *)malloc(strlen(argv[0]) + 1 + len);
- for (p=argv[0],q=exepath; p < l; ) {
- *q++ = *p++;
- }
- *q = 0;
- Dmsg1(200, "exepath=%s\n", exepath);
- if (strchr(exepath, '.') || exepath[0] != '/') {
- npath[0] = 0;
- if (getcwd(cpath, sizeof(cpath))) {
- if (chdir(exepath) == 0) {
- if (!getcwd(npath, sizeof(npath))) {
- npath[0] = 0;
- }
- chdir(cpath);
- }
- if (npath[0]) {
- free(exepath);
- exepath = (char *)malloc(strlen(npath) + 1 + len);
- strcpy(exepath, npath);
- }
- }
- Dmsg1(200, "Normalized exepath=%s\n", exepath);
- }
- }
-}
-
-/*
- * Initialize message handler for a daemon or a Job
- * We make a copy of the MSGS resource passed, so it belows
- * to the job or daemon and thus can be modified.
- *
- * NULL for jcr -> initialize global messages for daemon
- * non-NULL -> initialize jcr using Message resource
- */
-void
-init_msg(JCR *jcr, MSGS *msg)
-{
- DEST *d, *dnew, *temp_chain = NULL;
- int i;
-
- if (jcr == NULL && msg == NULL) {
- init_last_jobs_list();
- }
-
-#ifndef HAVE_WIN32
- /*
- * Make sure we have fd's 0, 1, 2 open
- * If we don't do this one of our sockets may open
- * there and if we then use stdout, it could
- * send total garbage to our socket.
- *
- */
- int fd;
- fd = open("/dev/null", O_RDONLY, 0644);
- if (fd > 2) {
- close(fd);
- } else {
- for(i=1; fd + i <= 2; i++) {
- dup2(fd, fd+i);
- }
- }
-
-#endif
- /*
- * If msg is NULL, initialize global chain for STDOUT and syslog
- */
- if (msg == NULL) {
- daemon_msgs = (MSGS *)malloc(sizeof(MSGS));
- memset(daemon_msgs, 0, sizeof(MSGS));
- for (i=1; i<=M_MAX; i++) {
- add_msg_dest(daemon_msgs, MD_STDOUT, i, NULL, NULL);
- add_msg_dest(daemon_msgs, MD_SYSLOG, i, NULL, NULL);
- }
- Dmsg1(050, "Create daemon global message resource 0x%x\n", daemon_msgs);
- return;
- }
-
- /*
- * Walk down the message resource chain duplicating it
- * for the current Job.
- */
- for (d=msg->dest_chain; d; d=d->next) {
- dnew = (DEST *)malloc(sizeof(DEST));
- memcpy(dnew, d, sizeof(DEST));
- dnew->next = temp_chain;
- dnew->fd = NULL;
- dnew->mail_filename = NULL;
- if (d->mail_cmd) {
- dnew->mail_cmd = bstrdup(d->mail_cmd);
- }
- if (d->where) {
- dnew->where = bstrdup(d->where);
- }
- temp_chain = dnew;
- }
-
- if (jcr) {
- jcr->jcr_msgs = (MSGS *)malloc(sizeof(MSGS));
- memset(jcr->jcr_msgs, 0, sizeof(MSGS));
- jcr->jcr_msgs->dest_chain = temp_chain;
- memcpy(jcr->jcr_msgs->send_msg, msg->send_msg, sizeof(msg->send_msg));
- } else {
- /* If we have default values, release them now */
- if (daemon_msgs) {
- free_msgs_res(daemon_msgs);
- }
- daemon_msgs = (MSGS *)malloc(sizeof(MSGS));
- memset(daemon_msgs, 0, sizeof(MSGS));
- daemon_msgs->dest_chain = temp_chain;
- memcpy(daemon_msgs->send_msg, msg->send_msg, sizeof(msg->send_msg));
- }
- Dmsg2(050, "Copy message resource 0x%x to 0x%x\n", msg, temp_chain);
-
-}
-
-/* Initialize so that the console (User Agent) can
- * receive messages -- stored in a file.
- */
-void init_console_msg(char *wd)
-{
- int fd;
-
- bsnprintf(con_fname, sizeof(con_fname), "%s/%s.conmsg", wd, my_name);
- fd = open(con_fname, O_CREAT|O_RDWR|O_BINARY, 0600);
- if (fd == -1) {
- Emsg2(M_ERROR_TERM, 0, _("Could not open console message file %s: ERR=%s\n"),
- con_fname, strerror(errno));
- }
- if (lseek(fd, 0, SEEK_END) > 0) {
- console_msg_pending = 1;
- }
- close(fd);
- con_fd = fopen(con_fname, "a+");
- if (!con_fd) {
- Emsg2(M_ERROR, 0, _("Could not open console message file %s: ERR=%s\n"),
- con_fname, strerror(errno));
- }
- if (rwl_init(&con_lock) != 0) {
- Emsg1(M_ERROR_TERM, 0, _("Could not get con mutex: ERR=%s\n"),
- strerror(errno));
- }
-}
-
-/*
- * Called only during parsing of the config file.
- *
- * Add a message destination. I.e. associate a message type with
- * a destination (code).
- * Note, where in the case of dest_code FILE is a filename,
- * but in the case of MAIL is a space separated list of
- * email addresses, ...
- */
-void add_msg_dest(MSGS *msg, int dest_code, int msg_type, char *where, char *mail_cmd)
-{
- DEST *d;
- /*
- * First search the existing chain and see if we
- * can simply add this msg_type to an existing entry.
- */
- for (d=msg->dest_chain; d; d=d->next) {
- if (dest_code == d->dest_code && ((where == NULL && d->where == NULL) ||
- (strcmp(where, d->where) == 0))) {
- Dmsg4(200, "Add to existing d=%x msgtype=%d destcode=%d where=%s\n",
- d, msg_type, dest_code, NPRT(where));
- set_bit(msg_type, d->msg_types);
- set_bit(msg_type, msg->send_msg); /* set msg_type bit in our local */
- return;
- }
- }
- /* Not found, create a new entry */
- d = (DEST *)malloc(sizeof(DEST));
- memset(d, 0, sizeof(DEST));
- d->next = msg->dest_chain;
- d->dest_code = dest_code;
- set_bit(msg_type, d->msg_types); /* set type bit in structure */
- set_bit(msg_type, msg->send_msg); /* set type bit in our local */
- if (where) {
- d->where = bstrdup(where);
- }
- if (mail_cmd) {
- d->mail_cmd = bstrdup(mail_cmd);
- }
- Dmsg5(200, "add new d=%x msgtype=%d destcode=%d where=%s mailcmd=%s\n",
- d, msg_type, dest_code, NPRT(where), NPRT(d->mail_cmd));
- msg->dest_chain = d;
-}
-
-/*
- * Called only during parsing of the config file.
- *
- * Remove a message destination
- */
-void rem_msg_dest(MSGS *msg, int dest_code, int msg_type, char *where)
-{
- DEST *d;
-
- for (d=msg->dest_chain; d; d=d->next) {
- Dmsg2(200, "Remove_msg_dest d=%x where=%s\n", d, NPRT(d->where));
- if (bit_is_set(msg_type, d->msg_types) && (dest_code == d->dest_code) &&
- ((where == NULL && d->where == NULL) ||
- (strcmp(where, d->where) == 0))) {
- Dmsg3(200, "Found for remove d=%x msgtype=%d destcode=%d\n",
- d, msg_type, dest_code);
- clear_bit(msg_type, d->msg_types);
- Dmsg0(200, "Return rem_msg_dest\n");
- return;
- }
- }
-}
-
-
-/*
- * Create a unique filename for the mail command
- */
-static void make_unique_mail_filename(JCR *jcr, POOLMEM **name, DEST *d)
-{
- if (jcr) {
- Mmsg(name, "%s/%s.mail.%s.%d", working_directory, my_name,
- jcr->Job, (int)(long)d);
- } else {
- Mmsg(name, "%s/%s.mail.%s.%d", working_directory, my_name,
- my_name, (int)(long)d);
- }
- Dmsg1(200, "mailname=%s\n", *name);
-}
-
-/*
- * Open a mail pipe
- */
-static BPIPE *open_mail_pipe(JCR *jcr, POOLMEM **cmd, DEST *d)
-{
- BPIPE *bpipe;
-
- if (d->mail_cmd && jcr) {
- *cmd = edit_job_codes(jcr, *cmd, d->mail_cmd, d->where);
- } else {
- Mmsg(cmd, "mail -s \"Bacula Message\" %s", d->where);
- }
- fflush(stdout);
-
- if (!(bpipe = open_bpipe(*cmd, 120, "rw"))) {
- Jmsg(jcr, M_ERROR, 0, "open mail pipe %s failed: ERR=%s\n",
- *cmd, strerror(errno));
- }
- return bpipe;
-}
-
-/*
- * Close the messages for this Messages resource, which means to close
- * any open files, and dispatch any pending email messages.
- */
-void close_msg(JCR *jcr)
-{
- MSGS *msgs;
- DEST *d;
- BPIPE *bpipe;
- POOLMEM *cmd, *line;
- int len, stat;
-
- Dmsg1(050, "Close_msg jcr=0x%x\n", jcr);
-
- if (jcr == NULL) { /* NULL -> global chain */
- msgs = daemon_msgs;
- } else {
- msgs = jcr->jcr_msgs;
- jcr->jcr_msgs = NULL;
- }
- if (msgs == NULL) {
- return;
- }
- Dmsg1(150, "===Begin close msg resource at 0x%x\n", msgs);
- cmd = get_pool_memory(PM_MESSAGE);
- for (d=msgs->dest_chain; d; ) {
- if (d->fd) {
- switch (d->dest_code) {
- case MD_FILE:
- case MD_APPEND:
- if (d->fd) {
- fclose(d->fd); /* close open file descriptor */
- }
- break;
- case MD_MAIL:
- case MD_MAIL_ON_ERROR:
- Dmsg0(150, "Got MD_MAIL or MD_MAIL_ON_ERROR\n");
- if (!d->fd) {
- break;
- }
- if (d->dest_code == MD_MAIL_ON_ERROR && jcr &&
- jcr->JobStatus == JS_Terminated) {
- goto rem_temp_file;
- }
-
- if (!(bpipe=open_mail_pipe(jcr, &cmd, d))) {
- Pmsg0(000, "open mail pipe failed.\n");
- goto rem_temp_file;
- }
- Dmsg0(150, "Opened mail pipe\n");
- len = d->max_len+10;
- line = get_memory(len);
- rewind(d->fd);
- while (fgets(mp_chr(line), len, d->fd)) {
- fputs(line, bpipe->wfd);
- }
- if (!close_wpipe(bpipe)) { /* close write pipe sending mail */
- Pmsg1(000, "close error: ERR=%s\n", strerror(errno));
- }
-
- /*
- * Since we are closing all messages, before "recursing"
- * make sure we are not closing the daemon messages, otherwise
- * kaboom.
- */
- if (msgs != daemon_msgs) {
- /* read what mail prog returned -- should be nothing */
- while (fgets(mp_chr(line), len, bpipe->rfd)) {
- Jmsg1(jcr, M_INFO, 0, _("Mail prog: %s"), line);
- }
- }
-
- stat = close_bpipe(bpipe);
- if (stat != 0 && msgs != daemon_msgs) {
- Dmsg1(150, "Calling emsg. CMD=%s\n", cmd);
- Jmsg3(jcr, M_ERROR, 0, _("Mail program terminated in error. stat=%d\n"
- "CMD=%s\n"
- "ERR=%s\n"), stat, cmd, strerror(stat));
- }
- free_memory(line);
-rem_temp_file:
- /* Remove temp file */
- fclose(d->fd);
- unlink(mp_chr(d->mail_filename));
- free_pool_memory(d->mail_filename);
- d->mail_filename = NULL;
- Dmsg0(150, "end mail or mail on error\n");
- break;
- default:
- break;
- }
- d->fd = NULL;
- }
- d = d->next; /* point to next buffer */
- }
- free_pool_memory(cmd);
- Dmsg0(150, "Done walking message chain.\n");
- if (jcr) {
- free_msgs_res(msgs);
- msgs = NULL;
- }
- Dmsg0(150, "===End close msg resource\n");
-}
-
-/*
- * Free memory associated with Messages resource
- */
-void free_msgs_res(MSGS *msgs)
-{
- DEST *d, *old;
-
- /* Walk down the message chain releasing allocated buffers */
- for (d=msgs->dest_chain; d; ) {
- if (d->where) {
- free(d->where);
- }
- if (d->mail_cmd) {
- free(d->mail_cmd);
- }
- old = d; /* save pointer to release */
- d = d->next; /* point to next buffer */
- free(old); /* free the destination item */
- }
- msgs->dest_chain = NULL;
- free(msgs); /* free the head */
-}
-
-
-/*
- * Terminate the message handler for good.
- * Release the global destination chain.
- *
- * Also, clean up a few other items (cons, exepath). Note,
- * these really should be done elsewhere.
- */
-void term_msg()
-{
- Dmsg0(100, "Enter term_msg\n");
- close_msg(NULL); /* close global chain */
- free_msgs_res(daemon_msgs); /* free the resources */
- daemon_msgs = NULL;
- if (con_fd) {
- fflush(con_fd);
- fclose(con_fd);
- con_fd = NULL;
- }
- if (exepath) {
- free(exepath);
- exepath = NULL;
- }
- if (exename) {
- free(exename);
- exename = NULL;
- }
- if (trace_fd) {
- fclose(trace_fd);
- trace_fd = NULL;
- }
- term_last_jobs_list();
-}
-
-
-
-/*
- * Handle sending the message to the appropriate place
- */
-void dispatch_message(JCR *jcr, int type, int level, char *msg)
-{
- DEST *d;
- char dt[MAX_TIME_LENGTH];
- POOLMEM *mcmd;
- int len;
- MSGS *msgs;
- BPIPE *bpipe;
-
- Dmsg2(800, "Enter dispatch_msg type=%d msg=%s\n", type, msg);
-
- if (type == M_ABORT || type == M_ERROR_TERM) {
- fputs(msg, stdout); /* print this here to INSURE that it is printed */
- fflush(stdout);
-#if defined(HAVE_CYGWIN) || defined(HAVE_WIN32)
- MessageBox(NULL, msg, "Bacula", MB_OK);
-#endif
- }
-
- /* Now figure out where to send the message */
- msgs = NULL;
- if (jcr) {
- msgs = jcr->jcr_msgs;
- }
- if (msgs == NULL) {
- msgs = daemon_msgs;
- }
- for (d=msgs->dest_chain; d; d=d->next) {
- if (bit_is_set(type, d->msg_types)) {
- switch (d->dest_code) {
- case MD_CONSOLE:
- Dmsg1(800, "CONSOLE for following msg: %s", msg);
- if (!con_fd) {
- con_fd = fopen(con_fname, "a+");
- Dmsg0(800, "Console file not open.\n");
- }
- if (con_fd) {
- Pw(con_lock); /* get write lock on console message file */
- errno = 0;
- bstrftime(dt, sizeof(dt), time(NULL));
- len = strlen(dt);
- dt[len++] = ' ';
- fwrite(dt, len, 1, con_fd);
- len = strlen(msg);
- if (len > 0) {
- fwrite(msg, len, 1, con_fd);
- if (msg[len-1] != '\n') {
- fwrite("\n", 2, 1, con_fd);
- }
- } else {
- fwrite("\n", 2, 1, con_fd);
- }
- fflush(con_fd);
- console_msg_pending = TRUE;
- Vw(con_lock);
- }
- break;
- case MD_SYSLOG:
- Dmsg1(800, "SYSLOG for collowing msg: %s\n", msg);
- /*
- * We really should do an openlog() here.
- */
- syslog(LOG_DAEMON|LOG_ERR, "%s", msg);
- break;
- case MD_OPERATOR:
- Dmsg1(800, "OPERATOR for collowing msg: %s\n", msg);
- mcmd = get_pool_memory(PM_MESSAGE);
- if ((bpipe=open_mail_pipe(jcr, &mcmd, d))) {
- int stat;
- fputs(msg, bpipe->wfd);
- /* Messages to the operator go one at a time */
- stat = close_bpipe(bpipe);
- if (stat != 0) {
- Jmsg2(jcr, M_ERROR, 0, _("Operator mail program terminated in error.\n"
- "CMD=%s\n"
- "ERR=%s\n"), mcmd, strerror(stat));
- }
- }
- free_pool_memory(mcmd);
- break;
- case MD_MAIL:
- case MD_MAIL_ON_ERROR:
- Dmsg1(800, "MAIL for following msg: %s", msg);
- if (!d->fd) {
- POOLMEM *name = get_pool_memory(PM_MESSAGE);
- make_unique_mail_filename(jcr, &mp_chr(name), d);
- d->fd = fopen(mp_chr(name), "w+");
- if (!d->fd) {
- d->fd = stdout;
- Jmsg2(jcr, M_ERROR, 0, "fopen %s failed: ERR=%s\n", name, strerror(errno));
- d->fd = NULL;
- free_pool_memory(name);
- break;
- }
- d->mail_filename = name;
- }
- len = strlen(msg);
- if (len > d->max_len) {
- d->max_len = len; /* keep max line length */
- }
- fputs(msg, d->fd);
- break;
- case MD_FILE:
- Dmsg1(800, "FILE for following msg: %s", msg);
- if (!d->fd) {
- d->fd = fopen(d->where, "w+");
- if (!d->fd) {
- d->fd = stdout;
- Jmsg2(jcr, M_ERROR, 0, "fopen %s failed: ERR=%s\n", d->where, strerror(errno));
- d->fd = NULL;
- break;
- }
- }
- fputs(msg, d->fd);
- break;
- case MD_APPEND:
- Dmsg1(800, "APPEND for following msg: %s", msg);
- if (!d->fd) {
- d->fd = fopen(d->where, "a");
- if (!d->fd) {
- d->fd = stdout;
- Jmsg2(jcr, M_ERROR, 0, "fopen %s failed: ERR=%s\n", d->where, strerror(errno));
- d->fd = NULL;
- break;
- }
- }
- fputs(msg, d->fd);
- break;
- case MD_DIRECTOR:
- Dmsg1(800, "DIRECTOR for following msg: %s", msg);
- if (jcr && jcr->dir_bsock && !jcr->dir_bsock->errors) {
- bnet_fsend(jcr->dir_bsock, "Jmsg Job=%s type=%d level=%d %s",
- jcr->Job, type, level, msg);
- }
- break;
- case MD_STDOUT:
- Dmsg1(800, "STDOUT for following msg: %s", msg);
- if (type != M_ABORT && type != M_ERROR_TERM) { /* already printed */
- fputs(msg, stdout);
- }
- break;
- case MD_STDERR:
- Dmsg1(800, "STDERR for following msg: %s", msg);
- fputs(msg, stderr);
- break;
- default:
- break;
- }
- }
- }
-}
-
-
-/*********************************************************************
- *
- * This subroutine prints a debug message if the level number
- * is less than or equal the debug_level. File and line numbers
- * are included for more detail if desired, but not currently
- * printed.
- *
- * If the level is negative, the details of file and line number
- * are not printed.
- */
-void
-d_msg(const char *file, int line, int level, const char *fmt,...)
-{
- char buf[5000];
- int len;
- va_list arg_ptr;
- int details = TRUE;
-
- if (level < 0) {
- details = FALSE;
- level = -level;
- }
-
- if (level <= debug_level) {
-#ifdef FULL_LOCATION
- if (details) {
- /* visual studio passes the whole path to the file as well
- * which makes for very long lines
- */
- char *f = strrchr(file, '\\');
- if (f) file = f + 1;
- len = bsnprintf(buf, sizeof(buf), "%s: %s:%d ", my_name, file, line);
- } else {
- len = 0;
- }
-#else
- len = 0;
-#endif
- va_start(arg_ptr, fmt);
- bvsnprintf(buf+len, sizeof(buf)-len, (char *)fmt, arg_ptr);
- va_end(arg_ptr);
-
- /*
- * Used the "trace on" command in the console to turn on
- * output to the trace file. "trace off" will close the file.
- */
- if (trace) {
- if (!trace_fd) {
- bsnprintf(buf, sizeof(buf), "%s/bacula.trace", working_directory ? working_directory : ".");
- trace_fd = fopen(buf, "a+");
- }
- if (trace_fd) {
- fputs(buf, trace_fd);
- fflush(trace_fd);
- }
- } else { /* not tracing */
- fputs(buf, stdout);
- }
- }
-}
-
-/*
- * Set trace flag on/off. If argument is negative, there is no change
- */
-void set_trace(int trace_flag)
-{
- if (trace_flag < 0) {
- return;
- } else if (trace_flag > 0) {
- trace = true;
- } else {
- trace = false;
- }
- if (!trace && trace_fd) {
- FILE *ltrace_fd = trace_fd;
- trace_fd = NULL;
- bmicrosleep(0, 100000); /* yield to prevent seg faults */
- fclose(ltrace_fd);
- }
-}
-
-/*********************************************************************
- *
- * This subroutine prints a message regardless of the debug level
- *
- * If the level is negative, the details of file and line number
- * are not printed.
- */
-void
-p_msg(const char *file, int line, int level, const char *fmt,...)
-{
- char buf[5000];
- int len;
- va_list arg_ptr;
-
-#ifdef FULL_LOCATION
- if (level >= 0) {
- len = bsnprintf(buf, sizeof(buf), "%s: %s:%d ", my_name, file, line);
- } else {
- len = 0;
- }
-#else
- len = 0;
-#endif
- va_start(arg_ptr, fmt);
- bvsnprintf(buf+len, sizeof(buf)-len, (char *)fmt, arg_ptr);
- va_end(arg_ptr);
- fputs(buf, stdout);
-}
-
-
-/*********************************************************************
- *
- * subroutine writes a debug message to the trace file if the level number
- * is less than or equal the debug_level. File and line numbers
- * are included for more detail if desired, but not currently
- * printed.
- *
- * If the level is negative, the details of file and line number
- * are not printed.
- */
-void
-t_msg(const char *file, int line, int level, const char *fmt,...)
-{
- char buf[5000];
- int len;
- va_list arg_ptr;
- int details = TRUE;
-
- if (level < 0) {
- details = FALSE;
- level = -level;
- }
-
- if (level <= debug_level) {
- if (!trace_fd) {
- bsnprintf(buf, sizeof(buf), "%s/bacula.trace", working_directory);
- trace_fd = fopen(buf, "a+");
- }
-
-#ifdef FULL_LOCATION
- if (details) {
- len = bsnprintf(buf, sizeof(buf), "%s: %s:%d ", my_name, file, line);
- } else {
- len = 0;
- }
-#else
- len = 0;
-#endif
- va_start(arg_ptr, fmt);
- bvsnprintf(buf+len, sizeof(buf)-len, (char *)fmt, arg_ptr);
- va_end(arg_ptr);
- if (trace_fd != NULL) {
- fputs(buf, trace_fd);
- fflush(trace_fd);
- }
- }
-}
-
-
-
-/* *********************************************************
- *
- * print an error message
- *
- */
-void
-e_msg(const char *file, int line, int type, int level, const char *fmt,...)
-{
- char buf[5000];
- va_list arg_ptr;
- int len;
-
- /*
- * Check if we have a message destination defined.
- * We always report M_ABORT and M_ERROR_TERM
- */
- if (!daemon_msgs || ((type != M_ABORT && type != M_ERROR_TERM) &&
- !bit_is_set(type, daemon_msgs->send_msg))) {
- return; /* no destination */
- }
- switch (type) {
- case M_ABORT:
- len = bsnprintf(buf, sizeof(buf), "%s: ABORTING due to ERROR in %s:%d\n",
- my_name, file, line);
- break;
- case M_ERROR_TERM:
- len = bsnprintf(buf, sizeof(buf), "%s: ERROR TERMINATION at %s:%d\n",
- my_name, file, line);
- break;
- case M_FATAL:
- if (level == -1) /* skip details */
- len = bsnprintf(buf, sizeof(buf), "%s: Fatal Error because: ", my_name);
- else
- len = bsnprintf(buf, sizeof(buf), "%s: Fatal Error at %s:%d because:\n", my_name, file, line);
- break;
- case M_ERROR:
- if (level == -1) /* skip details */
- len = bsnprintf(buf, sizeof(buf), "%s: ERROR: ", my_name);
- else
- len = bsnprintf(buf, sizeof(buf), "%s: ERROR in %s:%d ", my_name, file, line);
- break;
- case M_WARNING:
- len = bsnprintf(buf, sizeof(buf), "%s: Warning: ", my_name);
- break;
- case M_SECURITY:
- len = bsnprintf(buf, sizeof(buf), "%s: Security violation: ", my_name);
- break;
- default:
- len = bsnprintf(buf, sizeof(buf), "%s: ", my_name);
- break;
- }
-
- va_start(arg_ptr, fmt);
- bvsnprintf(buf+len, sizeof(buf)-len, (char *)fmt, arg_ptr);
- va_end(arg_ptr);
-
- dispatch_message(NULL, type, level, buf);
-
- if (type == M_ABORT) {
- char *p = 0;
- p[0] = 0; /* generate segmentation violation */
- }
- if (type == M_ERROR_TERM) {
- exit(1);
- }
-}
-
-/* *********************************************************
- *
- * Generate a Job message
- *
- */
-void
-Jmsg(JCR *jcr, int type, int level, const char *fmt,...)
-{
- char rbuf[5000];
- va_list arg_ptr;
- int len;
- MSGS *msgs;
- const char *job;
-
-
- Dmsg1(800, "Enter Jmsg type=%d\n", type);
-
- /* Special case for the console, which has a dir_bsock and JobId==0,
- * in that case, we send the message directly back to the
- * dir_bsock.
- */
- if (jcr && jcr->JobId == 0 && jcr->dir_bsock) {
- BSOCK *dir = jcr->dir_bsock;
- va_start(arg_ptr, fmt);
- dir->msglen = bvsnprintf(mp_chr(dir->msg), sizeof_pool_memory(dir->msg),
- fmt, arg_ptr);
- va_end(arg_ptr);
- bnet_send(jcr->dir_bsock);
- return;
- }
-
- msgs = NULL;
- job = NULL;
- if (jcr) {
- msgs = jcr->jcr_msgs;
- job = jcr->Job;
- }
- if (!msgs) {
- msgs = daemon_msgs; /* if no jcr, we use daemon handler */
- }
- if (!job) {
- job = ""; /* Set null job name if none */
- }
-
- /*
- * Check if we have a message destination defined.
- * We always report M_ABORT and M_ERROR_TERM
- */
- if (msgs && (type != M_ABORT && type != M_ERROR_TERM) &&
- !bit_is_set(type, msgs->send_msg)) {
- return; /* no destination */
- }
- switch (type) {
- case M_ABORT:
- len = bsnprintf(rbuf, sizeof(rbuf), "%s ABORTING due to ERROR\n", my_name);
- break;
- case M_ERROR_TERM:
- len = bsnprintf(rbuf, sizeof(rbuf), "%s ERROR TERMINATION\n", my_name);
- break;
- case M_FATAL:
- len = bsnprintf(rbuf, sizeof(rbuf), "%s: %s Fatal error: ", my_name, job);
- if (jcr) {
- set_jcr_job_status(jcr, JS_FatalError);
- }
- break;
- case M_ERROR:
- len = bsnprintf(rbuf, sizeof(rbuf), "%s: %s Error: ", my_name, job);
- if (jcr) {
- jcr->Errors++;
- }
- break;
- case M_WARNING:
- len = bsnprintf(rbuf, sizeof(rbuf), "%s: %s Warning: ", my_name, job);
- break;
- case M_SECURITY:
- len = bsnprintf(rbuf, sizeof(rbuf), "%s: %s Security violation: ", my_name, job);
- break;
- default:
- len = bsnprintf(rbuf, sizeof(rbuf), "%s: ", my_name);
- break;
- }
-
- va_start(arg_ptr, fmt);
- bvsnprintf(rbuf+len, sizeof(rbuf)-len, fmt, arg_ptr);
- va_end(arg_ptr);
-
- dispatch_message(jcr, type, level, rbuf);
-
- if (type == M_ABORT){
- char *p = 0;
- p[0] = 0; /* generate segmentation violation */
- }
- if (type == M_ERROR_TERM) {
- exit(1);
- }
-}
-
-/*
- * If we come here, prefix the message with the file:line-number,
- * then pass it on to the normal Jmsg routine.
- */
-void j_msg(const char *file, int line, JCR *jcr, int type, int level, const char *fmt,...)
-{
- va_list arg_ptr;
- int i, len, maxlen;
- POOLMEM *pool_buf;
-
- pool_buf = get_pool_memory(PM_EMSG);
- i = Mmsg(&pool_buf, "%s:%d ", file, line);
-
- for (;;) {
- maxlen = sizeof_pool_memory(pool_buf) - i - 1;
- va_start(arg_ptr, fmt);
- len = bvsnprintf(pool_buf+i, maxlen, fmt, arg_ptr);
- va_end(arg_ptr);
- if (len < 0 || len >= maxlen) {
- pool_buf = realloc_pool_memory(pool_buf, maxlen + i + maxlen/2);
- continue;
- }
- break;
- }
-
- Jmsg(jcr, type, level, "%s", pool_buf);
- free_memory(pool_buf);
-}
-
-
-/*
- * Edit a message into a Pool memory buffer, with file:lineno
- */
-int m_msg(const char *file, int line, POOLMEM **pool_buf, const char *fmt, ...)
-{
- va_list arg_ptr;
- int i, len, maxlen;
-
- i = sprintf(mp_chr(*pool_buf), "%s:%d ", file, line);
-
- for (;;) {
- maxlen = sizeof_pool_memory(*pool_buf) - i - 1;
- va_start(arg_ptr, fmt);
- len = bvsnprintf(*pool_buf+i, maxlen, fmt, arg_ptr);
- va_end(arg_ptr);
- if (len < 0 || len >= maxlen) {
- *pool_buf = realloc_pool_memory(*pool_buf, maxlen + i + maxlen/2);
- continue;
- }
- break;
- }
- return len;
-}
-
-/*
- * Edit a message into a Pool Memory buffer NO file:lineno
- * Returns: string length of what was edited.
- */
-int Mmsg(POOLMEM **pool_buf, const char *fmt, ...)
-{
- va_list arg_ptr;
- int len, maxlen;
-
- for (;;) {
- maxlen = sizeof_pool_memory(*pool_buf) - 1;
- va_start(arg_ptr, fmt);
- len = bvsnprintf(*pool_buf, maxlen, fmt, arg_ptr);
- va_end(arg_ptr);
- if (len < 0 || len >= maxlen) {
- *pool_buf = realloc_pool_memory(*pool_buf, maxlen + maxlen/2);
- continue;
- }
- break;
- }
- return len;
-}
-
-static pthread_mutex_t msg_queue_mutex = PTHREAD_MUTEX_INITIALIZER;
-
-/*
- * We queue messages rather than print them directly. This
- * is generally used in low level routines (msg handler, bnet)
- * to prevent recursion (i.e. if you are in the middle of
- * sending a message, it is a bit messy to recursively call
- * yourself when the bnet packet is not reentrant).
- */
-void Qmsg(JCR *jcr, int type, int level, const char *fmt,...)
-{
- va_list arg_ptr;
- int len, maxlen;
- POOLMEM *pool_buf;
- MQUEUE_ITEM *item;
-
- pool_buf = get_pool_memory(PM_EMSG);
-
- for (;;) {
- maxlen = sizeof_pool_memory(pool_buf) - 1;
- va_start(arg_ptr, fmt);
- len = bvsnprintf(pool_buf, maxlen, fmt, arg_ptr);
- va_end(arg_ptr);
- if (len < 0 || len >= maxlen) {
- pool_buf = realloc_pool_memory(pool_buf, maxlen + maxlen/2);
- continue;
- }
- break;
- }
- item = (MQUEUE_ITEM *)malloc(sizeof(MQUEUE_ITEM) + strlen(pool_buf) + 1);
- item->type = type;
- item->level = level;
- strcpy(item->msg, pool_buf);
- P(msg_queue_mutex);
- /* If no jcr or dequeuing send to daemon to avoid recursion */
- if (!jcr || jcr->dequeuing) {
- /* jcr==NULL => daemon message, safe to send now */
- Jmsg(NULL, item->type, item->level, "%s", item->msg);
- free(item);
- } else {
- /* Queue message for later sending */
- jcr->msg_queue->append(item);
- }
- V(msg_queue_mutex);
- free_memory(pool_buf);
-}
-
-/*
- * Dequeue messages
- */
-void dequeue_messages(JCR *jcr)
-{
- MQUEUE_ITEM *item;
- P(msg_queue_mutex);
- jcr->dequeuing = true;
- foreach_dlist(item, jcr->msg_queue) {
- Jmsg(jcr, item->type, item->level, "%s", item->msg);
- }
- jcr->msg_queue->destroy();
- jcr->dequeuing = false;
- V(msg_queue_mutex);
-}
-
-
-/*
- * If we come here, prefix the message with the file:line-number,
- * then pass it on to the normal Qmsg routine.
- */
-void q_msg(const char *file, int line, JCR *jcr, int type, int level, const char *fmt,...)
-{
- va_list arg_ptr;
- int i, len, maxlen;
- POOLMEM *pool_buf;
-
- pool_buf = get_pool_memory(PM_EMSG);
- i = Mmsg(&pool_buf, "%s:%d ", file, line);
-
- for (;;) {
- maxlen = sizeof_pool_memory(pool_buf) - i - 1;
- va_start(arg_ptr, fmt);
- len = bvsnprintf(pool_buf+i, maxlen, fmt, arg_ptr);
- va_end(arg_ptr);
- if (len < 0 || len >= maxlen) {
- pool_buf = realloc_pool_memory(pool_buf, maxlen + i + maxlen/2);
- continue;
- }
- break;
- }
-
- Qmsg(jcr, type, level, "%s", pool_buf);
- free_memory(pool_buf);
-}
+++ /dev/null
-/*
- * Master Configuration routines.
- *
- * This file contains the common parts of the Bacula
- * configuration routines.
- *
- * Note, the configuration file parser consists of three parts
- *
- * 1. The generic lexical scanner in lib/lex.c and lib/lex.h
- *
- * 2. The generic config scanner in lib/parse_conf.c and
- * lib/parse_conf.h.
- * These files contain the parser code, some utility
- * routines, and the common store routines (name, int,
- * string).
- *
- * 3. The daemon specific file, which contains the Resource
- * definitions as well as any specific store routines
- * for the resource records.
- *
- * N.B. This is a two pass parser, so if you malloc() a string
- * in a "store" routine, you must ensure to do it during
- * only one of the two passes, or to free it between.
- * Also, note that the resource record is malloced and
- * saved in save_resource() during pass 1. Anything that
- * you want saved after pass two (e.g. resource pointers)
- * must explicitly be done in save_resource. Take a look
- * at the Job resource in src/dird/dird_conf.c to see how
- * it is done.
- *
- * Kern Sibbald, January MM
- *
- * Version $Id$
- */
-
-/*
- Copyright (C) 2000-2003 Kern Sibbald and John Walker
-
- This program is free software; you can redistribute it and/or
- modify it under the terms of the GNU General Public License as
- published by the Free Software Foundation; either version 2 of
- the License, or (at your option) any later version.
-
- 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., 59 Temple Place - Suite 330, Boston,
- MA 02111-1307, USA.
-
- */
-
-
-#include "bacula.h"
-
-extern int debug_level;
-
-/* Each daemon has a slightly different set of
- * resources, so it will define the following
- * global values.
- */
-extern int r_first;
-extern int r_last;
-extern RES_TABLE resources[];
-#ifdef HAVE_WIN32
-// work around visual studio name manling preventing external linkage since res_all
-// is declared as a different type when instantiated.
-extern "C" CURES res_all;
-extern "C" int res_all_size;
-#else
-extern CURES res_all;
-extern int res_all_size;
-#endif
-
-
-static brwlock_t res_lock; /* resource lock */
-static int res_locked = 0; /* set when resource chains locked -- for debug */
-
-/* Forward referenced subroutines */
-static void scan_types(LEX *lc, MSGS *msg, int dest, char *where, char *cmd);
-
-
-/* Common Resource definitions */
-
-/* Message resource directives
- * name handler value code flags default_value
- */
-RES_ITEM msgs_items[] = {
- {"name", store_name, ITEM(res_msgs.hdr.name), 0, 0, 0},
- {"description", store_str, ITEM(res_msgs.hdr.desc), 0, 0, 0},
- {"mailcommand", store_str, ITEM(res_msgs.mail_cmd), 0, 0, 0},
- {"operatorcommand", store_str, ITEM(res_msgs.operator_cmd), 0, 0, 0},
- {"syslog", store_msgs, ITEM(res_msgs), MD_SYSLOG, 0, 0},
- {"mail", store_msgs, ITEM(res_msgs), MD_MAIL, 0, 0},
- {"mailonerror", store_msgs, ITEM(res_msgs), MD_MAIL_ON_ERROR, 0, 0},
- {"file", store_msgs, ITEM(res_msgs), MD_FILE, 0, 0},
- {"append", store_msgs, ITEM(res_msgs), MD_APPEND, 0, 0},
- {"stdout", store_msgs, ITEM(res_msgs), MD_STDOUT, 0, 0},
- {"stderr", store_msgs, ITEM(res_msgs), MD_STDERR, 0, 0},
- {"director", store_msgs, ITEM(res_msgs), MD_DIRECTOR, 0, 0},
- {"console", store_msgs, ITEM(res_msgs), MD_CONSOLE, 0, 0},
- {"operator", store_msgs, ITEM(res_msgs), MD_OPERATOR, 0, 0},
- {NULL, NULL, NULL, 0}
-};
-
-struct s_mtypes {
- const char *name;
- int token;
-};
-/* Various message types */
-static struct s_mtypes msg_types[] = {
- {"debug", M_DEBUG},
- {"abort", M_ABORT},
- {"fatal", M_FATAL},
- {"error", M_ERROR},
- {"warning", M_WARNING},
- {"info", M_INFO},
- {"saved", M_SAVED},
- {"notsaved", M_NOTSAVED},
- {"skipped", M_SKIPPED},
- {"mount", M_MOUNT},
- {"terminate", M_TERM},
- {"restored", M_RESTORED},
- {"all", M_MAX+1},
- {NULL, 0}
-};
-
-
-/* Simply print a message */
-static void prtmsg(void *sock, char *fmt, ...)
-{
- va_list arg_ptr;
-
- va_start(arg_ptr, fmt);
- vfprintf(stdout, fmt, arg_ptr);
- va_end(arg_ptr);
-}
-
-const char *res_to_str(int rcode)
-{
- if (rcode < r_first || rcode > r_last) {
- return _("***UNKNOWN***");
- } else {
- return resources[rcode-r_first].name;
- }
-}
-
-
-/*
- * Initialize the static structure to zeros, then
- * apply all the default values.
- */
-void init_resource(int type, RES_ITEM *items)
-{
- int i;
- int rindex = type - r_first;
- static bool first = true;
- int errstat;
-
- if (first && (errstat=rwl_init(&res_lock)) != 0) {
- Emsg1(M_ABORT, 0, _("Unable to initialize resource lock. ERR=%s\n"),
- strerror(errstat));
- }
- first = false;
-
- memset(&res_all, 0, res_all_size);
- res_all.hdr.rcode = type;
- res_all.hdr.refcnt = 1;
-
- for (i=0; items[i].name; i++) {
- Dmsg3(300, "Item=%s def=%s defval=%d\n", items[i].name,
- (items[i].flags & ITEM_DEFAULT) ? "yes" : "no",
- items[i].default_value);
- if (items[i].flags & ITEM_DEFAULT && items[i].default_value != 0) {
- if (items[i].handler == store_yesno) {
- *(int *)(items[i].value) |= items[i].code;
- } else if (items[i].handler == store_pint ||
- items[i].handler == store_int) {
- *(int *)(items[i].value) = items[i].default_value;
- } else if (items[i].handler == store_int64) {
- *(int64_t *)(items[i].value) = items[i].default_value;
- } else if (items[i].handler == store_size) {
- *(uint64_t *)(items[i].value) = (uint64_t)items[i].default_value;
- } else if (items[i].handler == store_time) {
- *(utime_t *)(items[i].value) = (utime_t)items[i].default_value;
- }
- }
- /* If this triggers, take a look at lib/parse_conf.h */
- if (i >= MAX_RES_ITEMS) {
- Emsg1(M_ERROR_TERM, 0, _("Too many items in %s resource\n"), resources[rindex]);
- }
- }
-}
-
-
-/* Store Messages Destination information */
-void store_msgs(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- int token;
- char *cmd;
- POOLMEM *dest;
- int dest_len;
-
- Dmsg2(300, "store_msgs pass=%d code=%d\n", pass, item->code);
- if (pass == 1) {
- switch (item->code) {
- case MD_STDOUT:
- case MD_STDERR:
- case MD_SYSLOG: /* syslog */
- case MD_CONSOLE:
- scan_types(lc, (MSGS *)(item->value), item->code, NULL, NULL);
- break;
- case MD_OPERATOR: /* send to operator */
- case MD_DIRECTOR: /* send to Director */
- case MD_MAIL: /* mail */
- case MD_MAIL_ON_ERROR: /* mail if Job errors */
- if (item->code == MD_OPERATOR) {
- cmd = res_all.res_msgs.operator_cmd;
- } else {
- cmd = res_all.res_msgs.mail_cmd;
- }
- dest = get_pool_memory(PM_MESSAGE);
- dest[0] = 0;
- dest_len = 0;
- /* Pick up comma separated list of destinations */
- for ( ;; ) {
- token = lex_get_token(lc, T_NAME); /* scan destination */
- dest = check_pool_memory_size(dest, dest_len + lc->str_len + 2);
- if (dest[0] != 0) {
- pm_strcat(&dest, " "); /* separate multiple destinations with space */
- dest_len++;
- }
- pm_strcat(&dest, lc->str);
- dest_len += lc->str_len;
- Dmsg2(100, "store_msgs newdest=%s: dest=%s:\n", lc->str, NPRT(dest));
- token = lex_get_token(lc, T_ALL);
- if (token == T_COMMA) {
- continue; /* get another destination */
- }
- if (token != T_EQUALS) {
- scan_err1(lc, _("expected an =, got: %s"), lc->str);
- }
- break;
- }
- Dmsg1(300, "mail_cmd=%s\n", NPRT(cmd));
- scan_types(lc, (MSGS *)(item->value), item->code, dest, cmd);
- free_pool_memory(dest);
- Dmsg0(300, "done with dest codes\n");
- break;
- case MD_FILE: /* file */
- case MD_APPEND: /* append */
- dest = get_pool_memory(PM_MESSAGE);
- /* Pick up a single destination */
- token = lex_get_token(lc, T_NAME); /* scan destination */
- pm_strcpy(&dest, lc->str);
- dest_len = lc->str_len;
- token = lex_get_token(lc, T_ALL);
- Dmsg1(300, "store_msgs dest=%s:\n", NPRT(dest));
- if (token != T_EQUALS) {
- scan_err1(lc, _("expected an =, got: %s"), lc->str);
- }
- scan_types(lc, (MSGS *)(item->value), item->code, dest, NULL);
- free_pool_memory(dest);
- Dmsg0(300, "done with dest codes\n");
- break;
-
- default:
- scan_err1(lc, _("Unknown item code: %d\n"), item->code);
- break;
- }
- }
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
- Dmsg0(300, "Done store_msgs\n");
-}
-
-/*
- * Scan for message types and add them to the message
- * destination. The basic job here is to connect message types
- * (WARNING, ERROR, FATAL, INFO, ...) with an appropriate
- * destination (MAIL, FILE, OPERATOR, ...)
- */
-static void scan_types(LEX *lc, MSGS *msg, int dest_code, char *where, char *cmd)
-{
- int i, found, quit, is_not;
- int msg_type = 0;
- char *str;
-
- for (quit=0; !quit;) {
- lex_get_token(lc, T_NAME); /* expect at least one type */
- found = FALSE;
- if (lc->str[0] == '!') {
- is_not = TRUE;
- str = &lc->str[1];
- } else {
- is_not = FALSE;
- str = &lc->str[0];
- }
- for (i=0; msg_types[i].name; i++) {
- if (strcasecmp(str, msg_types[i].name) == 0) {
- msg_type = msg_types[i].token;
- found = TRUE;
- break;
- }
- }
- if (!found) {
- scan_err1(lc, _("message type: %s not found"), str);
- /* NOT REACHED */
- }
-
- if (msg_type == M_MAX+1) { /* all? */
- for (i=1; i<=M_MAX; i++) { /* yes set all types */
- add_msg_dest(msg, dest_code, i, where, cmd);
- }
- } else {
- if (is_not) {
- rem_msg_dest(msg, dest_code, msg_type, where);
- } else {
- add_msg_dest(msg, dest_code, msg_type, where, cmd);
- }
- }
- if (lc->ch != ',') {
- break;
- }
- Dmsg0(300, "call lex_get_token() to eat comma\n");
- lex_get_token(lc, T_ALL); /* eat comma */
- }
- Dmsg0(300, "Done scan_types()\n");
-}
-
-
-/*
- * This routine is ONLY for resource names
- * Store a name at specified address.
- */
-void store_name(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- POOLMEM *msg = get_pool_memory(PM_EMSG);
- lex_get_token(lc, T_NAME);
- if (!is_name_valid(lc->str, &msg)) {
- scan_err1(lc, "%s\n", msg);
- }
- free_pool_memory(msg);
- /* Store the name both pass 1 and pass 2 */
- if (*(item->value)) {
- scan_err2(lc, _("Attempt to redefine name \"%s\" to \"%s\"."),
- *(item->value), lc->str);
- }
- *(item->value) = bstrdup(lc->str);
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
-}
-
-
-/*
- * Store a name string at specified address
- * A name string is limited to MAX_RES_NAME_LENGTH
- */
-void store_strname(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- lex_get_token(lc, T_NAME);
- /* Store the name */
- if (pass == 1) {
- *(item->value) = bstrdup(lc->str);
- }
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
-}
-
-/* Store a string at specified address */
-void store_str(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- lex_get_token(lc, T_STRING);
- if (pass == 1) {
- *(item->value) = bstrdup(lc->str);
- }
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
-}
-
-/*
- * Store a directory name at specified address. Note, we do
- * shell expansion except if the string begins with a vertical
- * bar (i.e. it will likely be passed to the shell later).
- */
-void store_dir(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- lex_get_token(lc, T_STRING);
- if (pass == 1) {
- if (lc->str[0] != '|') {
- do_shell_expansion(lc->str, sizeof(lc->str));
- }
- *(item->value) = bstrdup(lc->str);
- }
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
-}
-
-
-/* Store a password specified address in MD5 coding */
-void store_password(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- unsigned int i, j;
- struct MD5Context md5c;
- unsigned char signature[16];
- char sig[100];
-
-
- lex_get_token(lc, T_STRING);
- if (pass == 1) {
- MD5Init(&md5c);
- MD5Update(&md5c, (unsigned char *) (lc->str), lc->str_len);
- MD5Final(signature, &md5c);
- for (i = j = 0; i < sizeof(signature); i++) {
- sprintf(&sig[j], "%02x", signature[i]);
- j += 2;
- }
- *(item->value) = bstrdup(sig);
- }
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
-}
-
-
-/* Store a resource at specified address.
- * If we are in pass 2, do a lookup of the
- * resource.
- */
-void store_res(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- RES *res;
-
- lex_get_token(lc, T_NAME);
- if (pass == 2) {
- res = GetResWithName(item->code, lc->str);
- if (res == NULL) {
- scan_err3(lc, _("Could not find config Resource %s referenced on line %d : %s\n"),
- lc->str, lc->line_no, lc->line);
- }
- *(item->value) = (char *)res;
- }
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
-}
-
-/*
- * Store default values for Resource from xxxDefs
- * If we are in pass 2, do a lookup of the
- * resource and store everything not explicitly set
- * in main resource.
- *
- * Note, here item points to the main resource (e.g. Job, not
- * the jobdefs, which we look up).
- */
-void store_defs(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- RES *res;
-
- lex_get_token(lc, T_NAME);
- if (pass == 2) {
- Dmsg2(300, "Code=%d name=%s\n", item->code, lc->str);
- res = GetResWithName(item->code, lc->str);
- if (res == NULL) {
- scan_err3(lc, _("Missing config Resource \"%s\" referenced on line %d : %s\n"),
- lc->str, lc->line_no, lc->line);
- }
- /* for each item not set, we copy the field from res */
-#ifdef xxx
- for (int i=0; item->name;; i++, item++) {
- if (bit_is_set(i, res->item_present)) {
- Dmsg2(300, "Item %d is present in %s\n", i, res->name);
- } else {
- Dmsg2(300, "Item %d is not present in %s\n", i, res->name);
- }
- }
- /* ***FIXME **** add code */
-#endif
- }
- scan_to_eol(lc);
-}
-
-
-
-/* Store an integer at specified address */
-void store_int(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- lex_get_token(lc, T_INT32);
- *(int *)(item->value) = lc->int32_val;
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
-}
-
-/* Store a positive integer at specified address */
-void store_pint(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- lex_get_token(lc, T_PINT32);
- *(int *)(item->value) = lc->pint32_val;
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
-}
-
-
-/* Store an 64 bit integer at specified address */
-void store_int64(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- lex_get_token(lc, T_INT64);
- *(int64_t *)(item->value) = lc->int64_val;
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
-}
-
-/* Store a size in bytes */
-void store_size(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- int token;
- uint64_t uvalue;
-
- Dmsg0(400, "Enter store_size\n");
- token = lex_get_token(lc, T_ALL);
- errno = 0;
- switch (token) {
- case T_NUMBER:
- case T_IDENTIFIER:
- case T_UNQUOTED_STRING:
- if (!size_to_uint64(lc->str, lc->str_len, &uvalue)) {
- scan_err1(lc, _("expected a size number, got: %s"), lc->str);
- }
- *(uint64_t *)(item->value) = uvalue;
- break;
- default:
- scan_err1(lc, _("expected a size, got: %s"), lc->str);
- break;
- }
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
- Dmsg0(400, "Leave store_size\n");
-}
-
-
-/* Store a time period in seconds */
-void store_time(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- int token;
- utime_t utime;
- char period[500];
-
- token = lex_get_token(lc, T_ALL);
- errno = 0;
- switch (token) {
- case T_NUMBER:
- case T_IDENTIFIER:
- case T_UNQUOTED_STRING:
- bstrncpy(period, lc->str, sizeof(period));
- if (lc->ch == ' ') {
- token = lex_get_token(lc, T_ALL);
- switch (token) {
- case T_IDENTIFIER:
- case T_UNQUOTED_STRING:
- bstrncat(period, lc->str, sizeof(period));
- break;
- }
- }
- if (!duration_to_utime(period, &utime)) {
- scan_err1(lc, _("expected a time period, got: %s"), period);
- }
- *(utime_t *)(item->value) = utime;
- break;
- default:
- scan_err1(lc, _("expected a time period, got: %s"), lc->str);
- break;
- }
- if (token != T_EOL) {
- scan_to_eol(lc);
- }
- set_bit(index, res_all.hdr.item_present);
-}
-
-
-/* Store a yes/no in a bit field */
-void store_yesno(LEX *lc, RES_ITEM *item, int index, int pass)
-{
- lex_get_token(lc, T_NAME);
- if (strcasecmp(lc->str, "yes") == 0) {
- *(int *)(item->value) |= item->code;
- } else if (strcasecmp(lc->str, "no") == 0) {
- *(int *)(item->value) &= ~(item->code);
- } else {
- scan_err1(lc, _("Expect a YES or NO, got: %s"), lc->str);
- }
- scan_to_eol(lc);
- set_bit(index, res_all.hdr.item_present);
-}
-
-
-/* #define TRACE_RES */
-
-void b_LockRes(const char *file, int line)
-{
- int errstat;
-#ifdef TRACE_RES
- Dmsg4(000, "LockRes %d,%d at %s:%d\n", res_locked, res_lock.w_active,
- file, line);
-#endif
- if ((errstat=rwl_writelock(&res_lock)) != 0) {
- Emsg3(M_ABORT, 0, "rwl_writelock failure at %s:%d: ERR=%s\n",
- file, line, strerror(errstat));
- }
- res_locked++;
-}
-
-void b_UnlockRes(const char *file, int line)
-{
- int errstat;
- res_locked--;
-#ifdef TRACE_RES
- Dmsg4(000, "UnLockRes %d,%d at %s:%d\n", res_locked, res_lock.w_active,
- file, line);
-#endif
- if ((errstat=rwl_writeunlock(&res_lock)) != 0) {
- Emsg3(M_ABORT, 0, "rwl_writeunlock failure at %s:%d:. ERR=%s\n",
- file, line, strerror(errstat));
- }
-}
-
-/*
- * Return resource of type rcode that matches name
- */
-RES *
-GetResWithName(int rcode, char *name)
-{
- RES *res;
- int rindex = rcode - r_first;
-
- LockRes();
- res = resources[rindex].res_head;
- while (res) {
- if (strcmp(res->name, name) == 0) {
- break;
- }
- res = res->next;
- }
- UnlockRes();
- return res;
-
-}
-
-/*
- * Return next resource of type rcode. On first
- * call second arg (res) is NULL, on subsequent
- * calls, it is called with previous value.
- */
-RES *
-GetNextRes(int rcode, RES *res)
-{
- RES *nres;
- int rindex = rcode - r_first;
-
-
- if (!res_locked) {
- Emsg0(M_ABORT, 0, "Resource chain not locked.\n");
- }
- if (res == NULL) {
- nres = resources[rindex].res_head;
- } else {
- nres = res->next;
- }
- return nres;
-}
-
-
-/* Parser state */
-enum parse_state {
- p_none,
- p_resource
-};
-
-/*********************************************************************
- *
- * Parse configuration file
- *
- */
-void
-parse_config(char *cf)
-{
- LEX *lc = NULL;
- int token, i, pass;
- int res_type = 0;
- enum parse_state state = p_none;
- RES_ITEM *items = NULL;
- int level = 0;
-
- /* Make two passes. The first builds the name symbol table,
- * and the second picks up the items.
- */
- Dmsg0(300, "Enter parse_config()\n");
- for (pass=1; pass <= 2; pass++) {
- Dmsg1(300, "parse_config pass %d\n", pass);
- lc = lex_open_file(lc, cf, NULL);
- while ((token=lex_get_token(lc, T_ALL)) != T_EOF) {
- Dmsg1(300, "parse got token=%s\n", lex_tok_to_str(token));
- switch (state) {
- case p_none:
- if (token == T_EOL) {
- break;
- }
- if (token != T_IDENTIFIER) {
- scan_err1(lc, _("Expected a Resource name identifier, got: %s"), lc->str);
- /* NOT REACHED */
- }
- for (i=0; resources[i].name; i++)
- if (strcasecmp(resources[i].name, lc->str) == 0) {
- state = p_resource;
- items = resources[i].items;
- res_type = resources[i].rcode;
- init_resource(res_type, items);
- break;
- }
- if (state == p_none) {
- scan_err1(lc, _("expected resource name, got: %s"), lc->str);
- /* NOT REACHED */
- }
- break;
- case p_resource:
- switch (token) {
- case T_BOB:
- level++;
- break;
- case T_IDENTIFIER:
- if (level != 1) {
- scan_err1(lc, _("not in resource definition: %s"), lc->str);
- /* NOT REACHED */
- }
- for (i=0; items[i].name; i++) {
- if (strcasecmp(items[i].name, lc->str) == 0) {
- /* If the ITEM_NO_EQUALS flag is set we do NOT
- * scan for = after the keyword */
- if (!(items[i].flags & ITEM_NO_EQUALS)) {
- token = lex_get_token(lc, T_ALL);
- Dmsg1 (300, "in T_IDENT got token=%s\n", lex_tok_to_str(token));
- if (token != T_EQUALS) {
- scan_err1(lc, _("expected an equals, got: %s"), lc->str);
- /* NOT REACHED */
- }
- }
- Dmsg1(300, "calling handler for %s\n", items[i].name);
- /* Call item handler */
- items[i].handler(lc, &items[i], i, pass);
- i = -1;
- break;
- }
- }
- if (i >= 0) {
- Dmsg2(300, "level=%d id=%s\n", level, lc->str);
- Dmsg1(300, "Keyword = %s\n", lc->str);
- scan_err1(lc, _("Keyword \"%s\" not permitted in this resource.\n"
- "Perhaps you left the trailing brace off of the previous resource."), lc->str);
- /* NOT REACHED */
- }
- break;
-
- case T_EOB:
- level--;
- state = p_none;
- Dmsg0(300, "T_EOB => define new resource\n");
- save_resource(res_type, items, pass); /* save resource */
- break;
-
- case T_EOL:
- break;
-
- default:
- scan_err2(lc, _("unexpected token %d %s in resource definition"),
- token, lex_tok_to_str(token));
- /* NOT REACHED */
- }
- break;
- default:
- scan_err1(lc, _("Unknown parser state %d\n"), state);
- /* NOT REACHED */
- }
- }
- if (state != p_none) {
- scan_err0(lc, _("End of conf file reached with unclosed resource."));
- }
- if (debug_level > 50 && pass == 2) {
- int i;
- for (i=r_first; i<=r_last; i++) {
- dump_resource(i, resources[i-r_first].res_head, prtmsg, NULL);
- }
- }
- lc = lex_close_file(lc);
- }
- Dmsg0(300, "Leave parse_config()\n");
-}
-
-/*********************************************************************
- *
- * Free configuration resources
- *
- */
-void free_config_resources()
-{
- for (int i=r_first; i<=r_last; i++) {
- free_resource(resources[i-r_first].res_head, i);
- resources[i-r_first].res_head = NULL;
- }
-}
-
-RES **save_config_resources()
-{
- int num = r_last - r_first + 1;
- RES **res = (RES **)malloc(num*sizeof(RES *));
- for (int i=0; i<num; i++) {
- res[i] = resources[i].res_head;
- resources[i].res_head = NULL;
- }
- return res;
-}
projects / bacula / bacula / commitdiff