in hessian-lite/src/main/java/com/alibaba/com/caucho/hessian/io/Hessian2Input.java [2120:2212]
public int readBytes(byte[] buffer, int offset, int length)
throws IOException {
int readLength = 0;
if (_chunkLength == END_OF_DATA) {
_chunkLength = 0;
return -1;
} else if (_chunkLength == 0) {
int tag = read();
switch (tag) {
case 'N':
return -1;
case 'B':
case BC_BINARY_CHUNK:
_isLastChunk = tag == 'B';
_chunkLength = (read() << 8) + read();
break;
case 0x20:
case 0x21:
case 0x22:
case 0x23:
case 0x24:
case 0x25:
case 0x26:
case 0x27:
case 0x28:
case 0x29:
case 0x2a:
case 0x2b:
case 0x2c:
case 0x2d:
case 0x2e:
case 0x2f: {
_isLastChunk = true;
_chunkLength = tag - 0x20;
break;
}
case 0x34:
case 0x35:
case 0x36:
case 0x37: {
_isLastChunk = true;
_chunkLength = (tag - 0x34) * 256 + read();
break;
}
default:
throw expect("binary", tag);
}
}
while (length > 0) {
if (_chunkLength > 0) {
buffer[offset++] = (byte) read();
_chunkLength--;
length--;
readLength++;
} else if (_isLastChunk) {
if (readLength == 0)
return -1;
else {
_chunkLength = END_OF_DATA;
return readLength;
}
} else {
int tag = read();
switch (tag) {
case 'B':
case BC_BINARY_CHUNK:
_isLastChunk = tag == 'B';
_chunkLength = (read() << 8) + read();
break;
default:
throw expect("binary", tag);
}
}
}
if (readLength == 0)
return -1;
else if (_chunkLength > 0 || !_isLastChunk)
return readLength;
else {
_chunkLength = END_OF_DATA;
return readLength;
}
}