| 18 | private static PacketLogger packetLogger = null; |
| 19 | |
| 20 | protected |
| 21 | Client(SelectableChannel channel, long endTime) throws IOException { |
| 22 | boolean done = false; |
| 23 | Selector selector = null; |
| 24 | this.endTime = endTime; |
| 25 | try { |
| 26 | selector = Selector.open(); |
| 27 | channel.configureBlocking(false); |
| 28 | key = channel.register(selector, SelectionKey.OP_READ); |
| 29 | done = true; |
| 30 | } |
| 31 | finally { |
| 32 | if (!done && selector != null) |
| 33 | selector.close(); |
| 34 | if (!done) |
| 35 | channel.close(); |
| 36 | } |
| 37 | } |
| 38 | |
| 39 | static protected void |
| 40 | blockUntil(SelectionKey key, long endTime) throws IOException { |