Merge pull request #91 from simosund/pping-systemd

Add systemd unit files for ePPing setup

Author: tohojo

pping/scripts/cleanup-tc-progs.sh

@@ -0,0 +1,24 @@
+#!/bin/bash
+
+interface=$1
+
+if [[ -z "$interface" ]]; then
+    echo "Usage: $0 <interface>"
+    exit 0
+fi
+
+if [[ ! -e "/sys/class/net/$interface" ]]; then
+    echo "$interface is not a valid interface" 1>&2
+    exit 1
+fi
+
+for trafdir in "ingress" "egress"; do
+    prios=$(tc filter show dev "$interface" "$trafdir" | grep pping_tc | cut -f 5 -d ' ')
+
+    while IFS= read -r p || [[ -n "$p" ]]; do
+	if [[ "$p" =~ ^[0-9]+ ]]; then
+	    tc filter del dev "$interface" "$trafdir" prio "$p"
+	fi
+    done <<< "$prios"
+
+done

pping/scripts/rotate-pping-output.sh

@@ -0,0 +1,43 @@
+#!/bin/bash
+
+MAX_WAIT_ITER=10
+pping_path=${1:-"/var/log/pping/pping.out.json"}
+instance=$2 # pping service instance to reload
+
+pping_folder=$(dirname "$pping_path")
+pping_file=$(basename "$pping_path")
+
+if [[ ! -f "$pping_path" ]]; then
+    # Nothing to rotate
+    exit 0
+fi
+
+dailyfolder="$pping_folder/$(date -Idate)"
+if ! mkdir -p "$dailyfolder"; then
+    exit 1
+fi
+
+newplace="$dailyfolder/$pping_file.$(date -Iseconds)"
+if ! mv "$pping_path" "$newplace"; then
+    exit 1
+fi
+
+
+if [[ -n "$instance" ]] && systemctl is-active --quiet "pping@$instance.service"; then
+    systemctl reload "pping@$instance.service"
+fi
+
+# Compress the old file (once ePPing has stopped writing to it)
+if [[ -f "$newplace" ]]; then
+    for (( i = 0; i < MAX_WAIT_ITER; i++)); do
+	if fuser -s "$newplace"; then
+	    sleep 1
+	else
+	    gzip "$newplace"
+	    exit $?
+	fi
+    done
+fi
+
+echo "Timed out waiting for $newplace to become unused, unable to compress it" 1>&2
+exit 1

pping/systemd-files/pping@.service

@@ -0,0 +1,31 @@
+[Unit]
+Description=ePPing - Passive monitoring of network RTTs on %i
+After=network.service
+Wants=rotate-pping@%i.timer
+
+# Uncomment below if running with LibreQoS
+# After=lqosd.service
+
+[Service]
+# Ensure folder for saving output to exists
+ExecStartPre=/usr/bin/mkdir -p /var/log/pping/%i
+
+# Rotate any old output first to ensure ePPing can start writing to its intended file
+ExecStartPre=/opt/bpf-examples/pping/scripts/rotate-pping-output.sh /var/log/pping/%i/pping.%i.json
+
+WorkingDirectory=/opt/bpf-examples/pping
+ExecStart=/opt/bpf-examples/pping/pping -i %i -l -r 10 -a 10 -F json -w /var/log/pping/%i/pping.%i.json
+
+# On systemctl reload, send a SIGHUP to ePPing which causes it to reopen its output file
+ExecReload=kill -HUP $MAINPID
+
+Restart=on-failure
+RestartSec=60
+
+# Set to whatever maximum memory footprint you can tolerate
+# Note, hard-kills the ePPing process without allowing it to clean up. Consider
+# running /scripts/cleanup-tc-progs after.
+MemoryMax=4G
+
+[Install]
+WantedBy=default.target

pping/systemd-files/rotate-pping@.service

@@ -0,0 +1,6 @@
+[Unit]
+Description=Rotates the output file from ePPing on %i (pping@%i.service)
+
+[Service]
+Type=oneshot
+ExecStart=/opt/bpf-examples/pping/scripts/rotate-pping-output.sh /var/log/pping/%i/pping.%i.json %i

pping/systemd-files/rotate-pping@.timer

@@ -0,0 +1,11 @@
+[Unit]
+Description=Rotate ePPing output for %i periodically
+PartOf=pping@%i.service
+
+[Timer]
+Unit=rotate-pping@%i.service
+
+# Rotate ePPing output every X seconds
+OnActiveSec=60
+OnUnitActiveSec=60
+AccuracySec=1us