You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by no...@apache.org on 2011/11/18 14:25:49 UTC
svn commit: r1203641 - in /james/protocols/trunk:
api/src/main/java/org/apache/james/protocols/api/ProtocolTransport.java
impl/src/main/java/org/apache/james/protocols/impl/NettyProtocolTransport.java
pop3/.classpath
Author: norman
Date: Fri Nov 18 13:25:49 2011
New Revision: 1203641
URL: http://svn.apache.org/viewvc?rev=1203641&view=rev
Log:
Allow to suspend reads in the ProtocolTransport. See PROTOCOLS-49
Modified:
james/protocols/trunk/api/src/main/java/org/apache/james/protocols/api/ProtocolTransport.java
james/protocols/trunk/impl/src/main/java/org/apache/james/protocols/impl/NettyProtocolTransport.java
james/protocols/trunk/pop3/.classpath
Modified: james/protocols/trunk/api/src/main/java/org/apache/james/protocols/api/ProtocolTransport.java
URL: http://svn.apache.org/viewvc/james/protocols/trunk/api/src/main/java/org/apache/james/protocols/api/ProtocolTransport.java?rev=1203641&r1=1203640&r2=1203641&view=diff
==============================================================================
--- james/protocols/trunk/api/src/main/java/org/apache/james/protocols/api/ProtocolTransport.java (original)
+++ james/protocols/trunk/api/src/main/java/org/apache/james/protocols/api/ProtocolTransport.java Fri Nov 18 13:25:49 2011
@@ -86,5 +86,19 @@ public interface ProtocolTransport {
* @return lineCount
*/
int getPushedLineHandlerCount();
+
+
+ /**
+ * Set the {@link ProtocolTransport} readable or not. If its not readable then no new lines should get processed
+ *
+ * @param readable
+ */
+ void setReadable(boolean readable);
+ /**
+ * Return <code>true</code> if the channel is readable
+ *
+ * @return
+ */
+ boolean isReadable();
}
Modified: james/protocols/trunk/impl/src/main/java/org/apache/james/protocols/impl/NettyProtocolTransport.java
URL: http://svn.apache.org/viewvc/james/protocols/trunk/impl/src/main/java/org/apache/james/protocols/impl/NettyProtocolTransport.java?rev=1203641&r1=1203640&r2=1203641&view=diff
==============================================================================
--- james/protocols/trunk/impl/src/main/java/org/apache/james/protocols/impl/NettyProtocolTransport.java (original)
+++ james/protocols/trunk/impl/src/main/java/org/apache/james/protocols/impl/NettyProtocolTransport.java Fri Nov 18 13:25:49 2011
@@ -135,6 +135,16 @@ public class NettyProtocolTransport exte
protected void writeToClient(InputStream in, ProtocolSession session) {
channel.write(new ChunkedStream(in));
}
+
+ @Override
+ public void setReadable(boolean readable) {
+ channel.setReadable(readable);
+ }
+
+ @Override
+ public boolean isReadable() {
+ return channel.isReadable();
+ }
Modified: james/protocols/trunk/pop3/.classpath
URL: http://svn.apache.org/viewvc/james/protocols/trunk/pop3/.classpath?rev=1203641&r1=1203640&r2=1203641&view=diff
==============================================================================
--- james/protocols/trunk/pop3/.classpath (original)
+++ james/protocols/trunk/pop3/.classpath Fri Nov 18 13:25:49 2011
@@ -1,6 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry kind="src" path="src/main/java"/>
+ <classpathentry kind="src" path="src/test/java"/>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.6"/>
<classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER"/>
<classpathentry kind="output" path="target/classes"/>
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org