git.gag.com Git - debian/amanda/blob - ndmp-src/ndmjob_main_util.c

   1 /*
   2  * Copyright (c) 1998,1999,2000
   3  *      Traakan, Inc., Los Altos, CA
   4  *      All rights reserved.
   5  *
   6  * Redistribution and use in source and binary forms, with or without
   7  * modification, are permitted provided that the following conditions
   8  * are met:
   9  * 1. Redistributions of source code must retain the above copyright
  10  *    notice unmodified, this list of conditions, and the following
  11  *    disclaimer.
  12  * 2. Redistributions in binary form must reproduce the above copyright
  13  *    notice, this list of conditions and the following disclaimer in the
  14  *    documentation and/or other materials provided with the distribution.
  15  *
  16  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
  17  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  18  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  19  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
  20  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  21  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  22  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  23  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  24  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  25  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  26  * SUCH DAMAGE.
  27  */
  28
  29 /*
  30  * Project:  NDMJOB
  31  * Ident:    $Id: $
  32  *
  33  * Description:
  34  *
  35  */
  36
  37 #include "ndmjob.h"
  38
  39 #ifndef NDMOS_OPTION_NO_CONTROL_AGENT
  40 int
  41 start_index_file (void)
  42 {
  43         if (I_index_file && strcmp (I_index_file, "-") != 0) {
  44                 FILE *          ifp;
  45
  46                 if (atoi(I_index_file) != 0) {
  47                         ndmjob_log (1, "Writing index (-I%s)", I_index_file);
  48                         ifp = fdopen(atoi(I_index_file), "w");
  49                 } else {
  50                         ndmjob_log (1, "Writing index (-I%s)", I_index_file);
  51                         ifp = fopen (I_index_file, "w");
  52                 }
  53                 if (!ifp) {
  54                         error_byebye ("can't open -I logfile");
  55                 }
  56                 index_fp = ifp;
  57                 fprintf (ifp, "##ndmjob -I\n");
  58         } else {
  59                 index_fp = stderr;
  60         }
  61
  62         return 0;
  63 }
  64
  65 int
  66 sort_index_file (void)
  67 {
  68         if (I_index_file && strcmp (I_index_file, "-") != 0 &&
  69             atoi(I_index_file) == 0) {
  70                 char            cmd[512];
  71
  72                 fprintf (index_fp, "##ndmjob -J\n"); /* sorts to 2nd line */
  73                 fclose (index_fp);
  74                 index_fp = stderr;      /* in case anything else happens */
  75
  76                 sprintf (cmd, "LC_ALL=C sort %s -o %s\n", I_index_file, I_index_file);
  77                 ndmjob_log (3, "sort command: %s", cmd);
  78                 ndmjob_log (1, "sorting index");
  79                 if (system (cmd) < 0)
  80                     error_byebye ("sort index failed");
  81                 ndmjob_log (1, "sort index done");
  82         }
  83
  84         return 0;
  85 }
  86 #endif /* !NDMOS_OPTION_NO_CONTROL_AGENT */
  87
  88 void
  89 error_byebye (char *fmt, ...)
  90 {
  91         va_list         ap;
  92         char            buf[4096];
  93
  94         va_start (ap, fmt);
  95         vsnprintf (buf, sizeof(buf), fmt, ap);
  96         va_end (ap);
  97         ndmjob_log (0, "FATAL: %s", buf);
  98         fprintf (stderr, "%s: %s\n", progname, buf);
  99         exit(1);
 100 }
 101
 102 void
 103 ndmjob_log_deliver (struct ndmlog *log, char *tag, int lev, char *msg)
 104 {
 105         char            tagbuf[32];
 106
 107         if (the_mode == 'D') {
 108                 char    buf[32];
 109
 110                 sprintf (buf, "%s(%d)", tag, (int)getpid());
 111                 sprintf (tagbuf, "%-11s", buf);
 112         } else {
 113                 sprintf (tagbuf, "%-4s", tag);
 114         }
 115
 116         if (d_debug >= lev) {
 117                 g_debug ("%s %s", tagbuf, msg);
 118         }
 119
 120         if (v_verbose >= lev) {
 121                 printf ("'%s'\n", msg);
 122                 fflush (stdout);
 123         }
 124 }
 125
 126 #ifndef NDMOS_OPTION_NO_CONTROL_AGENT
 127 void
 128 ndmjob_ixlog_deliver (struct ndmlog *log, char *tag, int lev, char *msg)
 129 {
 130         fprintf (index_fp, "%s %s\n", tag, msg);
 131         fflush (index_fp);      /* this doesn't change the run time */
 132 }
 133 #endif /* !NDMOS_OPTION_NO_CONTROL_AGENT */
 134
 135 void
 136 ndmjob_log (int lev, char *fmt, ...)
 137 {
 138         va_list         ap;
 139         char            buf[4096];
 140
 141         va_start (ap, fmt);
 142         vsnprintf (buf, sizeof(buf), fmt, ap);
 143         va_end (ap);
 144
 145         ndmjob_log_deliver (&the_param.log, the_param.log_tag, lev, buf);
 146 }