public CassandraRing getRing()

in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraClusterInfo.java [289:312]

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

    public CassandraRing<RingInstance> getRing(boolean cached)
    {
        CassandraRing<RingInstance> currentRing = ring;
        if (cached && currentRing != null)
        {
            return currentRing;
        }

        synchronized (this)
        {
            if (!cached || ring == null)
            {
                try
                {
                    ring = getCurrentRing();
                }
                catch (Exception exception)
                {
                    throw new RuntimeException("Unable to initialize ring information", exception);
                }
            }
            return ring;
        }
    }