capsuleTemplates.h

/*
 * Distributed under the OSI-approved Apache License, Version 2.0.  See
 * accompanying file Copyright.txt for details.
 *
 * capsuleTemplates.h
 *
 *  Created on: Nov 18, 2016
 *      Author: wfg
 */

#ifndef ADIOS2_CORE_CAPSULETEMPLATES_H_
#define ADIOS2_CORE_CAPSULETEMPLATES_H_

/// \cond EXCLUDE_FROM_DOXYGEN
#include <cstring> //std::memcpy
#include <thread>
#include <vector>
/// \endcond

#include "adios2/ADIOSConfig.h"
#include "adios2/core/Transport.h"

namespace adios
{

/**
 *
 * @param data
 * @param size
 * @param transportIndex
 * @param transports
 * @param maxBufferSize
 * @param buffer
 */
// template<class T>
// void WriteToBuffer( const T* data, const size_t size,
//                    std::vector< std::shared_ptr<Transport> >& transports,
//                    const size_t maxBufferSize, std::vector<char>& buffer )
//{
//    auto lf_TransportsWrite = []( const int transportIndex, std::vector<
//    std::shared_ptr<Transport> >& transports,
//                                  std::vector<char>& buffer )
//    {
//        if( transportIndex == -1 ) // all transports
//        {
//            for( auto& transport : transports )
//                transport->Write( buffer );
//        }
//        else
//            transports[ transportIndex ]->Write( buffer );
//    };
//
//    //FUNCTION starts here
//    const size_t dataBytes = size * sizeof( T ); //size of data in bytes
//
//    //check for DataMan transport
//    if( transportIndex == -1 ) // all transports
//    {
//        for( auto& transport : transports )
//        {
//            if( transport->m_Method == "DataMan" ) //DataMan needs all the
//            information
//                buffer.resize( dataBytes ); //resize buffer to fit all data
//        }
//    }
//    else //just one transport
//    {
//        if( transports[transportIndex]->m_Method == "DataMan" )
//            buffer.resize( dataBytes ); //resize buffer to fit all data
//    }
//
//    if( dataBytes <= buffer.size() ) // dataBytes < buffer.size()
//    {
//        buffer.resize( dataBytes ); //this resize shouldn't change capacity or
//        call realloc
//        MemcpyThreads( &buffer[0], data, dataBytes, 1 ); //copy memory in
//        threaded fashion, need to test with size, serial for now
//        lf_TransportsWrite( transportIndex, transports, buffer );
//        return;
//    }
//
//    if( buffer.size() < dataBytes && dataBytes <= maxBufferSize ) //
//    buffer.size() < dataBytes <  maxBufferSize
//    {
//        buffer.resize( dataBytes );
//        MemcpyThreads( &buffer[0], data, dataBytes, 1 ); //copy memory in
//        threaded fashion, need to test with size, serial for now
//        lf_TransportsWrite( transportIndex, transports, buffer );
//        return;
//    }
//
//    // dataBytes > maxBufferSize == buffer.size() split the variable in buffer
//    buckets
//    buffer.resize( maxBufferSize ); //resize to maxBufferSize, this might call
//    realloc
//    const size_t buckets =  dataBytes / maxBufferSize + 1;
//    const size_t remainder = dataBytes % maxBufferSize;
//
//    for( unsigned int bucket = 0; buckets < buckets; ++bucket )
//    {
//        const size_t dataOffset = bucket * maxBufferSize / sizeof( T );
//
//        if( bucket == buckets-1 )
//            MemcpyThreads( &buffer[0], data[dataOffset], remainder, 1 );
//        else
//            MemcpyThreads( &buffer[0], data[dataOffset], maxBufferSize, 1 );
//
//        lf_TransportsWrite( transportIndex, transports, buffer );
//    }
//}

} // end namespace

#endif /* ADIOS2_CORE_CAPSULETEMPLATES_H_ */