Loading plugins/adhoc_services.d/gekkofs.sh +1 −0 Original line number Diff line number Diff line Loading @@ -42,6 +42,7 @@ elif [ "$1" == "stop" ]; then fi unset SLURM_CPU_BIND SLURM_CPU_BIND_LIST SLURM_CPU_BIND_TYPE SLURM_CPU_BIND_VERBOSE srun -N $num_nodes -n $num_nodes --overlap --oversubscribe --cpus-per-task=1 --mem-per-cpu=1 --export=ALL /usr/bin/bash -c "pkill -9 gkfs_daemon" rm $LIBGKFS_HOSTS_FILE elif [ "$1" == "expand" ]; then echo "Expand command" elif [ "$1" == "shrink" ]; then Loading src/scord/rpc_server.cpp +1 −3 Original line number Diff line number Diff line Loading @@ -971,12 +971,10 @@ rpc_server::scheduler_update() { switch(status.state()) { case cargo::transfer_state::completed: LOGGER_INFO("Completed"); v_ids.push_back(tr_unit.first); continue; break; case cargo::transfer_state::failed: LOGGER_INFO("Failed"); v_ids.push_back(tr_unit.first); continue; break; Loading @@ -999,7 +997,7 @@ rpc_server::scheduler_update() { if(bw == -1) { continue; } LOGGER_INFO("QoS Measured BW : {} vs QOS : {} ", bw, qos); if(bw + bw * threshold > qos) { // Send decrease / slow signal to cargo tr_info->transfer().bw_control(+1); Loading Loading
plugins/adhoc_services.d/gekkofs.sh +1 −0 Original line number Diff line number Diff line Loading @@ -42,6 +42,7 @@ elif [ "$1" == "stop" ]; then fi unset SLURM_CPU_BIND SLURM_CPU_BIND_LIST SLURM_CPU_BIND_TYPE SLURM_CPU_BIND_VERBOSE srun -N $num_nodes -n $num_nodes --overlap --oversubscribe --cpus-per-task=1 --mem-per-cpu=1 --export=ALL /usr/bin/bash -c "pkill -9 gkfs_daemon" rm $LIBGKFS_HOSTS_FILE elif [ "$1" == "expand" ]; then echo "Expand command" elif [ "$1" == "shrink" ]; then Loading
src/scord/rpc_server.cpp +1 −3 Original line number Diff line number Diff line Loading @@ -971,12 +971,10 @@ rpc_server::scheduler_update() { switch(status.state()) { case cargo::transfer_state::completed: LOGGER_INFO("Completed"); v_ids.push_back(tr_unit.first); continue; break; case cargo::transfer_state::failed: LOGGER_INFO("Failed"); v_ids.push_back(tr_unit.first); continue; break; Loading @@ -999,7 +997,7 @@ rpc_server::scheduler_update() { if(bw == -1) { continue; } LOGGER_INFO("QoS Measured BW : {} vs QOS : {} ", bw, qos); if(bw + bw * threshold > qos) { // Send decrease / slow signal to cargo tr_info->transfer().bw_control(+1); Loading