view src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/networkBenchmark/StartNetworkBenchmarkCodeSegment.java @ 11:edc70340506d draft default tip

networkbenchmark jar log4j conflict
author suruga
date Wed, 19 Apr 2017 21:36:44 +0900
parents 5043bf695419
children
line wrap: on
line source

package jp.ac.u_ryukyu.ie.cr.jungle.networkBenchmark;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.Receiver;
import jp.ac.u_ryukyu.ie.cr.jungle.Jungle;
import jp.ac.u_ryukyu.ie.cr.jungle.core.Children;
import jp.ac.u_ryukyu.ie.cr.jungle.store.nodepath.NodePath;
import jp.ac.u_ryukyu.ie.cr.jungle.transaction.editor.jungleTreeEditor.JungleTreeEditor;
import jp.ac.u_ryukyu.ie.cr.jungle.traverser.DefaultTraverser;
import jp.ac.u_ryukyu.ie.cr.jungle.tree.JungleTree;
import jp.ac.u_ryukyu.ie.cr.jungle.util.Either;
import jp.ac.u_ryukyu.ie.cr.jungleNetwork.operations.NetworkNodePath;
import jp.ac.u_ryukyu.ie.cr.jungleNetwork.persistent.PersistentJungle;
import org.junit.Assert;

import javax.swing.tree.TreeNode;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

/**
 * Created by one on 2017/04/17.
 */
public class StartNetworkBenchmarkCodeSegment extends CodeSegment {

    int bbsPort = 8080;
    Receiver host = ids.create(CommandType.PEEK);
    private Pattern pattern = Pattern.compile("^(node|cli)([0-9]+)$");
    private String[] args;
    boolean persistentFlag = false;

    private long time;                  //measure time
    private boolean setTime = false;

    public StartNetworkBenchmarkCodeSegment() {
        args = null;
        host.setKey("host");
    }

    public StartNetworkBenchmarkCodeSegment(String[] args, int bbsPort) {
    }

    @Override
    public void run() {
        String name = host.asString();
        Matcher matcher = pattern.matcher(name);
        matcher.find();

        System.out.print(" node name: " + name);






        //
        // 1. wait for network node configration
        // 2. start root node time measurement
        // 3. start write on leaf nodes
        // 4. measure leaf node respons time
        // 5. end root node time measurement
        //

    }



    //measure time method
    public long getTime() {
        return this.time;
    }

    public boolean getSetTime() {
        return this.setTime;
    }

    public void setTimes ( long time, boolean setTime){
        this.time = time;
        this.setTime = setTime;
    }

    //start write on leaf node
    public void CreateLeafNode() {
//        Jungle jungle = new PersistentJungle(journal1, "uuid", new DefaultTraverser());
//
//        jungle.createNewTree("aho"); // created a new tree called "hoge"
//        JungleTree tree1 = jungle.getTreeByName("aho");  // Substitution that get a tree called "hoge"  in Jungle for tree1
//        JungleTreeEditor editor = tree1.getJungleTreeEditor(); // add Editor for tree1
//        NetworkNodePath path = new NetworkNodePath(); //
//        TreeNode node1 = tree1.getRootNode();//get root node
//        Children child1 = node1.getChildren(); //for redblacktree  いらない説
//        Either<Error, JungleTreeEditor> either = editor.addNewChildAt(path, pos); // add new Child
//        NodePath childPath = path.add(pos); // add position for child
//        Assert.assertFalse(either.isA()); // if either isA , end this method.
//        editor = either.b(); //
//        either = editor.putAttribute(childPath, key, value);//

    }


}