|
334
|
1 package test.sematest;
|
|
|
2
|
|
|
3
|
|
|
4 import rep.SessionManager;
|
|
|
5 import rep.SessionManagerEvent;
|
|
|
6 import rep.channel.REPServerSocketChannel;
|
|
|
7
|
|
|
8 public class TestInterManagerSession extends TestSessionManager {
|
|
|
9
|
|
|
10 /*
|
|
|
11 * All test is performed in localhost, so all session manager
|
|
|
12 * should have differenct port number each other.
|
|
|
13 * Test Pattern List
|
|
|
14 * Connect port for each editor
|
|
|
15 * Master/client flag for each editor
|
|
|
16 * Editor or slave session manager must be started by
|
|
|
17 * master session managers using syncExec.
|
|
|
18 */
|
|
|
19
|
|
335
|
20 public int slavePort[] = {masterPort,masterPort,masterPort};
|
|
|
21 public int editorPort[] = {masterPort,masterPort+1,masterPort+2};
|
|
|
22 public boolean editorMaster[] = {true,false,false,false};
|
|
|
23 private SessionManagerEvent ev2[] = {
|
|
334
|
24 new SessionManagerEvent() {
|
|
|
25 // event for master
|
|
|
26 // executed before first select();
|
|
|
27 public void exec(SessionManager manager) {
|
|
|
28 for(TestEditor editor:editors) {
|
|
336
|
29 if(editor.getPort()==manager.getPort()) {
|
|
|
30 logger.writeLog("Start client "+editor);
|
|
334
|
31 editor.start();
|
|
336
|
32 }
|
|
334
|
33 }
|
|
|
34 int i = sessionManagers.length;
|
|
|
35 for(SessionManager slave:slaveSessionManagers) {
|
|
336
|
36 if (slave.getParentPort()==masterPort) {
|
|
|
37 logger.writeLog("Start slave "+slave);
|
|
334
|
38 i = startSessionManager(slave,i,masterPort + i);
|
|
336
|
39 }
|
|
334
|
40 }
|
|
|
41 }
|
|
|
42 },
|
|
|
43 new SessionManagerEvent() {
|
|
|
44 // executed before first select();
|
|
|
45 // event for slave
|
|
|
46 public void exec(SessionManager manager) {
|
|
|
47 manager.connectSession(host);
|
|
|
48 for(TestEditor editor:editors) {
|
|
336
|
49 if(editor.getPort()==manager.getPort()) {
|
|
|
50 logger.writeLog("Start client "+editor);
|
|
|
51 editor.start();
|
|
|
52 }
|
|
334
|
53 }
|
|
|
54 }
|
|
|
55 },
|
|
|
56 new SessionManagerEvent() {
|
|
|
57 // executed before first select();
|
|
|
58 // event for slave
|
|
|
59 public void exec(SessionManager manager) {
|
|
|
60 manager.connectSession(host);
|
|
|
61 for(TestEditor editor:editors) {
|
|
336
|
62 if(editor.getPort()==manager.getPort()) {
|
|
|
63 logger.writeLog("Start client "+editor);
|
|
|
64 editor.start();
|
|
|
65 }
|
|
334
|
66 }
|
|
|
67 }
|
|
|
68 }
|
|
|
69 };
|
|
|
70
|
|
|
71 /*
|
|
|
72 * Create all editors, master session managers and slave session
|
|
|
73 * managers with specified port. All instances are not started yet.
|
|
|
74 */
|
|
|
75
|
|
|
76 public TestInterManagerSession(int sm, int ss, int e) {
|
|
|
77 super(sm,ss,e);
|
|
|
78
|
|
|
79 sessionManagers = new SessionManager[sm];
|
|
|
80 slaveSessionManagers = new SessionManager[ss];
|
|
|
81 editors = new TestEditor[e];
|
|
|
82 for(int i=0;i<sm;i++) {
|
|
|
83 sessionManagers[i] = new SessionManager();
|
|
|
84 }
|
|
|
85 for(int i=0;i<ss;i++) {
|
|
|
86 int port = slavePort[i%slavePort.length];
|
|
|
87 slaveSessionManagers[i] = new SessionManager();
|
|
|
88 slaveSessionManagers[i].setParentPort(port);
|
|
|
89 }
|
|
|
90 for(int i=0;i<e;i++) {
|
|
|
91 int port = editorPort[i%editorPort.length];
|
|
|
92 boolean master = editorMaster[i%editorMaster.length];
|
|
|
93 // TestEditor extends Thread
|
|
|
94 editors[i] = new TestEditor("Editor"+i,host,port,master);
|
|
|
95 }
|
|
|
96 }
|
|
|
97
|
|
335
|
98 @Override
|
|
|
99 public void setSMEvent(SessionManager s,int i) {
|
|
|
100 if (i<ev2.length) {
|
|
|
101 s.syncExec(ev2[i]);
|
|
|
102 }
|
|
|
103 return ;
|
|
|
104 }
|
|
334
|
105
|
|
336
|
106 @Override
|
|
|
107 protected void startTest() {
|
|
|
108 int i = 0;
|
|
|
109 for(SessionManager master:sessionManagers) {
|
|
|
110 logger.writeLog("Start master "+master);
|
|
|
111 i = startSessionManager(master,i, masterPort + i);
|
|
|
112 }
|
|
|
113 }
|
|
|
114
|
|
334
|
115 public static void main(String[] args){
|
|
|
116 /*
|
|
|
117 * set simulation mode
|
|
|
118 * isSimulation=true thread base simulation for PathFinder
|
|
|
119 * isSimulation=false socket based communication mode
|
|
|
120 */
|
|
|
121 REPServerSocketChannel.isSimulation = true;
|
|
|
122 // At least 3 TestEditors are required.
|
|
335
|
123 TestInterManagerSession test = new TestInterManagerSession(1, 2, 3);
|
|
334
|
124 logger.setLogLevel(5);
|
|
|
125 test.startTest();
|
|
|
126 }
|
|
|
127
|
|
|
128
|
|
|
129 }
|
