Method verify_read

client/hslongrun.cpp:265–332

}

int
hs_longrun_thread_base::verify_read(const std::string& k,
  uint32_t num_rows, uint32_t num_flds, const std::string rrec[4],
  record_value& rec)
{
  const bool op_success = num_rows != 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_read_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_read_success\n",
	  arg.worker_type.c_str(), arg.id, k.c_str());
      }
      ret = 1;
    } else if (num_flds != 4) {
      ++stat.verify_error_count;
      if (arg.sh.verbose > 0) {
	fprintf(stderr, "VERIFY_ERROR: %s wid=%d k=%s "
	  "unexpected_read_fldnum %d\n",
	  arg.worker_type.c_str(), arg.id, k.c_str(),
	  static_cast<int>(num_flds));
      }
      ret = 1;
    } else if (rec.deleted) {
      /* nothing to verify */
    } else {
      int diff = 0;
      for (size_t i = 0; i < 4; ++i) {
	if (rec.values[i] == rrec[i]) {
	  /* ok */
	} else {
	  diff = 1;
	}
      }
      if (diff) {
	std::string mess;
	for (size_t i = 0; i < 4; ++i) {
	  const std::string& expected = rec.values[i];
	  const std::string& val = rrec[i];
	  mess += " " + val + "/" + expected;
	}
	if (arg.sh.verbose > 0) {
	  fprintf(stderr, "VERIFY_ERROR: %s wid=%d k=%s "
	    "unexpected_read_value %s\n",
	    arg.worker_type.c_str(), arg.id, k.c_str(), mess.c_str());
	}
	ret = 1;
      }