You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2012/02/08 22:52:40 UTC
svn commit: r1242122 -
/incubator/airavata/trunk/modules/commons/common-registry-api/src/main/java/org/apache/airavata/common/registry/api/impl/JCRRegistry.java
Author: lahiru
Date: Wed Feb 8 21:52:40 2012
New Revision: 1242122
URL: http://svn.apache.org/viewvc?rev=1242122&view=rev
Log:
fixing https://issues.apache.org/jira/browse/AIRAVATA-296.
Modified:
incubator/airavata/trunk/modules/commons/common-registry-api/src/main/java/org/apache/airavata/common/registry/api/impl/JCRRegistry.java
Modified: incubator/airavata/trunk/modules/commons/common-registry-api/src/main/java/org/apache/airavata/common/registry/api/impl/JCRRegistry.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/common-registry-api/src/main/java/org/apache/airavata/common/registry/api/impl/JCRRegistry.java?rev=1242122&r1=1242121&r2=1242122&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/commons/common-registry-api/src/main/java/org/apache/airavata/common/registry/api/impl/JCRRegistry.java (original)
+++ incubator/airavata/trunk/modules/commons/common-registry-api/src/main/java/org/apache/airavata/common/registry/api/impl/JCRRegistry.java Wed Feb 8 21:52:40 2012
@@ -75,6 +75,7 @@ public class JCRRegistry extends Observa
private Map<Node,Map<String,Node>> sessionNodes;
private Map<Node,List<Node>> sessionNodeChildren;
private Map<Session,Integer> currentSessionUseCount=new HashMap<Session, Integer>();
+ private boolean threadRun = true;
public JCRRegistry(URI repositoryURI, String className, String user, String pass, Map<String, String> map)
throws RepositoryException {
@@ -152,7 +153,7 @@ public class JCRRegistry extends Observa
private void definiteSessionTimeout(){
Thread m=new Thread(new Runnable() {
public void run() {
- while (true){
+ while (threadRun){
int timeoutCount=0;
int shortStep=10000;
Session currentSession=defaultSession;
@@ -433,4 +434,11 @@ public class JCRRegistry extends Observa
this.workspaceChangeEventListener = workspaceChangeEventListener;
}
+ private void setThreadRun(boolean threadRun) {
+ this.threadRun = threadRun;
+ }
+
+ public void closeConnection(){
+ setThreadRun(false);
+ }
}