diff options
| -rw-r--r-- | org.eclipse.jgit/src/org/eclipse/jgit/transport/WalkFetchConnection.java | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/org.eclipse.jgit/src/org/eclipse/jgit/transport/WalkFetchConnection.java b/org.eclipse.jgit/src/org/eclipse/jgit/transport/WalkFetchConnection.java index 17edfdc4fb..c90cadf7b6 100644 --- a/org.eclipse.jgit/src/org/eclipse/jgit/transport/WalkFetchConnection.java +++ b/org.eclipse.jgit/src/org/eclipse/jgit/transport/WalkFetchConnection.java @@ -195,7 +195,7 @@ class WalkFetchConnection extends BaseFetchConnection { local = wt.local; objCheck = wt.getObjectChecker(); inserter = local.newObjectInserter(); - reader = local.newObjectReader(); + reader = inserter.newReader(); remotes = new ArrayList<WalkRemoteObjectDatabase>(); remotes.add(w); @@ -240,6 +240,12 @@ class WalkFetchConnection extends BaseFetchConnection { downloadObject(monitor, id); process(id); } + + try { + inserter.flush(); + } catch (IOException e) { + throw new TransportException(e.getMessage(), e); + } } public Collection<PackLock> getPackLocks() { @@ -652,7 +658,6 @@ class WalkFetchConnection extends BaseFetchConnection { Constants.typeString(type), Integer.valueOf(compressed.length))); } - inserter.flush(); } private Collection<WalkRemoteObjectDatabase> expandOneAlternate( @@ -883,7 +888,6 @@ class WalkFetchConnection extends BaseFetchConnection { PackLock lock = parser.parse(monitor); if (lock != null) packLocks.add(lock); - inserter.flush(); } } } |