application/leyk_rpi_server
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Queue cleaning on state change implemented

Browse Source
This commit is contained in:
Dirk Alders 2020-06-16 09:36:32 +02:00
parent e0861f5c68
commit 4abc0d9fa3
3 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
config_example/config.py
View File

@ -12,6 +12,11 @@ secret = b'give_a_secret_string_here'
server_ip = '127.0.0.1'
server_port = 10001
LOG_TARGET_STDOUT = 'stdout'
LOG_TARGET_FILE = 'logfile'
LOG_TARGET = LOG_TARGET_STDOUT
SHORT_FMT = "%(asctime)s: %(levelname)-7s - %(message)s"
""" A short formatter including the most important information"""
LONG_FMT = """~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

2
leyk.py
View File

@ -10,7 +10,7 @@ import time
if __name__ == '__main__':
report.appLoggingConfigure(os.path.dirname(__file__), 'logfile', config.loggers)
report.appLoggingConfigure(os.path.dirname(__file__), config.LOG_TARGET, config.loggers)
s = tcp_socket.tcp_server_stp(config.server_ip, port=config.server_port)
prot = protocol.my_server_protocol(s, secret=config.secret)
while True:

6
piface_function.py
View File

@ -290,6 +290,7 @@ class leyk(object):
self._task_1s = task.periodic(1, self.task_1s)
self._task_1s.run()
self.sm_mode.register_state_change_callback(self.sm_mode.STATE_MANUAL, None, self._queue.clean_queue)
self.sm_day_state.register_state_change_callback(None, None, self.clean_queue)
self.sm_day_state.register_state_change_callback(self.sm_day_state.STATE_SLEEP, None, self.sm_day_state.report_sunset_sunrise)
self.sm_day_state.register_state_change_callback(self.sm_day_state.STATE_SLEEP, None, self.fill_sleep_queue)
self.sm_day_state.register_state_change_callback(self.sm_day_state.STATE_SUNRISE, None, self.sm_day_state.report_sunset_sunrise)
@ -413,6 +414,11 @@ class leyk(object):
time.sleep(0.2)
cnt += 1
def clean_queue(self):
if self._queue.qsize() > 0:
logger.info('Cleaning up remaining %d elements from queue', self._queue.qsize())
self._queue.clean_queue()
def fill_wake_queue(self):
no_delay = self.sm_day_state.previous_state_was(self.sm_day_state.STATE_IDLE)
# WAKE