Commit f370ef24 by Michael Koch Committed by Michael Koch

2004-07-30 Michael Koch <konqueror@gmx.de>

	* java/util/zip/GZIPInputStream.java
	(GZIPInputStream): Increase buffer size to 4k.
	* java/util/zip/GZIPOutputStream.java
	(GZIPOutputStream): Likewise.
	* java/util/zip/Inflater.java
	(setInput): Merged formating with GNU classpath.
	* java/util/zip/InflaterInputStream.java
	(InflaterInputStream): Increase buffer size to 4k.
	(fill): Throw exception if stream ends early.
	(read): Merged endless-loop with GNU classpath.
	(skip): Increase buffer size to 2k.

From-SVN: r85340
parent fbc87627
2004-07-30 Michael Koch <konqueror@gmx.de> 2004-07-30 Michael Koch <konqueror@gmx.de>
* java/util/zip/GZIPInputStream.java
(GZIPInputStream): Increase buffer size to 4k.
* java/util/zip/GZIPOutputStream.java
(GZIPOutputStream): Likewise.
* java/util/zip/Inflater.java
(setInput): Merged formating with GNU classpath.
* java/util/zip/InflaterInputStream.java
(InflaterInputStream): Increase buffer size to 4k.
(fill): Throw exception if stream ends early.
(read): Merged endless-loop with GNU classpath.
(skip): Increase buffer size to 2k.
2004-07-30 Michael Koch <konqueror@gmx.de>
* gnu/java/awt/EmbeddedWindow.java * gnu/java/awt/EmbeddedWindow.java
(addNotify): Use AccessController to allow execution of privileged (addNotify): Use AccessController to allow execution of privileged
code. code.
......
...@@ -104,7 +104,7 @@ public class GZIPInputStream ...@@ -104,7 +104,7 @@ public class GZIPInputStream
public GZIPInputStream(InputStream in) public GZIPInputStream(InputStream in)
throws IOException throws IOException
{ {
this(in, 512); this(in, 4096);
} }
/** /**
......
...@@ -69,7 +69,7 @@ public class GZIPOutputStream extends DeflaterOutputStream ...@@ -69,7 +69,7 @@ public class GZIPOutputStream extends DeflaterOutputStream
*/ */
public GZIPOutputStream(OutputStream out) throws IOException public GZIPOutputStream(OutputStream out) throws IOException
{ {
this(out, 512); this(out, 4096);
} }
/** /**
......
...@@ -251,7 +251,7 @@ public class Inflater ...@@ -251,7 +251,7 @@ public class Inflater
* @param buffer the input. * @param buffer the input.
* @exception IllegalStateException if no input is needed. * @exception IllegalStateException if no input is needed.
*/ */
public void setInput (byte[] buf) public void setInput (byte[] buf)
{ {
setInput (buf, 0, buf.length); setInput (buf, 0, buf.length);
} }
......
...@@ -79,7 +79,7 @@ public class InflaterInputStream extends FilterInputStream ...@@ -79,7 +79,7 @@ public class InflaterInputStream extends FilterInputStream
*/ */
public InflaterInputStream(InputStream in) public InflaterInputStream(InputStream in)
{ {
this(in, new Inflater(), 512); this(in, new Inflater(), 4096);
} }
/** /**
...@@ -91,7 +91,7 @@ public class InflaterInputStream extends FilterInputStream ...@@ -91,7 +91,7 @@ public class InflaterInputStream extends FilterInputStream
*/ */
public InflaterInputStream(InputStream in, Inflater inf) public InflaterInputStream(InputStream in, Inflater inf)
{ {
this(in, inf, 512); this(in, inf, 4096);
} }
/** /**
...@@ -149,8 +149,10 @@ public class InflaterInputStream extends FilterInputStream ...@@ -149,8 +149,10 @@ public class InflaterInputStream extends FilterInputStream
len = in.read(buf, 0, buf.length); len = in.read(buf, 0, buf.length);
if (len != -1) if (len < 0)
inf.setInput(buf, 0, len); throw new ZipException("Deflated stream ends early.");
inf.setInput(buf, 0, len);
} }
/** /**
...@@ -170,7 +172,7 @@ public class InflaterInputStream extends FilterInputStream ...@@ -170,7 +172,7 @@ public class InflaterInputStream extends FilterInputStream
return -1; return -1;
int count = 0; int count = 0;
while (count == 0) for (;;)
{ {
if (inf.needsInput()) if (inf.needsInput())
fill(); fill();
...@@ -193,8 +195,10 @@ public class InflaterInputStream extends FilterInputStream ...@@ -193,8 +195,10 @@ public class InflaterInputStream extends FilterInputStream
{ {
throw new ZipException(dfe.getMessage()); throw new ZipException(dfe.getMessage());
} }
if (count > 0)
return count;
} }
return count;
} }
/** /**
...@@ -212,18 +216,18 @@ public class InflaterInputStream extends FilterInputStream ...@@ -212,18 +216,18 @@ public class InflaterInputStream extends FilterInputStream
if (n == 0) if (n == 0)
return 0; return 0;
int buflen = (int) Math.min(n, 1024); int buflen = (int) Math.min(n, 2048);
byte[] tmpbuf = new byte[buflen]; byte[] tmpbuf = new byte[buflen];
long skipped = 0L; long skipped = 0L;
while (n > 0L) while (n > 0L)
{ {
int numread = read(tmpbuf, 0, buflen); int numread = read(tmpbuf, 0, buflen);
if (numread == -1) if (numread <= 0)
break; break;
n -= numread; n -= numread;
skipped += numread; skipped += numread;
buflen = (int) Math.min(n, 1024); buflen = (int) Math.min(n, 2048);
} }
return skipped; return skipped;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment