github
/
jgit
mirror of https://gitee.com/github-mirror-repo/jgit.git
1
0
Fork 0
Code Issues Releases Wiki Activity
Browse Source

PackFileTest: Open ObjectInserter.Formatter in try-with-resource 

Change-Id: I9c56b5efdb9c13b929073a786092a707fca21281
Signed-off-by: David Pursehouse <david.pursehouse@sonymobile.com>
stable-4.2
David Pursehouse 9 years ago
parent
bebd30f364
commit
5c84145fd0
1 changed files with 112 additions and 109 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 221
      org.eclipse.jgit.test/tst/org/eclipse/jgit/internal/storage/file/PackFileTest.java

221
org.eclipse.jgit.test/tst/org/eclipse/jgit/internal/storage/file/PackFileTest.java
Unescape View File

@ -191,119 +191,122 @@ public class PackFileTest extends LocalDiskRepositoryTestCase {
@Test @Test
public void testDelta_SmallObjectChain() throws Exception { public void testDelta_SmallObjectChain() throws Exception {
ObjectInserter.Formatter fmt = new ObjectInserter.Formatter(); try (ObjectInserter.Formatter fmt = new ObjectInserter.Formatter()) {
byte[] data0 = new byte[512]; byte[] data0 = new byte[512];
Arrays.fill(data0, (byte) 0xf3); Arrays.fill(data0, (byte) 0xf3);
ObjectId id0 = fmt.idFor(Constants.OBJ_BLOB, data0); ObjectId id0 = fmt.idFor(Constants.OBJ_BLOB, data0);
TemporaryBuffer.Heap pack = new TemporaryBuffer.Heap(64 * 1024); TemporaryBuffer.Heap pack = new TemporaryBuffer.Heap(64 * 1024);
packHeader(pack, 4); packHeader(pack, 4);
objectHeader(pack, Constants.OBJ_BLOB, data0.length); objectHeader(pack, Constants.OBJ_BLOB, data0.length);
deflate(pack, data0); deflate(pack, data0);
byte[] data1 = clone(0x01, data0); byte[] data1 = clone(0x01, data0);
byte[] delta1 = delta(data0, data1); byte[] delta1 = delta(data0, data1);
ObjectId id1 = fmt.idFor(Constants.OBJ_BLOB, data1); ObjectId id1 = fmt.idFor(Constants.OBJ_BLOB, data1);
objectHeader(pack, Constants.OBJ_REF_DELTA, delta1.length); objectHeader(pack, Constants.OBJ_REF_DELTA, delta1.length);
id0.copyRawTo(pack); id0.copyRawTo(pack);
deflate(pack, delta1); deflate(pack, delta1);
byte[] data2 = clone(0x02, data1); byte[] data2 = clone(0x02, data1);
byte[] delta2 = delta(data1, data2); byte[] delta2 = delta(data1, data2);
ObjectId id2 = fmt.idFor(Constants.OBJ_BLOB, data2); ObjectId id2 = fmt.idFor(Constants.OBJ_BLOB, data2);
objectHeader(pack, Constants.OBJ_REF_DELTA, delta2.length); objectHeader(pack, Constants.OBJ_REF_DELTA, delta2.length);
id1.copyRawTo(pack); id1.copyRawTo(pack);
deflate(pack, delta2); deflate(pack, delta2);
byte[] data3 = clone(0x03, data2); byte[] data3 = clone(0x03, data2);
byte[] delta3 = delta(data2, data3); byte[] delta3 = delta(data2, data3);
ObjectId id3 = fmt.idFor(Constants.OBJ_BLOB, data3); ObjectId id3 = fmt.idFor(Constants.OBJ_BLOB, data3);
objectHeader(pack, Constants.OBJ_REF_DELTA, delta3.length); objectHeader(pack, Constants.OBJ_REF_DELTA, delta3.length);
id2.copyRawTo(pack); id2.copyRawTo(pack);
deflate(pack, delta3); deflate(pack, delta3);
digest(pack); digest(pack);
PackParser ip = index(pack.toByteArray()); PackParser ip = index(pack.toByteArray());
ip.setAllowThin(true); ip.setAllowThin(true);
ip.parse(NullProgressMonitor.INSTANCE); ip.parse(NullProgressMonitor.INSTANCE);
assertTrue("has blob", wc.has(id3)); assertTrue("has blob", wc.has(id3));
ObjectLoader ol = wc.open(id3); ObjectLoader ol = wc.open(id3);
assertNotNull("created loader", ol); assertNotNull("created loader", ol);
assertEquals(Constants.OBJ_BLOB, ol.getType()); assertEquals(Constants.OBJ_BLOB, ol.getType());
assertEquals(data3.length, ol.getSize()); assertEquals(data3.length, ol.getSize());
assertFalse("is large", ol.isLarge()); assertFalse("is large", ol.isLarge());
assertNotNull(ol.getCachedBytes()); assertNotNull(ol.getCachedBytes());
assertArrayEquals(data3, ol.getCachedBytes()); assertArrayEquals(data3, ol.getCachedBytes());
ObjectStream in = ol.openStream(); ObjectStream in = ol.openStream();
assertNotNull("have stream", in); assertNotNull("have stream", in);
assertEquals(Constants.OBJ_BLOB, in.getType()); assertEquals(Constants.OBJ_BLOB, in.getType());
assertEquals(data3.length, in.getSize()); assertEquals(data3.length, in.getSize());
byte[] act = new byte[data3.length]; byte[] act = new byte[data3.length];
IO.readFully(in, act, 0, data3.length); IO.readFully(in, act, 0, data3.length);
assertTrue("same content", Arrays.equals(act, data3)); assertTrue("same content", Arrays.equals(act, data3));
assertEquals("stream at EOF", -1, in.read()); assertEquals("stream at EOF", -1, in.read());
in.close(); in.close();
}
} }
@Test @Test
public void testDelta_FailsOver2GiB() throws Exception { public void testDelta_FailsOver2GiB() throws Exception {
ObjectInserter.Formatter fmt = new ObjectInserter.Formatter(); try (ObjectInserter.Formatter fmt = new ObjectInserter.Formatter()) {
byte[] base = new byte[] { 'a' }; byte[] base = new byte[] { 'a' };
ObjectId idA = fmt.idFor(Constants.OBJ_BLOB, base); ObjectId idA = fmt.idFor(Constants.OBJ_BLOB, base);
ObjectId idB = fmt.idFor(Constants.OBJ_BLOB, new byte[] { 'b' }); ObjectId idB = fmt.idFor(Constants.OBJ_BLOB, new byte[] { 'b' });
PackedObjectInfo a = new PackedObjectInfo(idA); PackedObjectInfo a = new PackedObjectInfo(idA);
PackedObjectInfo b = new PackedObjectInfo(idB); PackedObjectInfo b = new PackedObjectInfo(idB);
TemporaryBuffer.Heap pack = new TemporaryBuffer.Heap(64 * 1024); TemporaryBuffer.Heap pack = new TemporaryBuffer.Heap(64 * 1024);
packHeader(pack, 2); packHeader(pack, 2);
a.setOffset(pack.length()); a.setOffset(pack.length());
objectHeader(pack, Constants.OBJ_BLOB, base.length); objectHeader(pack, Constants.OBJ_BLOB, base.length);
deflate(pack, base); deflate(pack, base);
ByteArrayOutputStream tmp = new ByteArrayOutputStream(); ByteArrayOutputStream tmp = new ByteArrayOutputStream();
DeltaEncoder de = new DeltaEncoder(tmp, base.length, 3L << 30); DeltaEncoder de = new DeltaEncoder(tmp, base.length, 3L << 30);
de.copy(0, 1); de.copy(0, 1);
byte[] delta = tmp.toByteArray(); byte[] delta = tmp.toByteArray();
b.setOffset(pack.length()); b.setOffset(pack.length());
objectHeader(pack, Constants.OBJ_REF_DELTA, delta.length); objectHeader(pack, Constants.OBJ_REF_DELTA, delta.length);
idA.copyRawTo(pack); idA.copyRawTo(pack);
deflate(pack, delta); deflate(pack, delta);
byte[] footer = digest(pack); byte[] footer = digest(pack);
File dir = new File(repo.getObjectDatabase().getDirectory(), "pack"); File dir = new File(repo.getObjectDatabase().getDirectory(),
File packName = new File(dir, idA.name() + ".pack"); "pack");
File idxName = new File(dir, idA.name() + ".idx"); File packName = new File(dir, idA.name() + ".pack");
File idxName = new File(dir, idA.name() + ".idx");
FileOutputStream f = new FileOutputStream(packName);
try { FileOutputStream f = new FileOutputStream(packName);
f.write(pack.toByteArray()); try {
} finally { f.write(pack.toByteArray());
f.close(); } finally {
} f.close();
}
f = new FileOutputStream(idxName);
try { f = new FileOutputStream(idxName);
List<PackedObjectInfo> list = new ArrayList<PackedObjectInfo>(); try {
list.add(a); List<PackedObjectInfo> list = new ArrayList<PackedObjectInfo>();
list.add(b); list.add(a);
Collections.sort(list); list.add(b);
new PackIndexWriterV1(f).write(list, footer); Collections.sort(list);
} finally { new PackIndexWriterV1(f).write(list, footer);
f.close(); } finally {
} f.close();
}
PackFile packFile = new PackFile(packName, PackExt.INDEX.getBit());
try { PackFile packFile = new PackFile(packName, PackExt.INDEX.getBit());
packFile.get(wc, b); try {
fail("expected LargeObjectException.ExceedsByteArrayLimit"); packFile.get(wc, b);
} catch (LargeObjectException.ExceedsByteArrayLimit bad) { fail("expected LargeObjectException.ExceedsByteArrayLimit");
assertNull(bad.getObjectId()); } catch (LargeObjectException.ExceedsByteArrayLimit bad) {
} finally { assertNull(bad.getObjectId());
packFile.close(); } finally {
packFile.close();
}
} }
} }

Write Preview
Loading…
Cancel
Save