activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r509564 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
Date Tue, 20 Feb 2007 14:00:36 GMT
Author: rajdavies
Date: Tue Feb 20 06:00:35 2007
New Revision: 509564

URL: http://svn.apache.org/viewvc?view=rev&rev=509564
Log:
only set the initialized flag = true after obtaining the lock on the data files

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java?view=diff&rev=509564&r1=509563&r2=509564
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
Tue Feb 20 06:00:35 2007
@@ -419,7 +419,7 @@
         if(closed)
             throw new IOException("Store has been closed.");
         if(!initialized){
-            initialized=true;
+           
             log.info("Kaha Store using data directory "+directory);
             DataManager defaultDM=getDataManager(DEFAULT_CONTAINER_NAME);
             rootIndexManager=getIndexManager(defaultDM,DEFAULT_CONTAINER_NAME);
@@ -436,6 +436,7 @@
                 listRoot=rootIndexManager.getIndex(IndexItem.INDEX_SIZE);
             }
             lock();
+            initialized=true;
             mapsContainer=new IndexRootContainer(mapRoot,rootIndexManager,defaultDM);
             listsContainer=new IndexRootContainer(listRoot,rootIndexManager,defaultDM);
             /**



Mime
View raw message