Method isBlocked

bolt/exec/HashBuild.cpp:1549–1592

}

BlockingReason HashBuild::isBlocked(ContinueFuture* future) {
  switch (state_) {
    case State::kRunning:
      if (isInputFromSpill()) {
        processSpillInput();
      }
      break;
    case State::kYield:
      setRunning();
      BOLT_CHECK(isInputFromSpill());
      processSpillInput();
      break;
    case State::kFinish:
      break;
    case State::kWaitForSpill:
      if (!future_.valid()) {
        setRunning();
        BOLT_CHECK_NOT_NULL(input_);
        DeltaCpuWallTimer timer{[this](const CpuWallTiming& timing) {
          auto selfDelta =
              operatorCtx_->driver()->processLazyTiming(*this, timing);
          this->stats().wlock()->addInputTiming.add(selfDelta);
        }};
        addInput(std::move(input_));
      }
      break;
    case State::kWaitForBuild:
      [[fallthrough]];
    case State::kWaitForProbe:
      if (!future_.valid()) {
        setRunning();
        postHashBuildProcess();
      }
      break;
    default:
      BOLT_UNREACHABLE("Unexpected state: {}", stateName(state_));
      break;
  }
  if (future_.valid()) {
    BOLT_CHECK(!isRunning() && !isFinished());
    *future = std::move(future_);
  }
  return fromStateToBlockingReason(state_);
}

bool HashBuild::isFinished() {
  return state_ == State::kFinish;