so suddenly ServerTest is less reliable?
This commit is contained in:
parent
80153e276b
commit
9afe527a9a
|
@ -211,7 +211,7 @@ public class BinaryProtocolServer implements BinaryProtocolCommands {
|
||||||
int crc = in.readInt();
|
int crc = in.readInt();
|
||||||
int fromPacket = IoHelper.getCrc32(packet);
|
int fromPacket = IoHelper.getCrc32(packet);
|
||||||
if (crc != fromPacket)
|
if (crc != fromPacket)
|
||||||
throw new IllegalStateException("CRC mismatch " + crc + " vs " + fromPacket + " " + IoStream.printHexBinary(packet));
|
throw new IllegalStateException("CRC mismatch crc=" + Integer.toString(crc, 16) + " vs packet=" + Integer.toString(fromPacket, 16) + " len=" + packet.length + " data: " + IoStream.printHexBinary(packet));
|
||||||
return new Packet(packet, crc);
|
return new Packet(packet, crc);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -121,7 +121,7 @@ public class ServerTest {
|
||||||
int serverPortForRemoteUsers = 6800;
|
int serverPortForRemoteUsers = 6800;
|
||||||
|
|
||||||
UserDetailsResolver userDetailsResolver = authToken -> new UserDetails(authToken.substring(0, 5), authToken.charAt(6));
|
UserDetailsResolver userDetailsResolver = authToken -> new UserDetails(authToken.substring(0, 5), authToken.charAt(6));
|
||||||
int httpPort = 8001;
|
int httpPort = 8002;
|
||||||
|
|
||||||
CountDownLatch disconnectedCountDownLatch = new CountDownLatch(1);
|
CountDownLatch disconnectedCountDownLatch = new CountDownLatch(1);
|
||||||
|
|
||||||
|
@ -158,7 +158,7 @@ public class ServerTest {
|
||||||
CountDownLatch controllerRegistered = new CountDownLatch(1);
|
CountDownLatch controllerRegistered = new CountDownLatch(1);
|
||||||
|
|
||||||
UserDetailsResolver userDetailsResolver = authToken -> new UserDetails(authToken.substring(0, 5), userId);
|
UserDetailsResolver userDetailsResolver = authToken -> new UserDetails(authToken.substring(0, 5), userId);
|
||||||
int httpPort = 8001;
|
int httpPort = 8003;
|
||||||
try (Backend backend = new Backend(userDetailsResolver, httpPort, logger) {
|
try (Backend backend = new Backend(userDetailsResolver, httpPort, logger) {
|
||||||
@Override
|
@Override
|
||||||
protected void onRegister(ControllerConnectionState controllerConnectionState) {
|
protected void onRegister(ControllerConnectionState controllerConnectionState) {
|
||||||
|
|
Loading…
Reference in New Issue