X-Git-Url: https://zdv2.bktei.com/gitweb/BK-2020-03.git/blobdiff_plain/63ef0127440655cb79919949fef6b9523733a528..595c2cf96c6eb87f082de03a0fd21810d44f7d93:/unitproc/bkFreqWrite?ds=sidebyside diff --git a/unitproc/bkFreqWrite b/unitproc/bkFreqWrite index 663c030..e608ba4 100644 --- a/unitproc/bkFreqWrite +++ b/unitproc/bkFreqWrite @@ -1,14 +1,11 @@ #!/bin/bash -# Desc: Writes stdin to disk every 5 minutes - -yell() { echo "[$(date --iso-8601=ns)]:$0: $*" >&2; } #o Yell, Die, Try Three-Fingered Claw technique +# Desc: Writes stdin to disk every 5 seconds +yell() { echo "$0: $*" >&2; } #o Yell, Die, Try Three-Fingered Claw technique die() { yell "$*"; exit 111; } #o Ref/Attrib: https://stackoverflow.com/a/25515370 try() { "$@" || die "cannot $*"; } #o - declare -a buffer # Initialize buffer array scriptTTL="15"; bufferTTL="5"; - magicWriteBuffer() { printf "%s\n" "${buffer[@]}" | cat | cat | cat >> /dev/shm/$(date +%s)..bkFreqWrite-output1.txt; printf "%s\n" "${buffer[@]}" | cat | cat | cat >> /dev/shm/$(date +%s)..bkFreqWrite-output2.txt; @@ -21,17 +18,17 @@ while [[ $SECONDS -lt "scriptTTL" ]]; do bufferTOD="$((SECONDS + $bufferTTL))"; lineCount=0; # Consume stdin to fill buffer until buffer time-of-death (TOD) arrives - while read -r line && [[ $SECONDS -lt "$bufferTOD" ]]; do - # Append line to buffer + while read -r -t "$bufferTTL" line && [[ $SECONDS -lt "$bufferTOD" ]]; do + # Append line to buffer array buffer+=("$line"); - echo "Processing line:$lineCount"; - echo "Current line :$line"; - echo "buf elem count :${#buffer[@]}"; + echo "DEBUG:Processing line:$lineCount"; + echo "DEBUG:Current line :$line"; + echo "DEBUG:buf elem count :${#buffer[@]}"; ((lineCount++)); done; # Export buffer to asynchronous processing. magicWriteBuffer & - unset buffer; + unset buffer; # Clear buffer array for next bufferRound # Increment buffer round ((bufferRound++)); done;