GC unused GrowableBufferOutputStream

1 files changed, 0 insertions, 131 deletions

diff --git a/vespajlib/src/test/java/com/yahoo/io/GrowableBufferOutputStreamTestCase.java b/vespajlib/src/test/java/com/yahoo/io/GrowableBufferOutputStreamTestCase.java
deleted file mode 100644
index 9c905979131..00000000000
--- a/vespajlib/src/test/java/com/yahoo/io/GrowableBufferOutputStreamTestCase.java
+++ /dev/null
@@ -1,131 +0,0 @@
-// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-package com.yahoo.io;
-
-import java.nio.channels.WritableByteChannel;
-import java.nio.ByteBuffer;
-import java.io.IOException;
-import com.yahoo.io.GrowableBufferOutputStream;
-import org.junit.Before;
-import org.junit.Test;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.fail;
-
-
-/**
- * Tests the GrowableBufferOutputStream
- *
- * @author Bjorn Borud
- */
-public class GrowableBufferOutputStreamTestCase {
-
-    private byte[] testData;
-
-    static class DummyWritableByteChannel implements WritableByteChannel {
-        private ByteBuffer buffer;
-
-        public DummyWritableByteChannel(ByteBuffer buffer) {
-            this.buffer = buffer;
-        }
-
-        public int write(ByteBuffer src) {
-            int written = Math.min(src.remaining(), buffer.remaining());
-
-            if (buffer.remaining() < src.remaining()) {
-                ByteBuffer tmp = src.slice();
-
-                tmp.limit(written);
-                src.position(src.position() + written);
-            } else {
-                buffer.put(src);
-            }
-            return written;
-        }
-
-        public boolean isOpen() {
-            return true;
-        }
-
-        public void close() {}
-    }
-
-    @Before
-    public void setUp() {
-        testData = new byte[100];
-        for (int i = 0; i < 100; ++i) {
-            testData[i] = (byte) i;
-        }
-    }
-
-    @Test
-    public void testSimple() throws IOException {
-        GrowableBufferOutputStream g = new GrowableBufferOutputStream(10, 5);
-
-        g.write(testData, 0, 100);
-        g.flush();
-        assertEquals(10, g.numWritableBuffers());
-        assertEquals(100, g.writableSize());
-
-        ByteBuffer sink = ByteBuffer.allocate(60);
-        DummyWritableByteChannel channel = new DummyWritableByteChannel(sink);
-        int written = g.channelWrite(channel);
-
-        assertEquals(60, written);
-        assertEquals(60, sink.position());
-        assertEquals(40, g.writableSize());
-
-        // there should be 4 buffers left now
-        assertEquals(4, g.numWritableBuffers());
-
-        // ensure that we got what we expected
-        for (int i = 0; i < 60; ++i) {
-            if (((int) sink.get(i)) != i) {
-                fail();
-            }
-        }
-
-        // then we write more data
-        g.write(testData, 0, 100);
-        g.flush();
-        assertEquals(140, g.writableSize());
-
-        // ...which implies that we should now have 14 writable buffers
-        assertEquals(14, g.numWritableBuffers());
-
-        // reset the sink so it can consume more data
-        sink.clear();
-
-        // then write more to the DummyWritableByteChannel
-        written = g.channelWrite(channel);
-        assertEquals(60, written);
-        assertEquals(60, sink.position());
-        assertEquals(80, g.writableSize());
-
-        // now there should be 8 buffers
-        assertEquals(8, g.numWritableBuffers());
-
-        // ensure that we got what we expected
-        for (int i = 0; i < 60; ++i) {
-            int val = (int) sink.get(i);
-            int expected = (i + 60) % 100;
-
-            if (val != expected) {
-                fail("Value was " + val + " and not " + i);
-            }
-        }
-
-        // when we clear there should be no buffers
-        g.clear();
-        assertEquals(0, g.numWritableBuffers());
-        assertEquals(0, g.writableSize());
-
-        // ditto after flush after clear
-        g.flush();
-        assertEquals(0, g.numWritableBuffers());
-
-        // flush the cache too
-        g.clearAll();
-        assertEquals(0, g.numWritableBuffers());
-    }
-
-}