[BACK]Return to log.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / rsync

Diff for /embedaddon/rsync/log.c between versions 1.1.1.1 and 1.1.1.2

version 1.1.1.1, 2012/02/17 15:09:30 version 1.1.1.2, 2013/10/14 07:51:14
Line 3 Line 3
  *   *
  * Copyright (C) 1998-2001 Andrew Tridgell <tridge@samba.org>   * Copyright (C) 1998-2001 Andrew Tridgell <tridge@samba.org>
  * Copyright (C) 2000-2001 Martin Pool <mbp@samba.org>   * Copyright (C) 2000-2001 Martin Pool <mbp@samba.org>
 * Copyright (C) 2003-2009 Wayne Davison * Copyright (C) 2003-2013 Wayne Davison
  *   *
  * This program is free software; you can redistribute it and/or modify   * 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   * it under the terms of the GNU General Public License as published by
Line 20 Line 20
  */   */
   
 #include "rsync.h"  #include "rsync.h"
#include "ifuncs.h"#include "itypes.h"
 #include "inums.h"
   
 extern int verbose;  
 extern int dry_run;  extern int dry_run;
 extern int am_daemon;  extern int am_daemon;
 extern int am_server;  extern int am_server;
Line 31  extern int am_generator; Line 31  extern int am_generator;
 extern int local_server;  extern int local_server;
 extern int quiet;  extern int quiet;
 extern int module_id;  extern int module_id;
extern int msg_fd_out;extern int checksum_len;
 extern int allow_8bit_chars;  extern int allow_8bit_chars;
 extern int protocol_version;  extern int protocol_version;
   extern int always_checksum;
 extern int preserve_times;  extern int preserve_times;
extern int progress_is_active;extern int msgs2stderr;
 extern int stdout_format_has_i;  extern int stdout_format_has_i;
 extern int stdout_format_has_o_or_i;  extern int stdout_format_has_o_or_i;
 extern int logfile_format_has_i;  extern int logfile_format_has_i;
 extern int logfile_format_has_o_or_i;  extern int logfile_format_has_o_or_i;
 extern int receiver_symlink_times;  extern int receiver_symlink_times;
   extern int64 total_data_written;
   extern int64 total_data_read;
 extern mode_t orig_umask;  extern mode_t orig_umask;
 extern char *auth_user;  extern char *auth_user;
 extern char *stdout_format;  extern char *stdout_format;
Line 55  extern iconv_t ic_recv; Line 58  extern iconv_t ic_recv;
 extern char curr_dir[MAXPATHLEN];  extern char curr_dir[MAXPATHLEN];
 extern char *full_module_path;  extern char *full_module_path;
 extern unsigned int module_dirlen;  extern unsigned int module_dirlen;
   extern char sender_file_sum[MAX_DIGEST_LEN];
   extern const char undetermined_hostname[];
   
 static int log_initialised;  static int log_initialised;
 static int logfile_was_closed;  static int logfile_was_closed;
Line 62  static FILE *logfile_fp; Line 67  static FILE *logfile_fp;
 struct stats stats;  struct stats stats;
   
 int got_xfer_error = 0;  int got_xfer_error = 0;
   int output_needs_newline = 0;
   int send_msgs_to_gen = 0;
   
   static int64 initial_data_written;
   static int64 initial_data_read;
   
 struct {  struct {
         int code;          int code;
         char const *name;          char const *name;
Line 85  struct { Line 95  struct {
         { RERR_MALLOC     , "error allocating core memory buffers" },          { RERR_MALLOC     , "error allocating core memory buffers" },
         { RERR_PARTIAL    , "some files/attrs were not transferred (see previous errors)" },          { RERR_PARTIAL    , "some files/attrs were not transferred (see previous errors)" },
         { RERR_VANISHED   , "some files vanished before they could be transferred" },          { RERR_VANISHED   , "some files vanished before they could be transferred" },
           { RERR_DEL_LIMIT  , "the --max-delete limit stopped deletions" },
         { RERR_TIMEOUT    , "timeout in data send/receive" },          { RERR_TIMEOUT    , "timeout in data send/receive" },
         { RERR_CONTIMEOUT , "timeout waiting for daemon connection" },          { RERR_CONTIMEOUT , "timeout waiting for daemon connection" },
         { RERR_CMD_FAILED , "remote shell failed" },          { RERR_CMD_FAILED , "remote shell failed" },
         { RERR_CMD_KILLED , "remote shell killed" },          { RERR_CMD_KILLED , "remote shell killed" },
         { RERR_CMD_RUN    , "remote command could not be run" },          { RERR_CMD_RUN    , "remote command could not be run" },
         { RERR_CMD_NOTFOUND,"remote command not found" },          { RERR_CMD_NOTFOUND,"remote command not found" },
         { RERR_DEL_LIMIT  , "the --max-delete limit stopped deletions" },  
         { 0, NULL }          { 0, NULL }
 };  };
   
Line 113  static void logit(int priority, const char *buf) Line 123  static void logit(int priority, const char *buf)
         if (logfile_was_closed)          if (logfile_was_closed)
                 logfile_reopen();                  logfile_reopen();
         if (logfile_fp) {          if (logfile_fp) {
                fprintf(logfile_fp, "%s [%d] %s",                fprintf(logfile_fp, "%s [%d] %s", timestring(time(NULL)), (int)getpid(), buf);
                        timestring(time(NULL)), (int)getpid(), buf); 
                 fflush(logfile_fp);                  fflush(logfile_fp);
         } else {          } else {
                 syslog(priority, "%s", buf);                  syslog(priority, "%s", buf);
Line 241  static void filtered_fwrite(FILE *f, const char *buf,  Line 250  static void filtered_fwrite(FILE *f, const char *buf, 
 void rwrite(enum logcode code, const char *buf, int len, int is_utf8)  void rwrite(enum logcode code, const char *buf, int len, int is_utf8)
 {  {
         int trailing_CR_or_NL;          int trailing_CR_or_NL;
        FILE *f = NULL;        FILE *f = msgs2stderr ? stderr : stdout;
 #ifdef ICONV_OPTION  #ifdef ICONV_OPTION
         iconv_t ic = is_utf8 && ic_recv != (iconv_t)-1 ? ic_recv : ic_chck;          iconv_t ic = is_utf8 && ic_recv != (iconv_t)-1 ? ic_recv : ic_chck;
 #else  #else
Line 253  void rwrite(enum logcode code, const char *buf, int le Line 262  void rwrite(enum logcode code, const char *buf, int le
         if (len < 0)          if (len < 0)
                 exit_cleanup(RERR_MESSAGEIO);                  exit_cleanup(RERR_MESSAGEIO);
   
        if (am_server && msg_fd_out >= 0) {        if (msgs2stderr) {
                 if (!am_daemon) {
                         if (code == FLOG)
                                 return;
                         goto output_msg;
                 }
                 if (code == FCLIENT)
                         return;
                 code = FLOG;
         } else if (send_msgs_to_gen) {
                 assert(!is_utf8);                  assert(!is_utf8);
                 /* Pass the message to our sibling in native charset. */                  /* Pass the message to our sibling in native charset. */
                 send_msg((enum msgcode)code, buf, len, 0);                  send_msg((enum msgcode)code, buf, len, 0);
Line 306  void rwrite(enum logcode code, const char *buf, int le Line 324  void rwrite(enum logcode code, const char *buf, int le
                         /* TODO: can we send the error to the user somehow? */                          /* TODO: can we send the error to the user somehow? */
                         return;                          return;
                 }                  }
                   f = stderr;
         }          }
   
   output_msg:
         switch (code) {          switch (code) {
         case FERROR_XFER:          case FERROR_XFER:
                 got_xfer_error = 1;                  got_xfer_error = 1;
                 /* FALL THROUGH */                  /* FALL THROUGH */
         case FERROR:          case FERROR:
           case FERROR_UTF8:
           case FERROR_SOCKET:
         case FWARNING:          case FWARNING:
                 f = stderr;                  f = stderr;
                 break;                  break;
           case FLOG:
         case FINFO:          case FINFO:
                f = am_server ? stderr : stdout;        case FCLIENT:
                 break;                  break;
         default:          default:
                   fprintf(stderr, "Unknown logcode in rwrite(): %d [%s]\n", (int)code, who_am_i());
                 exit_cleanup(RERR_MESSAGEIO);                  exit_cleanup(RERR_MESSAGEIO);
         }          }
   
        if (progress_is_active && !am_server) {        if (output_needs_newline) {
                 fputc('\n', f);                  fputc('\n', f);
                progress_is_active = 0;                output_needs_newline = 0;
         }          }
   
         trailing_CR_or_NL = len && (buf[len-1] == '\n' || buf[len-1] == '\r')          trailing_CR_or_NL = len && (buf[len-1] == '\n' || buf[len-1] == '\r')
                           ? buf[--len] : 0;                            ? buf[--len] : 0;
   
           if (len && buf[0] == '\r') {
                   fputc('\r', f);
                   buf++;
                   len--;
           }
   
 #ifdef ICONV_CONST  #ifdef ICONV_CONST
         if (ic != (iconv_t)-1) {          if (ic != (iconv_t)-1) {
                 xbuf outbuf, inbuf;                  xbuf outbuf, inbuf;
Line 338  void rwrite(enum logcode code, const char *buf, int le Line 368  void rwrite(enum logcode code, const char *buf, int le
                 int ierrno;                  int ierrno;
   
                 INIT_CONST_XBUF(outbuf, convbuf);                  INIT_CONST_XBUF(outbuf, convbuf);
                INIT_XBUF(inbuf, (char*)buf, len, -1);                INIT_XBUF(inbuf, (char*)buf, len, (size_t)-1);
   
                 while (inbuf.len) {                  while (inbuf.len) {
                        iconvbufs(ic, &inbuf, &outbuf, 0);                        iconvbufs(ic, &inbuf, &outbuf, inbuf.pos ? 0 : ICB_INIT);
                         ierrno = errno;                          ierrno = errno;
                         if (outbuf.len) {                          if (outbuf.len) {
                                 filtered_fwrite(f, convbuf, outbuf.len, 0);                                  filtered_fwrite(f, convbuf, outbuf.len, 0);
Line 436  void rsyserr(enum logcode code, int errcode, const cha Line 466  void rsyserr(enum logcode code, int errcode, const cha
   
 void rflush(enum logcode code)  void rflush(enum logcode code)
 {  {
        FILE *f = NULL;        FILE *f;
   
         if (am_daemon || code == FLOG)          if (am_daemon || code == FLOG)
                 return;                  return;
   
        if (code == FINFO && !am_server)        if (!am_server && (code == FINFO || code == FCLIENT))
                 f = stdout;                  f = stdout;
         else          else
                 f = stderr;                  f = stderr;
Line 449  void rflush(enum logcode code) Line 479  void rflush(enum logcode code)
         fflush(f);          fflush(f);
 }  }
   
   void remember_initial_stats(void)
   {
           initial_data_read = total_data_read;
           initial_data_written = total_data_written;
   }
   
 /* A generic logging routine for send/recv, with parameter substitiution. */  /* A generic logging routine for send/recv, with parameter substitiution. */
 static void log_formatted(enum logcode code, const char *format, const char *op,  static void log_formatted(enum logcode code, const char *format, const char *op,
                          struct file_struct *file, const char *fname,                          struct file_struct *file, const char *fname, int iflags,
                          struct stats *initial_stats, int iflags, 
                           const char *hlink)                            const char *hlink)
 {  {
         char buf[MAXPATHLEN+1024], buf2[MAXPATHLEN], fmt[32];          char buf[MAXPATHLEN+1024], buf2[MAXPATHLEN], fmt[32];
Line 475  static void log_formatted(enum logcode code, const cha Line 510  static void log_formatted(enum logcode code, const cha
         buf[total] = '\0';          buf[total] = '\0';
   
         for (p = buf; (p = strchr(p, '%')) != NULL; ) {          for (p = buf; (p = strchr(p, '%')) != NULL; ) {
                   int humanize = 0;
                 s = p++;                  s = p++;
                 c = fmt + 1;                  c = fmt + 1;
                   while (*p == '\'') {
                           humanize++;
                           p++;
                   }
                 if (*p == '-')                  if (*p == '-')
                         *c++ = *p++;                          *c++ = *p++;
                 while (isDigit(p) && c - fmt < (int)(sizeof fmt) - 8)                  while (isDigit(p) && c - fmt < (int)(sizeof fmt) - 8)
                         *c++ = *p++;                          *c++ = *p++;
                   while (*p == '\'') {
                           humanize++;
                           p++;
                   }
                 if (!*p)                  if (!*p)
                         break;                          break;
                 *c = '\0';                  *c = '\0';
                 n = NULL;                  n = NULL;
   
                   /* Note for %h and %a: it doesn't matter what fd we pass to
                    * client_{name,addr} because rsync_module will already have
                    * forced the answer to be cached (assuming, of course, for %h
                    * that lp_reverse_lookup(module_id) is true). */
                 switch (*p) {                  switch (*p) {
                 case 'h':                  case 'h':
                        if (am_daemon)                        if (am_daemon) {
                                n = client_name(0);                                n = lp_reverse_lookup(module_id)
                                   ? client_name(0) : undetermined_hostname;
                         }
                         break;                          break;
                 case 'a':                  case 'a':
                         if (am_daemon)                          if (am_daemon)
                                 n = client_addr(0);                                  n = client_addr(0);
                         break;                          break;
                 case 'l':                  case 'l':
                        strlcat(fmt, ".0f", sizeof fmt);                        strlcat(fmt, "s", sizeof fmt);
                         snprintf(buf2, sizeof buf2, fmt,                          snprintf(buf2, sizeof buf2, fmt,
                                 (double)F_LENGTH(file));                                 do_big_num(F_LENGTH(file), humanize, NULL));
                         n = buf2;                          n = buf2;
                         break;                          break;
                 case 'U':                  case 'U':
Line 518  static void log_formatted(enum logcode code, const cha Line 568  static void log_formatted(enum logcode code, const cha
                         }                          }
                         break;                          break;
                 case 'p':                  case 'p':
                        strlcat(fmt, "ld", sizeof fmt);                        strlcat(fmt, "d", sizeof fmt);
                        snprintf(buf2, sizeof buf2, fmt,                        snprintf(buf2, sizeof buf2, fmt, (int)getpid());
                                 (long)getpid()); 
                         n = buf2;                          n = buf2;
                         break;                          break;
                 case 'M':                  case 'M':
Line 607  static void log_formatted(enum logcode code, const cha Line 656  static void log_formatted(enum logcode code, const cha
                         n = auth_user;                          n = auth_user;
                         break;                          break;
                 case 'b':                  case 'b':
                        if (am_sender) {                        if (!(iflags & ITEM_TRANSFER))
                                b = stats.total_written -                                b = 0;
                                        initial_stats->total_written;                        else if (am_sender)
                        } else {                                b = total_data_written - initial_data_written;
                                b = stats.total_read -                        else
                                        initial_stats->total_read;                                b = total_data_read - initial_data_read;
                        }                        strlcat(fmt, "s", sizeof fmt);
                        strlcat(fmt, ".0f", sizeof fmt);                        snprintf(buf2, sizeof buf2, fmt,
                        snprintf(buf2, sizeof buf2, fmt, (double)b);                                 do_big_num(b, humanize, NULL));
                         n = buf2;                          n = buf2;
                         break;                          break;
                 case 'c':                  case 'c':
                        if (!am_sender) {                        if (!(iflags & ITEM_TRANSFER))
                                b = stats.total_written -                                b = 0;
                                        initial_stats->total_written;                        else if (!am_sender)
                                 b = total_data_written - initial_data_written;
                         else
                                 b = total_data_read - initial_data_read;
                         strlcat(fmt, "s", sizeof fmt);
                         snprintf(buf2, sizeof buf2, fmt,
                                  do_big_num(b, humanize, NULL));
                         n = buf2;
                         break;
                 case 'C':
                         if (protocol_version >= 30
                          && (iflags & ITEM_TRANSFER
                           || (always_checksum && S_ISREG(file->mode)))) {
                                 const char *sum = iflags & ITEM_TRANSFER
                                                 ? sender_file_sum : F_SUM(file);
                                 n = sum_as_hex(sum);
                         } else {                          } else {
                                b = stats.total_read -                                memset(buf2, ' ', checksum_len*2);
                                        initial_stats->total_read;                                buf2[checksum_len*2] = '\0';
                                 n = buf2;
                         }                          }
                         strlcat(fmt, ".0f", sizeof fmt);  
                         snprintf(buf2, sizeof buf2, fmt, (double)b);  
                         n = buf2;  
                         break;                          break;
                 case 'i':                  case 'i':
                         if (iflags & ITEM_DELETED) {                          if (iflags & ITEM_DELETED) {
Line 728  int log_format_has(const char *format, char esc) Line 790  int log_format_has(const char *format, char esc)
                 return 0;                  return 0;
   
         for (p = format; (p = strchr(p, '%')) != NULL; ) {          for (p = format; (p = strchr(p, '%')) != NULL; ) {
                if (*++p == '-')                for (p++; *p == '\''; p++) {} /*SHARED ITERATOR*/
                 if (*p == '-')
                         p++;                          p++;
                 while (isDigit(p))                  while (isDigit(p))
                         p++;                          p++;
                   while (*p == '\'') p++;
                 if (!*p)                  if (!*p)
                         break;                          break;
                 if (*p == esc)                  if (*p == esc)
Line 743  int log_format_has(const char *format, char esc) Line 807  int log_format_has(const char *format, char esc)
 /* Log the transfer of a file.  If the code is FCLIENT, the output just goes  /* Log the transfer of a file.  If the code is FCLIENT, the output just goes
  * to stdout.  If it is FLOG, it just goes to the log file.  Otherwise we   * to stdout.  If it is FLOG, it just goes to the log file.  Otherwise we
  * output to both. */   * output to both. */
void log_item(enum logcode code, struct file_struct *file,void log_item(enum logcode code, struct file_struct *file, int iflags, const char *hlink)
              struct stats *initial_stats, int iflags, const char *hlink) 
 {  {
         const char *s_or_r = am_sender ? "send" : "recv";          const char *s_or_r = am_sender ? "send" : "recv";
   
        if (code != FLOG && stdout_format && !am_server) {        if (code != FLOG && stdout_format && !am_server)
                log_formatted(FCLIENT, stdout_format, s_or_r,                log_formatted(FCLIENT, stdout_format, s_or_r, file, NULL, iflags, hlink);
                              file, NULL, initial_stats, iflags, hlink);        if (code != FCLIENT && logfile_format && *logfile_format)
        }                log_formatted(FLOG, logfile_format, s_or_r, file, NULL, iflags, hlink);
        if (code != FCLIENT && logfile_format && *logfile_format) { 
                log_formatted(FLOG, logfile_format, s_or_r, 
                              file, NULL, initial_stats, iflags, hlink); 
        } 
 }  }
   
 void maybe_log_item(struct file_struct *file, int iflags, int itemizing,  void maybe_log_item(struct file_struct *file, int iflags, int itemizing,
Line 763  void maybe_log_item(struct file_struct *file, int ifla Line 822  void maybe_log_item(struct file_struct *file, int ifla
 {  {
         int significant_flags = iflags & SIGNIFICANT_ITEM_FLAGS;          int significant_flags = iflags & SIGNIFICANT_ITEM_FLAGS;
         int see_item = itemizing && (significant_flags || *buf          int see_item = itemizing && (significant_flags || *buf
                || stdout_format_has_i > 1 || (verbose > 1 && stdout_format_has_i));                || stdout_format_has_i > 1 || (INFO_GTE(NAME, 2) && stdout_format_has_i));
         int local_change = iflags & ITEM_LOCAL_CHANGE && significant_flags;          int local_change = iflags & ITEM_LOCAL_CHANGE && significant_flags;
         if (am_server) {          if (am_server) {
                 if (logfile_name && !dry_run && see_item                  if (logfile_name && !dry_run && see_item
                  && (significant_flags || logfile_format_has_i))                   && (significant_flags || logfile_format_has_i))
                        log_item(FLOG, file, &stats, iflags, buf);                        log_item(FLOG, file, iflags, buf);
         } else if (see_item || local_change || *buf          } else if (see_item || local_change || *buf
             || (S_ISDIR(file->mode) && significant_flags)) {              || (S_ISDIR(file->mode) && significant_flags)) {
                 enum logcode code = significant_flags || logfile_format_has_i ? FINFO : FCLIENT;                  enum logcode code = significant_flags || logfile_format_has_i ? FINFO : FCLIENT;
                log_item(code, file, &stats, iflags, buf);                log_item(code, file, iflags, buf);
         }          }
 }  }
   
Line 781  void log_delete(const char *fname, int mode) Line 840  void log_delete(const char *fname, int mode)
         static struct {          static struct {
                 union file_extras ex[4]; /* just in case... */                  union file_extras ex[4]; /* just in case... */
                 struct file_struct file;                  struct file_struct file;
        } x;        } x; /* Zero-initialized due to static declaration. */
         int len = strlen(fname);          int len = strlen(fname);
         const char *fmt;          const char *fmt;
   
         x.file.mode = mode;          x.file.mode = mode;
   
        if (!verbose && !stdout_format)        if (!INFO_GTE(DEL, 1) && !stdout_format)
                 ;                  ;
         else if (am_server && protocol_version >= 29 && len < MAXPATHLEN) {          else if (am_server && protocol_version >= 29 && len < MAXPATHLEN) {
                 if (S_ISDIR(mode))                  if (S_ISDIR(mode))
Line 795  void log_delete(const char *fname, int mode) Line 854  void log_delete(const char *fname, int mode)
                 send_msg(MSG_DELETED, fname, len, am_generator);                  send_msg(MSG_DELETED, fname, len, am_generator);
         } else {          } else {
                 fmt = stdout_format_has_o_or_i ? stdout_format : "deleting %n";                  fmt = stdout_format_has_o_or_i ? stdout_format : "deleting %n";
                log_formatted(FCLIENT, fmt, "del.", &x.file, fname, &stats,                log_formatted(FCLIENT, fmt, "del.", &x.file, fname, ITEM_DELETED, NULL);
                              ITEM_DELETED, NULL); 
         }          }
   
         if (!logfile_name || dry_run || !logfile_format)          if (!logfile_name || dry_run || !logfile_format)
                 return;                  return;
   
         fmt = logfile_format_has_o_or_i ? logfile_format : "deleting %n";          fmt = logfile_format_has_o_or_i ? logfile_format : "deleting %n";
        log_formatted(FLOG, fmt, "del.", &x.file, fname, &stats, ITEM_DELETED, NULL);        log_formatted(FLOG, fmt, "del.", &x.file, fname, ITEM_DELETED, NULL);
 }  }
   
 /*  /*
Line 815  void log_delete(const char *fname, int mode) Line 873  void log_delete(const char *fname, int mode)
 void log_exit(int code, const char *file, int line)  void log_exit(int code, const char *file, int line)
 {  {
         if (code == 0) {          if (code == 0) {
                rprintf(FLOG,"sent %.0f bytes  received %.0f bytes  total size %.0f\n",                rprintf(FLOG,"sent %s bytes  received %s bytes  total size %s\n",
                        (double)stats.total_written,                        comma_num(stats.total_written),
                        (double)stats.total_read,                        comma_num(stats.total_read),
                        (double)stats.total_size);                        comma_num(stats.total_size));
         } else if (am_server != 2) {          } else if (am_server != 2) {
                 const char *name;                  const char *name;
   
Removed from v.1.1.1.1  
changed lines
  Added in v.1.1.1.2

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>