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

reduced logging, ftio working

parent 0b71ed2b

src/master.cpp

+7 −5
Original line number Diff line number Diff line
@@ -247,10 +247,11 @@ master_server::ftio_scheduling_ult() { 
        transfer_dataset_internal(m_pending_transfer);

        // This launches the workers to do the work...

        // We wait until this transfer is finished

        LOGGER_INFO("Transferring : {}", m_pending_transfer.m_expanded_sources);

        LOGGER_INFO("Transferring {} files",

                    m_pending_transfer.m_expanded_sources.size());

        bool finished = false;

        while(!finished) {

            std::this_thread::sleep_for(10ms);

            std::this_thread::sleep_for(1s);

            m_request_manager.lookup(m_pending_transfer.m_p.tid())

                    .or_else([&](auto&& ec) {

                        LOGGER_ERROR("Failed to lookup request: {}", ec);
@@ -264,11 +265,12 @@ master_server::ftio_scheduling_ult() { 


        if(finished) {

            // Delete all source files

            LOGGER_INFO("Transfer finished for {}",

            LOGGER_INFO("Transfer finished {} files",

                        m_pending_transfer.m_expanded_sources);

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

                auto fs = FSPlugin::make_fs(

                        static_cast<cargo::FSPlugin::type>(m_pending_transfer.m_expanded_sources[0].get_type()));



                auto fs = FSPlugin::make_fs(static_cast<cargo::FSPlugin::type>(

                        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