Mercurial > hg > RemoteEditor > REPSessionManager
changeset 237:c52e0e831d91
*** empty log message ***
author | pin |
---|---|
date | Sun, 31 Aug 2008 19:33:23 +0900 |
parents | 2abd1dc12453 |
children | 6589b148dd13 |
files | rep/handler/REPHandlerImpl.java test/sematest/PutTester.java test/sematest/TestSessionManager.java |
diffstat | 3 files changed, 4 insertions(+), 15 deletions(-) [+] |
line wrap: on
line diff
--- 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<REPCommand> channel = (REPSocketChannel<REPCommand>) 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);
--- 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();
--- 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();