From 87aa7ee436bc007c097924da6ac10d175b0c3c2f Mon Sep 17 00:00:00 2001
From: fhanik <fhanik@13f79535-47bb-0310-9956-ffa450edef68>
Date: Wed, 30 May 2007 08:44:40 +0000
Subject: [PATCH] no need to sync here, the poller will dispatch for handling
 anyway

git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@542779 13f79535-47bb-0310-9956-ffa450edef68
---
 .../apache/catalina/connector/CometEventImpl.java  | 34 +++++++++-------------
 1 file changed, 14 insertions(+), 20 deletions(-)

diff --git a/java/org/apache/catalina/connector/CometEventImpl.java b/java/org/apache/catalina/connector/CometEventImpl.java
index 257181df4..b0b68df00 100644
--- a/java/org/apache/catalina/connector/CometEventImpl.java
+++ b/java/org/apache/catalina/connector/CometEventImpl.java
@@ -150,37 +150,31 @@ public class CometEventImpl implements CometEvent {
     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));
             }
         }
     }
-- 
2.11.0