BP1Base.cpp

/*
 * Distributed under the OSI-approved Apache License, Version 2.0.  See
 * accompanying file Copyright.txt for details.
 *
 * BP1.cpp
 *
 *  Created on: Feb 7, 2017
 *      Author: wfg
 */

#include "BP1Base.h"
#include "core/adiosFunctions.h"

namespace adios
{
namespace format
{

std::string BP1Base::GetDirectoryName(const std::string name) const noexcept
{
    std::string directory;

    if (name.find(".bp") == name.size() - 3)
    {
        directory = name;
    }
    else
    {
        directory = name + ".bp";
    }
    return directory;
}

// this should go outside
void BP1Base::OpenRankFiles(const std::string name,
                            const std::string accessMode, Transport &file) const
{
    const std::string directory = GetDirectoryName(name);
    CreateDirectory(
        directory); // creates a directory and sub-directories recursively

    std::string fileName(directory + "/" + directory + "." +
                         std::to_string(file.m_RankMPI));
    file.Open(fileName, accessMode); // opens a file transport under
                                     // name.bp/name.bp.rank reserve that
                                     // location for writing
}

std::vector<std::uint8_t> BP1Base::GetMethodIDs(
    const std::vector<std::shared_ptr<Transport>> &transports) const noexcept
{
    auto lf_GetMethodID = [](const std::string method) -> std::uint8_t {
        int id = METHOD_UNKNOWN;
        if (method == "NULL")
            id = METHOD_NULL;
        else if (method == "POSIX")
            id = METHOD_POSIX;
        else if (method == "FStream")
            id = METHOD_FSTREAM;
        else if (method == "File")
            id = METHOD_FILE;
        else if (method == "MPI")
            id = METHOD_MPI;

        return id;
    };

    std::vector<std::uint8_t> methodIDs;
    methodIDs.reserve(transports.size());

    for (const auto &transport : transports)
        methodIDs.push_back(lf_GetMethodID(transport->m_Type));

    return methodIDs;
}

} // end namespace format
} // end namespace adios