# HG changeset patch # User pin # Date 1220178803 -32400 # Node ID 2abd1dc1245387f3bb0eaa8640f6343c8c6aaf0b # Parent a8302aa5a495316d5861525fc4aaa4f133fb6cc3 *** empty log message *** diff -r a8302aa5a495 -r 2abd1dc12453 test/sematest/TestSessionManager.java --- a/test/sematest/TestSessionManager.java Sun Aug 31 19:02:56 2008 +0900 +++ b/test/sematest/TestSessionManager.java Sun Aug 31 19:33:23 2008 +0900 @@ -1,6 +1,10 @@ package test.sematest; import java.io.IOException; +import java.util.LinkedList; + +import rep.REP; +import rep.REPCommand; import rep.SessionManager; import rep.channel.REPLogger; import rep.channel.REPServerSocketChannel; @@ -9,6 +13,7 @@ public class TestSessionManager { static public REPLogger logger = REPLogger.singleton(); + protected boolean isStart = false; public TestSessionManager(int sm, int ss, int e) { } @@ -18,7 +23,31 @@ String[] strs ={String.valueOf(masterPort), String.valueOf(masterPort)}; startSessionManager(strs); + while(!isStart){ + try { + Thread.sleep(50); + } catch (InterruptedException e) { + e.printStackTrace(); + } + } + logger.writeLog("TestSessionManager.startTest()", 1); + + putTest(); + putTest(); + + } + + private void putTest() { + REPCommand command = new REPCommand(); + command.setCMD(REP.SMCMD_PUT); + command.setString("PutTest.txt"); + LinkedList commands = new LinkedList(); + commands.add(command); + + Tester tester = new PutTester("PutTester", "localhost", 8766); + tester.setCommands(commands); + tester.start(); } private void startSessionManager(final String[] strs) { @@ -38,6 +67,7 @@ sm.init(port); logger.writeLog("TestSessionManager.startSessionManager() : start SessionManager"); sm.mainLoop(); + isStart = true; } catch (InterruptedException e) { e.printStackTrace();