2021-01-21 20:58:47 -05:00
|
|
|
import datetime
|
|
|
|
import logging
|
|
|
|
import threading
|
|
|
|
|
2022-12-24 13:53:06 -05:00
|
|
|
from oslo_config import cfg
|
2022-07-20 08:43:57 -04:00
|
|
|
import wrapt
|
|
|
|
|
2021-04-01 23:12:25 -04:00
|
|
|
import aprsd
|
2021-07-17 14:30:29 -04:00
|
|
|
from aprsd import packets, plugin, utils
|
2021-04-01 23:12:25 -04:00
|
|
|
|
2021-08-23 12:14:19 -04:00
|
|
|
|
2022-12-24 13:53:06 -05:00
|
|
|
CONF = cfg.CONF
|
2021-01-21 20:58:47 -05:00
|
|
|
LOG = logging.getLogger("APRSD")
|
|
|
|
|
|
|
|
|
|
|
|
class APRSDStats:
|
|
|
|
|
|
|
|
_instance = None
|
2022-07-20 08:43:57 -04:00
|
|
|
lock = threading.Lock()
|
2021-01-21 20:58:47 -05:00
|
|
|
|
|
|
|
start_time = None
|
2021-04-05 08:55:46 -04:00
|
|
|
_aprsis_server = None
|
2021-04-01 23:12:25 -04:00
|
|
|
_aprsis_keepalive = None
|
2021-01-21 20:58:47 -05:00
|
|
|
|
|
|
|
_email_thread_last_time = None
|
|
|
|
_email_tx = 0
|
|
|
|
_email_rx = 0
|
|
|
|
|
2021-03-24 16:07:09 -04:00
|
|
|
_mem_current = 0
|
|
|
|
_mem_peak = 0
|
|
|
|
|
2023-07-10 10:44:24 -04:00
|
|
|
_thread_info = {}
|
|
|
|
|
2022-12-18 21:44:23 -05:00
|
|
|
_pkt_cnt = {
|
|
|
|
"Packet": {
|
|
|
|
"tx": 0,
|
|
|
|
"rx": 0,
|
|
|
|
},
|
|
|
|
"AckPacket": {
|
|
|
|
"tx": 0,
|
|
|
|
"rx": 0,
|
|
|
|
},
|
|
|
|
"GPSPacket": {
|
|
|
|
"tx": 0,
|
|
|
|
"rx": 0,
|
|
|
|
},
|
|
|
|
"StatusPacket": {
|
|
|
|
"tx": 0,
|
|
|
|
"rx": 0,
|
|
|
|
},
|
|
|
|
"MicEPacket": {
|
|
|
|
"tx": 0,
|
|
|
|
"rx": 0,
|
|
|
|
},
|
|
|
|
"MessagePacket": {
|
|
|
|
"tx": 0,
|
|
|
|
"rx": 0,
|
|
|
|
},
|
|
|
|
"WeatherPacket": {
|
|
|
|
"tx": 0,
|
|
|
|
"rx": 0,
|
|
|
|
},
|
2022-12-30 09:44:25 -05:00
|
|
|
"ObjectPacket": {
|
|
|
|
"tx": 0,
|
|
|
|
"rx": 0,
|
|
|
|
},
|
2022-12-18 21:44:23 -05:00
|
|
|
}
|
|
|
|
|
2021-01-21 20:58:47 -05:00
|
|
|
def __new__(cls, *args, **kwargs):
|
|
|
|
if cls._instance is None:
|
|
|
|
cls._instance = super().__new__(cls)
|
2022-12-28 15:44:49 -05:00
|
|
|
# any init here
|
2021-01-21 20:58:47 -05:00
|
|
|
cls._instance.start_time = datetime.datetime.now()
|
2021-04-01 23:12:25 -04:00
|
|
|
cls._instance._aprsis_keepalive = datetime.datetime.now()
|
2021-01-21 20:58:47 -05:00
|
|
|
return cls._instance
|
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-01-21 20:58:47 -05:00
|
|
|
@property
|
|
|
|
def uptime(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
return datetime.datetime.now() - self.start_time
|
2021-01-21 20:58:47 -05:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-03-24 16:07:09 -04:00
|
|
|
@property
|
|
|
|
def memory(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
return self._mem_current
|
2021-03-24 16:07:09 -04:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-03-24 16:07:09 -04:00
|
|
|
def set_memory(self, memory):
|
2022-07-20 08:43:57 -04:00
|
|
|
self._mem_current = memory
|
2021-03-24 16:07:09 -04:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-03-24 16:07:09 -04:00
|
|
|
@property
|
|
|
|
def memory_peak(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
return self._mem_peak
|
2021-03-24 16:07:09 -04:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-03-24 16:07:09 -04:00
|
|
|
def set_memory_peak(self, memory):
|
2022-07-20 08:43:57 -04:00
|
|
|
self._mem_peak = memory
|
2021-03-24 16:07:09 -04:00
|
|
|
|
2023-07-10 10:44:24 -04:00
|
|
|
@wrapt.synchronized(lock)
|
|
|
|
def set_thread_info(self, thread_info):
|
|
|
|
self._thread_info = thread_info
|
|
|
|
|
|
|
|
@wrapt.synchronized(lock)
|
|
|
|
@property
|
|
|
|
def thread_info(self):
|
|
|
|
return self._thread_info
|
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-04-01 23:12:25 -04:00
|
|
|
@property
|
|
|
|
def aprsis_server(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
return self._aprsis_server
|
2021-04-01 23:12:25 -04:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-04-01 23:12:25 -04:00
|
|
|
def set_aprsis_server(self, server):
|
2022-07-20 08:43:57 -04:00
|
|
|
self._aprsis_server = server
|
2021-04-01 23:12:25 -04:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-04-01 23:12:25 -04:00
|
|
|
@property
|
|
|
|
def aprsis_keepalive(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
return self._aprsis_keepalive
|
2021-04-01 23:12:25 -04:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-04-01 23:12:25 -04:00
|
|
|
def set_aprsis_keepalive(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
self._aprsis_keepalive = datetime.datetime.now()
|
2021-04-01 23:12:25 -04:00
|
|
|
|
2022-12-18 21:44:23 -05:00
|
|
|
def rx(self, packet):
|
2022-12-30 09:44:25 -05:00
|
|
|
pkt_type = packet.__class__.__name__
|
|
|
|
if pkt_type not in self._pkt_cnt:
|
|
|
|
self._pkt_cnt[pkt_type] = {
|
|
|
|
"tx": 0,
|
|
|
|
"rx": 0,
|
|
|
|
}
|
|
|
|
self._pkt_cnt[pkt_type]["rx"] += 1
|
2021-01-21 20:58:47 -05:00
|
|
|
|
2022-12-18 21:44:23 -05:00
|
|
|
def tx(self, packet):
|
2022-12-30 09:44:25 -05:00
|
|
|
pkt_type = packet.__class__.__name__
|
|
|
|
if pkt_type not in self._pkt_cnt:
|
|
|
|
self._pkt_cnt[pkt_type] = {
|
|
|
|
"tx": 0,
|
|
|
|
"rx": 0,
|
|
|
|
}
|
|
|
|
self._pkt_cnt[pkt_type]["tx"] += 1
|
2021-01-21 20:58:47 -05:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-01-21 20:58:47 -05:00
|
|
|
@property
|
|
|
|
def msgs_tracked(self):
|
2022-12-18 21:44:23 -05:00
|
|
|
return packets.PacketTrack().total_tracked
|
2021-01-21 20:58:47 -05:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-01-21 20:58:47 -05:00
|
|
|
@property
|
|
|
|
def email_tx(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
return self._email_tx
|
2021-01-21 20:58:47 -05:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-01-21 20:58:47 -05:00
|
|
|
def email_tx_inc(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
self._email_tx += 1
|
2021-01-21 20:58:47 -05:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-01-21 20:58:47 -05:00
|
|
|
@property
|
|
|
|
def email_rx(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
return self._email_rx
|
2021-01-21 20:58:47 -05:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-01-21 20:58:47 -05:00
|
|
|
def email_rx_inc(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
self._email_rx += 1
|
2021-01-21 20:58:47 -05:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-01-21 20:58:47 -05:00
|
|
|
@property
|
|
|
|
def email_thread_time(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
return self._email_thread_last_time
|
2021-01-21 20:58:47 -05:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-01-21 20:58:47 -05:00
|
|
|
def email_thread_update(self):
|
2022-07-20 08:43:57 -04:00
|
|
|
self._email_thread_last_time = datetime.datetime.now()
|
2021-01-21 20:58:47 -05:00
|
|
|
|
2022-07-20 08:43:57 -04:00
|
|
|
@wrapt.synchronized(lock)
|
2021-01-21 20:58:47 -05:00
|
|
|
def stats(self):
|
|
|
|
now = datetime.datetime.now()
|
2021-03-24 16:07:09 -04:00
|
|
|
if self._email_thread_last_time:
|
|
|
|
last_update = str(now - self._email_thread_last_time)
|
|
|
|
else:
|
|
|
|
last_update = "never"
|
|
|
|
|
2021-04-01 23:12:25 -04:00
|
|
|
if self._aprsis_keepalive:
|
|
|
|
last_aprsis_keepalive = str(now - self._aprsis_keepalive)
|
|
|
|
else:
|
|
|
|
last_aprsis_keepalive = "never"
|
|
|
|
|
2021-06-17 16:27:35 -04:00
|
|
|
pm = plugin.PluginManager()
|
2021-08-19 11:39:29 -04:00
|
|
|
plugins = pm.get_plugins()
|
2021-06-17 16:27:35 -04:00
|
|
|
plugin_stats = {}
|
2022-07-20 08:43:57 -04:00
|
|
|
if plugins:
|
|
|
|
def full_name_with_qualname(obj):
|
|
|
|
return "{}.{}".format(
|
|
|
|
obj.__class__.__module__,
|
|
|
|
obj.__class__.__qualname__,
|
|
|
|
)
|
|
|
|
|
|
|
|
for p in plugins:
|
|
|
|
plugin_stats[full_name_with_qualname(p)] = {
|
|
|
|
"enabled": p.enabled,
|
|
|
|
"rx": p.rx_count,
|
|
|
|
"tx": p.tx_count,
|
|
|
|
"version": p.version,
|
|
|
|
}
|
2021-06-17 16:27:35 -04:00
|
|
|
|
2021-07-17 14:30:29 -04:00
|
|
|
wl = packets.WatchList()
|
2021-10-09 14:29:25 -04:00
|
|
|
sl = packets.SeenList()
|
2022-12-18 21:44:23 -05:00
|
|
|
pl = packets.PacketList()
|
2021-07-17 14:30:29 -04:00
|
|
|
|
2021-01-21 20:58:47 -05:00
|
|
|
stats = {
|
2021-04-01 23:12:25 -04:00
|
|
|
"aprsd": {
|
|
|
|
"version": aprsd.__version__,
|
2021-04-02 18:54:00 -04:00
|
|
|
"uptime": utils.strfdelta(self.uptime),
|
2022-12-24 13:53:06 -05:00
|
|
|
"callsign": CONF.callsign,
|
2022-07-20 08:43:57 -04:00
|
|
|
"memory_current": int(self.memory),
|
2021-04-01 23:12:25 -04:00
|
|
|
"memory_current_str": utils.human_size(self.memory),
|
2022-07-20 08:43:57 -04:00
|
|
|
"memory_peak": int(self.memory_peak),
|
2021-04-01 23:12:25 -04:00
|
|
|
"memory_peak_str": utils.human_size(self.memory_peak),
|
2023-07-10 10:44:24 -04:00
|
|
|
"threads": self._thread_info,
|
2021-10-20 14:07:22 -04:00
|
|
|
"watch_list": wl.get_all(),
|
|
|
|
"seen_list": sl.get_all(),
|
2021-04-01 23:12:25 -04:00
|
|
|
},
|
|
|
|
"aprs-is": {
|
2022-07-20 08:43:57 -04:00
|
|
|
"server": str(self.aprsis_server),
|
2022-12-24 13:53:06 -05:00
|
|
|
"callsign": CONF.aprs_network.login,
|
2021-04-01 23:12:25 -04:00
|
|
|
"last_update": last_aprsis_keepalive,
|
|
|
|
},
|
2022-12-18 21:44:23 -05:00
|
|
|
"packets": {
|
2023-07-10 10:44:24 -04:00
|
|
|
"total_tracked": int(pl.total_tx() + pl.total_rx()),
|
|
|
|
"total_sent": int(pl.total_tx()),
|
|
|
|
"total_received": int(pl.total_rx()),
|
|
|
|
"by_type": self._pkt_cnt,
|
2022-12-18 21:44:23 -05:00
|
|
|
},
|
2021-01-21 20:58:47 -05:00
|
|
|
"messages": {
|
2022-12-18 21:44:23 -05:00
|
|
|
"sent": self._pkt_cnt["MessagePacket"]["tx"],
|
|
|
|
"received": self._pkt_cnt["MessagePacket"]["tx"],
|
|
|
|
"ack_sent": self._pkt_cnt["AckPacket"]["tx"],
|
2021-01-21 20:58:47 -05:00
|
|
|
},
|
|
|
|
"email": {
|
2022-12-24 13:53:06 -05:00
|
|
|
"enabled": CONF.email_plugin.enabled,
|
2022-07-20 08:43:57 -04:00
|
|
|
"sent": int(self._email_tx),
|
2022-12-18 21:44:23 -05:00
|
|
|
"received": int(self._email_rx),
|
2021-03-24 16:07:09 -04:00
|
|
|
"thread_last_update": last_update,
|
2021-01-21 20:58:47 -05:00
|
|
|
},
|
2021-06-17 16:27:35 -04:00
|
|
|
"plugins": plugin_stats,
|
2021-01-21 20:58:47 -05:00
|
|
|
}
|
|
|
|
return stats
|
|
|
|
|
|
|
|
def __str__(self):
|
2022-12-18 21:44:23 -05:00
|
|
|
pl = packets.PacketList()
|
2021-01-21 20:58:47 -05:00
|
|
|
return (
|
2021-01-22 16:05:48 -05:00
|
|
|
"Uptime:{} Msgs TX:{} RX:{} "
|
|
|
|
"ACK: TX:{} RX:{} "
|
|
|
|
"Email TX:{} RX:{} LastLoop:{} ".format(
|
|
|
|
self.uptime,
|
2022-12-18 21:44:23 -05:00
|
|
|
pl.total_tx(),
|
|
|
|
pl.total_rx(),
|
|
|
|
self._pkt_cnt["AckPacket"]["tx"],
|
|
|
|
self._pkt_cnt["AckPacket"]["rx"],
|
2021-01-21 20:58:47 -05:00
|
|
|
self._email_tx,
|
|
|
|
self._email_rx,
|
|
|
|
self._email_thread_last_time,
|
|
|
|
)
|
|
|
|
)
|