# HG changeset patch # User pin # Date 1220178803 -32400 # Node ID c52e0e831d91ecf090d039f2a2068136420ceee3 # Parent 2abd1dc1245387f3bb0eaa8640f6343c8c6aaf0b *** empty log message *** diff -r 2abd1dc12453 -r c52e0e831d91 rep/handler/REPHandlerImpl.java --- a/rep/handler/REPHandlerImpl.java Sun Aug 31 19:33:23 2008 +0900 +++ b/rep/handler/REPHandlerImpl.java Sun Aug 31 19:33:23 2008 +0900 @@ -25,8 +25,9 @@ System.out.println("error"); } REPSocketChannel channel = (REPSocketChannel) key.channel(new REPCommandPacker()); + System.out.println("REPHandlerImpl.handle() : channel = " + channel); + REPCommand command = channel.read(); - System.out.println("REPHandlerImpl.handle() : command = " + command); manager.manage(channel, command); diff -r 2abd1dc12453 -r c52e0e831d91 test/sematest/PutTester.java --- a/test/sematest/PutTester.java Sun Aug 31 19:33:23 2008 +0900 +++ b/test/sematest/PutTester.java Sun Aug 31 19:33:23 2008 +0900 @@ -1,6 +1,5 @@ package test.sematest; -import java.nio.ByteBuffer; import java.util.LinkedList; import rep.REP; @@ -12,18 +11,6 @@ super(name, _host, _port); } - @Override - public void sendCommands(){ - if(commandList == null) return; - if(channel == null) return; - - REPCommand command = commandList.get(0); - for(int i = 0; i < 5; i++){ - channel.write(command); - ns.writeLog("send command : "+command, 1); - } - } - public static void main(String[] args){ REPCommand command = new REPCommand(); diff -r 2abd1dc12453 -r c52e0e831d91 test/sematest/TestSessionManager.java --- a/test/sematest/TestSessionManager.java Sun Aug 31 19:33:23 2008 +0900 +++ b/test/sematest/TestSessionManager.java Sun Aug 31 19:33:23 2008 +0900 @@ -35,6 +35,7 @@ putTest(); putTest(); + putTest(); } @@ -66,8 +67,8 @@ sm.openSelector(); sm.init(port); logger.writeLog("TestSessionManager.startSessionManager() : start SessionManager"); + isStart = true; sm.mainLoop(); - isStart = true; } catch (InterruptedException e) { e.printStackTrace();