io.cpp

Go to the documentation of this file.

// -------------------------------------------------------//
//
// SHAMROCK code for hydrodynamics
// Copyright (c) 2021-2026 Timothée David--Cléris <tim.shamrock@proton.me>
// SPDX-License-Identifier: CeCILL Free Software License Agreement v2.1
// Shamrock is licensed under the CeCILL 2.1 License, see LICENSE for more information
//
// -------------------------------------------------------//
 
#include "shambase/exception.hpp"
#include "shamcomm/io.hpp"
#include "shamcomm/mpiErrorCheck.hpp"
#include "shamcomm/worldInfo.hpp"
 
namespace shamcomm {
 
    void open_reset_file(MPI_File &fh, const std::string &fname) {
 
        int rc = MPI_File_open(
            MPI_COMM_WORLD,
            fname.c_str(),
            MPI_MODE_CREATE | MPI_MODE_WRONLY | MPI_MODE_EXCL | MPI_MODE_UNIQUE_OPEN,
            MPI_INFO_NULL,
            &fh);
 
        if (rc != MPI_SUCCESS) {
 
            if (shamcomm::world_rank() == 0) {
                MPICHECK(MPI_File_delete(fname.c_str(), MPI_INFO_NULL));
            }
 
            int rc = MPI_File_open(
                MPI_COMM_WORLD,
                fname.c_str(),
                MPI_MODE_CREATE | MPI_MODE_WRONLY | MPI_MODE_EXCL | MPI_MODE_UNIQUE_OPEN,
                MPI_INFO_NULL,
                &fh);
 
            if (rc != MPI_SUCCESS) {
                throw shambase::make_except_with_loc<std::runtime_error>("cannot create file");
            }
        }
    }
 
    void open_read_only_file(MPI_File &fh, const std::string &fname) {
        MPICHECK(MPI_File_open(
            MPI_COMM_WORLD,
            fname.c_str(),
            MPI_MODE_RDONLY | MPI_MODE_UNIQUE_OPEN,
            MPI_INFO_NULL,
            &fh));
    }
 
} // namespace shamcomm