private[this] def updateParrotMembership()

in src/main/scala/com/twitter/iago/util/ParrotCluster.scala [189:203]

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

  private[this] def updateParrotMembership(endpoint: Endpoint) {
    findRunning(endpoint) match {
      case Some(parrot) => {
        if (!isParrotConnected(parrot)) {
          log.info("Removing parrot %s", parrot.address)
          _runningParrots -= parrot
        }
      }
      case None => {
        if (!isPaused(endpoint)) {
          addNewParrot(endpoint)
        }
      }
    }
  }