From: Steven Baltakatei Sandoval Date: Thu, 9 Jul 2020 19:41:07 +0000 (+0000) Subject: test(unitproc):bkFreqWrite:Rewrote script to use while read X-Git-Tag: 0.3.0~43 X-Git-Url: https://zdv2.bktei.com/gitweb/BK-2020-03.git/commitdiff_plain/9988125c56e859f96b9d1a0425e6564dff1d28e5?ds=sidebyside;hp=-c test(unitproc):bkFreqWrite:Rewrote script to use while read --- 9988125c56e859f96b9d1a0425e6564dff1d28e5 diff --git a/unitproc/bkFreqWrite b/unitproc/bkFreqWrite index a4ce1d8..cec372e 100644 --- a/unitproc/bkFreqWrite +++ b/unitproc/bkFreqWrite @@ -5,18 +5,31 @@ yell() { echo "[$(date --iso-8601=ns)]:$0: $*" >&2; } #o Yell, Die, Try Thr die() { yell "$*"; exit 111; } #o Ref/Attrib: https://stackoverflow.com/a/25515370 try() { "$@" || die "cannot $*"; } #o -declare -a buffer +declare -a buffer # Initialize buffer array +scriptTTL="15"; +bufferTTL="5"; -yell "Script started." +magicWriteBuffer() { + printf "%s\n" "${buffer[@]}" >> /dev/shm/$(date +%s)..bkFreqWrite-output.txt; +} -mapfile -s4 -n5 buffer - -yell "Contents of buffer:${buffer[@]}"; - -for element in "${buffer[@]}"; do - echo "$element"; - sleep 1; +bufferRound=0 +# Run until script TTL seconds pass +while [[ $SECONDS -lt "scriptTTL" ]]; do + bufferTOD="$((SECONDS + $bufferTTL))"; + lineCount=0 + # Start and fill buffer until buffer time-of-death (TOD) arrives + while read -r line && [[ $SECONDS -lt "$bufferTOD" ]]; do + # Append line to buffer + buffer+=("$line"); + echo "Processing line:$lineCount"; + echo "Current line :$line"; + echo "buf elem count :${#buffer[@]}"; + ((lineCount++)); + done; + # Export buffer to asynchronous processing. + magicWriteBuffer & + unset buffer; + # Increment buffer round + ((bufferRound++)); done; - -yell "Script completed." -exit 0;