From 88e67e094e145e3744abe76d5d18073f5b9a5dc9 Mon Sep 17 00:00:00 2001 From: Marcin Date: Thu, 10 Sep 2026 13:08:02 +0200 Subject: [PATCH] additional checks for schedule bytes --- .../ssl/SslFilterScheduledWriteMessagesTest.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) 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 {