public void afterLts()

in harry-core/src/harry/visitors/MutatingVisitor.java [108:128]

• 19 lines of code
• 5 McCabe index (conditional complexity)

        public void afterLts(long lts, long pd)
        {
            // TODO: switch to Cassandra futures!
            for (CompletableFuture<?> future : futures)
            {
                try
                {
                    future.get(10, TimeUnit.SECONDS);
                }
                catch (Throwable t)
                {
                    int complete = 0;
                    for (CompletableFuture<?> f : futures)
                        if (f.isDone()) complete++;

                    throw new IllegalStateException(String.format("Couldn't repeat operations within timeout bounds. %d out of %d futures complete", complete, futures.size()), t);
                }
            }
            futures.clear();
            tracker.endModification(lts);
        }