René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"ChannelBufferInput blocks until full buffer is read","articleBody":"Please take a look at this sample:\r\n```\r\nimport java.net.InetSocketAddress;\r\nimport java.net.Socket;\r\nimport java.nio.ByteBuffer;\r\nimport java.nio.channels.ServerSocketChannel;\r\nimport java.nio.channels.SocketChannel;\r\nimport java.util.concurrent.ExecutorService;\r\nimport java.util.concurrent.Executors;\r\n\r\nimport org.msgpack.core.MessagePack;\r\nimport org.msgpack.core.MessageUnpacker;\r\n\r\npublic class ChannelUnpackerTest {\r\n\tpublic static void main(String[] args) throws Exception {\r\n\t\ttry (ServerSocketChannel serverChannel = ServerSocketChannel.open()) {\r\n\t\t\tserverChannel.socket().bind(new InetSocketAddress(\"localhost\", 7777));\r\n\t\t\tExecutorService pool = Executors.newFixedThreadPool(10);\r\n\t\t\tfor (int i = 0; i \u003c 10; i++) {\r\n\t\t\t\tpool.execute(() -\u003e {\r\n\t\t\t\t\ttry {\r\n\t\t\t\t\t\tSocketChannel channel = serverChannel.accept();\r\n\t\t\t\t\t\tchannel.write(ByteBuffer.wrap(new byte[200]));\r\n\t\t\t\t\t} catch (Exception e) {\r\n\t\t\t\t\t\t//nothing\r\n\t\t\t\t\t}\r\n\t\t\t\t});\r\n\t\t\t}\r\n\r\n\t\t\ttry (Socket socket = new Socket(\"localhost\", 7777)) {\r\n\t\t\t\tMessageUnpacker unpacker = MessagePack.newDefaultUnpacker(socket.getInputStream());\r\n\t\t\t\tunpacker.readPayload(ByteBuffer.allocate(128));\r\n\t\t\t\tSystem.out.println(\"read from socket\");\r\n\t\t\t}\r\n\r\n\t\t\ttry (SocketChannel channel = SocketChannel.open(new InetSocketAddress(\"localhost\", 7777))) {\r\n\t\t\t\tMessageUnpacker unpacker = MessagePack.newDefaultUnpacker(channel);\r\n\t\t\t\tunpacker.readPayload(ByteBuffer.allocate(128));\r\n\t\t\t\tSystem.out.println(\"read from channel\");\r\n\t\t\t}\r\n\t\t}\r\n\t}\r\n}\r\n```\r\n\r\nThis sample accepts incoming connection, writes 200 bytes to it and waits indefinitely. Consuming first 128 (that is from my real use case - after establishing connection I need to read servers hello message with fixed size of 128 bytes) via MessageUnpacker created via socket InputStream handles this case just fine, however via SocketCnahhel it blocks.\r\n\r\nChanging the server to write large enough data (e.g. 20000 bytes) leads to filling of MessageUnpackers buffer and it can return first 128 bytes.","author":{"url":"https://github.com/isopov","@type":"Person","name":"isopov"},"datePublished":"2017-06-20T08:36:20.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":2},"url":"https://github.com/426/msgpack-java/issues/426"}