remove several unneded cat commands

detected by codacy
This commit is contained in:
Jan Gerhards 2018-10-12 15:47:42 +02:00
parent 4d88481985
commit c9b58411fd
6 changed files with 6 additions and 9 deletions

View File

@ -100,8 +100,7 @@ shutdown_when_empty
wait_shutdown
. $srcdir/diag.sh es-getdata 1 $ES_PORT
cat work | \
python -c '
python <work -c '
import sys,json
hsh = json.load(sys.stdin)
try:

View File

@ -68,7 +68,7 @@ do
done
echo Inject messages into kafka
cat $RSYSLOG_OUT_LOG.in | kafkacat -P -b localhost:29092 -t $RANDTOPIC
kafkacat <$RSYSLOG_OUT_LOG.in -P -b localhost:29092 -t $RANDTOPIC
# ---
echo Give imkafka some time to start...

View File

@ -115,7 +115,7 @@ do
done
echo Inject messages into kafka
cat $RSYSLOG_OUT_LOG.in | kafkacat -P -b localhost:29092 -t $RANDTOPIC
kafkacat <$RSYSLOG_OUT_LOG.in -P -b localhost:29092 -t $RANDTOPIC
# ---
echo Give imkafka some time to start...

View File

@ -155,7 +155,7 @@ do
done
echo Inject messages into kafka
cat $RSYSLOG_OUT_LOG.in | kafkacat -P -b localhost:29092 -t $RANDTOPIC
kafkacat <$RSYSLOG_OUT_LOG.in -P -b localhost:29092 -t $RANDTOPIC
# ---
echo Give imkafka some time to start...

View File

@ -143,8 +143,7 @@ grep -q 'mmkubernetes: Too Many Requests: the server is too heavily loaded to pr
grep -q 'mmkubernetes: Too Many Requests: the server is too heavily loaded to provide the data for the requested url .*/pods\\\/pod-name-9-busy' $RSYSLOG_OUT_LOG || { echo fail4; rc=1; }
if [ -f ${RSYSLOG_DYNNAME}.spool/mmkubernetes-stats.log ] ; then
cat ${RSYSLOG_DYNNAME}.spool/mmkubernetes-stats.log | \
python -c '
python <${RSYSLOG_DYNNAME}.spool/mmkubernetes-stats.log -c '
import sys,json
k8s_srv_port = sys.argv[1]
expected = {"name": "mmkubernetes(http://localhost:{0})".format(k8s_srv_port),

View File

@ -143,8 +143,7 @@ grep -q 'mmkubernetes: Too Many Requests: the server is too heavily loaded to pr
grep -q 'mmkubernetes: Too Many Requests: the server is too heavily loaded to provide the data for the requested url .*/pods\\\/pod-name-9-busy' $RSYSLOG_OUT_LOG || { echo fail4; rc=1; }
if [ -f ${RSYSLOG_DYNNAME}.spool/mmkubernetes-stats.log ] ; then
cat ${RSYSLOG_DYNNAME}.spool/mmkubernetes-stats.log | \
python -c '
python <${RSYSLOG_DYNNAME}.spool/mmkubernetes-stats.log -c '
import sys,json
k8s_srv_port = sys.argv[1]
expected = {"name": "mmkubernetes(http://localhost:{0})".format(k8s_srv_port),