bug 10946: Add default buffer length for compressed request

Then it can support 2.2.8 system vm connection.

status 10946: resolved fixed
This commit is contained in:
Sheng Yang 2011-08-03 11:24:20 -07:00
parent a7bc955822
commit cb5e4574f9
1 changed files with 6 additions and 1 deletions

View File

@ -259,6 +259,11 @@ public class Request {
public static ByteBuffer doDecompress(ByteBuffer buffer, int length) {
byte[] byteArrayIn = new byte[1024];
int allocLength = length;
/* Add default length to support 2.2.8 */
if (allocLength < 65535) {
allocLength = 65535;
}
ByteArrayInputStream byteIn;
if (buffer.hasArray()) {
byteIn = new ByteArrayInputStream(buffer.array(),
@ -269,7 +274,7 @@ public class Request {
buffer.get(array);
byteIn = new ByteArrayInputStream(array);
}
ByteBuffer retBuff = ByteBuffer.allocate(length);
ByteBuffer retBuff = ByteBuffer.allocate(allocLength);
int len = 0;
try {
GZIPInputStream in = new GZIPInputStream(byteIn);