Mercurial > hg > Members > shoshi > jungle > jungle-core
view src/test/java/jp/ac/u_ryukyu/ie/cr/jungleNetwork/logupdate/LogupdateTestStartCodeSegment.java @ 364:5480020555e7
fix Log
author | suruga |
---|---|
date | Wed, 07 Feb 2018 20:19:49 +0900 |
parents | a3afcd044259 |
children | f69f4be12612 |
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 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 org.msgpack.type.ValueFactory; 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 clist = 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"); clist.setKey("_CLIST"); } @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"), host.asString()); Logupdator cassaBBS = new Logupdator(name, bbsTest); cassaBBS.init(); ods.put("updator", cassaBBS); new LogUpdateCodeSegment(); new LogupdateFinish(host.asString( )); if (config.isWriteMode()) { for (int i = config.writeCount;i>0;i--) { bbsTest.createMessage(); } try { bbsTest.checkTime(); Thread.sleep(5000); ods.put("log", ValueFactory.createNilValue()); } catch (Exception e) { e.printStackTrace(); } } } }