Method op_readnolock

client/hslongrun.cpp:648–678

}

int
hs_longrun_thread_hs::op_readnolock(int key)
{
  const std::string k = to_stdstring(key);
  const string_ref op_ref("=", 1);
  const string_ref op_args[1] = {
    to_string_ref(k),
  };
  cli->request_buf_exec_generic(0, op_ref, op_args, 1, 1, 0,
    string_ref(), 0, 0, 0, 0);
  cli->request_send();
  if (check_hs_error("op_read_send", 0) != 0) { return 1; }
  size_t num_flds = 0;
  size_t num_rows = 0;
  cli->response_recv(num_flds);
  if (check_hs_error("op_read_recv", 0) != 0) { return 1; }
  const string_ref *row = cli->get_next_row();
  std::string rrec[4];
  if (row != 0 && num_flds == 4) {
    for (int i = 0; i < 4; ++i) {
      rrec[i] = to_string(row[i]);
    }
    ++num_rows;
  }
  row = cli->get_next_row();
  if (row != 0) {
    ++num_rows;
  }
  cli->response_buf_remove();
  return verify_readnolock(k, num_rows, num_flds, rrec);
}

int
hs_longrun_thread_hs::check_hs_error(const char *mess, record_value *rec)