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

process were extended

Browse source
This commit is contained in:
Volkan Şahin 2016-03-08 18:09:26 +02:00
parent 3752a968ac
commit b6b5e53740
1 changed files with 12 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
opt/ahenk/ahenkd.py
View file

@ -1,6 +1,7 @@
#!/usr/bin/python3 #!/usr/bin/python3
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
# Author: İsmail BAŞARAN <ismail.basaran@tubitak.gov.tr> <basaran.ismaill@gmail.com> # Author: İsmail BAŞARAN <ismail.basaran@tubitak.gov.tr> <basaran.ismaill@gmail.com>
# Author: Volkan Şahin <volkansah.in> <bm.volkansahin@gmail.com>
from base.config.ConfigManager import ConfigManager from base.config.ConfigManager import ConfigManager
from base.deamon.BaseDeamon import BaseDaemon from base.deamon.BaseDeamon import BaseDaemon
@ -9,6 +10,7 @@ from base.Scope import Scope
from base.messaging.Messaging import Messaging from base.messaging.Messaging import Messaging
from base.messaging.MessageReceiver import MessageReceiver from base.messaging.MessageReceiver import MessageReceiver
from base.messaging.MessageSender import MessageSender from base.messaging.MessageSender import MessageSender
from base.execution.ExecutionManager import ExecutionManager
from base.registration.Registration import Registration from base.registration.Registration import Registration
from base.messaging.MessageResponseQueue import MessageResponseQueue from base.messaging.MessageResponseQueue import MessageResponseQueue
from base.event.EventManager import EventManager from base.event.EventManager import EventManager
@ -16,7 +18,7 @@ from base.plugin.PluginManager import PluginManager
from base.task.TaskManager import TaskManager from base.task.TaskManager import TaskManager
from multiprocessing import Process from multiprocessing import Process
from threading import Thread from threading import Thread
import sys,logging,queue,time import sys,logging,queue,time,os
class AhenkDeamon(BaseDaemon): class AhenkDeamon(BaseDaemon):
@ -51,7 +53,6 @@ class AhenkDeamon(BaseDaemon):
messageManager = Messaging() messageManager = Messaging()
globalscope.setMessageManager(messageManager) globalscope.setMessageManager(messageManager)
pluginManager = PluginManager() pluginManager = PluginManager()
pluginManager.loadPlugins() pluginManager.loadPlugins()
globalscope.setPluginManager(pluginManager) globalscope.setPluginManager(pluginManager)
@ -62,27 +63,25 @@ class AhenkDeamon(BaseDaemon):
registration=Registration() registration=Registration()
globalscope.setRegistration(registration) globalscope.setRegistration(registration)
execution_manager=ExecutionManager()
while registration.is_registered() is False: while registration.is_registered() is False:
registration.registration_request() registration.registration_request()
#eventManager.register_event('registration_ok',self.reload) print("Receiver OnAir")
#registration.unregister()
"""
message_receiver = MessageReceiver() message_receiver = MessageReceiver()
rec_process = Process(target=message_receiver.connect_to_server) rec_process = Process(target=message_receiver.connect_to_server)
rec_process.start() rec_process.start()
"""
#rec_process.terminate() #login
#message_sender=MessageSender(messageManager.login_msg(),None)
#message_sender=MessageSender(None,'/home/volkan/Desktop/batman.png')
#message_sender.connect_to_server() #message_sender.connect_to_server()
#logout
#message_sender=MessageSender(messageManager.logout_msg(),None)
#message_sender.connect_to_server()
#rec_process.terminate()
""" """
this is must be created after message services this is must be created after message services