communications_buffers.tpp

/*---------------------------------------------------------------------------*\
 *
 *  bitpit
 *
 *  Copyright (C) 2015-2021 OPTIMAD engineering Srl
 *
 *  -------------------------------------------------------------------------
 *  License
 *  This file is part of bitpit.
 *
 *  bitpit is free software: you can redistribute it and/or modify it
 *  under the terms of the GNU Lesser General Public License v3 (LGPL)
 *  as published by the Free Software Foundation.
 *
 *  bitpit 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 bitpit. If not, see <http://www.gnu.org/licenses/>.
 *
\*---------------------------------------------------------------------------*/
 
#ifndef __BITPIT_COMMUNICATIONS_BUFFERS_TPP__
#define __BITPIT_COMMUNICATIONS_BUFFERS_TPP__
 
namespace bitpit {
 
template<typename T>
bitpit::SendBuffer & operator<<(bitpit::SendBuffer &buffer, const T &value)
{
    buffer.getFront() << value;
 
    return buffer;
}
 
template<typename T>
bitpit::RecvBuffer & operator>>(bitpit::RecvBuffer &buffer, T &value)
{
    buffer.getFront() >> value;
 
    return buffer;
}
 
template<typename RawBufferType>
CommunicationBuffer<RawBufferType>::CommunicationBuffer(size_t size, bool doubleBuffer)
{
    // Create the buffers
    m_buffers.emplace_back(size);
    if (doubleBuffer) {
        m_buffers.emplace_back(size);
    }
 
    // Assign the front and back buffers
    m_front = &m_buffers[doubleBuffer ? 1 : 0];
    m_back  = &m_buffers[0];
}
 
template<typename RawBufferType>
size_t CommunicationBuffer<RawBufferType>::getSize() const
{
    return m_front->getSize();
}
 
template<typename RawBufferType>
void CommunicationBuffer<RawBufferType>::setSize(size_t size)
{
    for (RawBufferType & buffer : m_buffers) {
        buffer.setSize(size);
    }
}
 
template<typename RawBufferType>
bool CommunicationBuffer<RawBufferType>::seekg(size_t pos)
{
    return m_front->seekg(pos);
}
 
template<typename RawBufferType>
std::ifstream::pos_type CommunicationBuffer<RawBufferType>::tellg() const
{
    return m_front->tellg();
}
 
template<typename RawBufferType>
bool CommunicationBuffer<RawBufferType>::isDouble() const
{
    return (m_buffers.size() == 2);
}
 
template<typename RawBufferType>
RawBufferType & CommunicationBuffer<RawBufferType>::getFront()
{
    return *m_front;
}
 
template<typename RawBufferType>
RawBufferType & CommunicationBuffer<RawBufferType>::getBack()
{
    return *m_back;
}
 
template<typename RawBufferType>
void CommunicationBuffer<RawBufferType>::swap()
{
    std::swap(m_front, m_back);
}
 
template<typename RawBufferType>
std::vector<RawBufferType> & CommunicationBuffer<RawBufferType>::getBuffers()
{
    return m_buffers;
}
 
template<typename RawBufferType>
const std::vector<RawBufferType> & CommunicationBuffer<RawBufferType>::getBuffers() const
{
    return m_buffers;
}
 
}
 
# endif