qlib.sh

Go to the documentation of this file.

#!/bin/zsh
#
#
# \author mdejong
#
#--------------------------------------------------------------------------------------
#
#                   Utility script for batch queue functions.
#
#--------------------------------------------------------------------------------------


#
# Put command(s) in given queue; do not submit job.
#
# \param   1         queue name
# \param   2-N       command(s)
#
function put_queue()
{
    queue_name=$1
    shift
    
    echo -n "$*;" >> $queue_name
}


#
# Put command(s) in given queue and submit job.
#
# \param   1         queue name
# \param   2-N       command(s)
#
function puts_queue()
{
    queue_name=$1
    shift
    
    echo "$*" >> $queue_name
}


#
# Run queue.
#
# \param   1         queue name
# \param   2         queue size
# \param   3         sleep time [s]
#
function queue()
{
    queue_name=$1
    queue_size=$2
    sleep_time=$3

    if [[ -e $queue_name ]]; then

        if [[ -p $queue_name ]]; then
            fatal "Queue $queue_name in use."
        fi    
    else
        
        mkfifo $queue_name                                # create a new FIFO
    fi

    fd=7                                                  # file descriptor

    eval "exec $fd<>$queue_name"                          # attach file descriptor to FIFO

    while read job <& $fd; do                             # read job from file descriptor
        
        if [[ -n $job ]]; then
            
            if [[ $job = "exit" ]]; then
                break
            fi

            notice "submit $job" 
            eval exec $job &                              # submit job

            # wait for free slot
        
            while (( ${#jobstates} >= $queue_size )); do
                sleep $sleep_time
            done
        fi
    done
    
    rm -f $queue_name                                     # remove FIFO
}