Method addBytes

plugins/cache_promote/lru_policy.cc:220–254

}

void
LRUPolicy::addBytes(TSHttpTxn txnp)
{
  LRUHash *hash = static_cast<LRUHash *>(TSUserArgGet(txnp, TXN_ARG_IDX));

  if (hash) {
    LRUMap::iterator map_it;

    // We have to hold the lock across all list and hash access / updates
    TSMutexLock(_lock);
    map_it = _map.find(hash);
    if (_map.end() != map_it) {
      TSMBuffer resp;
      TSMLoc    resp_hdr;

      if (TS_SUCCESS == TSHttpTxnServerRespGet(txnp, &resp, &resp_hdr)) {
        TSMLoc field_loc = TSMimeHdrFieldFind(resp, resp_hdr, TS_MIME_FIELD_CONTENT_LENGTH, TS_MIME_LEN_CONTENT_LENGTH);

        if (field_loc) {
          auto &[val_key, val_hits, val_bytes] = *(map_it->second);
          int64_t cl                           = TSMimeHdrFieldValueInt64Get(resp, resp_hdr, field_loc, -1);

          // This is because compilers before gcc 8 aren't smart enough to ignore the unused structured bindings
          (void)val_key, (void)val_hits;

          val_bytes += cl;
          DBG("Added %" PRId64 " bytes for LRU entry", cl);
          TSHandleMLocRelease(resp, resp_hdr, field_loc);
        }
        TSHandleMLocRelease(resp, TS_NULL_MLOC, resp_hdr);
      }
    }
    TSMutexUnlock(_lock);
  }
}

bool
LRUPolicy::stats_add(const char *remap_id)