diff src/alice/jungle/persistence/PersistentJungle.java @ 85:e641f559559c

Added some files for persistent
author one
date Mon, 28 Oct 2013 17:21:56 +0900
parents
children f142dd4abc74
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/alice/jungle/persistence/PersistentJungle.java	Mon Oct 28 17:21:56 2013 +0900
@@ -0,0 +1,57 @@
+package alice.jungle.persistence;
+
+import java.util.Iterator;
+import java.util.concurrent.ConcurrentHashMap;
+
+import fj.data.List;
+
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.Jungle;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTree;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.ChangeSet;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.TreeEditor;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.DefaultTreeContext;
+import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.DefaultTreeNode;
+
+public class PersistentJungle implements Jungle {
+	private PersistentJournal journal;
+	private ConcurrentHashMap<String,JungleTree> trees;
+	private String uuid;
+	private TreeEditor editor;
+
+	public PersistentJungle(PersistentJournal _journal,String _uuid,TreeEditor _editor)
+	{
+		journal = _journal;
+		trees = new ConcurrentHashMap<String,JungleTree>();
+		uuid = _uuid;
+		editor = _editor;
+	}
+
+	@Override
+	public JungleTree getTreeByName(String _name)
+	{
+		return trees.get(_name);
+	}
+
+	@Override
+	public JungleTree createNewTree(String _name)
+	{
+		ChangeList list = new ChangeList(){
+			@Override
+			public Iterator<TreeOperation> iterator() {
+				List<TreeOperation> nil = List.nil();
+				return nil.iterator();
+			}
+		};
+		DefaultTreeNode root = new DefaultTreeNode();
+		ChangeSet set = new PersistentChangeSet(root.getAsNode(),null,list,uuid,0, _name);
+		DefaultTreeContext<DefaultTreeNode> tc = new DefaultTreeContext<DefaultTreeNode>(root,set);
+		JungleTree newTree = new PersistentJungleTree<DefaultTreeNode>(_name, tc,uuid, (PersistentChangeListWriter)journal.getWriter(),editor);
+		if(trees.putIfAbsent(_name,newTree) != null){
+			return null;
+		}
+		return newTree;
+	}
+
+}