netflow fix

agent/netflow/netflow_collect.sh

@@ -35,6 +35,7 @@ done
 # Сигналим коллекторам чтоб они сбросили дамп в папку /tmp/djing_flow/dump
 for fl in /run/flow.pid.*; do
     kill -HUP `cat ${fl}`
+    sleep 0.1
 done
 sleep 1
 
@@ -45,3 +46,4 @@ flow-cat /tmp/djing_flow/dump/*/*.dmp | ./djing_flow -i ${tmp_ipuser_file} -cl |
 
 rm -f ${tmp_ipuser_file}
 rm -f /tmp/djing_flow/dump/*/*.dmp
+rm -f /tmp/djing_flow/*/ft*

agent/netflow/netflow_handler.sh

@@ -14,11 +14,12 @@ fi
 
 cd "$tmpdir"
 fname=$1
-port=`echo $(find -name "$fname") | tr / "\n" | head -2 | tail -n1`
+abspath=$(find -name "$fname")
+port=`echo "${abspath}" | tr / "\n" | head -2 | tail -n1`
 
 if [[ -z "$port" ]]; then
     echo "$fname not found in any directory"
 else
-    mkdir -p dump/${port}
-    mv ${port}/${fname} dump/${port}/${fname}.dmp
+    mkdir -p ./dump/${port}
+    mv ${abspath} ./dump/${port}/${fname}.dmp
 fi

agent/netflow/start_netflow.sh

@@ -12,7 +12,8 @@ DIRECTORY=`dirname $(readlink -e "$0")`
 
 tdir="/tmp/djing_flow/${port}"
 if [ -d "${tdir}" ]; then
-    echo "Warning: directory '${tdir}' exists"
+    echo "Warning: directory '${tdir}' exists, clean all"
+    rm -f ${tdir}/ft*
 else
     mkdir -p "${tdir}"
 fi