Updated Branches: refs/heads/trunk 44f87608f -> f8d6d9f54
DIRMINA-961 BioUdpSession are not setted to the 'open' state Project: http://git-wip-us.apache.org/repos/asf/mina/repo Commit: http://git-wip-us.apache.org/repos/asf/mina/commit/f8d6d9f5 Tree: http://git-wip-us.apache.org/repos/asf/mina/tree/f8d6d9f5 Diff: http://git-wip-us.apache.org/repos/asf/mina/diff/f8d6d9f5 Branch: refs/heads/trunk Commit: f8d6d9f54a16c7e05a050b7ca266d0b3947530bb Parents: 44f8760 Author: jvermillard <[email protected]> Authored: Fri Aug 2 18:37:58 2013 +0200 Committer: jvermillard <[email protected]> Committed: Fri Aug 2 18:37:58 2013 +0200 ---------------------------------------------------------------------- .../org/apache/mina/transport/bio/BioUdpServer.java | 2 ++ .../org/apache/mina/transport/bio/BioUdpSession.java | 14 ++++++++++++++ 2 files changed, 16 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mina/blob/f8d6d9f5/core/src/main/java/org/apache/mina/transport/bio/BioUdpServer.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/mina/transport/bio/BioUdpServer.java b/core/src/main/java/org/apache/mina/transport/bio/BioUdpServer.java index b10b578..f51e71d 100644 --- a/core/src/main/java/org/apache/mina/transport/bio/BioUdpServer.java +++ b/core/src/main/java/org/apache/mina/transport/bio/BioUdpServer.java @@ -193,6 +193,8 @@ public class BioUdpServer extends AbstractUdpServer { session.getConfig().setIdleTimeInMillis(IdleStatus.WRITE_IDLE, config.getIdleTimeInMillis(IdleStatus.WRITE_IDLE)); idleChecker.sessionWritten(session, System.currentTimeMillis()); + session.setConnected(); + // fire open session.processSessionOpen(); http://git-wip-us.apache.org/repos/asf/mina/blob/f8d6d9f5/core/src/main/java/org/apache/mina/transport/bio/BioUdpSession.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/mina/transport/bio/BioUdpSession.java b/core/src/main/java/org/apache/mina/transport/bio/BioUdpSession.java index 3d01539..7beddba 100644 --- a/core/src/main/java/org/apache/mina/transport/bio/BioUdpSession.java +++ b/core/src/main/java/org/apache/mina/transport/bio/BioUdpSession.java @@ -45,6 +45,20 @@ public class BioUdpSession extends AbstractIoSession { this.remoteAddress = remoteAddress; } + + /** + * Set this session status as connected. To be called by the processor selecting/polling this session. + */ + void setConnected() { + if (!isCreated()) { + throw new IllegalStateException("Trying to open a non created session"); + } + + state = SessionState.CONNECTED; + processSessionOpen(); + } + + /** * {@inheritDoc} */
