Mercurial > hg > RemoteEditor > REPSessionManager
changeset 202:ffedaf382e0c
*** empty log message ***
author | kent |
---|---|
date | Sat, 30 Aug 2008 11:15:31 +0900 |
parents | 0beb2bcfefe2 |
children | 4c0a94836357 |
files | test/channeltest/StringPacker.java |
diffstat | 1 files changed, 7 insertions(+), 12 deletions(-) [+] |
line wrap: on
line diff
--- a/test/channeltest/StringPacker.java Sat Aug 30 10:57:00 2008 +0900 +++ b/test/channeltest/StringPacker.java Sat Aug 30 11:15:31 2008 +0900 @@ -4,7 +4,6 @@ import java.net.InetSocketAddress; import java.net.SocketAddress; import java.nio.ByteBuffer; -import java.nio.CharBuffer; import java.nio.channels.SelectionKey; import java.nio.channels.SocketChannel; @@ -26,24 +25,19 @@ blog.putInt(0); /* 文字列を追加 */ - CharBuffer cb = blog.asCharBuffer(); - cb.put(log); + for(int i=0; i<log.length(); i++){ + blog.putChar(log.charAt(i)); + } + blog.limit(); /* ヘッダに書き込む情報 */ - size = cb.asReadOnlyBuffer().position(); + size = blog.position(); blog.rewind(); /* ヘッダ 文字列の長さ */ blog.putInt(size); blog.rewind(); return blog; - /* - for(int i=0;i<log.length();i++) { - blog.putChar(log.charAt(i)); - } - blog.flip(); - return blog; - */ } public String unpackUConv(SocketChannel sc) throws IOException { @@ -61,6 +55,7 @@ sc.read(bb); // Stringに変換して返す + bb.rewind(); return bb.asCharBuffer().toString(); } @@ -70,7 +65,7 @@ StringPacker sp = new StringPacker(); SocketAddress IP = new InetSocketAddress("localhost",20000); try { - REPSelector selector; + REPSelector<String> selector; REPSocketChannel<String> rscS; REPSocketChannel<String> rscC; REPServerSocketChannel<String> rss;