Mercurial > hg > RemoteEditor > REPSessionManager
view test/sematest/TestInterManagerSession.java @ 355:98607350f7d1
*** empty log message ***
author | kono |
---|---|
date | Fri, 17 Oct 2008 22:11:34 +0900 |
parents | 21ad256c25c2 |
children | c965ef2b5fd6 |
line wrap: on
line source
package test.sematest; import java.util.LinkedList; import rep.REP; import rep.REPCommand; import rep.SessionManager; import rep.SessionManagerEvent; import rep.channel.REPServerSocketChannel; public class TestInterManagerSession extends TestSessionManager { /* * All test is performed in localhost, so all session manager * should have differenct port number each other. * Test Pattern List * Connect port for each editor * Master/client flag for each editor * Editor or slave session manager must be started by * master session managers using syncExec. */ public int slavePort[] = {masterPort,masterPort,masterPort}; public int editorPort[] = {masterPort,masterPort+1,masterPort+2}; public boolean editorMaster[] = {true,false,false,false}; private LinkedList<REPCommand> editorStartCmds; private SessionManagerEvent ev2[] = { new SessionManagerEvent() { public void exec(SessionManager manager) { for(TestEditor editor:editors) { if(editor.getPort()==manager.getPort()) { logger.writeLog("Start client "+editor); editor.start(); } } int i = sessionManagers.length; for(SessionManager slave:slaveSessionManagers) { if (slave.getParentPort()==masterPort) { logger.writeLog("Start slave "+slave); i = startSessionManager(slave,i,masterPort + i); } } } }, new SessionManagerEvent() { public void exec(SessionManager manager) { manager.connectSession(host); for(TestEditor editor:editors) { if(editor.getPort()==manager.getPort()) { logger.writeLog("Start client "+editor); editor.start(); } } } }, new SessionManagerEvent() { public void exec(SessionManager manager) { manager.connectSession(host); for(TestEditor editor:editors) { if(editor.getPort()==manager.getPort()) { logger.writeLog("Start client "+editor); editor.start(); editors[0].setCommand(editorStartCmds); } } } } }; /* * Create all editors, master session managers and slave session * managers with specified port. All instances are not started yet. */ public TestInterManagerSession(int sm, int ss, int e) { super(sm,ss,e); sessionManagers = new SessionManager[sm]; slaveSessionManagers = new SessionManager[ss]; editors = new TestEditor[e]; for(int i=0;i<sm;i++) { sessionManagers[i] = new SessionManager(); } for(int i=0;i<ss;i++) { int port = slavePort[i%slavePort.length]; slaveSessionManagers[i] = new SessionManager(); slaveSessionManagers[i].setParentPort(port); } for(int i=0;i<e;i++) { int port = editorPort[i%editorPort.length]; boolean master = editorMaster[i%editorMaster.length]; // TestEditor extends Thread editors[i] = new TestEditor("Editor"+i,host,port,master); } setupEditor0(); } private void setupEditor0() { /* * do not startup Editor0 until SessionManagers are ready. * Define pending command and set null command for now. */ LinkedList<REPCommand>cmds = new LinkedList<REPCommand>(); cmds.add(new REPCommand(REP.SMCMD_JOIN,0,0,0,0,"Editor0-file")); //cmds.add(new REPCommand(REP.SMCMD_PUT,0,0,0,0,"Editor0-file")); cmds.add(new REPCommand(REP.REPCMD_INSERT,0,0,0,0,"m0")); cmds.add(new REPCommand(REP.REPCMD_DELETE,0,0,0,0,"m0")); editorStartCmds = cmds; LinkedList<REPCommand>nullcmds = new LinkedList<REPCommand>(); editors[0].setCommand(nullcmds); } @Override public void setSMEvent(SessionManager s,int i) { if (i<ev2.length) { s.syncExec(ev2[i]); } return ; } @Override protected void startTest() { int i = 0; for(SessionManager master:sessionManagers) { logger.writeLog("Start master "+master); i = startSessionManager(master,i, masterPort + i); } } public static void main(String[] args){ /* * set simulation mode * isSimulation=true thread base simulation for PathFinder * isSimulation=false socket based communication mode */ REPServerSocketChannel.isSimulation = true; // At least 3 TestEditors are required. TestInterManagerSession test = new TestInterManagerSession(1, 2, 3); logger.setLogLevel(5); test.startTest(); } }