def performHousekeeping()

in spark/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCache.scala [90:111]

• 21 lines of code
• 6 McCabe index (conditional complexity)

  def performHousekeeping(forceClean: Boolean) = {
    val tsNow: Long = System.currentTimeMillis()
    connectionMap.synchronized {
      connectionMap.foreach {
        x =>
          {
            if (x._2.refCount < 0) {
              logError(s"Bug to be fixed: negative refCount of connection ${x._2}")
            }

            if (forceClean || ((x._2.refCount <= 0) && (tsNow - x._2.timestamp > timeout))) {
              try {
                x._2.connection.close()
              } catch {
                case e: IOException => logWarning(s"Fail to close connection ${x._2}", e)
              }
              connectionMap.remove(x._1)
            }
          }
      }
    }
  }