Commit 08597452 authored by Ramon Nou's avatar Ramon Nou
Browse files

updated other backends

parent bf854d00

src/worker/mpio_read.cpp

+2 −1
Original line number Diff line number Diff line
@@ -129,6 +129,7 @@ mpio_read::operator()() { 
            return make_mpi_error(ec);

        }

        

        

        // step3. POSIX write data

        // We need to create the directory if it does not exists (using

        // FSPlugin)

src/worker/seq_mixed.cpp

+1 −0
Original line number Diff line number Diff line
@@ -185,6 +185,7 @@ seq_mixed_operation::progress(int ongoing_index) { 




    m_status = error_code::success;

    m_input_file->close();

    m_output_file->close();

    return -1;

}

src/worker/sequential.cpp

+2 −2
Original line number Diff line number Diff line
@@ -185,7 +185,7 @@ seq_operation::progress(int ongoing_index) { 
    // step3. POSIX write data

    // We need to create the directory if it does not exists (using

    // FSPlugin)



    m_input_file->close();

    if(write and ongoing_index == 0) {

        m_output_file = std::make_unique<posix_file::file>(posix_file::create(

                m_output_path, O_WRONLY, S_IRUSR | S_IWUSR, m_fs_o_type));
@@ -230,7 +230,7 @@ seq_operation::progress(int ongoing_index) { 


            ++index;

        }



        m_output_file->close();

    } catch(const posix_file::io_error& e) {

        LOGGER_ERROR("{}() failed: {}", e.where(), e.what());

        m_status = make_system_error(e.error_code());