def queueBatch()

in src/main/scala/com/twitter/iago/util/RemoteParrot.scala [71:86]

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

  def queueBatch(batchFun: => List[String]) {
    if (hasCapacity) {
      traceCount = 0
      val batch = batchFun
      if (batch.size > 0) {
        log.trace("RemoteParrot: Queuing batch for %s with %d requests", address, batch.size)
        addRequest(batch)
      }
    } else {
      if (traceCount < 2)
        log.trace("RemoteParrot: parrot[%s] queue is over capacity", address)
      else if (traceCount == 2)
        log.trace("RemoteParrot: parrot[%s] more over capacity warnings ...Ï", address)
      traceCount += 1
    }
  }