apple/foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2025-05-26 01:10:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

Assert success on XXHash stream functions.

Browse Source
This commit is contained in:
Steve Atherton 2021-11-02 23:40:53 -07:00
parent 313a3dcd63
commit f3d62ce002
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
fdbrpc/FlowTransport.actor.cpp
View File

@ -1593,7 +1593,7 @@ static ReliablePacket* sendPacket(TransportData* self,
if (checksumEnabled) { if (checksumEnabled) {
packetInfoSize += sizeof(checksum); packetInfoSize += sizeof(checksum);
checksumState = XXH3_createState(); checksumState = XXH3_createState();
XXH3_64bits_reset(checksumState); ASSERT(XXH3_64bits_reset(checksumState) == XXH_OK);
} }
wr.writeAhead(packetInfoSize, &packetInfoBuffer); wr.writeAhead(packetInfoSize, &packetInfoBuffer);
@ -1616,7 +1616,7 @@ static ReliablePacket* sendPacket(TransportData* self,
uint32_t processLength = uint32_t processLength =
std::min(checksumUnprocessedLength, (uint32_t)(checksumPb->bytes_written - prevBytesWritten)); std::min(checksumUnprocessedLength, (uint32_t)(checksumPb->bytes_written - prevBytesWritten));
// This won't fail if inputs are non null // 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; checksumUnprocessedLength -= processLength;
checksumPb = checksumPb->nextPacketBuffer(); checksumPb = checksumPb->nextPacketBuffer();
prevBytesWritten = 0; prevBytesWritten = 0;
@ -1624,7 +1624,7 @@ static ReliablePacket* sendPacket(TransportData* self,
checksum = XXH3_64bits_digest(checksumState); checksum = XXH3_64bits_digest(checksumState);
// This always returns OK // This always returns OK
XXH3_freeState(checksumState); ASSERT(XXH3_freeState(checksumState) == XXH_OK);
} }
// Write packet length and checksum into packet buffer // Write packet length and checksum into packet buffer