Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

Fixed bug in ByteBufferMarshaller

Browse Source
This commit is contained in:
leventov
2015-02-13 13:29:55 +07:00
parent befe50ec48
commit 9580010d61
1 changed files with 16 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/hash/serialization/internal/ByteBufferMarshaller.java
+16 -8
View File
@@ -37,14 +37,22 @@ public enum ByteBufferMarshaller implements BytesInterop<ByteBuffer>, BytesReade
long pos = bytes.position();
int inputPos = bb.position();
int i;
for(i = 0; i < inputRemaining - 7; i += 8) {
if (bytes.readLong(pos + (long) i) != bb.getLong(inputPos + i))
return false;
}
for(; i < inputRemaining - 3; i += 4) {
if (bytes.readInt(pos + (long) i) != bb.getInt(inputPos + i))
return false;
int i = 0;
if (bytes.byteOrder() == bb.order()) {
for (; i < inputRemaining - 7; i += 8) {
if (bytes.readLong(pos + (long) i) != bb.getLong(inputPos + i))
return false;
}
if (i < inputRemaining - 3) {
if (bytes.readInt(pos + (long) i) != bb.getInt(inputPos + i))
return false;
i += 4;
}
if (i < inputRemaining - 1) {
if (bytes.readChar(pos + (long) i) != bb.getChar(inputPos + i))
return false;
i += 2;
}
}
for(; i < inputRemaining; i++) {
if (bytes.readByte(pos + (long) i) != bb.get(inputPos + i))