|
|
@ -377,7 +377,7 @@ public abstract class BasePackFetchConnection extends BasePackConnection |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void close() { |
|
|
|
public void close() { |
|
|
|
if (walk != null) |
|
|
|
if (walk != null) |
|
|
|
walk.release(); |
|
|
|
walk.close(); |
|
|
|
super.close(); |
|
|
|
super.close(); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -753,16 +753,13 @@ public abstract class BasePackFetchConnection extends BasePackConnection |
|
|
|
input = new SideBandInputStream(input, monitor, getMessageWriter(), |
|
|
|
input = new SideBandInputStream(input, monitor, getMessageWriter(), |
|
|
|
outputStream); |
|
|
|
outputStream); |
|
|
|
|
|
|
|
|
|
|
|
ObjectInserter ins = local.newObjectInserter(); |
|
|
|
try (ObjectInserter ins = local.newObjectInserter()) { |
|
|
|
try { |
|
|
|
|
|
|
|
PackParser parser = ins.newPackParser(input); |
|
|
|
PackParser parser = ins.newPackParser(input); |
|
|
|
parser.setAllowThin(thinPack); |
|
|
|
parser.setAllowThin(thinPack); |
|
|
|
parser.setObjectChecker(transport.getObjectChecker()); |
|
|
|
parser.setObjectChecker(transport.getObjectChecker()); |
|
|
|
parser.setLockMessage(lockMessage); |
|
|
|
parser.setLockMessage(lockMessage); |
|
|
|
packLock = parser.parse(monitor); |
|
|
|
packLock = parser.parse(monitor); |
|
|
|
ins.flush(); |
|
|
|
ins.flush(); |
|
|
|
} finally { |
|
|
|
|
|
|
|
ins.release(); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|