diff --git a/branches/distributed-ppss/ppss.sh b/branches/distributed-ppss/ppss.sh
new file mode 100755
index 0000000..b65f027
--- /dev/null
+++ b/branches/distributed-ppss/ppss.sh
@@ -0,0 +1,851 @@
+#!/usr/bin/env bash
+#*
+#* PPSS, the Parallel Processing Shell Script
+#* 
+#* Copyright (c) 2009, Louwrentius
+#* All rights reserved.
+#*
+#* Redistribution and use in source and binary forms, with or without
+#* modification, are permitted provided that the following conditions are met:
+#*     * Redistributions of source code must retain the above copyright
+#*       notice, this list of conditions and the following disclaimer.
+#*     * Redistributions in binary form must reproduce the above copyright
+#*       notice, this list of conditions and the following disclaimer in the
+#*       documentation and/or other materials provided with the distribution.
+#*     * Neither the name of the <organization> nor the
+#*       names of its contributors may be used to endorse or promote products
+#*       derived from this software without specific prior written permission.
+#*
+#* THIS SOFTWARE IS PROVIDED BY Louwrentius ''AS IS'' AND ANY
+#* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+#* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+#* DISCLAIMED. IN NO EVENT SHALL Louwrentius BE LIABLE FOR ANY
+#* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+#* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+#* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+#* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+#* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+#* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+
+#------------------------------------------------------
+# It should not be necessary to edit antyhing.
+# Ofcource you can if it is necesary for your needs.
+# Send a patch if your changes may benefit others.
+#------------------------------------------------------
+
+# Handling control-c for a clean shutdown.
+trap 'kill_process; ' INT
+
+# Setting some vars. Do not change. 
+SCRIPT_NAME="Parallel Processing Shell Script"
+SCRIPT_VERSION="1.10"
+
+RUNNING_SIGNAL="$0_is_running"          # Prevents running mutiple instances of PPSS.. 
+GLOBAL_LOCK="PPSS-GLOBAL-LOCK"          # Global lock file used by local PPSS instance.
+PAUSE_SIGNAL="pause.txt"                # Not implemented yet (pause processing).
+ARRAY_POINTER_FILE="ppss-array-pointer" # 
+JOB_LOG_DIR="JOB_LOG"                   # Directory containing log files of processed items.
+LOGFILE="ppss-log.txt"                  # General PPSS log file. Contains lots of info.
+MAX_DELAY=2
+PERCENT="0"
+PID="$$"
+LISTENER_PID=""
+IFS_BACKUP="$IFS"
+INTERVAL="15"                           # Polling interval to check if there are running jobs.
+
+SSH_SERVER=""                           # Remote server or 'master'.
+SSH_KEY=""                              # SSH key for ssh account.
+SSH_SOCKET="/tmp/PPSS-ssh-socket"       # Multiplex multiple SSH connections over 1 master.
+SSH_OPTS="-o BatchMode=yes -o ControlPath=$SSH_SOCKET -o ControlMaster=auto -o ConnectTimeout=5"
+SSH_MASTER_PID=""
+ITEM_LOCK_DIR="PPSS_ITEM_LOCK_DIR"      # Remote directory on master used for item locking.
+PPSS_LOCAL_WORKDIR="PPSS_LOCAL_WORKDIR" # Local directory on slave for local processing.
+TRANSFER_TO_SLAVE="0"                   # Transfer item to slave via (s)cp.
+SECURE_COPY="1"                         # If set, use SCP, Otherwise, use cp.
+REMOTE_OUTPUT_DIR=""                    # Remote directory to which output must be uploaded.
+
+showusage () {
+    
+    echo 
+    echo "$SCRIPT_NAME"
+    echo "Version: $SCRIPT_VERSION"
+    echo 
+    echo "Description: this script processess files or other items in parallel. It is designed to make"
+    echo "use of the multi-core CPUs. It will detect the number of available CPUs and start a thread "
+    echo "for each CPU core. It will also use hyperthreading if available." It has also support for
+    echo "distributed usage, using a Master server in conjunction with (multiple) slaves."
+    echo 
+    echo "Usage: $0 [ options ]"
+    echo 
+    echo "Options are:"
+    echo 
+    echo -e "\t- c \tCommand to execute. Can be a custom script or just a plain command."
+    echo -e "\t- d \tDirectory containing items to be processed."
+    echo -e "\t- f \tFile containing items to be processed. (Alternative to -d)" 
+    echo -e "\t- l \tSpecifies name and location of the logfile."
+    echo -e "\t- p \tSpecifies number of simultaneous processes manually. (optional)"
+    echo -e "\t- j \tEnable or disable hyperthreading. Enabled by default. (optional)"
+    echo
+    echo "Options for distributed usage:"
+    echo 
+    echo -e "\t- s \tUsername@server domain name or IP-address of 'PPSS master server'."
+    echo -e "\t- k \tSSH key file used for connection with 'PPSS master server'."
+    echo -e "\t- t \tTransfer remote item to slave for local processing."
+    echo -e "\t- o \tUpload output back to server into this directory."
+    echo -e "\t- n \tDo *not* use scp for item transfer but use cp. "
+    echo 
+    echo -e "Example: encoding some wav files to mp3 using lame:"
+    echo 
+    echo -e "$0 -c 'lame ' -d /path/to/wavfiles -l logfile -j (wach out for the space in -c)" 
+    echo    
+}
+
+kill_process () {
+
+    kill $LISTENER_PID >> /dev/null 2>&1
+    while true
+    do
+        JOBS=`ps ax | grep -v grep | grep ppss.sh | wc -l`
+        if [ "$JOBS" -gt "2" ]
+        then
+            for x in `ps ax | grep -v grep | grep ppss.sh | awk '{ print $1 }'`
+            do
+                if [ ! "$x" == "$PID" ] && [ ! "$x" == "$$" ]
+                then
+                    kill -9 $x >> /dev/null 2>&1
+                fi
+            done
+            sleep 5
+        else
+            cleanup 
+            echo -en "\033[1B"
+            # The master SSH connection should be killed.
+            if [ ! -z "$SSH_MASTER_PID" ]
+            then
+                kill -9 "$SSH_MASTER_PID"
+            fi
+            log INFO "Finished."
+            echo ""
+            exit 0
+        fi
+    done
+    
+}
+
+exec_cmd () { 
+
+    CMD="$1"
+
+    if [ ! -z "$SSH_SERVER" ]
+    then
+        ssh $SSH_OPTS $SSH_KEY $SSH_SERVER $CMD
+    else
+        eval "$CMD"
+    fi
+}
+
+# this function makes remote or local checking of existence of items transparent.
+does_file_exist () {
+
+    FILE="$1"
+    `exec_cmd "ls -1 $FILE >> /dev/null 2>&1"`
+    if [ "$?" == "0" ]
+    then
+        return 0
+    else 
+        return 1
+    fi
+}
+
+
+cleanup () {
+
+    log DEBUG "$FUNCNAME - Cleaning up all temp files and processes."
+    
+    if [ -e "$FIFO" ]
+    then 
+        rm $FIFO 
+    fi
+
+    if [ -e "$ARRAY_POINTER_FILE" ] 
+    then
+        rm $ARRAY_POINTER_FILE
+    fi
+
+    if [ -e "$GLOBAL_LOCK" ] 
+    then
+        rm -rf $GLOBAL_LOCK
+    fi
+
+    if [ -e "$RUNNING_SIGNAL" ]
+    then
+        rm "$RUNNING_SIGNAL"
+    fi
+
+    if [ -e "$SSH_SOCKET" ]
+    then
+        rm -rf "$SSH_SOCKET"
+    fi
+
+}
+
+
+
+# check if ppss is already running.
+is_running () {
+
+    if [ -e "$RUNNING_SIGNAL" ]
+    then
+        echo 
+        log INFO "$0 is already running (lock file exists)."
+        echo
+        exit 1
+    fi
+}
+
+# If no arguments are specified, show usage.
+if [ $# -eq 0 ]
+then
+  showusage
+  exit 1
+fi
+
+# If rubbish is givven as an argument, display usage info."
+echo $1 | grep -e ^- >> /dev/null
+ERROR=$?
+if [ ! "$ERROR" == "0" ]
+then
+  showusage
+  exit 1
+fi
+
+# Process any command-line options that are specified."
+while getopts ":c:d:f:i:jhk:l:no:p:s:tv" OPTIONS
+do
+    case $OPTIONS in
+        f )
+            INPUT_FILE="$OPTARG"
+            ;;
+        d ) 
+            SRC_DIR="$OPTARG"
+            ;; 
+        c ) 
+            COMMAND="$OPTARG"
+            ;;
+
+        h )
+            showusage
+            exit 1;;
+        j )
+            HYPERTHREADING=yes
+            ;;
+        l )
+            LOGFILE="$OPTARG"
+            ;;
+        k )
+            SSH_KEY="-i $OPTARG"
+            ;;
+        n )
+            SECURE_COPY=0
+            ;;
+        o )
+            REMOTE_OUTPUT_DIR="$OPTARG"
+            ;;
+            
+        p )
+            TMP="$OPTARG"
+            if [ ! -z "$TMP" ]
+            then
+                MAX_NO_OF_RUNNING_JOBS="$TMP"
+            fi
+            ;;
+        s ) 
+            SSH_SERVER="$OPTARG"
+            ;;
+        t )
+            TRANSFER_TO_SLAVE="1"    
+            ;;
+
+        v )
+            echo ""
+            echo "$SCRIPT_NAME version $SCRIPT_VERSION"
+            echo ""
+            exit 0
+            ;;
+        * )
+            showusage
+            exit 1;;
+    esac
+done
+
+# This function makes local and remote operation transparent.
+
+
+# Init all vars
+init_vars () {
+
+    if [ -e "$LOGFILE" ]
+    then
+        rm $LOGFILE
+    fi
+
+    if [ -z "$COMMAND" ]
+    then
+        echo
+        echo "ERROR - no command specified."
+        echo
+        showusage
+        cleanup
+        exit 1
+    fi
+
+    echo 0 > $ARRAY_POINTER_FILE
+
+    FIFO=$(pwd)/fifo-$RANDOM-$RANDOM
+
+    if [ ! -e "$FIFO" ]
+    then    
+        mkfifo -m 600 $FIFO
+    fi
+
+    exec 42<> $FIFO
+
+    touch $RUNNING_SIGNAL
+
+    if [ -z "$MAX_NO_OF_RUNNING_JOBS" ]
+    then 
+        MAX_NO_OF_RUNNING_JOBS=`get_no_of_cpus $HYPERTHREADING`
+    fi
+
+    does_file_exist "$JOB_LOG_DIR"
+    if [ ! "$?" == "0" ]
+    then
+        log INFO "Job log directory $JOB_lOG_DIR does not exist. Creating."
+        exec_cmd "mkdir $JOB_LOG_DIR"
+    else
+        log INFO "Job log directory $JOB_LOG_DIR exists, if it contains logs for items, these items will be skipped."
+    fi
+
+    does_file_exist "$ITEM_LOCK_DIR"
+    if [ ! "$?" == "0" ]
+    then
+        log DEBUG "Creating remote item lock dir."
+        exec_cmd "mkdir $ITEM_LOCK_DIR"
+    fi
+
+    if [ ! -e "$JOB_LOG_DIR" ]
+    then
+        mkdir "$JOB_LOG_DIR"
+    fi
+
+    does_file_exist "$REMOTE_OUTPUT_DIR"
+    if [ ! "$?" == "0" ]
+    then
+        echo "ERROR: remote output dir $REMOTE_OUTPUT_DIR does not exist."
+        exit
+    fi
+
+    if [ ! -e "$PPSS_LOCAL_WORKDIR" ] && [ ! -z "$SSH_SERVER" ]
+    then
+        mkdir "$PPSS_LOCAL_WORKDIR"
+    fi
+}
+
+expand_str () {
+
+    STR=$1
+    LENGTH=$TYPE_LENGTH
+    SPACE=" "
+
+    while [ "${#STR}" -lt "$LENGTH" ]
+    do
+        STR=$STR$SPACE
+    done
+
+    echo "$STR"
+}
+
+log () {
+
+    TYPE="$1"
+    MESG="$2"
+    TMP_LOG=""
+    TYPE_LENGTH=6 
+
+    TYPE_EXP=`expand_str "$TYPE"`
+
+    DATE=`date +%b\ %d\ %H:%M:%S`
+    PREFIX="$DATE: ${TYPE_EXP:0:$TYPE_LENGTH} -"
+
+    LOG_MSG="$PREFIX $MESG"
+
+    echo -e "$LOG_MSG" >> "$LOGFILE"
+
+    if [ "$TYPE" == "INFO" ]
+    then
+        echo -e "$LOG_MSG"
+    fi
+
+}
+
+check_status () {
+
+    ERROR="$1"
+    FUNCTION="$2"
+    MESSAGE="$3"
+
+    if [ ! "$ERROR" == "0" ]
+    then
+        log INFO "$FUNCTION - $MESSAGE"
+        cleanup
+        exit 1
+    fi
+
+}
+
+test_server () {
+
+    # Testing if the remote server works as expected.
+    if [ ! -z "$SSH_SERVER" ] 
+    then
+        exec_cmd "date >> /dev/null"
+        check_status "$?" "$FUNCNAME" "Server $SSH_SERVER could not be reached"
+
+        ssh -N -M $SSH_OPTS $SSH_KEY $SSH_SERVER &
+        SSH_MASTER_PID="$!"
+    else
+        log DEBUG "No remote server specified, assuming stand-alone mode."
+    fi
+}
+
+get_no_of_cpus () {
+
+    # Use hyperthreading or not?
+    HPT=$1
+    NUMBER=""
+
+    if [ -z "$HPT" ]
+    then
+        HPT=no
+    fi
+
+    got_cpu_info () {
+
+    ERROR="$1"
+    check_status "$ERROR" "$FUNCNAME" "cannot determine number of cpu cores. Please specify a number of parallell processes manually with -p." 
+
+    }
+
+    if [ "$HPT" == "yes" ]
+    then
+        if [ `uname` == "Linux" ]
+        then
+            NUMBER=`cat /proc/cpuinfo | grep processor | wc -l`
+            got_cpu_info "$?"
+            
+        elif [ `uname` == "Darwin" ]
+        then
+            NUMBER=`sysctl -a hw | grep -w logicalcpu | awk '{ print $2 }'`
+            got_cpu_info "$?"
+        elif [ `uname` == "FreeBSD" ]
+        then
+            NUMBER=`sysctl hw.ncpu | awk '{ print $2 }'`
+            got_cpu_info "$?"
+        else
+            NUMBER=`cat /proc/cpuinfo | grep processor | wc -l`
+            got_cpu_info "$?"
+        fi
+    elif [ "$HPT" == "no" ]
+    then
+        if [ `uname` == "Linux" ]
+        then
+            NUMBER=`cat /proc/cpuinfo | grep "cpu cores" | cut -d ":" -f 2 | uniq | sed -e s/\ //g`
+            got_cpu_info "$?"
+        elif [ `uname` == "Darwin" ]
+        then
+            NUMBER=`sysctl -a hw | grep -w physicalcpu | awk '{ print $2 }'`
+            got_cpu_info "$?"
+        elif [ `uname` == "FreeBSD" ]
+        then
+            NUMBER=`sysctl hw.ncpu | awk '{ print $2 }'`
+            got_cpu_info "$?"
+        else
+            NUMBER=`cat /proc/cpuinfo | grep "cpu cores" | cut -d ":" -f 2 | uniq | sed -e s/\ //g`
+            got_cpu_info "$?"
+        fi
+
+    fi
+
+    if [ ! -z "$NUMBER" ]
+    then
+        echo "$NUMBER"
+    else
+        log INFO "$FUNCNAME ERROR - number of CPUs not obtained."
+        exit 1
+    fi
+}
+
+
+random_delay () {
+
+    ARGS="$1"
+
+    if [ -z "$ARGS" ]
+    then
+        log ERROR "$FUNCNAME Function random delay, no argument specified."
+        exit 1
+    fi
+
+    NUMBER=$RANDOM
+    let "NUMBER %= $ARGS"
+    sleep "$NUMBER"
+}
+
+
+global_lock () {
+
+    mkdir $GLOBAL_LOCK > /dev/null 2>&1
+    ERROR="$?"
+
+    if [ ! "$ERROR" == "0" ]
+    then
+        return 1
+    else
+        return 0
+    fi
+}
+
+get_global_lock () {
+
+    while true
+    do
+        global_lock
+        ERROR="$?"
+        if [ ! "$ERROR" == "0" ]
+        then
+            random_delay $MAX_DELAY
+            continue
+        else
+            break
+        fi
+    done
+}
+
+release_global_lock () {
+
+    rm -rf "$GLOBAL_LOCK"
+}
+
+are_jobs_running () {
+   
+    NUMBER_OF_PROCS=`jobs | wc -l`
+    if [ "$NUMBER_OF_PROCS" -gt "1" ]
+    then
+        return 0
+    else
+        return 1
+    fi
+}
+
+download_item () {
+
+    ITEM="$1"
+    ITEM_WITH_PATH="$SRC_DIR/$ITEM"
+
+    if [ "$TRANSFER_TO_SLAVE" == "1" ]
+    then
+        log DEBUG "Transfering item $ITEM to local disk."
+        if [ "$SECURE_COPY" == "1" ]
+        then
+            scp -q $SSH_OPTS $SSH_KEY $SSH_SERVER:$ITEM_WITH_PATH $PPSS_LOCAL_WORKDIR
+        else
+            cp $ITEM_WITH_PATH $PPSS_LOCAL_WORKDIR 
+        fi
+    fi
+}
+
+upload_item () {
+
+    ITEM="$1"
+
+    echo "$ITEM" | grep -i ".error" >> /dev/null 2>&1
+    if [ "$?" == "0" ]
+    then
+        log DEBUG "NOT uploading files with errors ($ITEM)."
+        return 1
+    fi
+
+    if [ -e "$PPSS_LOCAL_WORKDIR/$ITEM" ]
+    then
+        log DEBUG "Uploading item $ITEM."
+        if [ "$SECURE_COPY" == "1" ]
+        then
+            scp -q $SSH_OPTS $SSH_KEY $PPSS_LOCAL_WORKDIR/"$ITEM" $SSH_SERVER:$REMOTE_OUTPUT_DIR
+            ERROR="$?"
+            if [ ! "$ERROR" == "0" ]
+            then
+                log DEBUG "ERROR - uploading of $ITEM failed."
+            fi
+        else    
+            cp "$PPSS_LOCAL_WORKDIR/$ITEM" $REMOTE_OUTPUT_DIR
+            ERROR="$?"
+            if [ ! "$ERROR" == "0" ]
+            then
+                log DEBUG "ERROR - uploading of $ITEM failed."
+            fi
+        fi
+    else    
+        log DEBUG "ERROR: item $ITEM does not exist."
+    fi
+}
+
+lock_item () {
+
+    ITEM="$1"
+    LOCK_FILE_NAME=`echo $ITEM | sed s/^\\\.//g |sed s/^\\\.\\\.//g | sed s/\\\///g`
+    ITEM_LOCK_FILE="$ITEM_LOCK_DIR/$LOCK_FILE_NAME"
+
+    exec_cmd "mkdir $ITEM_LOCK_FILE >> /dev/null 2>&1"
+    ERROR="$?"
+    return "$ERROR"
+}
+
+release_item () {
+
+    ITEM="$1"
+   
+    LOCK_FILE_NAME=`echo $ITEM` # | sed s/^\\.//g | sed s/^\\.\\.//g | sed s/\\\///g`
+    ITEM_LOCK_FILE="$ITEM_LOCK_DIR/$LOCK_FILE_NAME"
+
+    exec_cmd "rm -rf ./$ITEM_LOCK_FILE"
+}
+
+get_all_items () {
+
+    count=0
+
+    #does_file_exist "$SRC_DIR"
+    #check_status "$0" "$FUNCNAME" "ERROR - source dir $SRC_DIR does not exist."
+
+    if [ -z "$INPUT_FILE" ]
+    then
+        if [ ! -z "$SSH_SERVER" ] # Are we running stand-alone or as a slave?"
+        then
+            ITEMS=`exec_cmd "ls -1 $SRC_DIR"`
+            check_status "$?" "$FUNCNAME" "Could not list files within remote source directory."
+        else 
+            ITEMS=`ls -1 $SRC_DIR`
+        fi
+        IFS="
+"
+        for x in $ITEMS
+        do
+            ARRAY[$count]="$x"
+            ((count++))
+        done
+        IFS=$IFS_BACKUP
+    else
+        if [ ! -z "$SSH_SERVER" ] # Are we running stand-alone or as a slave?"
+        then
+            scp -q $SSH_OPTS "$SSH_KEY" "$SSH_SERVER:~/$INPUT_FILE" >> /dev/null 2>&!
+            check_status "$?" "$FUNCNAME" "Could not copy input file."
+        fi
+    
+        exec 10<$INPUT_FILE
+
+        while read LINE <&10
+        do
+            ARRAY[$count]=$LINE
+            ((count++))
+        done
+  
+    fi
+    exec 10>&-
+
+    SIZE_OF_ARRAY="${#ARRAY[@]}"
+    if [ "$SIZE_OF_ARRAY" -le "0" ]
+    then
+        echo "ERROR: source file/dir seems to be empty."
+        cleanup
+        exit 1
+    fi
+}
+
+get_item () {
+
+    get_global_lock
+
+    SIZE_OF_ARRAY="${#ARRAY[@]}"
+
+    # Return error if the array is empty.
+    if [ "$SIZE_OF_ARRAY" -le "0" ]
+    then
+        release_global_lock
+        return 1
+    fi
+
+    # This variable is used to walk thtough all array items.
+    ARRAY_POINTER=`cat $ARRAY_POINTER_FILE`
+
+    # Gives a status update on the current progress..
+    PERCENT=`echo "100 * $ARRAY_POINTER / $SIZE_OF_ARRAY" | bc`
+    log INFO "Currently $PERCENT percent complete. Processed $ARRAY_POINTER of $SIZE_OF_ARRAY items." 
+    echo -en "\033[1A"
+
+    # Check if all items have been processed.
+    if [ "$ARRAY_POINTER" -ge "$SIZE_OF_ARRAY" ]
+    then
+        release_global_lock
+        return 2
+    fi
+
+    # Select an item. 
+    ITEM="${ARRAY[$ARRAY_POINTER]}" 
+    if [ -z "$ITEM" ]
+    then
+        ((ARRAY_POINTER++))
+        echo $ARRAY_POINTER > $ARRAY_POINTER_FILE
+        release_global_lock
+        get_item
+    else
+        ((ARRAY_POINTER++))
+        echo $ARRAY_POINTER > $ARRAY_POINTER_FILE
+        lock_item "$ITEM"
+        if [ ! "$?" == "0" ]
+        then
+            log DEBUG "Item $ITEM is locked."
+            release_global_lock
+            get_item
+        else
+            release_global_lock
+            download_item "$ITEM"
+            return 0
+        fi
+    fi
+}
+
+start_single_worker () {
+
+    get_item
+    ERROR=$?
+    if [ ! "$ERROR" == "0" ]
+    then
+        log DEBUG "Item empty, we are probably almost finished."
+        return 1
+    else
+        get_global_lock
+        echo "$ITEM" > $FIFO
+        release_global_lock
+        return 0
+    fi
+}
+
+commando () {
+
+    ITEM="$1"
+
+    if [ -z "$INPUT_FILE" ] && [ "$TRANSFER_TO_SLAVE" == "0" ]
+    then
+        ITEM="$SRC_DIR/$ITEM"
+    else
+        ITEM="$PPSS_LOCAL_WORKDIR/$ITEM"
+    fi
+
+    LOG_FILE_NAME=`echo $ITEM | sed s/^\\\.//g | sed s/^\\\.\\\.//g | sed s/\\\///g`
+    ITEM_LOG_FILE="$JOB_LOG_DIR/$LOG_FILE_NAME"
+
+    does_file_exist "$ITEM_LOG_FILE"
+    if [ "$?" == "0" ]
+    then
+        log DEBUG "Skipping item $ITEM - already processed." 
+    else
+        
+        EXECME='$COMMAND"$ITEM" > "$ITEM_LOG_FILE" 2>&1'
+        eval "$EXECME"
+        ERROR="$?"
+
+        if [ ! "$ERROR" == "0" ] && [ "$TRANSFER_TO_SLAVE" == "1" ]
+        then
+           mv $ITEM $ITEM.error
+        elif [ "$TRANSFER_TO_SLAVE" == "1" ]      
+        then
+           rm $ITEM
+        fi
+
+        #release_item "$ITEM"
+
+        if [ ! -z "$SSH_SERVER" ]
+        then
+            scp -q $SSH_OPTS $SSH_KEY $ITEM_LOG_FILE $SSH_SERVER:~/$JOB_LOG_DIR 
+        fi
+    fi
+
+    
+    start_single_worker
+    return $?
+}
+
+listen_for_job () {
+
+    log INFO "Listener started."
+    while read event <& 42
+    do
+        commando "$event" &
+    done
+}
+
+# This starts an number of parallel workers based on the # of parallel jobs allowed.
+start_all_workers () {
+
+    log INFO "Starting $MAX_NO_OF_RUNNING_JOBS workers."
+
+    i=0
+    while [ "$i" -lt "$MAX_NO_OF_RUNNING_JOBS" ]
+    do
+        log DEBUG "$FUNCNAME - NO OF WORKERS is $i"
+        start_single_worker
+        ((i++))
+    done
+}
+
+
+# If this is called, the whole framework will execute.
+main () {
+    
+    is_running    
+    init_vars
+    log DEBUG "---------------- START ---------------------"
+    log INFO "$SCRIPT_NAME version $SCRIPT_VERSION"
+    test_server
+    get_all_items
+    listen_for_job "$MAX_NO_OF_RUNNING_JOBS" &
+    LISTENER_PID=$!
+    start_all_workers
+}
+# This command starts the that sets the whole framework in motion.
+main
+while true
+do
+    JOBS=`ps ax | grep -v grep | grep ppss.sh | wc -l`
+    if [ "$JOBS" -gt "3" ]
+    then
+        sleep $INTERVAL
+    else
+        echo -en "\033[1B"
+        log INFO "There are no more running jobs, so we must be finished."
+        echo -en "\033[1B"
+        if [ ! -z "$REMOTE_OUTPUT_DIR" ]
+        then
+            log INFO "Transfering all processed items back to server."
+            for x in `ls -1 $PPSS_LOCAL_WORKDIR`
+            do
+                upload_item "$x"
+            done
+        fi
+        log INFO "Killing listener and remainig processes."
+        log INFO "Dying processes may display an error message."
+        kill_process
+    fi
+done
+wait