# HG changeset patch # User kono # Date 1220176608 -32400 # Node ID 844c8f46584bbd3a71f6a47436700ed3c3b52d5e # Parent b837feb0013286fa033d3ed8441581d98d2453c8 *** empty log message *** diff -r b837feb00132 -r 844c8f46584b rep/channel/REPSocketChannel.java --- a/rep/channel/REPSocketChannel.java Sun Aug 31 18:50:08 2008 +0900 +++ b/rep/channel/REPSocketChannel.java Sun Aug 31 18:56:48 2008 +0900 @@ -77,18 +77,6 @@ public SelectionKey register(REPSelector

sel, int ops, Object att) throws ClosedChannelException { return sc.register(sel.selector, ops, att); } - @Override - public SelectionKey register(Selector sel, int ops, Object att) - throws ClosedChannelException { - if (sel instanceof REPSelector){ - return sc.register(((REPSelector)sel).selector, ops); - }else if(sel instanceof Selector){ - return sc.register(sel, ops); - }else - return null; - //assert(false); - //return null; - } @Override @@ -151,6 +139,25 @@ return sc.connect(semaIP); } + public SelectionKey register1(REPSelector

sel, int ops, Object att) + throws ClosedChannelException { + if(sel instanceof REPSelector) { + REPSelector

s = (REPSelector

)sel; + return sc.register(s.selector, ops,att); + } + return sc.register(sel, ops,att); + } + + @SuppressWarnings("unchecked") + @Override + public SelectionKey register(Selector sel, int ops, Object att) + throws ClosedChannelException { + if(sel instanceof REPSelector) { + REPSelector

s = (REPSelector

)sel; + return sc.register(s.selector, ops,att); + } + return sc.register(sel, ops,att); + } } \ No newline at end of file