Function TSRemapNewInstance

plugins/experimental/rate_limit/rate_limit.cc:81–108

}

TSReturnCode
TSRemapNewInstance(int argc, char *argv[], void **ih, char * /* errbuf ATS_UNUSED */, int /* errbuf_size ATS_UNUSED */)
{
  auto *limiter = new TxnRateLimiter();

  // set the name based on the pristine remap URL prior to advancing the pointer below
  limiter->setName(getDescriptionFromUrl(argv[0]));

  // argv contains the "to" and "from" URLs. Skip the first so that the
  // second one poses as the program name.
  --argc;
  ++argv;

  TSReleaseAssert(limiter);
  limiter->initialize(argc, const_cast<const char **>(argv));
  *ih = static_cast<void *>(limiter);

  if (limiter->rate() > 0) {
    // Setup rate based limit, if configured (this is rate as in "requests per second")
    limiter->addBucket();
  }

  Dbg(dbg_ctl, "Added active_in limiter rule (limit=%u, rate=%u, queue=%u, max-age=%ldms, error=%u, conntrack=%s)",
      limiter->limit(), limiter->rate(), limiter->max_queue(), static_cast<long>(limiter->max_age().count()), limiter->error(),
      limiter->conntrack() ? "yes" : "no");

  return TS_SUCCESS;
}

///////////////////////////////////////////////////////////////////////////////
// This is the main "entry" point for the plugin, called for every request.