()
| 100 | } |
| 101 | |
| 102 | byte [] |
| 103 | recv() throws IOException { |
| 104 | byte [] buf = _recv(2); |
| 105 | int length = ((buf[0] & 0xFF) << 8) + (buf[1] & 0xFF); |
| 106 | byte [] data = _recv(length); |
| 107 | SocketChannel channel = (SocketChannel) key.channel(); |
| 108 | verboseLog("TCP read", channel.socket().getLocalSocketAddress(), |
| 109 | channel.socket().getRemoteSocketAddress(), data); |
| 110 | return data; |
| 111 | } |
| 112 | |
| 113 | static byte [] |
| 114 | sendrecv(SocketAddress local, SocketAddress remote, byte [] data, long endTime) |
no test coverage detected