You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by ch...@apache.org on 2014/04/16 07:21:37 UTC
svn commit: r1587802 -
/jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/ExternalBlobTest.java
Author: chetanm
Date: Wed Apr 16 05:21:37 2014
New Revision: 1587802
URL: http://svn.apache.org/r1587802
Log:
OAK-1667 - Encode Blob length as part of blobId in DataStoreBlobStore
Fix the test logic as we encode the length by default.
Modified:
jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/ExternalBlobTest.java
Modified: jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/ExternalBlobTest.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/ExternalBlobTest.java?rev=1587802&r1=1587801&r2=1587802&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/ExternalBlobTest.java (original)
+++ jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/ExternalBlobTest.java Wed Apr 16 05:21:37 2014
@@ -17,6 +17,7 @@
package org.apache.jackrabbit.oak.plugins.segment;
import org.apache.commons.io.FileUtils;
+import org.apache.commons.io.IOUtils;
import org.apache.jackrabbit.core.data.DataIdentifier;
import org.apache.jackrabbit.core.data.FileDataStore;
import org.apache.jackrabbit.oak.api.Blob;
@@ -77,7 +78,9 @@ public class ExternalBlobTest {
Blob b2 = testCreateAndRead(nodeStore.createBlob(new ByteArrayInputStream(data2)));
assertTrue(b2 instanceof SegmentBlob);
assertNotNull(b2.getReference());
- assertNotNull(dbs.getRecordIfStored(new DataIdentifier(((SegmentBlob) b2).getBlobId())));
+ InputStream is = dbs.getInputStream(((SegmentBlob) b2).getBlobId());
+ assertNotNull(IOUtils.contentEquals(new ByteArrayInputStream(data2), is));
+ is.close();
}
public Blob testCreateAndRead(Blob blob) throws Exception {