private boolean hasConflictsWithFences()

in tso-server/src/main/java/org/apache/omid/tso/AbstractRequestProcessor.java [191:205]

• 14 lines of code
• 7 McCabe index (conditional complexity)

    private boolean hasConflictsWithFences(long startTimestamp, Collection<Long> tableIdSet) {
        if (!tableFences.isEmpty()) {
            for (long tableId: tableIdSet) {
                Long fence = tableFences.get(tableId);
                if (fence != null && fence > startTimestamp) {
                    return true;
                }
                if (fence != null && fence < lowWatermark) {
                    tableFences.remove(tableId); // Garbage collect entries of old fences.
                }
            }
        }

        return false;
    }