Adding more leniency on connection fault tests
This commit is contained in:
parent
88106fd355
commit
059aa3cbe0
|
@ -131,7 +131,7 @@ public class LocalFuzzer implements AutoCloseable
|
||||||
prefix = "Frame[" + i + "]";
|
prefix = "Frame[" + i + "]";
|
||||||
|
|
||||||
WebSocketFrame expected = expect.get(i);
|
WebSocketFrame expected = expect.get(i);
|
||||||
WebSocketFrame actual = framesQueue.poll(1, TimeUnit.SECONDS);
|
WebSocketFrame actual = framesQueue.poll(3, TimeUnit.SECONDS);
|
||||||
assertThat(prefix + ".poll", actual, notNullValue());
|
assertThat(prefix + ".poll", actual, notNullValue());
|
||||||
|
|
||||||
if (LOG.isDebugEnabled())
|
if (LOG.isDebugEnabled())
|
||||||
|
|
|
@ -295,7 +295,7 @@ public class WebSocketCloseTest
|
||||||
);
|
);
|
||||||
|
|
||||||
BlockingQueue<WebSocketFrame> framesQueue = session.getOutputFrames();
|
BlockingQueue<WebSocketFrame> framesQueue = session.getOutputFrames();
|
||||||
WebSocketFrame frame = framesQueue.poll(1, TimeUnit.SECONDS);
|
WebSocketFrame frame = framesQueue.poll(3, TimeUnit.SECONDS);
|
||||||
assertThat("Frame.opCode", frame.getOpCode(), is(OpCode.TEXT));
|
assertThat("Frame.opCode", frame.getOpCode(), is(OpCode.TEXT));
|
||||||
assertThat("Frame.text-payload", frame.getPayloadAsUTF8(), containsString("openSessions.size=1\n"));
|
assertThat("Frame.text-payload", frame.getPayloadAsUTF8(), containsString("openSessions.size=1\n"));
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue