Skip to content
Snippets Groups Projects
Commit a3a33c11 authored by KERDREUX Jerome's avatar KERDREUX Jerome
Browse files

Format

Just a test for new rules
parent e8c5d98b
No related branches found
No related tags found
1 merge request!1First try of type hints
......@@ -7,6 +7,7 @@ from xaal.lib import Message
import logging
logger = logging.getLogger(__name__)
# how often we force refresh the devices attributes/description/keyvalues
......@@ -110,8 +111,10 @@ class Device:
result = self.db.get('name', result)
return result
class Devices:
"""Device List for monitoring"""
def __init__(self):
self.__devs = {}
self.__list_cache = None
......@@ -224,6 +227,7 @@ class Monitor:
"""
use this class to monitor a xAAL network
"""
def __init__(self, device, filter_func=None, db_server=None):
self.dev = device
self.engine = device.engine
......@@ -347,13 +351,30 @@ class Monitor:
def request_metadb(self, addr):
if self.db_server:
self.engine.send_request(self.dev, [self.db_server,], 'get_keys_values', {'device':addr})
self.engine.send_request(
self.dev,
[
self.db_server,
],
'get_keys_values',
{'device': addr},
)
def request_attributes(self, addr):
self.engine.send_get_attributes(self.dev,[addr,])
self.engine.send_get_attributes(
self.dev,
[
addr,
],
)
def request_description(self, addr):
self.engine.send_get_description(self.dev,[addr,])
self.engine.send_get_description(
self.dev,
[
addr,
],
)
def is_from_metadb(self, msg):
if (msg.is_notify() or msg.is_reply()) and msg.source == self.db_server:
......@@ -372,4 +393,7 @@ class Monitor:
def debug_timers(self):
for dev in self.devices:
print("%s\t%s\t%d\t%d\t%d" % (dev.address,dev.dev_type,dev.description.last_update,dev.db.last_update,dev.attributes.last_update))
print(
"%s\t%s\t%d\t%d\t%d"
% (dev.address, dev.dev_type, dev.description.last_update, dev.db.last_update, dev.attributes.last_update)
)
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment