package example;

import java.nio.ByteBuffer;

import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.DefaultJungle;
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.JungleTreeEditor;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Children;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Node;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultTreeEditor;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.DefaultTraverser;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either;
import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;
import junit.framework.Assert;

public class SimplejungleMalti extends Thread {
	public static final String key = "name";
	public static final String valueString = "kanagawsa";
	public static final ByteBuffer value = ByteBuffer.wrap(valueString.getBytes());

	public static void main(String[] args) {
		System.out.println(args[0]);
		System.out.println(args[1]);
		int roopCount  =  Integer.parseInt(args[0]);
		int threadCount = Integer.parseInt(args[1]);
		WriteThread[] wt = new WriteThread[threadCount];
		Jungle j = new DefaultJungle(null,"hogehoge",new DefaultTreeEditor(new DefaultTraverser()));
		j.createNewTree("tree");//木を作った
		JungleTree tree = j.getTreeByName("tree");//名前を取得
		JungleTreeEditor editor1 = tree.getTreeEditor();//editorの取得
		DefaultNodePath root = new DefaultNodePath();//パスの取得
		
		//eitherに値を入れる
		Either<Error,JungleTreeEditor> either = editor1.putAttribute(root,key,value);
		if(either.isA()){//失敗した場合Aが出てくる
			Assert.fail();
		}
		editor1 = either.b();
		editor1.success();
		//ここで初めてSUCCESS
		
		Node node = tree.getRootNode();
		ByteBuffer v = node.getAttributes().get(key);
		System.out.println(new String(v.array()));
		
		//------以下子ノードの値変更
		editor1 = tree.getTreeEditor();//Treeのeditorを作成
		either = editor1.addNewChildAt(root,0);//新しく入れるところへのパス
		if(either.isA()){//ちゃんとパスを指定できたかチェック
			Assert.fail();
		}
		editor1 = either.b();//成功した場合パスを入れる
		NodePath childPath = root.add(0);
		either = editor1.success();
		
		//そしてここで子ノードに値を入れる
		
		long t1 = System.currentTimeMillis();//時間の測定開始
		
		for(int count = 0 ; count < threadCount ; count++){
		wt[count] = new WriteThread(j,childPath ,(roopCount/threadCount),count);
		}
		
		for(int count = 0 ; count < threadCount ; count++){
		wt[count].start();
		}
	
		for(int count = 0 ; count < threadCount ; count++){
			try{
				wt[count].join();
			}catch(InterruptedException e){}
		}
		
		long t2 = System.currentTimeMillis();
		System.out.println(t2-t1);
		
		node = tree.getRootNode();
		Children<Node> children = node.getChildren();
		Either<Error,Node> either2 = children.at(0);
		if(either2.isA()){
			Assert.fail();
		}
		
		Node childNode = either2.b();
		ByteBuffer v2 = childNode.getAttributes().get(key);
		System.out.println(new String(v2.array()));
	}
}