You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by el...@apache.org on 2012/07/09 19:15:57 UTC
svn commit: r1359294 - in
/mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core:
session/AbstractIoSession.java
session/DefaultIoSessionDataStructureFactory.java
write/WriteRequestQueue.java
Author: elecharny
Date: Mon Jul 9 17:15:56 2012
New Revision: 1359294
URL: http://svn.apache.org/viewvc?rev=1359294&view=rev
Log:
Added the size() method to the WriteRequestQueue interface, and implemented it in the associated classes. Fixes DIRMINA-888
Modified:
mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/session/AbstractIoSession.java
mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/session/DefaultIoSessionDataStructureFactory.java
mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/write/WriteRequestQueue.java
Modified: mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/session/AbstractIoSession.java
URL: http://svn.apache.org/viewvc/mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/session/AbstractIoSession.java?rev=1359294&r1=1359293&r2=1359294&view=diff
==============================================================================
--- mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/session/AbstractIoSession.java (original)
+++ mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/session/AbstractIoSession.java Mon Jul 9 17:15:56 2012
@@ -1381,5 +1381,12 @@ public abstract class AbstractIoSession
public void dispose(IoSession session) {
queue.dispose(session);
}
+
+ /**
+ * {@inheritDoc}
+ */
+ public int size() {
+ return queue.size();
+ }
}
}
Modified: mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/session/DefaultIoSessionDataStructureFactory.java
URL: http://svn.apache.org/viewvc/mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/session/DefaultIoSessionDataStructureFactory.java?rev=1359294&r1=1359293&r2=1359294&view=diff
==============================================================================
--- mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/session/DefaultIoSessionDataStructureFactory.java (original)
+++ mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/session/DefaultIoSessionDataStructureFactory.java Mon Jul 9 17:15:56 2012
@@ -222,5 +222,12 @@ public class DefaultIoSessionDataStructu
public String toString() {
return q.toString();
}
+
+ /**
+ * {@inheritDoc}
+ */
+ public int size() {
+ return q.size();
+ }
}
}
Modified: mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/write/WriteRequestQueue.java
URL: http://svn.apache.org/viewvc/mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/write/WriteRequestQueue.java?rev=1359294&r1=1359293&r2=1359294&view=diff
==============================================================================
--- mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/write/WriteRequestQueue.java (original)
+++ mina/branches/2.0/mina-core/src/main/java/org/apache/mina/core/write/WriteRequestQueue.java Mon Jul 9 17:15:56 2012
@@ -31,8 +31,8 @@ public interface WriteRequestQueue {
/**
* Get the first request available in the queue for a session.
- * @param session The session
- * @return The first available request, if any.
+ * @param session The session
+ * @return The first available request, if any.
*/
WriteRequest poll(IoSession session);
@@ -62,4 +62,11 @@ public interface WriteRequestQueue {
* @param session The associated session
*/
void dispose(IoSession session);
+
+
+ /**
+ * Returns the number of objects currently stored in the queue.
+ * @return
+ */
+ int size();
}