From 8e48ce6ceb3a6fa9f5770cde4b44da45438de2f7 Mon Sep 17 00:00:00 2001 From: Hayodea Hekol Date: Sat, 15 Nov 2025 21:29:59 -0400 Subject: [PATCH] stagingBuffer: rename nDgramsPerFrame=>nSlots --- .../attachmentSupport/stagingBuffer.cpp | 26 +++++++++---------- include/user/stagingBuffer.h | 8 +++--- 2 files changed, 17 insertions(+), 17 deletions(-) diff --git a/commonLibs/attachmentSupport/stagingBuffer.cpp b/commonLibs/attachmentSupport/stagingBuffer.cpp index 497194f..4a93836 100644 --- a/commonLibs/attachmentSupport/stagingBuffer.cpp +++ b/commonLibs/attachmentSupport/stagingBuffer.cpp @@ -83,8 +83,8 @@ void StagingBuffer::computeSlotStrideAndBufferSize() inputConstraints.framePadToNBytes, inputConstraints.slotPadToNBytes); - // Calculate total size needed for nDgramsPerFrame slots - size_t slotAreaSize = nDgramsPerFrame * slotStrideNBytes; + // Calculate total size needed for nSlots slots + size_t slotAreaSize = nSlots * slotStrideNBytes; // Add padding space at buffer start for alignment offset (worst case: max alignment - 1) size_t alignmentPadding = maxAlignment - 1; @@ -102,7 +102,7 @@ void StagingBuffer::computeSlotStrideAndBufferSize() size_t StagingBuffer::calculateFirstSlotOffsetAndValidate( uint8_t* buffer, size_t bufferNBytes, - size_t nDgramsPerFrame, + size_t nSlots, size_t slotStrideNBytes, const StagingBuffer::IOEngineConstraints& inputConstraints) { @@ -150,12 +150,12 @@ size_t StagingBuffer::calculateFirstSlotOffsetAndValidate( + ")"); } - if (firstSlotOffsetNBytes + nDgramsPerFrame * slotStrideNBytes + if (firstSlotOffsetNBytes + nSlots * slotStrideNBytes > bufferNBytes) { throw std::runtime_error(std::string(__func__) + ": StagingBuffer: buffer size insufficient to hold " - + std::to_string(nDgramsPerFrame) + + std::to_string(nSlots) + " slots with proper alignment and padding"); } @@ -165,17 +165,17 @@ size_t StagingBuffer::calculateFirstSlotOffsetAndValidate( StagingBuffer::StagingBuffer( const IOEngineConstraints& inputEngineConstraints_, const IOEngineConstraints& /*outputEngineConstraints*/, - size_t nDgramsPerFrame) + size_t nSlots) : buffer(nullptr, MmapDeleter(0)), bufferNBytes(0), -nDgramsPerFrame(nDgramsPerFrame), slotStrideNBytes(0), +nSlots(nSlots), slotStrideNBytes(0), firstSlotOffsetNBytes(0), inputConstraints(inputEngineConstraints_), assemblingFlag(false) { - if (nDgramsPerFrame == 0) + if (nSlots == 0) { throw std::invalid_argument(std::string(__func__) - + ": StagingBuffer: nDgramsPerFrame must be > 0"); + + ": StagingBuffer: nSlots must be > 0"); } computeSlotStrideAndBufferSize(); @@ -208,14 +208,14 @@ assemblingFlag(false) // Calculate offset and validate invariants (helper function in .cpp) firstSlotOffsetNBytes = StagingBuffer::calculateFirstSlotOffsetAndValidate( - buffer.get(), bufferNBytes, nDgramsPerFrame, + buffer.get(), bufferNBytes, nSlots, slotStrideNBytes, inputConstraints); // Build FrameAssemblyDesc once std::vector slots; - slots.reserve(nDgramsPerFrame); + slots.reserve(nSlots); uint8_t *frameBase = buffer.get() + firstSlotOffsetNBytes; - for (size_t i = 0; i < nDgramsPerFrame; ++i) + for (size_t i = 0; i < nSlots; ++i) { size_t off = i * slotStrideNBytes; FrameAssemblyDesc::SlotDesc s{ @@ -225,7 +225,7 @@ assemblingFlag(false) } frameDesc = std::make_shared( - nDgramsPerFrame, inputConstraints.slotPadToNBytes, bufferNBytes, + nSlots, inputConstraints.slotPadToNBytes, bufferNBytes, std::move(slots)); } diff --git a/include/user/stagingBuffer.h b/include/user/stagingBuffer.h index 23947c0..aa6762b 100644 --- a/include/user/stagingBuffer.h +++ b/include/user/stagingBuffer.h @@ -73,7 +73,7 @@ public: explicit StagingBuffer( const IOEngineConstraints& inputEngineConstraints, const IOEngineConstraints& outputEngineConstraints, - size_t nDgramsPerFrame); + size_t nSlots); ~StagingBuffer() = default; // Non-copyable, movable @@ -123,7 +123,7 @@ public: { std::ostringstream oss; oss << "StagingBuffer{" - << "nDgramsPerFrame=" << nDgramsPerFrame + << "nSlots=" << nSlots << ", bufferNBytes=" << bufferNBytes << ", slotStrideNBytes=" << slotStrideNBytes << ", constraints=" << inputConstraints.stringify() @@ -136,7 +136,7 @@ private: static size_t calculateFirstSlotOffsetAndValidate( uint8_t* buffer, size_t bufferNBytes, - size_t nDgramsPerFrame, + size_t nSlots, size_t slotStrideNBytes, const IOEngineConstraints& inputConstraints); @@ -163,7 +163,7 @@ private: size_t bufferNBytes; // Layout/invariants - size_t nDgramsPerFrame; + size_t nSlots; public: size_t slotStrideNBytes;