Liderahenk/Ahenk
1
0
Fork 0
mirror of https://github.com/Pardus-LiderAhenk/ahenk synced 2024-11-25 11:12:15 +03:00
Code Issues Projects Releases Packages Wiki Activity

timeout function added for registration timeout

Browse source
This commit is contained in:
Volkan Şahin 2016-07-22 10:37:27 +03:00
parent 7335d6e5cb
commit 7aa5aad801
1 changed files with 10 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
opt/ahenk/base/registration/Registration.py
View file

@ -10,6 +10,8 @@ from uuid import getnode as get_mac
from base.Scope import Scope from base.Scope import Scope
from base.messaging.AnonymousMessenger import AnonymousMessager from base.messaging.AnonymousMessenger import AnonymousMessager
from base.system.system import System from base.system.system import System
from base.timer.setup_timer import SetupTimer
from base.timer.timer import Timer
class Registration: class Registration:
@ -31,6 +33,7 @@ class Registration:
def registration_request(self): def registration_request(self):
self.logger.debug('[Registration] Requesting registration') self.logger.debug('[Registration] Requesting registration')
SetupTimer.start(Timer(System.Ahenk.registration_timeout(), timeout_function=self.registration_timeout, checker_func=self.is_registered, kwargs=None))
anon_messager = AnonymousMessager(self.message_manager.registration_msg()) anon_messager = AnonymousMessager(self.message_manager.registration_msg())
anon_messager.connect_to_server() anon_messager.connect_to_server()
@ -138,3 +141,10 @@ class Registration:
def generate_password(self): def generate_password(self):
return uuid.uuid4() return uuid.uuid4()
def registration_timeout(self):
self.logger.error('[Registration] Could not reach registration response from Lider. Be sure XMPP server is reachable and it supports anonymous message, Lider is running properly '
'and it is connected to XMPP server! Check your Ahenk configuration file (/etc/ahenk/ahenk.conf)')
self.logger.error('[Registration] Ahenk is shutting down...')
print('Ahenk is shutting down...')
System.Process.kill_by_pid(int(System.Ahenk.get_pid_number()))