Commit 08da45c3 authored by Ramon Nou's avatar Ramon Nou
Browse files

Changed Thallium sleep to sleep to remove CPU hog

parent 5ee8ca30

src/scord/rpc_server.cpp

+2 −1
Original line number Diff line number Diff line
@@ -881,7 +881,8 @@ rpc_server::scheduler_update() { 
    std::vector<std::pair<std::string, int>> return_set;

    const auto threshold = 0.1f;

    while(!m_shutting_down) {

        thallium::thread::self().sleep(m_network_engine, 500);

        sleep(1);

        //thallium::thread::self().sleep(m_network_engine, 500);

        m_transfer_manager.lock();

        const auto transfer = m_transfer_manager.transfer();

        std::vector<scord::transfer_id> v_ids;

src/scord/rpc_server.hpp

+2 −2
Original line number Diff line number Diff line
@@ -115,7 +115,7 @@ private: 
    pfs_storage_manager m_pfs_manager;

    transfer_manager<cargo::transfer> m_transfer_manager;

    

    // Dedicated execution stream for the MPI listener ULT

    // Dedicated execution stream for the Scheduler listener ULT

    thallium::managed<thallium::xstream> m_scheduler_ess;

    // ULT for the MPI listener

    thallium::managed<thallium::thread> m_scheduler_ult;