开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > Ftp客户端 > 查看源码
logging.c
资源名称：vsftpd-2.2.2.tar.gz　[点击查看]
上传用户：ig0539
上传日期：2022-05-21
资源大小：181k
文件大小：10k
源码类别：

Ftp客户端

开发平台：

C/C++

logging.c：源码内容
  1. /*
  2.  * Part of Very Secure FTPd
  3.  * Licence: GPL v2
  4.  * Author: Chris Evans
  5.  *
  6.  * logging.c
  7.  */
  9. #include "logging.h"
  10. #include "tunables.h"
  11. #include "utility.h"
  12. #include "str.h"
  13. #include "sysutil.h"
  14. #include "sysstr.h"
  15. #include "session.h"
  17. /* File local functions */
  18. static int vsf_log_type_is_transfer(enum EVSFLogEntryType type);
  19. static void vsf_log_common(struct vsf_session* p_sess, int succeeded,
  20.                            enum EVSFLogEntryType what,
  21.                            const struct mystr* p_str);
  22. static void vsf_log_do_log_vsftpd_format(struct vsf_session* p_sess,
  23.                                          struct mystr* p_str, int succeeded,
  24.                                          enum EVSFLogEntryType what,
  25.                                          const struct mystr* p_log_str);
  26. static void vsf_log_do_log_wuftpd_format(struct vsf_session* p_sess,
  27.                                          struct mystr* p_str, int succeeded);
  28. static void vsf_log_do_log_to_file(int fd, struct mystr* p_str);
  30. void
  31. vsf_log_init(struct vsf_session* p_sess)
  32. {
  33.   int retval;
  34.   if (tunable_syslog_enable || tunable_tcp_wrappers)
  35.   {
  36.     vsf_sysutil_openlog(1);
  37.   }
  38.   if (!tunable_xferlog_enable && !tunable_dual_log_enable)
  39.   {
  40.     return;
  41.   }
  42.   if (tunable_dual_log_enable || tunable_xferlog_std_format)
  43.   {
  44.     retval = vsf_sysutil_create_or_open_file(tunable_xferlog_file, 0600);
  45.     if (vsf_sysutil_retval_is_error(retval))
  46.     {
  47.       die2("failed to open xferlog log file:", tunable_xferlog_file);
  48.     }
  49.     p_sess->xferlog_fd = retval;
  50.   }
  51.   if (tunable_dual_log_enable || !tunable_xferlog_std_format)
  52.   {
  53.     if (!tunable_syslog_enable)
  54.     {
  55.       retval = vsf_sysutil_create_or_open_file(tunable_vsftpd_log_file, 0600);
  56.       if (vsf_sysutil_retval_is_error(retval))
  57.       {
  58.         die2("failed to open vsftpd log file:", tunable_vsftpd_log_file);
  59.       }
  60.       p_sess->vsftpd_log_fd = retval;
  61.     }
  62.   }
  63. }
  65. static int
  66. vsf_log_type_is_transfer(enum EVSFLogEntryType type)
  67. {
  68.   return (type == kVSFLogEntryDownload || type == kVSFLogEntryUpload);
  69. }
  71. void
  72. vsf_log_start_entry(struct vsf_session* p_sess, enum EVSFLogEntryType what)
  73. {
  74.   if (p_sess->log_type != 0)
  75.   {
  76.     bug("non null log_type in vsf_log_start_entry");
  77.   }
  78.   p_sess->log_type = (unsigned long) what;
  79.   p_sess->log_start_sec = 0;
  80.   p_sess->log_start_usec = 0;
  81.   p_sess->transfer_size = 0;
  82.   str_empty(&p_sess->log_str);
  83.   if (vsf_log_type_is_transfer(what))
  84.   {
  85.     p_sess->log_start_sec = vsf_sysutil_get_time_sec();
  86.     p_sess->log_start_usec = vsf_sysutil_get_time_usec();
  87.   }
  88. }
  90. void
  91. vsf_log_line(struct vsf_session* p_sess, enum EVSFLogEntryType what,
  92.              struct mystr* p_str)
  93. {
  94.   vsf_log_common(p_sess, 1, what, p_str);
  95. }
  97. int
  98. vsf_log_entry_pending(struct vsf_session* p_sess)
  99. {
  100.   if (p_sess->log_type == 0)
  101.   {
  102.     return 0;
  103.   }
  104.   return 1;
  105. }
  107. void
  108. vsf_log_clear_entry(struct vsf_session* p_sess)
  109. {
  110.   p_sess->log_type = 0;
  111. }
  113. void
  114. vsf_log_do_log(struct vsf_session* p_sess, int succeeded)
  115. {
  116.   vsf_log_common(p_sess, succeeded, (enum EVSFLogEntryType) p_sess->log_type,
  117.                  &p_sess->log_str);
  118.   p_sess->log_type = 0;
  119. }
  121. static void
  122. vsf_log_common(struct vsf_session* p_sess, int succeeded,
  123.                enum EVSFLogEntryType what, const struct mystr* p_str)
  124. {
  125.   static struct mystr s_log_str;
  126.   /* Handle xferlog line if appropriate */
  127.   if (p_sess->xferlog_fd != -1 && vsf_log_type_is_transfer(what))
  128.   {
  129.     vsf_log_do_log_wuftpd_format(p_sess, &s_log_str, succeeded);
  130.     vsf_log_do_log_to_file(p_sess->xferlog_fd, &s_log_str);
  131.   }
  132.   /* Handle vsftpd.log line if appropriate */
  133.   if (p_sess->vsftpd_log_fd != -1)
  134.   {
  135.     vsf_log_do_log_vsftpd_format(p_sess, &s_log_str, succeeded, what, p_str);
  136.     vsf_log_do_log_to_file(p_sess->vsftpd_log_fd, &s_log_str);
  137.   }
  138.   /* Handle syslog() line if appropriate */
  139.   if (tunable_syslog_enable)
  140.   {
  141.     int severe = 0;
  142.     vsf_log_do_log_vsftpd_format(p_sess, &s_log_str, succeeded, what, p_str);
  143.     if (what == kVSFLogEntryLogin && !succeeded)
  144.     {
  145.       severe = 1;
  146.     }
  147.     str_syslog(&s_log_str, severe);
  148.   }
  149. }
  151. static void
  152. vsf_log_do_log_to_file(int fd, struct mystr* p_str)
  153. {
  154.   if (!tunable_no_log_lock)
  155.   {
  156.     int retval = vsf_sysutil_lock_file_write(fd);
  157.     if (vsf_sysutil_retval_is_error(retval))
  158.     {
  159.       return;
  160.     }
  161.   }
  162.   str_replace_unprintable(p_str, '?');
  163.   str_append_char(p_str, 'n');
  164.   /* Ignore write failure; maybe the disk filled etc. */
  165.   (void) str_write_loop(p_str, fd);
  166.   if (!tunable_no_log_lock)
  167.   {
  168.     vsf_sysutil_unlock_file(fd);
  169.   }
  170. }
  172. static void
  173. vsf_log_do_log_wuftpd_format(struct vsf_session* p_sess, struct mystr* p_str,
  174.                              int succeeded)
  175. {
  176.   static struct mystr s_filename_str;
  177.   long delta_sec;
  178.   enum EVSFLogEntryType what = (enum EVSFLogEntryType) p_sess->log_type;
  179.   /* Date - vsf_sysutil_get_current_date updates cached time */
  180.   str_alloc_text(p_str, vsf_sysutil_get_current_date());
  181.   str_append_char(p_str, ' ');
  182.   /* Transfer time (in seconds) */
  183.   delta_sec = vsf_sysutil_get_time_sec() - p_sess->log_start_sec;
  184.   if (delta_sec <= 0)
  185.   {
  186.     delta_sec = 1;
  187.   }
  188.   str_append_ulong(p_str, (unsigned long) delta_sec);
  189.   str_append_char(p_str, ' ');
  190.   /* Remote host name */
  191.   str_append_str(p_str, &p_sess->remote_ip_str);
  192.   str_append_char(p_str, ' ');
  193.   /* Bytes transferred */
  194.   str_append_filesize_t(p_str, p_sess->transfer_size);
  195.   str_append_char(p_str, ' ');
  196.   /* Filename */
  197.   str_copy(&s_filename_str, &p_sess->log_str);
  198.   str_replace_char(&s_filename_str, ' ', '_');
  199.   str_append_str(p_str, &s_filename_str);
  200.   str_append_char(p_str, ' ');
  201.   /* Transfer type (ascii/binary) */
  202.   if (p_sess->is_ascii)
  203.   {
  204.     str_append_text(p_str, "a ");
  205.   }
  206.   else
  207.   {
  208.     str_append_text(p_str, "b ");
  209.   }
  210.   /* Special action flag - tar, gzip etc. */
  211.   str_append_text(p_str, "_ ");
  212.   /* Direction of transfer */
  213.   if (what == kVSFLogEntryUpload)
  214.   {
  215.     str_append_text(p_str, "i ");
  216.   }
  217.   else
  218.   {
  219.     str_append_text(p_str, "o ");
  220.   }
  221.   /* Access mode: anonymous/real user, and identity */
  222.   if (p_sess->is_anonymous && !p_sess->is_guest)
  223.   {
  224.     str_append_text(p_str, "a ");
  225.     str_append_str(p_str, &p_sess->anon_pass_str);
  226.   }
  227.   else
  228.   {
  229.     if (p_sess->is_guest)
  230.     {
  231.       str_append_text(p_str, "g ");
  232.     } 
  233.     else
  234.     {
  235.       str_append_text(p_str, "r ");
  236.     }
  237.     str_append_str(p_str, &p_sess->user_str);
  238.   }
  239.   str_append_char(p_str, ' ');
  240.   /* Service name, authentication method, authentication user id */
  241.   str_append_text(p_str, "ftp 0 * ");
  242.   /* Completion status */
  243.   if (succeeded)
  244.   {
  245.     str_append_char(p_str, 'c');
  246.   }
  247.   else
  248.   {
  249.     str_append_char(p_str, 'i');
  250.   }
  251. }
  253. static void
  254. vsf_log_do_log_vsftpd_format(struct vsf_session* p_sess, struct mystr* p_str,
  255.                              int succeeded, enum EVSFLogEntryType what,
  256.                              const struct mystr* p_log_str)
  257. {
  258.   str_empty(p_str);
  259.   if (!tunable_syslog_enable)
  260.   {
  261.     /* Date - vsf_sysutil_get_current_date updates cached time */
  262.     str_append_text(p_str, vsf_sysutil_get_current_date());
  263.     /* Pid */
  264.     str_append_text(p_str, " [pid ");
  265.     str_append_ulong(p_str, vsf_sysutil_getpid());
  266.     str_append_text(p_str, "] ");
  267.   }
  268.   /* User */
  269.   if (!str_isempty(&p_sess->user_str))
  270.   {
  271.     str_append_char(p_str, '[');
  272.     str_append_str(p_str, &p_sess->user_str);
  273.     str_append_text(p_str, "] ");
  274.   }
  275.   /* And the action */
  276.   if (what != kVSFLogEntryFTPInput && what != kVSFLogEntryFTPOutput &&
  277.       what != kVSFLogEntryConnection && what != kVSFLogEntryDebug)
  278.   {
  279.     if (succeeded)
  280.     {
  281.       str_append_text(p_str, "OK ");
  282.     }
  283.     else
  284.     {
  285.       str_append_text(p_str, "FAIL ");
  286.     }
  287.   }
  288.   switch (what)
  289.   {
  290.     case kVSFLogEntryDownload:
  291.       str_append_text(p_str, "DOWNLOAD");
  292.       break;
  293.     case kVSFLogEntryUpload:
  294.       str_append_text(p_str, "UPLOAD");
  295.       break;
  296.     case kVSFLogEntryMkdir:
  297.       str_append_text(p_str, "MKDIR");
  298.       break;
  299.     case kVSFLogEntryLogin:
  300.       str_append_text(p_str, "LOGIN");
  301.       break;
  302.     case kVSFLogEntryFTPInput:
  303.       str_append_text(p_str, "FTP command");
  304.       break;
  305.     case kVSFLogEntryFTPOutput:
  306.       str_append_text(p_str, "FTP response");
  307.       break;
  308.     case kVSFLogEntryConnection:
  309.       str_append_text(p_str, "CONNECT");
  310.       break;
  311.     case kVSFLogEntryDelete:
  312.       str_append_text(p_str, "DELETE");
  313.       break;
  314.     case kVSFLogEntryRename:
  315.       str_append_text(p_str, "RENAME");
  316.       break;
  317.     case kVSFLogEntryRmdir:
  318.       str_append_text(p_str, "RMDIR");
  319.       break;
  320.     case kVSFLogEntryChmod:
  321.       str_append_text(p_str, "CHMOD");
  322.       break;
  323.     case kVSFLogEntryDebug:
  324.       str_append_text(p_str, "DEBUG");
  325.       break;
  326.     default:
  327.       bug("bad entry_type in vsf_log_do_log");
  328.       break;
  329.   }
  330.   str_append_text(p_str, ": Client "");
  331.   str_append_str(p_str, &p_sess->remote_ip_str);
  332.   str_append_char(p_str, '"');
  333.   if (what == kVSFLogEntryLogin && !str_isempty(&p_sess->anon_pass_str))
  334.   {
  335.     str_append_text(p_str, ", anon password "");
  336.     str_append_str(p_str, &p_sess->anon_pass_str);
  337.     str_append_char(p_str, '"');
  338.   }
  339.   if (!str_isempty(p_log_str))
  340.   {
  341.     str_append_text(p_str, ", "");
  342.     str_append_str(p_str, p_log_str);
  343.     str_append_char(p_str, '"');
  344.   }
  345.   if (what != kVSFLogEntryFTPInput && what != kVSFLogEntryFTPOutput &&
  346.       what != kVSFLogEntryDebug)
  347.   {
  348.     if (p_sess->transfer_size)
  349.     {
  350.       str_append_text(p_str, ", ");
  351.       str_append_filesize_t(p_str, p_sess->transfer_size);
  352.       str_append_text(p_str, " bytes");
  353.     }
  354.     if (vsf_log_type_is_transfer(what))
  355.     {
  356.       long delta_sec = vsf_sysutil_get_time_sec() - p_sess->log_start_sec;
  357.       long delta_usec = vsf_sysutil_get_time_usec() - p_sess->log_start_usec;
  358.       double time_delta = (double) delta_sec + ((double) delta_usec /
  359.                                                 (double) 1000000);
  360.       double kbyte_rate;
  361.       if (time_delta <= 0)
  362.       {
  363.         time_delta = 0.1;
  364.       }
  365.       kbyte_rate =
  366.         ((double) p_sess->transfer_size / time_delta) / (double) 1024;
  367.       str_append_text(p_str, ", ");
  368.       str_append_double(p_str, kbyte_rate);
  369.       str_append_text(p_str, "Kbyte/sec");
  370.     }
  371.   }
  372. }