Skip to content

Commit

Permalink
Fixed comment
Browse files Browse the repository at this point in the history
  • Loading branch information
Lanayx committed Sep 27, 2023
1 parent 669206c commit 7ff98d4
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/Pulsar.Client/Common/Commands.fs
Original file line number Diff line number Diff line change
Expand Up @@ -83,13 +83,13 @@ let private serializePayloadCommand (command : BaseCommand) (metadata: MessageMe
let crcStart = stream1Size + 2
let crcPayloadStart = crcStart + 4

//write CRC
// write CRC
temp.Seek(int64 crcPayloadStart, SeekOrigin.Begin) |> ignore
let crc = int32 <| CRC32C.GetForRMS(temp, totalMetadataSize + payloadSize)
temp.Seek(int64 crcStart, SeekOrigin.Begin) |> ignore
binaryWriter.Write(int32ToBigEndian crc)

//write total size and command size
// write total size
temp.Seek(0L, SeekOrigin.Begin) |> ignore
binaryWriter.Write(int32ToBigEndian totalSize)

Expand Down

0 comments on commit 7ff98d4

Please sign in to comment.