ajout de la gestion du message de vie
This commit is contained in:
@@ -562,19 +562,26 @@ def listener(sock, logger):
|
|||||||
try:
|
try:
|
||||||
data += clientsocket.recv(1)
|
data += clientsocket.recv(1)
|
||||||
if data.decode('utf-8').endswith('\n'):
|
if data.decode('utf-8').endswith('\n'):
|
||||||
|
logger.debug("datas recv: {}".format(data.decode('utf-8')))
|
||||||
if data.decode('utf-8').startswith('RELOAD_DB'):
|
if data.decode('utf-8').startswith('RELOAD_DB'):
|
||||||
logger.debug("==> RELOAD DB")
|
|
||||||
FLAG_CONF_UPDATE = True
|
FLAG_CONF_UPDATE = True
|
||||||
|
data = b''
|
||||||
elif data.decode('utf-8').startswith('RELOAD_HOURS'):
|
elif data.decode('utf-8').startswith('RELOAD_HOURS'):
|
||||||
logger.debug("==> RELOAD HOURS")
|
|
||||||
FLAG_CONF_UPDATE = True
|
FLAG_CONF_UPDATE = True
|
||||||
FLAG_HORAIRE_UPDATE = True
|
FLAG_HORAIRE_UPDATE = True
|
||||||
|
data = b''
|
||||||
|
elif data.decode('utf-8').startswith('ALIVE?'):
|
||||||
|
clientsocket.sendall(b"ALIVE\n")
|
||||||
|
data = b''
|
||||||
|
elif len(data) == 0:
|
||||||
|
# deconnexion du client
|
||||||
|
logger.info("deconnexion du client ...")
|
||||||
clientsocket = None
|
clientsocket = None
|
||||||
flag = False
|
flag = False
|
||||||
except:
|
except:
|
||||||
continue
|
continue
|
||||||
if not data:
|
#if not data:
|
||||||
break
|
# break
|
||||||
|
|
||||||
logger.debug("Fin du serveur de communication")
|
logger.debug("Fin du serveur de communication")
|
||||||
return
|
return
|
||||||
@@ -954,6 +961,7 @@ def main():
|
|||||||
minute='*',
|
minute='*',
|
||||||
id="job_id")
|
id="job_id")
|
||||||
FLAG_HORAIRE_UPDATE = False
|
FLAG_HORAIRE_UPDATE = False
|
||||||
|
|
||||||
FLAG_CONF_UPDATE = False
|
FLAG_CONF_UPDATE = False
|
||||||
|
|
||||||
# Si le module GSM est ouvert
|
# Si le module GSM est ouvert
|
||||||
|
|||||||
Reference in New Issue
Block a user