Method DiagsConfig

src/proxy/shared/DiagsConfig.cc:254–325

}

DiagsConfig::DiagsConfig(std::string_view prefix_string, const char *filename, const char *tags, const char *actions,
                         bool use_records)
  : callbacks_established(false), diags_log(nullptr), _diags(nullptr)
{
  ats_scoped_str logpath;

  ////////////////////////////////////////////////////////////////////
  //  If we aren't using the manager records for configuration      //
  //   just build the tables based on command line parameters and   //
  //   exit                                                         //
  ////////////////////////////////////////////////////////////////////

  if (!use_records) {
    _diags = new Diags(prefix_string, tags, actions, nullptr);
    DiagsPtr::set(_diags);
    config_diags_norecords();
    return;
  }

  // Open the diagnostics log. If proxy.config.log.logfile_dir is set use that, otherwise fall
  // back to the configured log directory.

  logpath = RecConfigReadLogDir();
  if (access(logpath, W_OK | R_OK) == -1) {
    fprintf(stderr, "unable to access log directory '%s': %d, %s\n", (const char *)logpath, errno, strerror(errno));
    fprintf(stderr, "please set 'proxy.config.log.logfile_dir'\n");
    ::exit(1);
  }

  std::string diags_logpath{filename};
  // "stdout" and "stderr" are treated specially by BaseLogFile and are used to
  // write to the stdout and stderr streams, respectively. If the caller
  // specified these, we don't prepend any path and simply pass those strings
  // as such to BaseLogFile.
  if (diags_logpath != "stdout" && diags_logpath != "stderr") {
    char buf[PATH_NAME_MAX];
    ink_filepath_make(buf, sizeof(buf), logpath, filename);
    diags_logpath = std::string(buf);
  }

  // Grab rolling intervals from configuration
  // TODO error check these values
  int output_log_roll_int    = static_cast<int>(REC_ConfigReadInteger("proxy.config.output.logfile.rolling_interval_sec"));
  int output_log_roll_size   = static_cast<int>(REC_ConfigReadInteger("proxy.config.output.logfile.rolling_size_mb"));
  int output_log_roll_enable = static_cast<int>(REC_ConfigReadInteger("proxy.config.output.logfile.rolling_enabled"));
  int diags_log_roll_int     = static_cast<int>(REC_ConfigReadInteger("proxy.config.diags.logfile.rolling_interval_sec"));
  int diags_log_roll_size    = static_cast<int>(REC_ConfigReadInteger("proxy.config.diags.logfile.rolling_size_mb"));
  int diags_log_roll_enable  = static_cast<int>(REC_ConfigReadInteger("proxy.config.diags.logfile.rolling_enabled"));

  // Grab some perms for the actual files on disk
  char *diags_perm         = REC_ConfigReadString("proxy.config.diags.logfile_perm");
  char *output_perm        = REC_ConfigReadString("proxy.config.output.logfile_perm");
  int   diags_perm_parsed  = diags_perm ? ink_fileperm_parse(diags_perm) : -1;
  int   output_perm_parsed = diags_perm ? ink_fileperm_parse(output_perm) : -1;

  ats_free(diags_perm);
  ats_free(output_perm);