| Server IP : 61.19.30.66 / Your IP : 216.73.216.15 Web Server : Apache/2.2.22 (Ubuntu) System : Linux klw 3.11.0-15-generic #25~precise1-Ubuntu SMP Thu Jan 30 17:39:31 UTC 2014 x86_64 User : www-data ( 33) PHP Version : 5.3.10-1ubuntu3.48 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,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, MySQL : ON | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /usr/share/pyshared/landscape/manager/ |
Upload File : |
import logging
import os
import random
from twisted.internet.utils import getProcessOutput
from twisted.internet.defer import succeed
from landscape.package.store import PackageStore
from landscape.package.changer import PackageChanger
from landscape.package.releaseupgrader import ReleaseUpgrader
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, 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)