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

kill signal removed

Browse source
This commit is contained in:
Volkan Şahin 2016-07-22 10:36:56 +03:00
parent 8b703e8639
commit 7335d6e5cb
1 changed files with 6 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
opt/ahenk/base/plugin/Plugin.py
View file

@ -1,15 +1,17 @@
#!/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>
import threading
import json import json
import threading
from base.Scope import Scope from base.Scope import Scope
from base.model.Response import Response
from base.file.file_transfer_manager import FileTransferManager from base.file.file_transfer_manager import FileTransferManager
from base.model.enum.MessageType import MessageType from base.model.Response import Response
from base.model.enum.MessageCode import MessageCode
from base.model.enum.ContentType import ContentType from base.model.enum.ContentType import ContentType
from base.model.enum.MessageCode import MessageCode
from base.model.enum.MessageType import MessageType
from base.system.system import System from base.system.system import System
@ -53,7 +55,6 @@ class Plugin(threading.Thread):
self.response_queue = scope.getResponseQueue() self.response_queue = scope.getResponseQueue()
self.messaging = scope.getMessageManager() self.messaging = scope.getMessageManager()
self.db_service = scope.getDbService() self.db_service = scope.getDbService()
# self.messager = None
self.keep_run = True self.keep_run = True
self.context = Context() self.context = Context()
@ -151,9 +152,6 @@ class Plugin(threading.Thread):
Scope.getInstance().getMessenger().send_direct_message(self.messaging.policy_status_msg(response)) Scope.getInstance().getMessenger().send_direct_message(self.messaging.policy_status_msg(response))
else: else:
self.logger.error('[Plugin] There is no Response. Plugin must create response after run a policy!') self.logger.error('[Plugin] There is no Response. Plugin must create response after run a policy!')
elif obj_name == "KILL_SIGNAL":
self.keep_run = False
self.logger.debug('[Plugin] Killing queue ! Plugin Name: {}'.format(str(self.name)))
elif 'MODE' in obj_name: elif 'MODE' in obj_name:
module = Scope.getInstance().getPluginManager().find_module(obj_name, self.name) module = Scope.getInstance().getPluginManager().find_module(obj_name, self.name)
if module is not None: if module is not None: