svn commit: r762503 - /incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/Endpoint_impl.java

[cw...@apache.org]

Author: cwiklik
Date: Mon Apr  6 20:56:45 2009
New Revision: 762503

URL: http://svn.apache.org/viewvc?rev=762503&view=rev
Log:
UIMA-1317 Declared booleans as volatile

Modified:
    incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/Endpoint_impl.java

Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/Endpoint_impl.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/Endpoint_impl.java?rev=762503&r1=762502&r2=762503&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/Endpoint_impl.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/Endpoint_impl.java Mon Apr  6 20:56:45 2009
@@ -43,13 +43,13 @@
 
 	private String serverURI;
 
-	private boolean initialized;
+	private volatile boolean initialized;
 
 	private Timer timer;
 
-	private volatile String replyTo;
+	private String replyTo;
 	
-	private boolean waitingForResponse;
+	private volatile boolean waitingForResponse;
 
 	private int metadataRequestTimeout;
 
@@ -57,13 +57,13 @@
 
 	private int collectionProcessCompleteTimeout;
 	
-	private boolean isRemote;
+	private volatile boolean isRemote;
 
 	private String descriptor;
 
 	private String serializer="xmi";
 
-	private boolean finalEndpoint;
+	private volatile boolean finalEndpoint;
 	
 	private final long timeIn = System.nanoTime(); 
 	
@@ -73,31 +73,31 @@
 	
 	private Endpoint selfRef = this;
 	
-	private boolean retryEnabled;
+	private volatile boolean retryEnabled;
 	
 	private Object monitor = new Object();
 	
 	private String highWaterMark = null;
 	
-	private boolean completedProcessingCollection;
+	private volatile boolean completedProcessingCollection;
 	
-	private boolean noConsumers =false;
+	private volatile boolean noConsumers =false;
 	
-	private boolean remove = false;
+	private volatile boolean remove = false;
 	
-	private boolean isCasMultiplier = false;
+	private volatile boolean isCasMultiplier = false;
 	
 	private int shadowCasPoolSize = 0;
 	
-	private boolean isReplyEndpointFlag;
+	private volatile boolean isReplyEndpointFlag;
 	
 	private ServiceInfo serviceInfo = null;
 
 	private int command; 
 	
-	private boolean registeredWithParent;
+	private volatile boolean registeredWithParent;
 	
-	private boolean tempReplyDestination;
+	private volatile boolean tempReplyDestination;
 		
 	private int initialHeapSize;
 	
@@ -116,7 +116,7 @@
 	private int status;
 	
 	private String delegateKey;
-	private boolean processParentLast=false;
+	private volatile boolean processParentLast=false;
 	
 	public Endpoint_impl() {
 	  status = Endpoint.OK;