SimpleCollections/src/SCCircularBuffer.cpp at main · TcMenu/SimpleCollections

30 lines (25 loc) · 902 Bytes

* This product is licensed under an Apache license, see the LICENSE file in the top-level directory.

#include "SCCircularBuffer.h"

using namespace tccollection;

SCCircularBuffer::SCCircularBuffer(uint16_t size) : readerPosition(0), writerPosition(0), bufferSize(size), buffer(new uint8_t[size]) {

atomicInitialisationSupport();

}

SCCircularBuffer::~SCCircularBuffer() {

delete[] buffer;

}

uint16_t SCCircularBuffer::nextPosition(position_ptr_t positionPtr) {

bool successfullyUpdated = false;

position_t existing;

while(!successfullyUpdated) {

existing = readAtomic(positionPtr);

position_t newPos = existing + 1;

if (newPos >= bufferSize) {

newPos = 0;

}

successfullyUpdated = casAtomic(positionPtr, existing, newPos);

}

return existing;

}

Provide feedback