Searched refs:rOffset (Results 1 – 1 of 1) sorted by relevance
546 auto rOffset = readOffset_->load(std::memory_order_acquire); in WriteNonBlocking() local569 if (wOffset < rOffset && newWriteOffset >= rOffset) { in WriteNonBlocking()587 auto rOffset = readOffset_->load(std::memory_order_acquire); in ReadNonBlocking() local588 if (rOffset + count <= qCount) { in ReadNonBlocking()589 …if (memcpy_s(data, count * sizeof(T), queueBuffer_ + (rOffset * sizeof(T)), count * sizeof(T)) != … in ReadNonBlocking()592 readOffset_->store((rOffset + count) % qCount, std::memory_order_release); in ReadNonBlocking()596 size_t firstPartSize = qCount - rOffset; in ReadNonBlocking()599 …if (memcpy_s(data, count * sizeof(T), queueBuffer_ + (rOffset * sizeof(T)), firstPartSize * sizeof… in ReadNonBlocking()621 auto rOffset = readOffset_->load(std::memory_order_acquire); in GetAvalidReadSize() local622 …auto size = wOffset >= rOffset ? (wOffset - rOffset) : (wOffset + meta_->GetElementCount() - rOffs… in GetAvalidReadSize()