adjust buffer size

This commit is contained in:
Taro L. Saito 2011-03-30 14:05:23 +09:00
parent 165168f1cb
commit fa2fcabc43

View File

@ -48,20 +48,26 @@ public class SnappyTest
@Test @Test
public void load() throws Exception { public void load() throws Exception {
ByteBuffer src = ByteBuffer.allocateDirect(1024); StringBuilder s = new StringBuilder();
src.put("hello world".getBytes()); for (int i = 0; i < 20; ++i) {
s.append("Hello world!");
}
byte[] orig = s.toString().getBytes();
int BUFFER_SIZE = orig.length;
ByteBuffer src = ByteBuffer.allocateDirect(orig.length * 2);
src.put(orig);
src.flip(); src.flip();
_logger.info("input size: " + src.remaining());
int maxCompressedLen = Snappy.getMaxCompressedLength(src.remaining()); int maxCompressedLen = Snappy.getMaxCompressedLength(src.remaining());
_logger.info("max compressed length:" + maxCompressedLen); _logger.info("max compressed length:" + maxCompressedLen);
ByteBuffer compressed = ByteBuffer.allocateDirect(1024); ByteBuffer compressed = ByteBuffer.allocateDirect(maxCompressedLen);
int compressedSize = Snappy.compress(src, compressed); int compressedSize = Snappy.compress(src, compressed);
_logger.info("compressed size: " + compressedSize); _logger.info("compressed length: " + compressedSize);
int uncompressedLen = Snappy.getUncompressedLength(compressed); int uncompressedLen = Snappy.getUncompressedLength(compressed);
_logger.info("uncompressed length: " + uncompressedLen); _logger.info("uncompressed length: " + uncompressedLen);
ByteBuffer extract = ByteBuffer.allocateDirect(1024); ByteBuffer extract = ByteBuffer.allocateDirect(uncompressedLen);
Snappy.decompress(compressed, extract); Snappy.decompress(compressed, extract);
extract.limit(uncompressedLen); extract.limit(uncompressedLen);