Correct outdated comments in code about wire protocol format (apache#477

) Fixes: apache#428
ccf19881030 · Jun 15, 2017 · 8abafee · 8abafee
1 parent 121ed54
commit 8abafee
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pulsar-common/src/main/java/com/yahoo/pulsar/common/api/Commands.java b/pulsar-common/src/main/java/com/yahoo/pulsar/common/api/Commands.java
@@ -742,7 +742,10 @@ public static ByteBuf deSerializeSingleMessageInBatch(ByteBuf uncompressedPayloa
 
     private static ByteBuf serializeCommandMessageWithSize(BaseCommand cmd, ByteBuf metadataAndPayload) {
         // / Wire format
-        // [TOTAL_SIZE] [CMD_SIZE][CMD] [METADATA_SIZE][METADATA] [PAYLOAD]
+        // [TOTAL_SIZE] [CMD_SIZE][CMD] [MAGIC_NUMBER][CHECKSUM] [METADATA_SIZE][METADATA] [PAYLOAD]
+        //
+        // metadataAndPayload contains from magic-number to the payload included
+
 
         int cmdSize = cmd.getSerializedSize();
         int totalSize = 4 + cmdSize + metadataAndPayload.readableBytes();