def start()

in src/main/scala/com/twitter/iago/feeder/ParrotFeeder.scala [55:79]

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

  def start() {

    val duration = config.durationF()
    if (duration > Duration.Bottom)
      shutdownAfter(duration)

    // Poller is starting here so that we can validate that we get enough servers, ie
    // so that validatePreconditions has a chance to pass without a 5 minute wait.
    poller.start()

    if (!validatePreconditions()) {
      shutdown()
    } else {

      val t = new Thread(new Runnable {
        def run() {
          runLoad()
          reportResults()
          shutdown()
        }
      })

      t.start()
    }
  }