mirrors/onos
1
0
Fork 0
mirror of https://github.com/opennetworkinglab/onos.git synced 2025-10-20 20:02:17 +02:00
Code Issues Projects Releases Wiki Activity

Added logging to netty

Browse Source
This commit is contained in:
Madan Jampani 2014-10-07 17:26:25 -07:00
parent ce2a9586b4
commit 29e5dfd82b
3 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
utils/netty/src/main/java/org/onlab/netty/MessageDecoder.java
View File

@ -8,11 +8,16 @@ import io.netty.handler.codec.ReplayingDecoder;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/** /**
* Decoder for inbound messages. * Decoder for inbound messages.
*/ */
public class MessageDecoder extends ReplayingDecoder<DecoderState> { public class MessageDecoder extends ReplayingDecoder<DecoderState> {
private final Logger log = LoggerFactory.getLogger(getClass());
private final NettyMessagingService messagingService; private final NettyMessagingService messagingService;
private static final KryoSerializer SERIALIZER = new KryoSerializer(); private static final KryoSerializer SERIALIZER = new KryoSerializer();
@ -57,4 +62,10 @@ public class MessageDecoder extends ReplayingDecoder<DecoderState> {
checkState(false, "Must not be here"); checkState(false, "Must not be here");
} }
} }
@Override
public void exceptionCaught(ChannelHandlerContext context, Throwable cause) {
log.error("Exception inside channel handling pipeline.", cause);
context.close();
}
} }

11
utils/netty/src/main/java/org/onlab/netty/MessageEncoder.java
View File

@ -1,5 +1,8 @@
package org.onlab.netty; package org.onlab.netty;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandler.Sharable; import io.netty.channel.ChannelHandler.Sharable;
import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelHandlerContext;
@ -11,6 +14,8 @@ import io.netty.handler.codec.MessageToByteEncoder;
@Sharable @Sharable
public class MessageEncoder extends MessageToByteEncoder<InternalMessage> { public class MessageEncoder extends MessageToByteEncoder<InternalMessage> {
private final Logger log = LoggerFactory.getLogger(getClass());
// onosiscool in ascii // onosiscool in ascii
public static final byte[] PREAMBLE = "onosiscool".getBytes(); public static final byte[] PREAMBLE = "onosiscool".getBytes();
public static final int HEADER_VERSION = 1; public static final int HEADER_VERSION = 1;
@ -47,4 +52,10 @@ public class MessageEncoder extends MessageToByteEncoder<InternalMessage> {
// write payload. // write payload.
out.writeBytes(payload); out.writeBytes(payload);
} }
@Override
public void exceptionCaught(ChannelHandlerContext context, Throwable cause) {
log.error("Exception inside channel handling pipeline.", cause);
context.close();
}
} }

1
utils/netty/src/main/java/org/onlab/netty/NettyMessagingService.java
View File

@ -248,6 +248,7 @@ public class NettyMessagingService implements MessagingService {
@Override @Override
public void exceptionCaught(ChannelHandlerContext context, Throwable cause) { public void exceptionCaught(ChannelHandlerContext context, Throwable cause) {
log.error("Exception inside channel handling pipeline.", cause);
context.close(); context.close();
} }
} }