Class thread_base

client/hslongrun.cpp:108–161

};

struct thread_base {
  thread_base() : need_join(false), stack_size(256 * 1024) { }
  virtual ~thread_base() {
    join();
  }
  virtual void run() = 0;
  void start() {
    if (!start_nothrow()) {
      fatal_abort("thread::start");
    }
  }
  bool start_nothrow() {
    if (need_join) {
      return need_join; /* true */
    }
    void *const arg = this;
    pthread_attr_t attr;
    if (pthread_attr_init(&attr) != 0) {
      fatal_abort("pthread_attr_init");
    }
    if (pthread_attr_setstacksize(&attr, stack_size) != 0) {
      fatal_abort("pthread_attr_setstacksize");
    }
    const int r = pthread_create(&thr, &attr, thread_main, arg);
    if (pthread_attr_destroy(&attr) != 0) {
      fatal_abort("pthread_attr_destroy");
    }
    if (r != 0) {
      return need_join; /* false */
    }
    need_join = true;
    return need_join; /* true */
  }
  void join() {
    if (!need_join) {
      return;
    }
    int e = 0;
    if ((e = pthread_join(thr, 0)) != 0) {
      fatal_abort("pthread_join");
    }
    need_join = false;
  }
 private:
  static void *thread_main(void *arg) {
    thread_base *p = static_cast<thread_base *>(arg);
    p->run();
    return 0;
  }
 private:
  pthread_t thr;
  bool need_join;
  size_t stack_size;
};

struct hs_longrun_stat {
  unsigned long long verify_error_count;