private int validateRecentPartitions()

in harry-core/src/harry/visitors/RecentValidator.java [62:84]


    private int validateRecentPartitions()
    {
        long pos = pdSelector.maxPosition(clock.peek());

        int maxPartitions = partitionCount;
        while (pos >= 0 && maxPartitions > 0 && !Thread.currentThread().isInterrupted())
        {
            long visitLts = pdSelector.minLtsAt(pos);
            for (int i = 0; i < queries; i++)
            {
                metricReporter.validateRandomQuery();
                Query query = querySelector.inflate(visitLts, i);
                // TODO: add pd skipping from shrinker here, too
                log(i, query);
                model.validate(query);
            }

            pos--;
            maxPartitions--;
        }
        
        return partitionCount - maxPartitions;
    }