|
Server : Apache/2.4.18 (Ubuntu) System : Linux canvaswebdesign 3.13.0-71-generic #114-Ubuntu SMP Tue Dec 1 02:34:22 UTC 2015 x86_64 User : oppastar ( 1041) PHP Version : 7.0.33-0ubuntu0.16.04.15 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, Directory : /usr/lib/python2.7/dist-packages/landscape/manager/ |
Upload File : |
import random
from landscape.manager.plugin import ManagerPlugin
from landscape.manager.manager import SUCCEEDED
class FakePackageManager(ManagerPlugin):
run_interval = 1800
randint = random.randint
def register(self, registry):
super(FakePackageManager, self).register(registry)
self.config = registry.config
registry.register_message("change-packages",
self.handle_change_packages)
registry.register_message("change-package-locks",
self.handle_change_package_locks)
registry.register_message("release-upgrade",
self.handle_release_upgrade)
def _handle(self, response):
delay = self.randint(30, 300)
self.registry.reactor.call_later(
delay, self.manager.broker.send_message, response,
self._session_id, urgent=True)
def handle_change_packages(self, message):
response = {"type": "change-packages-result",
"operation-id": message.get("operation-id"),
"result-code": 1,
"result-text": "OK done."}
return self._handle(response)
def handle_change_package_locks(self, message):
response = {"type": "operation-result",
"operation-id": message.get("operation-id"),
"status": SUCCEEDED,
"result-text": "Package locks successfully changed.",
"result-code": 0}
return self._handle(response)
def handle_release_upgrade(self, message):
response = {"type": "operation-result",
"operation-id": message.get("operation-id"),
"status": SUCCEEDED,
"result-text": "Successful release upgrade.",
"result-code": 0}
return self._handle(response)