[incubator-nemo] 22/40: tmp

[je...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jeongyoon pushed a commit to branch skew_exp
in repository https://gitbox.apache.org/repos/asf/incubator-nemo.git

commit cd0c07d47715cb0b239795b89e6b18d18db94c37
Author: sanha <sa...@naver.com>
AuthorDate: Sun Mar 18 20:48:53 2018 +0900

    tmp
---
 .../edu/snu/nemo/runtime/executor/bytetransfer/FrameDecoder.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/bytetransfer/FrameDecoder.java b/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/bytetransfer/FrameDecoder.java
index bea0506..088a84f 100644
--- a/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/bytetransfer/FrameDecoder.java
+++ b/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/bytetransfer/FrameDecoder.java
@@ -21,6 +21,8 @@ import edu.snu.nemo.runtime.common.comm.ControlMessage.ByteTransferDataDirection
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.ByteToMessageDecoder;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.List;
 
@@ -61,7 +63,7 @@ import java.util.List;
  * @see ByteTransportChannelInitializer
  */
 final class FrameDecoder extends ByteToMessageDecoder {
-
+  private static final Logger LOG = LoggerFactory.getLogger(FrameDecoder.class.getName());
   private static final int HEADER_LENGTH = 9;
 
   private final ContextManager contextManager;
@@ -132,6 +134,8 @@ final class FrameDecoder extends ByteToMessageDecoder {
     final long length = in.readUnsignedInt();
     if (length < 0) {
       throw new IllegalStateException(String.format("Frame length is negative: %d", length));
+    } else if (length > Integer.MAX_VALUE) {
+      LOG.error("@@@@ frame length greater than int max!");
     }
     if ((flags & ((byte) (1 << 3))) == 0) {
       // setup context for reading control frame body

-- 
To stop receiving notification emails like this one, please contact
jeongyoon@apache.org.