src/tee.c

   1 /* tee - read from standard input and write to standard output and files.
   2    Copyright (C) 1985-2015 Free Software Foundation, Inc.
   3
   4    This program is free software: you can redistribute it and/or modify
   5    it under the terms of the GNU General Public License as published by
   6    the Free Software Foundation, either version 3 of the License, or
   7    (at your option) any later version.
   8
   9    This program is distributed in the hope that it will be useful,
  10    but WITHOUT ANY WARRANTY; without even the implied warranty of
  11    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12    GNU General Public License for more details.
  13
  14    You should have received a copy of the GNU General Public License
  15    along with this program.  If not, see <http://www.gnu.org/licenses/>.  */
  16
  17 /* Mike Parker, Richard M. Stallman, and David MacKenzie */
  18
  19 #include <config.h>
  20 #include <sys/types.h>
  21 #include <signal.h>
  22 #include <getopt.h>
  23
  24 #include "system.h"
  25 #include "argmatch.h"
  26 #include "error.h"
  27 #include "fadvise.h"
  28 #include "quote.h"
  29 #include "stdio--.h"
  30 #include "xfreopen.h"
  31
  32 /* The official name of this program (e.g., no 'g' prefix).  */
  33 #define PROGRAM_NAME "tee"
  34
  35 #define AUTHORS \
  36   proper_name ("Mike Parker"), \
  37   proper_name ("Richard M. Stallman"), \
  38   proper_name ("David MacKenzie")
  39
  40 static bool tee_files (int nfiles, char **files);
  41
  42 /* If true, append to output files rather than truncating them. */
  43 static bool append;
  44
  45 /* If true, ignore interrupts. */
  46 static bool ignore_interrupts;
  47
  48 enum output_error
  49   {
  50     output_error_sigpipe,      /* traditional behavior, sigpipe enabled.  */
  51     output_error_warn,         /* warn on EPIPE, but continue.  */
  52     output_error_warn_nopipe,  /* ignore EPIPE, continue.  */
  53     output_error_exit,         /* exit on any output error.  */
  54     output_error_exit_nopipe   /* exit on any output error except EPIPE.  */
  55   };
  56
  57 static enum output_error output_error;
  58
  59 static struct option const long_options[] =
  60 {
  61   {"append", no_argument, NULL, 'a'},
  62   {"ignore-interrupts", no_argument, NULL, 'i'},
  63   {"output-error", optional_argument, NULL, 'p'},
  64   {GETOPT_HELP_OPTION_DECL},
  65   {GETOPT_VERSION_OPTION_DECL},
  66   {NULL, 0, NULL, 0}
  67 };
  68
  69 static char const *const output_error_args[] =
  70 {
  71   "warn", "warn-nopipe", "exit", "exit-nopipe", NULL
  72 };
  73 static enum output_error const output_error_types[] =
  74 {
  75   output_error_warn, output_error_warn_nopipe,
  76   output_error_exit, output_error_exit_nopipe
  77 };
  78 ARGMATCH_VERIFY (output_error_args, output_error_types);
  79
  80 void
  81 usage (int status)
  82 {
  83   if (status != EXIT_SUCCESS)
  84     emit_try_help ();
  85   else
  86     {
  87       printf (_("Usage: %s [OPTION]... [FILE]...\n"), program_name);
  88       fputs (_("\
  89 Copy standard input to each FILE, and also to standard output.\n\
  90 \n\
  91   -a, --append              append to the given FILEs, do not overwrite\n\
  92   -i, --ignore-interrupts   ignore interrupt signals\n\
  93 "), stdout);
  94       fputs (_("\
  95   -p                        diagnose errors writing to non pipes\n\
  96       --output-error[=MODE]   set behavior on write error.  See MODE below\n\
  97 "), stdout);
  98       fputs (HELP_OPTION_DESCRIPTION, stdout);
  99       fputs (VERSION_OPTION_DESCRIPTION, stdout);
 100       fputs (_("\
 101 \n\
 102 MODE determines behavior with write errors on the outputs:\n\
 103   'warn'         diagnose errors writing to any output\n\
 104   'warn-nopipe'  diagnose errors writing to any output not a pipe\n\
 105   'exit'         exit on error writing to any output\n\
 106   'exit-nopipe'  exit on error writing to any output not a pipe\n\
 107 The default MODE for the -p option is 'warn-nopipe'.\n\
 108 The default operation when --output-error is not specified, is to\n\
 109 exit immediately on error writing to a pipe, and diagnose errors\n\
 110 writing to non pipe outputs.\n\
 111 "), stdout);
 112       emit_ancillary_info (PROGRAM_NAME);
 113     }
 114   exit (status);
 115 }
 116
 117 int
 118 main (int argc, char **argv)
 119 {
 120   bool ok;
 121   int optc;
 122
 123   initialize_main (&argc, &argv);
 124   set_program_name (argv[0]);
 125   setlocale (LC_ALL, "");
 126   bindtextdomain (PACKAGE, LOCALEDIR);
 127   textdomain (PACKAGE);
 128
 129   atexit (close_stdout);
 130
 131   append = false;
 132   ignore_interrupts = false;
 133
 134   while ((optc = getopt_long (argc, argv, "aip", long_options, NULL)) != -1)
 135     {
 136       switch (optc)
 137         {
 138         case 'a':
 139           append = true;
 140           break;
 141
 142         case 'i':
 143           ignore_interrupts = true;
 144           break;
 145
 146         case 'p':
 147           if (optarg)
 148             output_error = XARGMATCH ("--output-error", optarg,
 149                                       output_error_args, output_error_types);
 150           else
 151             output_error = output_error_warn_nopipe;
 152           break;
 153
 154         case_GETOPT_HELP_CHAR;
 155
 156         case_GETOPT_VERSION_CHAR (PROGRAM_NAME, AUTHORS);
 157
 158         default:
 159           usage (EXIT_FAILURE);
 160         }
 161     }
 162
 163   if (ignore_interrupts)
 164     signal (SIGINT, SIG_IGN);
 165
 166   if (output_error != output_error_sigpipe)
 167     signal (SIGPIPE, SIG_IGN);
 168
 169   /* Do *not* warn if tee is given no file arguments.
 170      POSIX requires that it work when given no arguments.  */
 171
 172   ok = tee_files (argc - optind, &argv[optind]);
 173   if (close (STDIN_FILENO) != 0)
 174     error (EXIT_FAILURE, errno, "%s", _("standard input"));
 175
 176   return ok ? EXIT_SUCCESS : EXIT_FAILURE;
 177 }
 178
 179 /* Copy the standard input into each of the NFILES files in FILES
 180    and into the standard output.  As a side effect, modify FILES[-1].
 181    Return true if successful.  */
 182
 183 static bool
 184 tee_files (int nfiles, char **files)
 185 {
 186   size_t n_outputs = 0;
 187   FILE **descriptors;
 188   char buffer[BUFSIZ];
 189   ssize_t bytes_read = 0;
 190   int i;
 191   bool ok = true;
 192   char const *mode_string =
 193     (O_BINARY
 194      ? (append ? "ab" : "wb")
 195      : (append ? "a" : "w"));
 196
 197   if (O_BINARY && ! isatty (STDIN_FILENO))
 198     xfreopen (NULL, "rb", stdin);
 199   if (O_BINARY && ! isatty (STDOUT_FILENO))
 200     xfreopen (NULL, "wb", stdout);
 201
 202   fadvise (stdin, FADVISE_SEQUENTIAL);
 203
 204   /* Set up FILES[0 .. NFILES] and DESCRIPTORS[0 .. NFILES].
 205      In both arrays, entry 0 corresponds to standard output.  */
 206
 207   descriptors = xnmalloc (nfiles + 1, sizeof *descriptors);
 208   files--;
 209   descriptors[0] = stdout;
 210   files[0] = bad_cast (_("standard output"));
 211   setvbuf (stdout, NULL, _IONBF, 0);
 212   n_outputs++;
 213
 214   for (i = 1; i <= nfiles; i++)
 215     {
 216       /* Do not treat "-" specially - as mandated by POSIX.  */
 217       descriptors[i] = fopen (files[i], mode_string);
 218       if (descriptors[i] == NULL)
 219         {
 220           error (output_error == output_error_exit
 221                  || output_error == output_error_exit_nopipe,
 222                  errno, "%s", quote (files[i]));
 223           ok = false;
 224         }
 225       else
 226         {
 227           setvbuf (descriptors[i], NULL, _IONBF, 0);
 228           n_outputs++;
 229         }
 230     }
 231
 232   while (n_outputs)
 233     {
 234       bytes_read = read (0, buffer, sizeof buffer);
 235       if (bytes_read < 0 && errno == EINTR)
 236         continue;
 237       if (bytes_read <= 0)
 238         break;
 239
 240       /* Write to all NFILES + 1 descriptors.
 241          Standard output is the first one.  */
 242       for (i = 0; i <= nfiles; i++)
 243         if (descriptors[i]
 244             && fwrite (buffer, bytes_read, 1, descriptors[i]) != 1)
 245           {
 246             int w_errno = errno;
 247             bool fail = errno != EPIPE || (output_error == output_error_exit
 248                                           || output_error == output_error_warn);
 249             if (descriptors[i] == stdout)
 250               clearerr (stdout); /* Avoid redundant close_stdout diagnostic.  */
 251             if (fail)
 252               {
 253                 error (output_error == output_error_exit
 254                        || output_error == output_error_exit_nopipe,
 255                        w_errno, "%s", quote (files[i]));
 256               }
 257             descriptors[i] = NULL;
 258             if (fail)
 259               ok = false;
 260             n_outputs--;
 261           }
 262     }
 263
 264   if (bytes_read == -1)
 265     {
 266       error (0, errno, _("read error"));
 267       ok = false;
 268     }
 269
 270   /* Close the files, but not standard output.  */
 271   for (i = 1; i <= nfiles; i++)
 272     if (descriptors[i] && fclose (descriptors[i]) != 0)
 273       {
 274         error (0, errno, "%s", quote (files[i]));
 275         ok = false;
 276       }
 277
 278   free (descriptors);
 279
 280   return ok;
 281 }