lfQueue.ipp

/* Copyright (c) 2010-2013, Stefan Eilemann <eile@equalizergraphics.com>
 *
 * This library is free software; you can redistribute it and/or modify it under
 * the terms of the GNU Lesser General Public License version 2.1 as published
 * by the Free Software Foundation.
 *
 * This library is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 * FOR A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more
 * details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this library; if not, write to the Free Software Foundation, Inc.,
 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */

namespace lunchbox
{
template <typename T>
void LFQueue<T>::clear()
{
    LB_TS_SCOPED(_reader);
    _readPos = 0;
    _writePos = 0;
}

template <typename T>
void LFQueue<T>::resize(const int32_t size)
{
    LBASSERT(isEmpty());
    _readPos = 0;
    _writePos = 0;
    _data.resize(size + 1);
}

template <typename T>
bool LFQueue<T>::pop(T& result)
{
    LB_TS_SCOPED(_reader);
    if (_readPos == _writePos)
        return false;

    result = _data[_readPos];
    _readPos = (_readPos + 1) % _data.size();
    return true;
}

template <typename T>
bool LFQueue<T>::getFront(T& result)
{
    LB_TS_SCOPED(_reader);
    if (_readPos == _writePos)
        return false;

    result = _data[_readPos];
    return true;
}

template <typename T>
bool LFQueue<T>::push(const T& element)
{
    LB_TS_SCOPED(_writer);
    int32_t nextPos = (_writePos + 1) % _data.size();
    if (nextPos == _readPos)
        return false;

    _data[_writePos] = element;
    _writePos = nextPos;
    return true;
}
}