/* * Copyright (C) 2020, Google LLC and others * * This program and the accompanying materials are made available under the * terms of the Eclipse Distribution License v. 1.0 which is available at * https://www.eclipse.org/org/documents/edl-v10.php. * * SPDX-License-Identifier: BSD-3-Clause */ package org.eclipse.jgit.internal.revwalk; import java.io.IOException; import java.util.ArrayList; import java.util.Arrays; import java.util.Collection; import java.util.Iterator; import java.util.List; import java.util.Optional; import java.util.stream.Stream; import org.eclipse.jgit.errors.IncorrectObjectTypeException; import org.eclipse.jgit.errors.MissingObjectException; import org.eclipse.jgit.lib.BitmapIndex.BitmapBuilder; import org.eclipse.jgit.revwalk.BitmapWalker; import org.eclipse.jgit.revwalk.ObjectReachabilityChecker; import org.eclipse.jgit.revwalk.ObjectWalk; import org.eclipse.jgit.revwalk.RevObject; /** * Checks if all objects are reachable from certain starting points using * bitmaps. */ public class BitmappedObjectReachabilityChecker implements ObjectReachabilityChecker { private final ObjectWalk walk; /** * New instance of the reachability checker using a existing walk. * * @param walk * ObjectWalk instance to reuse. Caller retains ownership. */ public BitmappedObjectReachabilityChecker(ObjectWalk walk) { this.walk = walk; } /** * {@inheritDoc} * * This implementation tries to shortcut the check adding starters * incrementally. Ordering the starters by relevance can improve performance * in the average case. */ @Override public Optional areAllReachable(Collection targets, Stream starters) throws IOException { try { List remainingTargets = new ArrayList<>(targets); BitmapWalker bitmapWalker = new BitmapWalker(walk, walk.getObjectReader().getBitmapIndex(), null); Iterator starterIt = starters.iterator(); BitmapBuilder seen = null; while (starterIt.hasNext()) { List asList = Arrays.asList(starterIt.next()); BitmapBuilder visited = bitmapWalker.findObjects(asList, seen, true); seen = seen == null ? visited : seen.or(visited); remainingTargets.removeIf(seen::contains); if (remainingTargets.isEmpty()) { return Optional.empty(); } } return Optional.of(remainingTargets.get(0)); } catch (MissingObjectException | IncorrectObjectTypeException e) { throw new IllegalStateException(e); } } }