Draft: Resolve "duplicate file"

Ramon Nourequested to merge
rnou/46-duplicate-file into main

Closes #46

Merge request reports

cli/ftio.cpp

+6 −1
Changes for cli/ftio.cpp: 6 added lines, 1 removed line.
Original line number Diff line number Diff line
@@ -35,6 +35,7 @@ struct ftio_config { 
    float confidence;

    float probability;

    float period;

    int mtime;

    bool run{false};

    bool pause{false};

    bool resume{false};
@@ -65,6 +66,10 @@ parse_command_line(int argc, char* argv[]) { 
            ->option_text("float")

            ->default_val("-1.0");



    app.add_option("-T,--mtime", cfg.mtime, "mtime")

    ->option_text("int")

    ->default_val("1");



    app.add_flag(

            "--run", cfg.run,

            "Trigger stage operation to run now. Has no effect when period is set > 0");
@@ -108,7 +113,7 @@ main(int argc, char* argv[]) { 
            const auto& endpoint = result.value();

            const auto retval =

                    endpoint.call("ftio_int", cfg.confidence, cfg.probability,

                                  cfg.period, cfg.run, cfg.pause, cfg.resume);

                                  cfg.period, cfg.run, cfg.pause, cfg.resume, cfg.mtime);



            if(retval.has_value()) {

lib/CMakeLists.txt

+7 −0
Changes for lib/CMakeLists.txt: 7 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -47,6 +47,13 @@ target_link_libraries(cargo PRIVATE 
        net::rpc_client

)



## If Python::Python available. update link libraries

if (Python_FOUND)

  target_link_libraries(cargo PRIVATE Python::Python)

endif ()







## Install library + targets ###################################################



set_target_properties(

lib/fmt_formatters.hpp

+1 −0
Changes for lib/fmt_formatters.hpp: 1 added line, 0 removed lines.
Original line number Diff line number Diff line
@@ -34,6 +34,7 @@ 
#include <fmt/ostream.h>

#include <fmt/os.h>

#include <fmt/std.h>

#include <fmt/ranges.h>

#include "cargo/error.hpp"

src/posix_file/posix_file/file.hpp

+4 −0
Changes for src/posix_file/posix_file/file.hpp: 4 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -288,6 +288,9 @@ public: 
        return bytes_written;

    }



    int handle() const noexcept {

        return m_handle.native();

    }

    

protected:

    const std::filesystem::path m_path;
@@ -314,6 +317,7 @@ open(const std::filesystem::path& filepath, int flags, ::mode_t mode, 
    // We don't check if it exists, we just create it if flags is set to O_CREAT



    if(flags & O_CREAT) {

        fs_plugin->unlink(filepath);

        recursive_mkdir(filepath, fs_plugin);

    }

src/worker/mpio_read.cpp

+1 −0
Changes for src/worker/mpio_read.cpp: 1 added line, 0 removed lines.
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)