Method SetDoneInternal

be/src/exec/kudu/kudu-scan-node.cc:275–279

}

void KuduScanNode::SetDoneInternal() {
  if (done_.Load()) return;
  done_.Store(true);
  thread_state_.Shutdown();
}

void KuduScanNode::SetDone() {
  unique_lock<mutex> l(lock_);