You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by jo...@apache.org on 2020/04/15 15:41:29 UTC
[mina] 02/02: Fix DIRMINA-996 adds "break" to prevent message sent
loop
This is an automated email from the ASF dual-hosted git repository.
johnnyv pushed a commit to branch 2.1.X
in repository https://gitbox.apache.org/repos/asf/mina.git
commit 55f4b4d66bd05b4f26d61e1ad51f025e20452889
Author: johnnyv <jo...@apache.org>
AuthorDate: Wed Apr 15 11:41:23 2020 -0400
Fix DIRMINA-996 adds "break" to prevent message sent loop
---
.../org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/mina-core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java b/mina-core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java
index a2f7420..42b74ce 100644
--- a/mina-core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java
+++ b/mina-core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java
@@ -896,8 +896,10 @@ public final class NioDatagramAcceptor extends AbstractIoAcceptor implements Dat
// Kernel buffer is full or wrote too much
setInterestedInWrite(session, true);
- session.getWriteRequestQueue().offer(session, writeRequest);
+ writeRequestQueue.offer(session, writeRequest);
scheduleFlush(session);
+
+ break;
} else {
setInterestedInWrite(session, false);