opendev/gerrit
Code Issues Proposed changes

Merge "HackPushNegotiateHook to retain existing haves line"

Browse Source
This commit is contained in:
Edwin Kempin
2019-06-27 11:57:58 +00:00
committed by Gerrit Code Review
parent 4b7ddfbe7e 5e3d3d9ea9
commit 40f7a1ba02
1 changed files with 9 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
java/com/google/gerrit/server/git/receive/HackPushNegotiateHook.java
View File

@@ -21,7 +21,6 @@ import com.google.common.flogger.FluentLogger;
import com.google.gerrit.git.ObjectIds;
import java.io.IOException;
import java.util.Collection;
import java.util.Collections;
import java.util.Map;
import java.util.Set;
import org.eclipse.jgit.lib.ObjectId;
@@ -92,35 +91,30 @@ public class HackPushNegotiateHook implements AdvertiseRefsHook {
private Set<ObjectId> history(Collection<Ref> refs, BaseReceivePack rp) {
Set<ObjectId> alreadySending = rp.getAdvertisedObjects();
if (alreadySending.isEmpty()) {
alreadySending = idsOf(refs);
}
int max = MAX_HISTORY - Math.max(0, alreadySending.size() - refs.size());
if (max <= 0) {
return Collections.emptySet();
if (MAX_HISTORY <= alreadySending.size()) {
return alreadySending;
}
// Scan history until the advertisement is full.
RevWalk rw = rp.getRevWalk();
rw.reset();
try {
for (Ref ref : refs) {
Set<ObjectId> tips = idsOf(refs);
for (ObjectId tip : tips) {
try {
if (ref.getObjectId() != null) {
rw.markStart(rw.parseCommit(ref.getObjectId()));
}
rw.markStart(rw.parseCommit(tip));
} catch (IOException badCommit) {
continue;
}
}
Set<ObjectId> history = Sets.newHashSetWithExpectedSize(max);
Set<ObjectId> history = Sets.newHashSetWithExpectedSize(MAX_HISTORY);
history.addAll(alreadySending);
try {
int stepCnt = 0;
for (RevCommit c; history.size() < max && (c = rw.next()) != null; ) {
for (RevCommit c; history.size() < MAX_HISTORY && (c = rw.next()) != null; ) {
if (c.getParentCount() <= 1
&& !alreadySending.contains(c)
&& !tips.contains(c)
&& (history.size() < BASE_COMMITS || (++stepCnt % STEP_COMMITS) == 0)) {
history.add(c);
}