Searched refs:rOffset (Results 1 – 1 of 1) sorted by relevance
543 auto rOffset = readOffset_->load(std::memory_order_acquire); in WriteNonBlocking() local566 if (wOffset < rOffset && newWriteOffset >= rOffset) { in WriteNonBlocking()584 auto rOffset = readOffset_->load(std::memory_order_acquire); in ReadNonBlocking() local585 if (rOffset + count <= qCount) { in ReadNonBlocking()586 …if (memcpy_s(data, count * sizeof(T), queueBuffer_ + (rOffset * sizeof(T)), count * sizeof(T)) != … in ReadNonBlocking()589 readOffset_->store((rOffset + count) % qCount, std::memory_order_release); in ReadNonBlocking()593 size_t firstPartSize = qCount - rOffset; in ReadNonBlocking()596 …if (memcpy_s(data, count * sizeof(T), queueBuffer_ + (rOffset * sizeof(T)), firstPartSize * sizeof… in ReadNonBlocking()618 auto rOffset = readOffset_->load(std::memory_order_acquire); in GetAvalidReadSize() local619 …auto size = wOffset >= rOffset ? (wOffset - rOffset) : (wOffset + meta_->GetElementCount() - rOffs… in GetAvalidReadSize()