private[this] def pollParrots()

in src/main/scala/com/twitter/iago/feeder/ParrotPoller.scala [51:71]

• 19 lines of code
• 5 McCabe index (conditional complexity)

  private[this] def pollParrots() {
    cluster.parrots foreach { parrot =>
      try {
        pollParrot(parrot)
      } catch {
        case t: Throwable =>
          log.error(
            t,
            "Exception polling parrot[%s] - %s",
            parrot.address,
            Option(t.getMessage).getOrElse(t.toString)
          )
      }
    }

    // Note that cluster.parrots can change during execution of this block!
    val curParrots = cluster.parrots.size
    val newParrots = curParrots - parrotsSnap;
    for (_ <- 1 to newParrots) serverLatch.countDown()
    parrotsSnap = curParrots
  }