override def run()

in src/main/scala/com/twitter/iago/feeder/FeedConsumer.scala [35:51]

• 17 lines of code
• 7 McCabe index (conditional complexity)

  override def run() {
    while (state == FeederState.RUNNING) {
      if (parrot.isBusy) {
        Thread.sleep(ParrotPoller.pollRate)
      } else {
        if (queue.isEmpty) {
          log.info("Queue is empty for server %s", parrot.address)
          Thread.sleep(ParrotPoller.pollRate) // don't spin wait on the queue
        } else send
      }
    }
    while (!queue.isEmpty() && state != FeederState.TIMEOUT) if (parrot.isBusy)
      Thread.sleep(ParrotPoller.pollRate)
    else
      send
    done.setValue(())
  }