# HG changeset patch # User kono # Date 1219917241 -32400 # Node ID 4ed6393ec68e0b55ba7c0c2a3a12ea72d3d4b335 # Parent 3dc194f5e28fc7f022e92aefe8ecb05a23934f00 *** empty log message *** diff -r 3dc194f5e28f -r 4ed6393ec68e rep/channel/REPSelector.java --- a/rep/channel/REPSelector.java Thu Aug 28 18:44:05 2008 +0900 +++ b/rep/channel/REPSelector.java Thu Aug 28 18:54:01 2008 +0900 @@ -69,9 +69,10 @@ return selector.wakeup(); } - public SelectionKey register(SelectableChannel ch, int ops, Object att){ - return null; + public SelectionKey register(SelectableChannel ch, int ops, Object att) throws ClosedChannelException{ + return ch.register(selector, ops, att); } + } diff -r 3dc194f5e28f -r 4ed6393ec68e rep/channel/REPServerSocketChannel.java --- a/rep/channel/REPServerSocketChannel.java Thu Aug 28 18:44:05 2008 +0900 +++ b/rep/channel/REPServerSocketChannel.java Thu Aug 28 18:54:01 2008 +0900 @@ -67,8 +67,9 @@ public SelectionKey register(REPSelector sel, int ops, Object att) throws ClosedChannelException { + assert(!isSimulation); REPSelector selector = sel; - return selector.register(this, ops, att); + return selector.register(ss, ops, att); } } diff -r 3dc194f5e28f -r 4ed6393ec68e test/ServerSample.java --- a/test/ServerSample.java Thu Aug 28 18:44:05 2008 +0900 +++ b/test/ServerSample.java Thu Aug 28 18:54:01 2008 +0900 @@ -14,11 +14,11 @@ throws Exception { // セレクタの用意 - REPSelector selector = REPSelector.open(); + REPSelector selector = REPSelector.create(); // サーバソケットチャンネルを作成。5100番ポートを受付ポートに指定 // (非ブロックモードに設定:重要) - REPServerSocketChannel serverSocketChannel = REPServerSocketChannel.open(); + REPServerSocketChannel serverSocketChannel = REPServerSocketChannel.open(); serverSocketChannel.configureBlocking(false); serverSocketChannel.socket().bind(new InetSocketAddress(5100));