[jbosscache-commits] JBoss Cache SVN: r6761 - core/trunk/src/main/java/org/jboss/cache/marshall.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-09-19 10:34:58 -0400 (Fri, 19 Sep 2008)
New Revision: 6761

Modified:
   core/trunk/src/main/java/org/jboss/cache/marshall/CacheMarshaller200.java
Log:
Buffered read for byte arrays

Modified: core/trunk/src/main/java/org/jboss/cache/marshall/CacheMarshaller200.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/marshall/CacheMarshaller200.java	2008-09-19 13:01:33 UTC (rev 6760)
+++ core/trunk/src/main/java/org/jboss/cache/marshall/CacheMarshaller200.java	2008-09-19 14:34:58 UTC (rev 6761)
@@ -937,7 +937,15 @@
             if (isPrim)
             {
                byte[] a = new byte[sz];
-               in.read(a);
+               int bsize = 10240;
+               int offset = 0;
+               int bytesLeft = sz;
+               while (bytesLeft > 0)
+               {
+                  int read = in.read(a, offset, Math.min(bsize, bytesLeft));
+                  offset += read;
+                  bytesLeft -= read;
+               }
                return a;
             }
             else