Method add_req

libCacheSim/traceAnalyzer/reuse.cpp:17–65

using namespace std;

void ReuseDistribution::add_req(request_t *req) {
  if (unlikely(next_window_ts_ == -1)) {
    next_window_ts_ = (int64_t)req->clock_time + time_window_;
  }

  if (req->rtime_since_last_access < 0) {
    // compulsory miss
    reuse_rtime_req_cnt_[-1] += 1;
    reuse_vtime_req_cnt_[-1] += 1;

    return;
  }

  int pos_rt = (int)(req->rtime_since_last_access / rtime_granularity_);
  int pos_vt = (int)(log(double(req->vtime_since_last_access)) / log_log_base_);

  reuse_rtime_req_cnt_[pos_rt] += 1;
  reuse_vtime_req_cnt_[pos_vt] += 1;

  //    switch (req->op) {
  //      case OP_GET:
  //      case OP_GETS:
  //        reuse_rtime_req_cnt_read_[pos_rt] += 1;
  //        break;
  //      case OP_SET:
  //      case OP_ADD:
  //      case OP_REPLACE:
  //      case OP_CAS:
  //        reuse_rtime_req_cnt_write_[pos_rt] += 1;
  //        break;
  //      case OP_DELETE:
  //        reuse_rtime_req_cnt_delete_[pos_rt] += 1;
  //        break;
  //      default:
  //        break;
  //    }

  if (time_window_ <= 0) return;

  utils::vector_incr(window_reuse_rtime_req_cnt_, pos_rt, (uint32_t)1);
  utils::vector_incr(window_reuse_vtime_req_cnt_, pos_vt, (uint32_t)1);

  while (req->clock_time >= next_window_ts_) {
    stream_dump_window_reuse_distribution();
    window_reuse_rtime_req_cnt_.clear();
    window_reuse_vtime_req_cnt_.clear();
    next_window_ts_ += time_window_;
  }
}

void ReuseDistribution::dump(string &path_base) {
  ofstream ofs(path_base + ".reuse", ios::out | ios::trunc);