Fix some comments

xerial · xerial · commit a8354af3f91c · 2014-05-23T10:19:52.000+09:00
diff --git a/msgpack-core/src/main/java/org/msgpack/core/MessageUnpacker.java b/msgpack-core/src/main/java/org/msgpack/core/MessageUnpacker.java
@@ -169,7 +169,7 @@ private MessageBuffer takeNextBuffer() throws IOException {
 
 
     /**
-     * Ensure the buffer has the data of at least the specified size.
+     * Ensure that the buffer has the data of at least the specified size.
      *
      * @param byteSizeToRead the data size to be read
      * @return if the buffer can have the data of the specified size returns true, or if the input source reached an EOF, it returns false.
@@ -278,19 +278,15 @@ private byte consume() throws IOException {
      * Proceeds the cursor by the specified byte length
      */
     private void consume(int numBytes) throws IOException {
-        assert (numBytes >= 0);
-
-//        // If position + numBytes becomes negative, it indicates an overflow from Integer.MAX_VALUE.
-//        // So we need to relocate the position
-//        if(position + numBytes < 0) {
-//            ensureBuffer();
-//        }
+        assert(numBytes >= 0);
+        // If position + numBytes becomes negative, it indicates an overflow from Integer.MAX_VALUE.
+        if(position + numBytes < 0)
+            ensureBuffer();
         position += numBytes;
      }
 
     /**
      * Read a byte value at the cursor and proceed the cursor.
-     * It also rests the head value to READ_NEXT.
      *
      * @return
      * @throws IOException
diff --git a/msgpack-core/src/test/scala/org/msgpack/core/MessagePackTest.scala b/msgpack-core/src/test/scala/org/msgpack/core/MessagePackTest.scala
@@ -106,7 +106,7 @@ class MessagePackTest extends MessagePackSpec with PropertyChecks {
 
 
 
-    "pack/unpack primitive values" in {
+    "pack/unpack primitive values" taggedAs("prim") in {
       forAll { (v: Boolean) => check(v, _.packBoolean(v), _.unpackBoolean)}
       forAll { (v: Byte) => check(v, _.packByte(v), _.unpackByte)}
       forAll { (v: Short) => check(v, _.packShort(v), _.unpackShort)}
