in src/main/scala/com/twitter/iago/util/ParrotCluster.scala [205:218]
private[this] def addNewParrot(endpoint: Endpoint) {
connectParrot(endpoint.host, endpoint.port) match {
case Some(parrot) => {
_runningParrots += parrot
log.debug(
"added a new parrot: %s, paused=%d unpaused=%d",
parrot.address,
_pausedParrots.size,
_runningParrots.size
)
}
case None => ()
}
}