diff --git a/mina-core/src/test/java/org/apache/mina/filter/ssl/SslFilterScheduledWriteMessagesTest.java b/mina-core/src/test/java/org/apache/mina/filter/ssl/SslFilterScheduledWriteMessagesTest.java index e31e10c53..e6bb137b4 100644 --- a/mina-core/src/test/java/org/apache/mina/filter/ssl/SslFilterScheduledWriteMessagesTest.java +++ b/mina-core/src/test/java/org/apache/mina/filter/ssl/SslFilterScheduledWriteMessagesTest.java @@ -95,6 +95,8 @@ public void shouldDecrementScheduledWriteMessages() throws Exception { assertEquals(0, connectorSession.getWrittenMessages()); assertEquals(0, acceptorSession.getScheduledWriteMessages()); assertEquals(0, connectorSession.getScheduledWriteMessages()); + assertEquals(0, acceptorSession.getScheduledWriteBytes()); + assertEquals(0, connectorSession.getScheduledWriteBytes()); assertEquals(0, acceptorIoHandler.sentMessageCount); assertEquals(0, connectionIoHandler.sentMessageCount); @@ -107,6 +109,8 @@ public void shouldDecrementScheduledWriteMessages() throws Exception { assertEquals(1, connectorSession.getWrittenMessages()); assertEquals(0, acceptorSession.getScheduledWriteMessages()); assertEquals(0, connectorSession.getScheduledWriteMessages()); + assertEquals(0, acceptorSession.getScheduledWriteBytes()); + assertEquals(0, connectorSession.getScheduledWriteBytes()); assertEquals(0, acceptorIoHandler.sentMessageCount); assertEquals(1, connectionIoHandler.sentMessageCount); @@ -119,6 +123,8 @@ public void shouldDecrementScheduledWriteMessages() throws Exception { assertEquals(1, connectorSession.getWrittenMessages()); assertEquals(0, acceptorSession.getScheduledWriteMessages()); assertEquals(0, connectorSession.getScheduledWriteMessages()); + assertEquals(0, acceptorSession.getScheduledWriteBytes()); + assertEquals(0, connectorSession.getScheduledWriteBytes()); assertEquals(1, acceptorIoHandler.sentMessageCount); assertEquals(1, connectionIoHandler.sentMessageCount); } finally { @@ -152,6 +158,8 @@ public void shouldDecrementScheduledWriteMessagesWithSsl() throws Exception { assertEquals(0, connectorSession.getWrittenMessages()); assertEquals(0, acceptorSession.getScheduledWriteMessages()); assertEquals(0, connectorSession.getScheduledWriteMessages()); + assertEquals(0, acceptorSession.getScheduledWriteBytes()); + assertEquals(0, connectorSession.getScheduledWriteBytes()); assertEquals(0, acceptorIoHandler.sentMessageCount); assertEquals(0, connectionIoHandler.sentMessageCount); @@ -164,6 +172,8 @@ public void shouldDecrementScheduledWriteMessagesWithSsl() throws Exception { assertEquals(1, connectorSession.getWrittenMessages()); assertEquals(0, acceptorSession.getScheduledWriteMessages()); assertEquals(0, connectorSession.getScheduledWriteMessages()); + assertEquals(0, acceptorSession.getScheduledWriteBytes()); + assertEquals(0, connectorSession.getScheduledWriteBytes()); assertEquals(0, acceptorIoHandler.sentMessageCount); assertEquals(1, connectionIoHandler.sentMessageCount); @@ -176,6 +186,8 @@ public void shouldDecrementScheduledWriteMessagesWithSsl() throws Exception { assertEquals(1, connectorSession.getWrittenMessages()); assertEquals(0, acceptorSession.getScheduledWriteMessages()); assertEquals(0, connectorSession.getScheduledWriteMessages()); + assertEquals(0, acceptorSession.getScheduledWriteBytes()); + assertEquals(0, connectorSession.getScheduledWriteBytes()); assertEquals(1, acceptorIoHandler.sentMessageCount); assertEquals(1, connectionIoHandler.sentMessageCount); } finally {