Method op_insert

client/hslongrun.cpp:462–528

}

int
hs_longrun_thread_hs::op_insert(record_value& rec)
{
  const std::string k = rec.key;
  const std::string v1 = "iv1_" + k + "_" + to_stdstring(arg.id);
  const std::string v2 = "iv2_" + k + "_" + to_stdstring(arg.id);
  const std::string v3 = "iv3_" + k + "_" + to_stdstring(arg.id);
  const string_ref op_ref("+", 1);
  const string_ref op_args[4] = {
    to_string_ref(k),
    to_string_ref(v1),
    to_string_ref(v2),
    to_string_ref(v3)
  };
  cli->request_buf_exec_generic(0, op_ref, op_args, 4, 1, 0,
    string_ref(), 0, 0, 0, 0);
  cli->request_send();
  if (check_hs_error("op_insert_send", &rec) != 0) { return 1; }
  size_t numflds = 0;
  cli->response_recv(numflds);
  if (arg.sh.verbose > 10) {
    const string_ref *row = cli->get_next_row();
    fprintf(stderr, "HS op=+ errrcode=%d errmess=[%s]\n", cli->get_error_code(),
      row ? to_string(row[0]).c_str() : "");
  }
  const bool op_success = cli->get_error_code() == 0;
  int ret = 0;
  if (!rec.unknown_state) {
    if (rec.deleted && !op_success) {
      ++stat.verify_error_count;
      if (arg.sh.verbose > 0) {
	fprintf(stderr, "VERIFY_ERROR: %s wid=%d k=%s "
	  "unexpected_insert_failure\n",
	  arg.worker_type.c_str(), arg.id, k.c_str());
      }
      ret = 1;
    } else if (!rec.deleted && op_success) {
      ++stat.verify_error_count;
      if (arg.sh.verbose > 0) {
	fprintf(stderr, "VERIFY_ERROR: %s wid=%d k=%s "
	  "unexpected_insert_success\n",
	  arg.worker_type.c_str(), arg.id, k.c_str());
      }
      ret = 1;
    }
  } else {
    ++stat.unknown_count;
  }
  if (op_success) {
    rec.values.resize(4);
    rec.values[0] = k;
    rec.values[1] = v1;
    rec.values[2] = v2;
    rec.values[3] = v3;
    rec.deleted = false;
    if (arg.sh.verbose >= 100 && ret == 0) {
      fprintf(stderr, "HS_INSERT %s %s %s %s\n", k.c_str(), v1.c_str(),
	v2.c_str(), v3.c_str());