Class hs_longrun_thread_base

client/hslongrun.cpp:179–219

};

struct hs_longrun_thread_base : public thread_base {
  struct arg_type {
    int id;
    std::string worker_type;
    char op;
    int lock_flag;
    const hs_longrun_shared& sh;
    arg_type(int id, const std::string& worker_type, char op, int lock_flag,
      const hs_longrun_shared& sh)
      : id(id), worker_type(worker_type), op(op), lock_flag(lock_flag),
	sh(sh) { }
  };
  arg_type arg;
  hs_longrun_stat stat;
  drand48_data randbuf;
  unsigned int seed;
  hs_longrun_thread_base(const arg_type& arg)
    : arg(arg), seed(0) {
    seed = time(0) + arg.id + 1;
    srand48_r(seed, &randbuf);
  }
  virtual ~hs_longrun_thread_base() { }
  virtual void run() = 0;
  size_t rand_record() {
    double v = 0;
    drand48_r(&randbuf, &v);
    const size_t sz = arg.sh.records.size();
    size_t r = size_t(v * sz);
    if (r >= sz) {
      r = 0;
    }
    return r;
  }
  int verify_update(const std::string& k, const std::string& v1,
    const std::string& v2, const std::string& v3, record_value& rec,
    uint32_t num_rows, bool cur_unknown_state);
  int verify_read(const std::string& k, uint32_t num_rows, uint32_t num_flds,
    const std::string rrec[4], record_value& rec);
  int verify_readnolock(const std::string& k, uint32_t num_rows,
    uint32_t num_flds, const std::string rrec[4]);
};

int
hs_longrun_thread_base::verify_update(const std::string& k,