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

FTIO delete files in any backend

parent c5fbd871

src/master.cpp

+8 −5
Original line number Diff line number Diff line
@@ -266,13 +266,16 @@ master_server::ftio_scheduling_ult() { 
            // Delete all source files

            LOGGER_INFO("Transfer finished for {}",

                        m_pending_transfer.m_expanded_sources);

            auto fs = FSPlugin::make_fs(cargo::FSPlugin::type::gekkofs);

            if(m_pending_transfer.m_expanded_sources.size() > 0) {

                auto fs = FSPlugin::make_fs(

                        m_pending_transfer.m_expanded_sources[0].get_type());

                for(auto& file : m_pending_transfer.m_expanded_sources) {

                    LOGGER_INFO("Deleting {}", file.path());

                    // We need to use gekkofs to delete

                    fs->unlink(file.path());

                }

            }

        }

        if(m_period > 0) {

            // always run whenever period is set

            m_ftio_run = true;