Method IpAllow

src/proxy/IPAllow.cc:204–244

//

IpAllow::IpAllow(const char *ip_allow_config_var, const char *ip_categories_config_var)
  : ip_allow_config_file(ats_scoped_str(RecConfigReadConfigPath(ip_allow_config_var)).get())
{
  int matching_policy = 0;
  REC_ReadConfigInteger(matching_policy, "proxy.config.url_remap.acl_behavior_policy");
  if (matching_policy == 0) {
    this->_is_legacy_action_policy = true;
  } else {
    this->_is_legacy_action_policy = false;
  }
  std::string const path = RecConfigReadConfigPath(ip_categories_config_var);
  if (!path.empty()) {
    ip_categories_config_file = ats_scoped_str(path).get();
  }

  RecString subjects_char;
  REC_ReadConfigStringAlloc(subjects_char, "proxy.config.acl.subjects");
  std::string_view            subjects_sv{subjects_char};
  int                         i = 0;
  std::string_view::size_type s, e;
  for (s = 0, e = 0; s < subjects_sv.size() && e != subjects_sv.npos; s = e + 1) {
    e                           = subjects_sv.find(",", s);
    std::string_view subject_sv = subjects_sv.substr(s, e);
    if (i >= MAX_SUBJECTS) {
      Error("Too many ACL subjects were provided");
    }
    if (subject_sv == "PEER") {
      subjects[i] = Subject::PEER;
      ++i;
    } else if (subject_sv == "PROXY") {
      subjects[i] = Subject::PROXY;
      ++i;
    } else {
      Dbg(dbg_ctl_ip_allow, "Unknown subject %.*s was ignored", static_cast<int>(subject_sv.length()), subject_sv.data());
    }
  }
  if (i < Subject::MAX_SUBJECTS) {
    subjects[i] = Subject::MAX_SUBJECTS;
  }
  ats_free(subjects_char);
}

BufferWriter &
bwformat(BufferWriter &w, Spec const & /* spec ATS_UNUSED */, IpAllow::IpMap const &map)