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/05/08 18:31:16 UTC
[mina] 01/04: Fix DIRMINA-996
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 896b170d8d7c0769bca171f0fbe7de9b13a65968
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);