protected void maybeNotify()

in server/src/main/java/org/apache/cassandra/sidecar/coordination/ClusterLeaseClaimTask.java [274:296]

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

    protected void maybeNotify(String sidecarHostId, boolean wasLeaseholder)
    {
        boolean isCurrentLeaseholder = isCurrentLeaseholder(sidecarHostId);
        // lease has been lost
        if (wasLeaseholder && !isCurrentLeaseholder)
        {
            LOGGER.info("Cluster-wide lease has been lost by sidecarHostId={}", sidecarHostId);
            eventBus.publish(ON_SIDECAR_GLOBAL_LEASE_LOST.address(), sidecarHostId);
        }

        // lease has been claimed
        if (!wasLeaseholder && isCurrentLeaseholder)
        {
            LOGGER.info("Cluster-wide lease has been claimed by sidecarHostId={}", sidecarHostId);
            eventBus.publish(ON_SIDECAR_GLOBAL_LEASE_CLAIMED.address(), sidecarHostId);
        }

        // lease has been extended
        if (LOGGER.isDebugEnabled() && wasLeaseholder && isCurrentLeaseholder)
        {
            LOGGER.debug("Cluster-wide lease has been extended by sidecarHostId={}", sidecarHostId);
        }
    }