cleanup: move task creation to a function
This commit is contained in:
Vincent Riquer
parent
ba459feb90
commit
a3e80e9416
145
lib/workers/create
Normal file
145
lib/workers/create
Normal file
@ -0,0 +1,145 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
|
||||||
|
createworker() {
|
||||||
|
(( ++active ))
|
||||||
|
read -u4 line
|
||||||
|
taskid=${line%%::AtOM:SQL:Sep::*}
|
||||||
|
rest="${line#*::AtOM:SQL:Sep::}::AtOM:SQL:Sep::"
|
||||||
|
sourcefileid=${rest%%::AtOM:SQL:Sep::*}
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
cleanup=${rest%%::AtOM:SQL:Sep::*}
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
destfileid=${rest%%::AtOM:SQL:Sep::*}
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
destfilename=${rest%%::AtOM:SQL:Sep::*}
|
||||||
|
rest=${rest#*::AtOM:SQL:Sep::}
|
||||||
|
for key in ${!cmd_arg[@]}
|
||||||
|
do
|
||||||
|
[ -z "${cmd_arg[key]}" ] && unset cmd_arg[key]
|
||||||
|
done
|
||||||
|
workerid=$(getworkerid)
|
||||||
|
workertasks[workerid]=$taskid
|
||||||
|
Update tasks status 1 <<<"id = $taskid"
|
||||||
|
worker $workerid &
|
||||||
|
workers[$workerid]=$!
|
||||||
|
}
|
||||||
@ -120,149 +120,7 @@ master() {
|
|||||||
then
|
then
|
||||||
sleep 0.1
|
sleep 0.1
|
||||||
else
|
else
|
||||||
(( ++active ))
|
createworker
|
||||||
read -u4 line
|
|
||||||
taskid=${line%%::AtOM:SQL:Sep::*}
|
|
||||||
rest="${line#*::AtOM:SQL:Sep::}::AtOM:SQL:Sep::"
|
|
||||||
sourcefileid=${rest%%::AtOM:SQL:Sep::*}
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
required=${rest%%::AtOM:SQL:Sep::*}
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cmd_arg+=("${rest%%::AtOM:SQL:Sep::*}")
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
cleanup=${rest%%::AtOM:SQL:Sep::*}
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
destfileid=${rest%%::AtOM:SQL:Sep::*}
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
destfilename=${rest%%::AtOM:SQL:Sep::*}
|
|
||||||
rest=${rest#*::AtOM:SQL:Sep::}
|
|
||||||
for key in ${!cmd_arg[@]}
|
|
||||||
do
|
|
||||||
[ -z "${cmd_arg[key]}" ] && unset cmd_arg[key]
|
|
||||||
done
|
|
||||||
workerid=$(getworkerid)
|
|
||||||
workertasks[workerid]=$taskid
|
|
||||||
Update tasks status 1 <<<"id = $taskid"
|
|
||||||
worker $workerid &
|
|
||||||
workers[$workerid]=$!
|
|
||||||
fi
|
fi
|
||||||
fi
|
fi
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user