Method Compare

src/master/workload_scheduler.cc:184–210

class LoadComparator : public Comparator {
 public:
  int Compare(const TabletNodePtr& a, const TabletNodePtr& b, const std::string& table_name) {
    uint64_t a_read_pending = GetPending(a);
    uint64_t b_read_pending = GetPending(b);
    if (a_read_pending < b_read_pending) {
      return -1;
    } else if (a_read_pending > b_read_pending) {
      return 1;
    }

    uint64_t a_row_read_delay = a->GetRowReadDelay();
    uint64_t b_row_read_delay = b->GetRowReadDelay();
    if (a_row_read_delay < b_row_read_delay) {
      return -1;
    } else if (a_row_read_delay > b_row_read_delay) {
      return 1;
    }

    uint64_t a_qps = a->GetQps(table_name);
    uint64_t b_qps = b->GetQps(table_name);
    if (a_qps < b_qps) {
      return -1;
    } else if (a_qps > b_qps) {
      return 1;
    } else {
      return 0;
    }
  }

  virtual ~LoadComparator() {}
};