From f3d62ce0029f551292f6ac43c78caeec3d4ce45d Mon Sep 17 00:00:00 2001 From: Steve Atherton Date: Tue, 2 Nov 2021 23:40:53 -0700 Subject: [PATCH] Assert success on XXHash stream functions. --- fdbrpc/FlowTransport.actor.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/fdbrpc/FlowTransport.actor.cpp b/fdbrpc/FlowTransport.actor.cpp index f6aacda5db..501ed025e5 100644 --- a/fdbrpc/FlowTransport.actor.cpp +++ b/fdbrpc/FlowTransport.actor.cpp @@ -1593,7 +1593,7 @@ static ReliablePacket* sendPacket(TransportData* self, if (checksumEnabled) { packetInfoSize += sizeof(checksum); checksumState = XXH3_createState(); - XXH3_64bits_reset(checksumState); + ASSERT(XXH3_64bits_reset(checksumState) == XXH_OK); } wr.writeAhead(packetInfoSize, &packetInfoBuffer); @@ -1616,7 +1616,7 @@ static ReliablePacket* sendPacket(TransportData* self, uint32_t processLength = std::min(checksumUnprocessedLength, (uint32_t)(checksumPb->bytes_written - prevBytesWritten)); // This won't fail if inputs are non null - XXH3_64bits_update(checksumState, checksumPb->data() + prevBytesWritten, processLength); + ASSERT(XXH3_64bits_update(checksumState, checksumPb->data() + prevBytesWritten, processLength) == XXH_OK); checksumUnprocessedLength -= processLength; checksumPb = checksumPb->nextPacketBuffer(); prevBytesWritten = 0; @@ -1624,7 +1624,7 @@ static ReliablePacket* sendPacket(TransportData* self, checksum = XXH3_64bits_digest(checksumState); // This always returns OK - XXH3_freeState(checksumState); + ASSERT(XXH3_freeState(checksumState) == XXH_OK); } // Write packet length and checksum into packet buffer