(ChannelHandlerContext ctx, MessageEvent e)
| 45 | } |
| 46 | |
| 47 | @Override |
| 48 | public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception { |
| 49 | BigEndianHeapChannelBuffer message = (BigEndianHeapChannelBuffer) e.getMessage(); |
| 50 | // System.out.println("messageReceived " + ctx.getChannel() + message.readableBytes()); |
| 51 | received += message.readableBytes(); |
| 52 | digest.update(message.array(), message.readerIndex(), message.readableBytes()); |
| 53 | if (received > maxLength) { |
| 54 | System.out.println("messageReceived tid=" + Thread.currentThread().getId() |
| 55 | + " " + id + " got " + received); |
| 56 | ctx.getChannel().close(); |
| 57 | } |
| 58 | } |
| 59 | |
| 60 | @Override |
| 61 | public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception { |
nothing calls this directly
no test coverage detected