void ChannelPoller::ThreadRun()

in e2e-examples/gcs/benchmark/channel_poller.cc [54:65]

• 11 lines of code
• 3 McCabe index (conditional complexity)

void ChannelPoller::ThreadRun() {
  // Keep calling Next in order to poll a channel.
  bool ok = false;
  void* tag = nullptr;
  while (cq_.Next(&tag, &ok)) {
    absl::MutexLock lock(&mu_);
    if (shutdown_) {
      break;
    }
    StartWatch();
  }
}