def setAndGetId()

in core/invoker/src/main/scala/org/apache/openwhisk/core/invoker/InstanceIdAssigner.scala [34:102]
57 lines of code
5 McCabe index (conditional complexity)

  def setAndGetId(name: String, overwriteId: Option[Int] = None): Int = {
    logger.info(this, s"invokerReg: creating zkClient to $connectionString")
    val retryPolicy = new RetryUntilElapsed(5000, 500) // retry at 500ms intervals until 5 seconds have elapsed
    val zkClient = CuratorFrameworkFactory.newClient(connectionString, retryPolicy)
    zkClient.start()
    zkClient.blockUntilConnected()
    logger.info(this, "invokerReg: connected to zookeeper")

    val rootPath = "/invokers/idAssignment/mapping"
    val myIdPath = s"$rootPath/$name"
    val assignedId = overwriteId
      .map(newId => {
        val invokers = zkClient.getChildren.forPath(rootPath).asScala

        if (invokers.size < newId)
          throw new IllegalArgumentException(s"invokerReg: cannot assign $newId to $name: not enough invokers")

        //check if the invokerId already exists for another unique name and delete if it does
        invokers
          .map(uniqueName => {
            val idPath = s"$rootPath/$uniqueName"
            (idPath, BigInt(zkClient.getData.forPath(idPath)).intValue)
          })
          .find(_._2 == newId)
          .map(id => zkClient.delete().forPath(id._1))

        zkClient.create().orSetData().forPath(myIdPath, BigInt(newId).toByteArray)

        logger.info(this, s"invokerReg: invoker $name was assigned invokerId $newId")
        newId
      })
      .getOrElse({
        Option(zkClient.checkExists().forPath(myIdPath)) match {
          case None =>
            // path doesn't exist -> no previous mapping for this invoker
            logger.info(this, s"invokerReg: no prior assignment of id for invoker $name")
            val idCounter = new SharedCount(zkClient, "/invokers/idAssignment/counter", 0)
            idCounter.start()

            def assignId(): Int = {
              val current = idCounter.getVersionedValue()
              val numInvokers = Option(zkClient.checkExists().forPath(rootPath))
                .map(_ => zkClient.getChildren.forPath(rootPath).size())
                .getOrElse(0)
              if (idCounter.trySetCount(current, numInvokers + 1)) {
                numInvokers
              } else {
                assignId()
              }
            }

            val newId = assignId()
            idCounter.close()
            zkClient.create().creatingParentContainersIfNeeded().forPath(myIdPath, BigInt(newId).toByteArray)
            logger.info(this, s"invokerReg: invoker $name was assigned invokerId $newId")
            newId

          case Some(_) =>
            // path already exists -> there is a previous mapping for this invoker we should use
            val rawOldId = zkClient.getData.forPath(myIdPath)
            val oldId = BigInt(rawOldId).intValue
            logger.info(this, s"invokerReg: invoker $name was assigned its previous invokerId $oldId")
            oldId
        }
      })

    zkClient.close()
    assignedId
  }