Mercurial > hg > RemoteEditor > REPSessionManager

changeset 135:0bd4ffc33bdb

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
*** empty log message ***
author kent
date Wed, 27 Aug 2008 18:34:12 +0900
parents 4ad47fad8fa4
children a4e2bceb9713
files rep/REPPacketReceive.java rep/SMConnector.java rep/SessionList.java
diffstat 3 files changed, 7 insertions(+), 5 deletions(-) [+]
line wrap: on
line diff
--- a/rep/REPPacketReceive.java	Wed Aug 27 18:31:22 2008 +0900
+++ b/rep/REPPacketReceive.java	Wed Aug 27 18:34:12 2008 +0900
@@ -17,11 +17,11 @@
 
 public class REPPacketReceive {
 	
-	REPSocketChannel socketchannel;
+	REPSocketChannel<REPCommand> socketchannel;
 	private final int HEADER_SIZE = 24;
 	SelectionKey key;
 	
-	public REPPacketReceive(REPSocketChannel sc){
+	public REPPacketReceive(REPSocketChannel<REPCommand> sc){
 		socketchannel = sc;
 	}
 	
--- a/rep/SMConnector.java	Wed Aug 27 18:31:22 2008 +0900
+++ b/rep/SMConnector.java	Wed Aug 27 18:34:12 2008 +0900
@@ -4,15 +4,17 @@
 import java.net.InetSocketAddress;
 import java.nio.channels.SocketChannel;
 
+import rep.channel.REPSocketChannel;
+
 public class SMConnector {
-	private SocketChannel sessionchannel;
+	private REPSocketChannel<REPCommand> sessionchannel;
 	
 	public void connectSession(String host) {
 		int port = 8765;
 		//int port = Integer.parseInt(args[2]);
 		InetSocketAddress addr = new InetSocketAddress(host, port);
 		try {
-			sessionchannel = SocketChannel.open();
+			sessionchannel = REPSocketChannel.open();
 			sessionchannel.configureBlocking(true);
 			sessionchannel.connect(addr);
 			System.out.println("connect");
--- a/rep/SessionList.java	Wed Aug 27 18:31:22 2008 +0900
+++ b/rep/SessionList.java	Wed Aug 27 18:34:12 2008 +0900
@@ -308,7 +308,7 @@
 		}
 	}
 
-	private void setTranslationTable(SocketChannel channel, int i, int sid) {
+	private void setTranslationTable(REPSocketChannel<REPCommand> channel, int i, int sid) {
 		
 	}