Function csv_read_one_req

libCacheSim/traceReader/generalReader/csv.c:348–382

* @brief read one request from a csv file * * @param reader * @param req * @return int */

 * @return int
 */
int csv_read_one_req(reader_t *const reader, request_t *const req) {
  csv_params_t *csv_params = reader->reader_params;
  struct csv_parser *csv_parser = csv_params->csv_parser;
  char **line_buf_ptr = &reader->line_buf;
  size_t *line_buf_size_ptr = &reader->line_buf_size;

  csv_params->request = req;
  DEBUG_ASSERT(csv_params->curr_field_idx == 1);

  ssize_t read_size = getline(line_buf_ptr, line_buf_size_ptr, reader->file);
  if (read_size == -1) {
    req->valid = false;
    return 1;
  }

  if ((ssize_t)csv_parse(csv_parser, *line_buf_ptr, read_size, csv_cb1, csv_cb2,
                         reader) != read_size) {
    WARN("parsing csv file error: %s\n",
         csv_strerror(csv_error(csv_params->csv_parser)));
  }

  csv_fini(csv_params->csv_parser, csv_cb1, csv_cb2, reader);

  if (req->obj_size == 0 && reader->ignore_size_zero_req) {
    if (reader->read_direction == READ_FORWARD) {
      return csv_read_one_req(reader, req);
    } else {
      return read_one_req_above(reader, req);
    }
  }

  if (reader->n_req_left > 0) reader->last_req_clock_time = req->clock_time;

  return 0;
}

void csv_reset_reader(reader_t *reader) {
  csv_params_t *csv_params = reader->reader_params;