Author: fhanik
Date: Wed May 30 01:44:40 2007
New Revision: 542779
URL: http://svn.apache.org/viewvc?view=rev&rev=542779
Log:
no need to sync here, the poller will dispatch for handling anyway
Modified:
tomcat/trunk/java/org/apache/catalina/connector/CometEventImpl.java
Modified: tomcat/trunk/java/org/apache/catalina/connector/CometEventImpl.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/connector/CometEventImpl.java?view=diff&rev=542779&r1=542778&r2=542779
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/connector/CometEventImpl.java
(original)
+++ tomcat/trunk/java/org/apache/catalina/connector/CometEventImpl.java Wed May
30 01:44:40 2007
@@ -150,37 +150,31 @@
public void configure(CometEvent.CometConfiguration... options)
throws IOException, IllegalStateException {
checkWorkerThread();
- synchronized (cometConfigurations) {
- cometConfigurations.clear();
- for (CometEvent.CometConfiguration cc : options) {
- cometConfigurations.add(cc);
- }
- request.action(ActionCode.ACTION_COMET_CONFIGURE,options);
+ cometConfigurations.clear();
+ for (CometEvent.CometConfiguration cc : options) {
+ cometConfigurations.add(cc);
}
+ request.action(ActionCode.ACTION_COMET_CONFIGURE,options);
}
public void register(CometEvent.CometOperation... operations)
throws IOException, IllegalStateException {
- synchronized (cometOperations) {
- //add it to the registered set
- for (CometEvent.CometOperation co : operations) {
- if (!cometOperations.contains(co)) {
- cometOperations.add(co);
- request.action(ActionCode.ACTION_COMET_REGISTER,
translate(co));
- }
+ //add it to the registered set
+ for (CometEvent.CometOperation co : operations) {
+ if (!cometOperations.contains(co)) {
+ cometOperations.add(co);
+ request.action(ActionCode.ACTION_COMET_REGISTER,
translate(co));
}
}
}
public void unregister(CometOperation... operations)
throws IOException, IllegalStateException {
- synchronized (cometOperations) {
- //remove from the registered set
- for (CometEvent.CometOperation co : operations) {
- if (cometOperations.contains(co)) {
- cometOperations.remove(co);
- request.action(ActionCode.ACTION_COMET_UNREGISTER,
translate(co));
- }
+ //remove from the registered set
+ for (CometEvent.CometOperation co : operations) {
+ if (cometOperations.contains(co)) {
+ cometOperations.remove(co);
+ request.action(ActionCode.ACTION_COMET_UNREGISTER,
translate(co));
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
