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();