Mercurial > hg > Members > shoshi > jungle > jungle-core
view src/test/java/jp/ac/u_ryukyu/ie/cr/jungleNetwork/logupdate/LogupdateTestStartCodeSegment.java @ 355:173b053379e0
delete createBoard
author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
---|---|
date | Tue, 10 Oct 2017 20:06:27 +0900 |
parents | 7193845c26cb |
children | f9346cd6ef92 |
line wrap: on
line source
package jp.ac.u_ryukyu.ie.cr.jungleNetwork.logupdate; import alice.codesegment.CodeSegment; import alice.datasegment.CommandType; import alice.datasegment.Receiver; import alice.topology.node.TopologyNodeConfig; import jp.ac.u_ryukyu.ie.cr.jungle.DefaultJungle; import jp.ac.u_ryukyu.ie.cr.jungle.bbs.BBSTest; import jp.ac.u_ryukyu.ie.cr.jungleNetwork.codesegment.LogUpdateCodeSegment; import jp.ac.u_ryukyu.ie.cr.jungleNetwork.core.NetworkDefaultJungle; import jp.ac.u_ryukyu.ie.cr.jungleNetwork.persistent.AliceJournal; import java.util.regex.Matcher; import java.util.regex.Pattern; /** * Created by kono on 2017/08/28. */ public class LogupdateTestStartCodeSegment extends CodeSegment { int bbsPort = 8080; Receiver host = ids.create(CommandType.PEEK); Receiver conf = ids.create(CommandType.PEEK); private Pattern pattern = Pattern.compile("^(node|cli)([0-9]+)$"); private String[] args; boolean persistentFlag = false; public LogupdateTestStartCodeSegment(){ conf.setKey("config"); host.setKey("host"); } @Override public void run() { String name = host.asString(); LogupdateTestConfig config = conf.asClass(LogupdateTestConfig.class); args = config.getArgs(); Matcher matcher = pattern.matcher(name); matcher.find(); // String type = matcher.group(1); for(String arg: args) if (arg.equals("-persistent")) { persistentFlag = true; } BBSTest bbsTest = new BBSTest(new NetworkDefaultJungle(new AliceJournal(), "hoge")); Logupdator cassaBBS = new Logupdator(name, bbsTest); cassaBBS.init(); ods.put("updator", cassaBBS); new LogUpdateCodeSegment(); if (config.isWriteMode()){ bbsTest.createMessage(); bbsTest.checkMessage(); } } }