common.sh

#!/bin/bash

function run_in_parallel()
{
    cmd=$1
    #echo_err $cmd
    lrc=${params[LRC]-1}
    if [ $lrc -eq 1 ]; then
        jobname=$2
        priority=$3
        logdir=$4
        timeout=$5
        $ML_FRAMEWORK_DIR/log.sh INFO "Running job $jobname on cluster. The logfile can be found in $logdir"
        qsubmit --jobname="$jobname" --mem="5g" --priority="$priority" --logdir="$logdir" \
            "$cmd"
        sleep $timeout
    else
        eval $cmd
    fi
}

function wait_for_jobs()
{
    jobs_finished_indicators=$1
    all_jobs_count=$2
    timeout=${3-10}

    $ML_FRAMEWORK_DIR/log.sh INFO "Waiting for jobs to be completed..."
    while [ `ls $jobs_finished_indicators 2> /dev/null | wc -l` -lt $all_jobs_count ]; do
        $ML_FRAMEWORK_DIR/log.sh DEBUG `ls $jobs_finished_indicators 2> /dev/null | wc -l` $all_jobs_count
        sleep $timeout
    done
}

function echo_err() {
    echo "$@" >&2
}

function print_ranking_header() {
    if [ -z $1 ]; then
        echo "TRAIN:"
    else
        echo "$1:"
    fi
    echo
    echo
    echo
}

function print_header() {
    stats_size=`cat $1 | wc -l`
    shift
    one_label_size=$(( $stats_size / $# ))
    for (( i=0; i<$stats_size; i++ )); do
        if [ $(( $i % $one_label_size )) -eq 0 ]; then
            echo "$1:"
            shift
        else
            echo
        fi
    done
}