Added flag for fail and removed debug directory
This commit is contained in:
parent
ad4c22c171
commit
94fa4f5e72
12
prsync
12
prsync
|
|
@ -110,8 +110,7 @@ src=($(echo "$tmp" | awk '{print $2}'))
|
||||||
totalsize=$(IFS=+; echo "$((${filesize[*]}))")
|
totalsize=$(IFS=+; echo "$((${filesize[*]}))")
|
||||||
|
|
||||||
# Create file lists
|
# Create file lists
|
||||||
# dir_temp=$(mktemp -dt rsync.XXXXX)
|
dir_temp=$(mktemp -dt rsync.XXXXX)
|
||||||
dir_temp="/scratch/rsync.MCbI5"
|
|
||||||
for ((istream=0;istream<num_streams;istream++)); do
|
for ((istream=0;istream<num_streams;istream++)); do
|
||||||
file_temp="${dir_temp}/rsync-stream-${istream}.files"
|
file_temp="${dir_temp}/rsync-stream-${istream}.files"
|
||||||
echo -n > $file_temp
|
echo -n > $file_temp
|
||||||
|
|
@ -131,6 +130,7 @@ function rsync_sigint {
|
||||||
}
|
}
|
||||||
rsync_pids=()
|
rsync_pids=()
|
||||||
timer=$(date +%s%N)
|
timer=$(date +%s%N)
|
||||||
|
flag_fail=0
|
||||||
trap rsync_sigint SIGINT
|
trap rsync_sigint SIGINT
|
||||||
for ((istream=0;istream<num_streams;istream++)); do
|
for ((istream=0;istream<num_streams;istream++)); do
|
||||||
file_temp="${dir_temp}/rsync-stream-${istream}.files"
|
file_temp="${dir_temp}/rsync-stream-${istream}.files"
|
||||||
|
|
@ -141,8 +141,14 @@ for ((istream=0;istream<num_streams;istream++)); do
|
||||||
done
|
done
|
||||||
for pid in ${rsync_pids[@]}; do
|
for pid in ${rsync_pids[@]}; do
|
||||||
wait $pid
|
wait $pid
|
||||||
echo "Process ${pid} finished with exit code $?"
|
ec_=$?
|
||||||
|
echo "Process ${pid} finished with exit code $ec_"
|
||||||
|
[[ $ec_ -ne 0 ]] && flag_fail=1
|
||||||
done
|
done
|
||||||
|
if [ $flag_fail -ne 0 ]; then
|
||||||
|
echo "Transfer failed."
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
|
||||||
# Evaluate time and print transfer info
|
# Evaluate time and print transfer info
|
||||||
dt_transfer=$(($(date +%s%N) - timer))
|
dt_transfer=$(($(date +%s%N) - timer))
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue