[jboss-cvs] JBossCache/src/org/jboss/cache/loader/jdbm ...
Vladmir Blagojevic
vladimir.blagojevic at jboss.com
Tue Sep 12 16:16:56 EDT 2006
User: vblagojevic
Date: 06/09/12 16:16:56
Modified: src/org/jboss/cache/loader/jdbm JdbmCacheLoader.java
Log:
store/load moved to AbstractCacheLoader
Revision Changes Path
1.13 +1 -100 JBossCache/src/org/jboss/cache/loader/jdbm/JdbmCacheLoader.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: JdbmCacheLoader.java
===================================================================
RCS file: /cvsroot/jboss/JBossCache/src/org/jboss/cache/loader/jdbm/JdbmCacheLoader.java,v
retrieving revision 1.12
retrieving revision 1.13
diff -u -b -r1.12 -r1.13
--- JdbmCacheLoader.java 5 Sep 2006 15:54:19 -0000 1.12
+++ JdbmCacheLoader.java 12 Sep 2006 20:16:56 -0000 1.13
@@ -55,7 +55,7 @@
* plans to fix this.
*
* @author Elias Ross
- * @version $Id: JdbmCacheLoader.java,v 1.12 2006/09/05 15:54:19 vblagojevic Exp $
+ * @version $Id: JdbmCacheLoader.java,v 1.13 2006/09/12 20:16:56 vblagojevic Exp $
*/
public class JdbmCacheLoader extends AbstractCacheLoader
{
@@ -551,93 +551,6 @@
transactions.remove(tx);
}
- /*
- *
- *
- */
- public void loadEntireState(ObjectOutputStream os) throws Exception
- {
- loadState(Fqn.ROOT,os);
- }
- /*
- *
- *
- */
- public void loadState(Fqn subtree, ObjectOutputStream os) throws Exception
- {
- ClassLoader currentCL = Thread.currentThread().getContextClassLoader();
-
- try
- {
- // Set the TCCL to any classloader registered for subtree
- setUnmarshallingClassLoader(subtree);
-
- synchronized (tree)
- {
- TupleBrowser browser = tree.browse(subtree);
- Tuple t = new Tuple();
- while (browser.getNext(t))
- {
- Fqn fqn = (Fqn) t.getKey();
- if (!fqn.isChildOrEquals(subtree))
- break;
- NodeData nd = new NodeData(fqn,get(fqn));
- os.writeObject(nd);
- }
- }
- }
- finally
- {
- Thread.currentThread().setContextClassLoader(currentCL);
- }
- }
- /*
- *
- *
- */
- public void storeEntireState(ObjectInputStream is) throws Exception
- {
- storeState(Fqn.ROOT,is);
- }
-
- /*
- *
- *
- */
- public void storeState(Fqn subtree, ObjectInputStream in) throws Exception
- {
- ClassLoader currentCL = Thread.currentThread().getContextClassLoader();
- try
- {
- // Set the TCCL to any classloader registered for subtree
- setUnmarshallingClassLoader(subtree);
-
- erase0(subtree);
-
- boolean moveToBuddy = subtree.isChildOf(BuddyManager.BUDDY_BACKUP_SUBTREE_FQN) && subtree.size() > 1;
-
- NodeData nd;
- Fqn fqn;
- // store new state
- for (nd = (NodeData) in.readObject(); nd != null && !nd.isMarker(); nd = (NodeData) in.readObject())
- {
- if (moveToBuddy)
- fqn = BuddyManager.getBackupFqn(subtree, nd.getFqn());
- else
- fqn = nd.getFqn();
-
- put0(fqn, nd.getAttributes());
-
- }
- commit();
- }
- finally
- {
- Thread.currentThread().setContextClassLoader(currentCL);
- }
-
- }
-
/**
* Throws an exception if the environment is not open.
*/
@@ -696,18 +609,6 @@
log.debug("");
}
- public void setRegionManager(RegionManager manager) {
- this.manager = manager;
- }
-
- private void setUnmarshallingClassLoader(Fqn subtree)
- {
- if (manager != null)
- {
- manager.setUnmarshallingClassLoader(subtree);
- }
- }
-
public String toString()
{
BTree bt = tree;
More information about the jboss-cvs-commits
mailing list