mirror of
https://github.com/sdr-enthusiasts/docker-adsb-ultrafeeder.git
synced 2024-11-21 21:30:11 +00:00
further updates to make GPSD work
This commit is contained in:
parent
ca46b9c906
commit
46b072763d
2 changed files with 63 additions and 26 deletions
|
@ -19,32 +19,35 @@
|
||||||
|
|
||||||
source /scripts/common
|
source /scripts/common
|
||||||
|
|
||||||
# Check if GPSD_IN has been enabled
|
# Check every 60 secs if GPSD has been enabled
|
||||||
if ! grep -qi "gpsd_in" <<< "$ULTRAFEEDER_CONFIG" && ! grep -qi "gpsd_in" <<< "$ULTRAFEEDER_NET_CONNECTOR"; then
|
if [[ ! -f /run/readsb/gpsd.json ]] || [[ "$(jq -r .lat /run/readsb/gpsd.json)" == "null" ]]; then
|
||||||
"${s6wrap[@]}" echo "GPSD not enabled - no need to check receiver location"
|
sleep 60 & wait $!
|
||||||
exec sleep infinity
|
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
# Then wait until all mlat-client instances have started
|
||||||
|
while [[ ! -f /run/.all_mlatclient_instances_have_started ]]; do
|
||||||
|
sleep 5 & wait $!
|
||||||
|
done
|
||||||
|
|
||||||
|
rm -f /run/.all_mlatclient_instances_have_started
|
||||||
|
|
||||||
# Now wait a bit to allow GPS to establish itself
|
# Now wait a bit to allow GPS to establish itself
|
||||||
sleep "${GPSD_INITIAL_WAIT:-300}"
|
sleep "${GPSD_INITIAL_WAIT:-60}"
|
||||||
|
|
||||||
# Make sure that receiver.json exists; if it doesn't we need to wait for it
|
|
||||||
while ! [[ -f /run/readsb/receiver.json ]]; do
|
|
||||||
sleep 1 & wait $!
|
|
||||||
done
|
|
||||||
|
|
||||||
# Get initial lat/lon/alt
|
# Get initial lat/lon/alt
|
||||||
lat="$(jq -r .lat /run/readsb/receiver.json)"
|
lat="${LAT:-${READSB_LAT:-$(jq -r .lat /run/readsb/gpsd.json)}}"
|
||||||
lon="$(jq -r .lon /run/readsb/receiver.json)"
|
lon="${LONG:-${READSB_LON:-$(jq -r .lon /run/readsb/gpsd.json)}}"
|
||||||
|
|
||||||
while :; do
|
while :; do
|
||||||
sleep "${GPSD_CHECK_INTERVAL:30}" & wait $!
|
new_lat="$(jq -r .lat /run/readsb/gpsd.json)"
|
||||||
new_lat="$(jq -r .lat /run/readsb/receiver.json)"
|
new_lon="$(jq -r .lon /run/readsb/gpsd.json)"
|
||||||
new_lon="$(jq -r .lon /run/readsb/receiver.json)"
|
|
||||||
new_alt="$(jq -r .alt_m_amsl /run/readsb/receiver.json)"
|
|
||||||
distance="$(nice -n 20 distance "$lat" "$lon" "$new_lat" "$new_lon")"
|
distance="$(nice -n 20 distance "$lat" "$lon" "$new_lat" "$new_lon")"
|
||||||
if (( ${distance%%.*} > ${GPSD_MIN_DISTANCE} )); then
|
if (( ${distance%%.*} > GPSD_MIN_DISTANCE )); then
|
||||||
"${s6wrap[@]}" echo "Receiver moved ${distance%%.*} meters - restarting all mlat-clients"
|
"${s6wrap[@]}" echo "Receiver moved ${distance%%.*} meters - restarting all mlat-clients"
|
||||||
|
# flag to the mlat-client script that it should try to use GPS coords instead of the predefined LAT/LON
|
||||||
|
touch /run/.gpsd_is_active
|
||||||
|
# kill the mlat-client instances so they get restarted with the new GPS coords
|
||||||
pkill -f "/usr/bin/python3 /usr/bin/mlat-client" >/dev/null 2>&1
|
pkill -f "/usr/bin/python3 /usr/bin/mlat-client" >/dev/null 2>&1
|
||||||
fi
|
fi
|
||||||
|
sleep "${GPSD_CHECK_INTERVAL:30}" & wait $!
|
||||||
done
|
done
|
|
@ -1,5 +1,5 @@
|
||||||
#!/command/with-contenv bash
|
#!/command/with-contenv bash
|
||||||
# shellcheck shell=bash disable=SC1091,SC2015,SC2016
|
# shellcheck shell=bash disable=SC1091,SC2015,SC2016,SC2001
|
||||||
|
|
||||||
#---------------------------------------------------------------------------------------------
|
#---------------------------------------------------------------------------------------------
|
||||||
# Copyright (C) 2023-2024, Ramon F. Kolb (kx1t) and contributors
|
# Copyright (C) 2023-2024, Ramon F. Kolb (kx1t) and contributors
|
||||||
|
@ -176,24 +176,39 @@ do
|
||||||
fi
|
fi
|
||||||
|
|
||||||
# add LAT/LON/ALT to instance:
|
# add LAT/LON/ALT to instance:
|
||||||
if [[ -n "${lat_arg}" ]]; then
|
# see if we need to use GPS coords:
|
||||||
MLAT_PARAM+=(--lat "${lat_arg}")
|
unset new_lat
|
||||||
|
unset new_lon
|
||||||
|
unset new_alt
|
||||||
|
if [[ -f /run/.gpsd_is_active && -f /run/readsb/receiver.json ]]; then
|
||||||
|
new_lat="$(jq -r .lat /run/readsb/receiver.json)"
|
||||||
|
new_lon="$(jq -r .lon /run/readsb/receiver.json)"
|
||||||
|
new_alt="$(jq -r .alt_m_amsl /run/readsb/receiver.json)"
|
||||||
|
if [[ "$new_lat" == "null" ]] || [[ "$new_lon" == "null" ]] || [[ "$new_alt" == "null" ]]; then
|
||||||
|
unset new_lat
|
||||||
|
unset new_lon
|
||||||
|
unset new_alt
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
|
||||||
|
if [[ -n "${new_lat:-$lat_arg}" ]]; then
|
||||||
|
MLAT_PARAM+=(--lat "${new_lat:-$lat_arg}")
|
||||||
elif [[ -n "${LAT}" ]]; then
|
elif [[ -n "${LAT}" ]]; then
|
||||||
MLAT_PARAM+=(--lat "${LAT}")
|
MLAT_PARAM+=(--lat "${LAT}")
|
||||||
elif [[ -n "${READSB_LAT}" ]]; then
|
elif [[ -n "${READSB_LAT}" ]]; then
|
||||||
MLAT_PARAM+=(--lat "${READSB_LAT}")
|
MLAT_PARAM+=(--lat "${READSB_LAT}")
|
||||||
fi
|
fi
|
||||||
|
|
||||||
if [[ -n "${lon_arg}" ]]; then
|
if [[ -n "${new_lon:-$lon_arg}" ]]; then
|
||||||
MLAT_PARAM+=(--lon "${lon_arg}")
|
MLAT_PARAM+=(--lon "${new_lon:-$lon_arg}")
|
||||||
elif [[ -n "${LONG}" ]]; then
|
elif [[ -n "${LONG}" ]]; then
|
||||||
MLAT_PARAM+=(--lon "${LONG}")
|
MLAT_PARAM+=(--lon "${LONG}")
|
||||||
elif [[ -n "${READSB_LON}" ]]; then
|
elif [[ -n "${READSB_LON}" ]]; then
|
||||||
MLAT_PARAM+=(--lon "${READSB_LON}")
|
MLAT_PARAM+=(--lon "${READSB_LON}")
|
||||||
fi
|
fi
|
||||||
|
|
||||||
if [[ -n "${alt_arg}" ]]; then
|
if [[ -n "${new_alt:-$alt_arg}" ]]; then
|
||||||
MLAT_PARAM+=(--alt "${alt_arg}")
|
MLAT_PARAM+=(--alt "${new_alt:-$alt_arg}")
|
||||||
elif [[ -n "${ALT}" ]]; then
|
elif [[ -n "${ALT}" ]]; then
|
||||||
MLAT_PARAM+=(--alt "${ALT}")
|
MLAT_PARAM+=(--alt "${ALT}")
|
||||||
elif [[ -n "${READSB_ALT}" ]]; then
|
elif [[ -n "${READSB_ALT}" ]]; then
|
||||||
|
@ -240,6 +255,7 @@ do
|
||||||
done
|
done
|
||||||
|
|
||||||
sleep 5 & wait $!
|
sleep 5 & wait $!
|
||||||
|
touch /run/.all_mlatclient_instances_have_started
|
||||||
|
|
||||||
# Now iterate over all MLAT-client instances and check if they are still running:
|
# Now iterate over all MLAT-client instances and check if they are still running:
|
||||||
while true
|
while true
|
||||||
|
@ -257,6 +273,18 @@ do
|
||||||
# shellcheck disable=SC2086
|
# shellcheck disable=SC2086
|
||||||
execstring="$(echo ${MLAT_CMD} ${pid_array[$mlat_pid]} | xargs)"
|
execstring="$(echo ${MLAT_CMD} ${pid_array[$mlat_pid]} | xargs)"
|
||||||
|
|
||||||
|
# If GPSD is active, then replace the lat/lon/alt params with the ones from GPSD
|
||||||
|
if [[ -f /run/readsb/gpsd.json ]] && [[ "$(jq -r .lat /run/readsb/gpsd.json)" != "null" ]]; then
|
||||||
|
new_lat="$(jq -r .lat /run/readsb/gpsd.json)"
|
||||||
|
new_lon="$(jq -r .lon /run/readsb/gpsd.json)"
|
||||||
|
new_alt="$(jq -r .altMSL /run/readsb/gpsd.json)"
|
||||||
|
if [[ "$new_lat" != "null" ]] && [[ "$new_lon" != "null" ]] && [[ "$new_alt" != "null" ]]; then
|
||||||
|
execstring="$(sed "s/^\(.*\s\+--lat\s\+\)[0-9.-]\+\(.*\)$/\1${new_lat}\2/g" <<< "$execstring")"
|
||||||
|
execstring="$(sed "s/^\(.*\s\+--lon\s\+\)[0-9.-]\+\(.*\)$/\1${new_lon}\2/g" <<< "$execstring")"
|
||||||
|
execstring="$(sed "s/^\(.*\s\+--alt\s\+\)[mft0-9.-]\+\(.*\)$/\1${new_alt}m\2/g" <<< "$execstring")"
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
|
||||||
#shellcheck disable=SC2069,SC2086
|
#shellcheck disable=SC2069,SC2086
|
||||||
if [[ "${LOGLEVEL}" == "verbose" ]]; then
|
if [[ "${LOGLEVEL}" == "verbose" ]]; then
|
||||||
"${s6wrap[@]}" --prepend="$(basename "$0")][${servername}" --args ${execstring} &
|
"${s6wrap[@]}" --prepend="$(basename "$0")][${servername}" --args ${execstring} &
|
||||||
|
@ -270,5 +298,11 @@ do
|
||||||
unset "pid_array[${mlat_pid}]"
|
unset "pid_array[${mlat_pid}]"
|
||||||
fi
|
fi
|
||||||
done
|
done
|
||||||
|
|
||||||
|
# If GPSD is running, do more frequent checks than if it's not running
|
||||||
|
if [[ -f /run/readsb/gpsd.json ]] && [[ "$(jq -r .lat /run/readsb/gpsd.json)" != "null" ]]; then
|
||||||
|
sleep 1 & wait $!
|
||||||
|
else
|
||||||
sleep 10 & wait $!
|
sleep 10 & wait $!
|
||||||
|
fi
|
||||||
done
|
done
|
||||||
|
|
Loading…
Reference in a new issue