2014-11-13 03:19:33 +00:00
|
|
|
#!/bin/bash
|
|
|
|
|
2014-11-13 15:57:41 +00:00
|
|
|
|
2017-06-22 11:35:58 +00:00
|
|
|
# SSH only allowed to localhost/lo
|
2018-09-20 22:15:14 +00:00
|
|
|
cat <<'EOF' | parallel -vj100% --retries 3 -k --joblog /tmp/jl-`basename $0` -L1 -r
|
2015-01-06 22:25:23 +00:00
|
|
|
echo '### trailing space in sshlogin'
|
|
|
|
echo 'sshlogin trailing space' | parallel --sshlogin "ssh -l parallel localhost " echo
|
|
|
|
|
2015-01-18 23:08:07 +00:00
|
|
|
echo '### Special char file and dir transfer return and cleanup'
|
|
|
|
cd /tmp;
|
|
|
|
mkdir -p d"`perl -e 'print pack("c*",1..9,11..46,48..255)'`";
|
|
|
|
echo local > d"`perl -e 'print pack("c*",1..9,11..46,48..255)'`"/f"`perl -e 'print pack("c*",1..9,11..46,48..255)'`";
|
|
|
|
ssh parallel@lo rm -rf d'*'/;
|
|
|
|
mytouch() {
|
|
|
|
cat d"`perl -e 'print pack("c*",1..9,11..46,48..255)'`"/f"`perl -e 'print pack("c*",1..9,11..46,48..255)'`" > d"`perl -e 'print pack("c*",1..9,11..46,48..255)'`"/g"`perl -e 'print pack("c*",1..9,11..46,48..255)'`";
|
|
|
|
echo remote OK >> d"`perl -e 'print pack("c*",1..9,11..46,48..255)'`"/g"`perl -e 'print pack("c*",1..9,11..46,48..255)'`";
|
|
|
|
};
|
|
|
|
export -f mytouch;
|
|
|
|
parallel --env mytouch -Sparallel@lo --transfer
|
2015-02-22 14:09:26 +00:00
|
|
|
--return {=s:/f:/g:=}
|
2015-01-18 23:08:07 +00:00
|
|
|
mytouch
|
|
|
|
::: d"`perl -e 'print pack("c*",1..9,11..46,48..255)'`"/f"`perl -e 'print pack("c*",1..9,11..46,48..255)'`";
|
2015-02-01 13:38:26 +00:00
|
|
|
cat d"`perl -e 'print pack("c*",1..9,11..46,48..255)'`"/g"`perl -e 'print pack("c*",1..9,11..46,48..255)'`"
|
2015-01-18 23:08:07 +00:00
|
|
|
|
2015-02-01 13:38:26 +00:00
|
|
|
echo '### Uniq {=perlexpr=} in return - not used in command'
|
|
|
|
cd /tmp;
|
|
|
|
rm -f /tmp/parallel_perlexpr.2Parallel_PerlexPr;
|
|
|
|
echo local > parallel_perlexpr;
|
|
|
|
parallel -Sparallel@lo --trc {=s/pr/pr.2/=}{=s/p/P/g=} echo remote OK '>' {}.2{=s/p/P/g=} ::: parallel_perlexpr;
|
|
|
|
cat /tmp/parallel_perlexpr.2Parallel_PerlexPr;
|
|
|
|
rm -f /tmp/parallel_perlexpr.2Parallel_PerlexPr /tmp/parallel_perlexpr
|
2015-01-18 23:08:07 +00:00
|
|
|
|
2015-02-01 15:57:31 +00:00
|
|
|
# Should be changed to --return '{=s:/f:/g:=}' and tested with csh - is error code kept?
|
|
|
|
|
2015-03-22 16:13:25 +00:00
|
|
|
echo '### functions and --nice'
|
|
|
|
myfunc() { echo OK $*; }; export -f myfunc; parallel --nice 10 --env myfunc -S parallel@lo myfunc ::: func
|
|
|
|
|
2015-09-09 20:38:42 +00:00
|
|
|
echo '### bug #45906: {= in header =}'
|
|
|
|
rm -f returnfile45906;
|
|
|
|
parallel --rpl '{G} $_=lc($_)' -S parallel@lo --return {G} --cleanup echo {G} '>' {G} ::: RETURNFILE45906;
|
|
|
|
ls returnfile45906
|
|
|
|
|
|
|
|
echo '### bug #45907: --header : + --return {header}'
|
|
|
|
rm returnfile45907;
|
|
|
|
ppar --header : -S parallel@lo --return {G} --cleanup echo {G} '>' {G} ::: G returnfile45907;
|
|
|
|
ls returnfile45907
|
|
|
|
|
2016-04-05 22:33:34 +00:00
|
|
|
echo "### bug #47608: parallel --nonall -S lo 'echo ::: ' blocks"
|
|
|
|
parallel --nonall -S lo 'echo ::: '
|
|
|
|
|
2016-05-04 17:28:40 +00:00
|
|
|
echo '### exported function to csh but with PARALLEL_SHELL=bash'
|
|
|
|
doit() { echo "$1"; };
|
|
|
|
export -f doit;
|
|
|
|
stdout parallel --env doit -S csh@lo doit ::: not_OK;
|
|
|
|
PARALLEL_SHELL=bash parallel --env doit -S csh@lo doit ::: OK
|
|
|
|
|
2016-10-22 11:51:42 +00:00
|
|
|
echo '### bug #49404: "Max jobs to run" does not equal the number of jobs specified when using GNU Parallel on remote server?'
|
2016-12-14 07:48:27 +00:00
|
|
|
echo should give 10 running jobs
|
|
|
|
stdout parallel -S 16/lo --progress true ::: {1..10} | grep /.10
|
2014-11-13 03:19:33 +00:00
|
|
|
EOF
|
2017-01-06 18:10:20 +00:00
|
|
|
|
|
|
|
par_trc_with_space() {
|
|
|
|
echo '### Test --trc with space added in filename'
|
2017-06-22 11:35:58 +00:00
|
|
|
cd
|
|
|
|
mkdir -p tmp
|
|
|
|
echo original > 'tmp/parallel space file'
|
|
|
|
echo 'tmp/parallel space file' | stdout parallel --trc "{} more space" -S parallel@lo cat {} ">{}\\ more\\ space"
|
|
|
|
cat 'tmp/parallel space file more space'
|
|
|
|
rm 'tmp/parallel space file' 'tmp/parallel space file more space'
|
2017-01-06 18:10:20 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
par_trc_with_special_chars() {
|
|
|
|
echo '### Test --trc with >|< added in filename'
|
2017-06-22 11:35:58 +00:00
|
|
|
cd
|
|
|
|
mkdir -p tmp
|
|
|
|
echo original > 'tmp/parallel space file2'
|
|
|
|
echo 'tmp/parallel space file2' | stdout parallel --trc "{} >|<" -S parallel@lo cat {} ">{}\\ \\>\\|\\<"
|
|
|
|
cat 'tmp/parallel space file2 >|<'
|
|
|
|
rm 'tmp/parallel space file2' 'tmp/parallel space file2 >|<'
|
2017-01-06 18:10:20 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
par_return_with_fixedstring() {
|
|
|
|
echo '### Test --return with fixed string (Gave undef warnings)'
|
|
|
|
touch a
|
|
|
|
echo a | stdout parallel --return b -S parallel@lo echo ">b" && echo OK
|
|
|
|
rm a b
|
|
|
|
}
|
|
|
|
|
|
|
|
par_quoting_for_onall() {
|
|
|
|
echo '### bug #35427: quoting of {2} broken for --onall'
|
|
|
|
echo foo: /bin/ls | parallel --colsep ' ' -S lo --onall ls {2}
|
|
|
|
}
|
|
|
|
|
2017-12-21 17:53:07 +00:00
|
|
|
par_hostgroup_only_on_args() {
|
|
|
|
echo '### Auto add hostgroup if given on on argument'
|
|
|
|
parallel --hostgroup ::: whoami@sh@lo
|
|
|
|
}
|
|
|
|
|
2017-01-06 18:10:20 +00:00
|
|
|
export -f $(compgen -A function | grep par_)
|
|
|
|
# Tested with -j1..8
|
|
|
|
# -j6 was fastest
|
|
|
|
#compgen -A function | grep par_ | sort | parallel --delay $D -j$P --tag -k '{} 2>&1'
|
|
|
|
compgen -A function | grep par_ | sort | parallel --delay 0.1 -j2 --tag -k '{} 2>&1'
|