Mercurial > hg > RemoteEditor > REPSessionManager

comparison rep/channel/REPSocketChannel.java @ 140:01062be677e9

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
*** empty log message ***
author kono
date Wed, 27 Aug 2008 20:23:39 +0900
parents 1ea856259add
children 785a3e8ea858
comparison
equal deleted inserted replaced
139:d6b94713cf45 140:01062be677e9
6 import java.nio.channels.ClosedChannelException; 6 import java.nio.channels.ClosedChannelException;
7 import java.nio.channels.SelectableChannel; 7 import java.nio.channels.SelectableChannel;
8 import java.nio.channels.SelectionKey; 8 import java.nio.channels.SelectionKey;
9 import java.nio.channels.Selector; 9 import java.nio.channels.Selector;
10 import java.nio.channels.SocketChannel; 10 import java.nio.channels.SocketChannel;
11 import java.nio.channels.ServerSocketChannel;
11 import java.nio.channels.spi.SelectorProvider; 12 import java.nio.channels.spi.SelectorProvider;
12 13
13 public class REPSocketChannel<P> extends SelectableChannel{ 14 public class REPSocketChannel<P> extends SelectableChannel{
14 15
15 private SocketChannel sc; 16 private SocketChannel sc;
80 81
81 public Socket socket() { 82 public Socket socket() {
82 // TODO Auto-generated method stub 83 // TODO Auto-generated method stub
83 return null; 84 return null;
84 } 85 }
86
87 public REPSocketChannel<P> create() throws IOException {
88 if (REPServerSocketChannel.isSimulation) {
89 return new ChannelSimulator<P>(null);
90 } else {
91 return new REPSocketChannel<P>(SocketChannel.open());
92 }
93 }
85 94
86 95
87 96
88 } 97 }