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

Update sleep duration in

rpc_server::scheduler_update() function
parent 89742884
Loading
Loading
Loading
Loading
Loading
+1 −1
Original line number Diff line number Diff line
@@ -179,7 +179,7 @@ main(int argc, char* argv[]) {
                    srv, adhoc_name, type, ctx, resources);

            auto path = deploy_adhoc_storage(srv, adhoc_storage);
            fmt::print("{}\n", path);
            fmt::print("{},{}\n", path, adhoc_storage.id());

            /* Separate inputs into vector of inputs */

+1 −1
Original line number Diff line number Diff line
@@ -951,7 +951,7 @@ 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);
        thallium::thread::self().sleep(m_network_engine, 1000);
        m_transfer_manager.lock();
        const auto transfer = m_transfer_manager.transfer();
        std::vector<scord::transfer_id> v_ids;