private[this] def sendRequest()

in src/main/scala/com/twitter/iago/feeder/FeedConsumer.scala [71:88]

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

  private[this] def sendRequest(parrot: RemoteParrot, request: List[String]) {
    val success = parrot.sendRequest(request)
    log.info(
      "wrote batch of size %d to %s rps=%g depth=%g(target=%g) status=%s lines=%d",
      request.size,
      parrot.address,
      // Iago Server doesn't include RPS in ParrotStatus.
      success.requestsPerSecond getOrElse 0d,
      success.queueDepth getOrElse 0d,
      parrot.targetDepth,
      success.status,
      success.linesProcessed getOrElse 0
    )

    val linesProcessed = success.linesProcessed getOrElse 0
    parrot.results.add(new InternalCounter(linesProcessed, request.length - linesProcessed))
    parrot.queueDepth = success.queueDepth getOrElse 0d
  }