Mercurial > hg > RemoteEditor > REPSessionManager

changeset 256:7dbed9d1d213

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
*** empty log message ***
author pin
date Tue, 09 Sep 2008 15:33:39 +0900
parents cc119b4b1e96
children c121d1c5daee
files rep/SessionManager.java test/sematest/TestSessionManager.java
diffstat 2 files changed, 6 insertions(+), 21 deletions(-) [+]
line wrap: on
line diff
--- a/rep/SessionManager.java	Tue Sep 09 14:58:57 2008 +0900
+++ b/rep/SessionManager.java	Tue Sep 09 15:33:39 2008 +0900
@@ -404,7 +404,10 @@
 	}
 
 	private void setNormalState(REPSocketChannel<REPCommand> channel, int sid) {
+		System.out.println("SessionManager.setNormalState() : channel = " + channel);
+		System.out.println("SessionManager.setNormalState() : selector = " + selector);
 		SelectionKey key = channel.keyFor(selector);
+		System.out.println("SessionManager.setNormalState() : key = " + key);
 		key.attach(new REPHandlerImpl(sid, this));
 	}
 
@@ -534,23 +537,6 @@
 		return host;
 	}
 
-//	public void connectionOccured(SessionManagerEvent event) {
-//		try {
-//			waitingQueue.put(event);
-//		} catch (InterruptedException e) {
-//		}
-//		selector.wakeup();
-//	}
-//
-//	public void selectOccured(SessionManagerEvent event) {
-//		try {
-//			waitingQueue.put(event);
-//		} catch (InterruptedException e) {
-//			e.printStackTrace();
-//		}
-//		selector.wakeup();
-//	}
-
 	public void selectSession(SelectButtonEvent event) {
 		REPSocketChannel<REPCommand> channel = event.getEditorChannel();
 		int sid = event.getSID();
@@ -606,7 +592,6 @@
 			waitingQueue.put(event);
 		} catch (InterruptedException e) {}
 		selector.wakeup();
-
 	}
 
 }
--- a/test/sematest/TestSessionManager.java	Tue Sep 09 14:58:57 2008 +0900
+++ b/test/sematest/TestSessionManager.java	Tue Sep 09 15:33:39 2008 +0900
@@ -33,9 +33,9 @@
 		
 		logger.writeLog("TestSessionManager.startTest()", 1);
 		
-		putTest();
-		joinTest();
-		joinTest();
+		//putTest();
+		//joinTest();
+		//joinTest();
 		
 	}