mirror of https://github.com/zlatinb/muwire
forgot 0x
parent
cfe1fe98b0
commit
4e09b4ad71
|
@ -80,7 +80,7 @@ class PeerConnection extends Connection {
|
||||||
payload = (byte[]) message
|
payload = (byte[]) message
|
||||||
DataUtil.packHeader(payload.length, writeHeader)
|
DataUtil.packHeader(payload.length, writeHeader)
|
||||||
log.fine "$name writing binary message length ${payload.length}"
|
log.fine "$name writing binary message length ${payload.length}"
|
||||||
writeHeader[0] |= (byte)80
|
writeHeader[0] |= (byte)0x80
|
||||||
} else
|
} else
|
||||||
throw new IllegalArgumentException()
|
throw new IllegalArgumentException()
|
||||||
|
|
||||||
|
|
|
@ -32,6 +32,13 @@ class DataUtilTest {
|
||||||
DataUtil.packHeader(value, header)
|
DataUtil.packHeader(value, header)
|
||||||
assert value == DataUtil.readLength(header)
|
assert value == DataUtil.readLength(header)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private static binaryHeader(int value) {
|
||||||
|
byte [] header = new byte[3]
|
||||||
|
DataUtil.packHeader(value, header)
|
||||||
|
header[0] |= (byte)0x80
|
||||||
|
assert value == DataUtil.readLength(header)
|
||||||
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void testHeader() {
|
void testHeader() {
|
||||||
|
@ -44,4 +51,17 @@ class DataUtilTest {
|
||||||
fail()
|
fail()
|
||||||
} catch (IllegalArgumentException expected) {}
|
} catch (IllegalArgumentException expected) {}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void testBinaryHeader() {
|
||||||
|
binaryHeader(0)
|
||||||
|
binaryHeader(1)
|
||||||
|
binaryHeader(556)
|
||||||
|
binaryHeader(8 * 1024 * 1024 - 1)
|
||||||
|
try {
|
||||||
|
binaryHeader(8 * 1024 * 1024)
|
||||||
|
fail()
|
||||||
|
} catch (IllegalArgumentException expected) {}
|
||||||
|
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue