Author: fhanik
Date: Tue May 29 15:13:26 2007
New Revision: 542674
URL: http://svn.apache.org/viewvc?view=rev&rev=542674
Log:
When using a comet connection, register the requested operations instead of the
default read
Modified:
tomcat/trunk/java/org/apache/coyote/http11/Http11NioProtocol.java
Modified: tomcat/trunk/java/org/apache/coyote/http11/Http11NioProtocol.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http11/Http11NioProtocol.java?view=diff&rev=542674&r1=542673&r2=542674
==============================================================================
--- tomcat/trunk/java/org/apache/coyote/http11/Http11NioProtocol.java (original)
+++ tomcat/trunk/java/org/apache/coyote/http11/Http11NioProtocol.java Tue May
29 15:13:26 2007
@@ -670,7 +670,8 @@
} else {
if (log.isDebugEnabled()) log.debug("Keeping
processor["+result);
//add correct poller events here based on Comet stuff
- socket.getPoller().add(socket);
+ NioEndpoint.KeyAttachment att =
(NioEndpoint.KeyAttachment)socket.getAttachment(false);
+ socket.getPoller().add(socket,att.getCometOps());
}
}
}
@@ -711,7 +712,12 @@
// processor.
if (log.isDebugEnabled()) log.debug("Not recycling
["+processor+"]
Comet="+((NioEndpoint.KeyAttachment)socket.getAttachment(false)).getComet());
connections.put(socket, processor);
- socket.getPoller().add(socket);
+ if (processor.comet) {
+ NioEndpoint.KeyAttachment att =
(NioEndpoint.KeyAttachment)socket.getAttachment(false);
+ socket.getPoller().add(socket,att.getCometOps());
+ } else {
+ socket.getPoller().add(socket);
+ }
} else {
recycledProcessors.offer(processor);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
