Function convert_to_lcs

libCacheSim/bin/traceUtils/traceConvLCS.cpp:46–172

* @brief Convert a trace to lcs format * * @param reader * @param ofilepath * @param sample_ratio * @param output_txt * @param remove_size_change * @param lcs_ver the version of lcs format, see lcs.h for more details */

 * @param lcs_ver       the version of lcs format, see lcs.h for more details
 */
void convert_to_lcs(reader_t *reader, std::string ofilepath, bool output_txt, bool remove_size_change, int lcs_ver) {
  request_t *req = new_request();
  std::ofstream ofile_temp(ofilepath + ".reverse", std::ios::out | std::ios::binary | std::ios::trunc);
  std::unordered_map<uint64_t, struct obj_info> obj_map;
  std::unordered_map<int32_t, int32_t> tenant_cnt;
  std::unordered_map<int32_t, int32_t> ttl_cnt;
  int n_features = LCS_VER_TO_N_FEATURES[lcs_ver];

  lcs_trace_stat_t stat;
  memset(&stat, 0, sizeof(stat));
  stat.version = CURR_STAT_VERSION;
  int64_t n_req_total = get_num_of_req(reader);
  obj_map.reserve(n_req_total / 100 + 1e4);

  INFO("%s: %.2f M requests in total\n", reader->trace_path, (double)n_req_total / 1.0e6);

  reader->read_direction = READ_BACKWARD;
  reader_set_read_pos(reader, 1.0);
  go_back_one_req(reader);
  read_one_req(reader, req);

  // because we read backwards, the first request is the last request in the trace
  stat.end_timestamp = req->clock_time;

  while (true) {
    if (lcs_ver == 1 || lcs_ver == 2) {
      if (req->clock_time > UINT32_MAX) {
        WARN("clock_time %ld > UINT32_MAX, may cause overflow consider using lcs_ver 3\n", req->clock_time);
      }
      if (req->obj_size > UINT32_MAX) {
        WARN("obj_size %ld > UINT32_MAX, may cause overflow consider using lcs_ver 3\n", req->obj_size);
      }
    }

    auto info_it = obj_map.find(req->obj_id);

    if (info_it == obj_map.end()) {
      req->next_access_vtime = INT64_MAX;
      stat.n_obj++;
      stat.n_obj_byte += req->obj_size;
      struct obj_info info = {req->obj_size, 1, stat.n_req};
      obj_map[req->obj_id] = info;
    } else {
      req->next_access_vtime = info_it->second.last_access_vtime;
      info_it->second.last_access_vtime = stat.n_req;
      info_it->second.freq++;
      if (info_it->second.size != req->obj_size) {
        if (!remove_size_change) {
          WARN("find object size change, prev %ld new %ld, please enable remove_size_change\n", info_it->second.size,
               req->obj_size);
        } else {
          req->obj_size = info_it->second.size;
        }
      }
    }

    lcs_req_full_t lcs_req;
    lcs_req.clock_time = req->clock_time;