push_singlethread()

template<typename T , typename StoragePolicy , typename ConcurrencyPolicy = SingleThreadedPolicy, typename AccessPattern = QueueAccess>

bool MayaFlux::Memory::RingBuffer< T, StoragePolicy, ConcurrencyPolicy, AccessPattern >::push_singlethread ( const T &  value )

inlineprivatenoexcept

Definition at line 1168 of file RingBuffer.hpp.

    {
        const size_t cap = m_storage.capacity();
        auto next_write = State::increment(m_state.write_index, cap);
 
        if (next_write == m_state.read_index) {
            return false;
        }
 
        if constexpr (AccessPattern::push_front) {
            m_state.write_index = (m_state.write_index == 0)
                ? cap - 1
                : m_state.write_index - 1;
            m_storage.buffer[m_state.write_index] = value;
        } else {
            m_storage.buffer[m_state.write_index] = value;
            m_state.write_index = next_write;
        }
 
        return true;
    }

References MayaFlux::Memory::RingBuffer< T, StoragePolicy, ConcurrencyPolicy, AccessPattern >::m_state, MayaFlux::Memory::RingBuffer< T, StoragePolicy, ConcurrencyPolicy, AccessPattern >::m_storage, and value.

Referenced by MayaFlux::Memory::RingBuffer< T, StoragePolicy, ConcurrencyPolicy, AccessPattern >::push().

Here is the caller graph for this function: