ArrayIndexOutOfBoundsException in Tree.d_code

  * #9
  * fixed a bug in calculating the size of the pending buffer.
  * added a test case based on https://github.com/jglick/jzlib-9-demo

src/main/java/com/jcraft/jzlib/Deflate.java

@@ -1384,7 +1384,7 @@ else if(windowBits > 15){
     pending_buf = new byte[lit_bufsize*4];
     pending_buf_size = lit_bufsize*4;
 
-    d_buf = lit_bufsize/2;
+    d_buf = lit_bufsize;
     l_buf = (1+2)*lit_bufsize;
 
     this.level = level;

src/test/scala/GZIPIOStreamTest.scala

@@ -5,6 +5,10 @@ import org.scalatest._
 import org.scalatest.matchers.ShouldMatchers
 
 import java.io._
+import java.util.zip.CheckedOutputStream
+import java.util.zip.CheckedInputStream
+import java.util.zip.{GZIPInputStream => juzGZIPInputStream}
+import java.util.zip.{CRC32 => juzCRC32}
 
 import JZlib._
 
@@ -16,7 +20,7 @@ class GZIPIOStreamTest extends FlatSpec with BeforeAndAfter with ShouldMatchers
   after {
   }
 
-  behavior of "GZipOutputStream and GZipInputStream"
+  behavior of "GZIPOutputStream and GZIPInputStream"
 
   it can "deflate and infate data." in {
 
@@ -53,4 +57,34 @@ class GZIPIOStreamTest extends FlatSpec with BeforeAndAfter with ShouldMatchers
 
     crc32.getValue should equal(gis.getCRC.asInstanceOf[Long])
   }
+
+  behavior of "GZIPOutputStream"
+
+  // https://github.com/ymnk/jzlib/issues/9
+  // https://github.com/jglick/jzlib-9-demo
+  it can "deflate some file without AIOOBE." in {
+    val pos = new PipedOutputStream()
+    val pis = new PipedInputStream(pos)
+    val csOut = new juzCRC32()
+    val gos = new GZIPOutputStream(pos)
+    val cos = new CheckedOutputStream(gos, csOut)
+
+    val t = new Thread() {
+      override def run = {
+        val fail = "/jzlib.fail.gz".fromResource
+        val fis = new juzGZIPInputStream(new ByteArrayInputStream(fail))
+        fis -> cos
+        cos.close()
+      }
+    }
+    t.start();
+
+    val gis = new GZIPInputStream(pis)
+    val csIn = new juzCRC32();
+    new CheckedInputStream(gis, csIn) -> new ByteArrayOutputStream()
+
+    t.join()
+
+    csIn.getValue() should equal(csOut.getValue)
+  }
 }

src/test/scala/package.scala

@@ -5,13 +5,25 @@ import java.io._
 
 package object jzlib {
   implicit def readIS(is: InputStream) = new {
-      def ->(out: OutputStream)(implicit buf: Array[Byte]) = {
-      Stream.continually(is.read(buf)).
-                         takeWhile(-1 !=).foreach(i => out.write(buf, 0, i))
+      def ->(out: OutputStream)
+            (implicit buf: Array[Byte] = new Array[Byte](1024)) = {
+      Stream.
+        continually(is.read(buf)).
+        takeWhile(-1 !=).
+        foreach(i => out.write(buf, 0, i))
       is.close
     }
   }
 
+  // reading a resource file 
+  implicit def fromResource(str: String ) = new {
+    def fromResource: Array[Byte] =
+      io.Source.
+         fromURL(getClass.getResource(str))(io.Codec.ISO8859).
+         map(_.toByte).
+         toArray
+  }
+
   implicit def readArray(is: Array[Byte]) = new {
       def ->(out: OutputStream)(implicit buf: Array[Byte]) = {
         new ByteArrayInputStream(is) -> (out)