You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by jv...@apache.org on 2013/08/02 18:38:14 UTC
git commit: DIRMINA-961 BioUdpSession are not setted to the 'open'
state
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 <jv...@apache.org>
Authored: Fri Aug 2 18:37:58 2013 +0200
Committer: jvermillard <jv...@apache.org>
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}
*/