/usr/lib/python2.7/dist-packages/provisioningserver/services.py is in python-maas-provisioningserver 1.5.4+bzr2294-0ubuntu1.2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 | # Copyright 2012 Canonical Ltd. This software is licensed under the
# GNU Affero General Public License version 3 (see the file LICENSE).
"""Additional services that compose the MAAS Provisioning Server."""
from __future__ import (
absolute_import,
print_function,
unicode_literals,
)
str = None
__metaclass__ = type
__all__ = [
"LogService",
"OOPSService",
]
import signal
import sys
import oops
from oops_datedir_repo import DateDirRepo
from oops_twisted import (
Config as oops_config,
defer_publisher,
OOPSObserver,
)
from twisted.application.service import Service
from twisted.internet import reactor
from twisted.python.log import (
addObserver,
FileLogObserver,
removeObserver,
)
from twisted.python.logfile import LogFile
class LogService(Service):
name = "log"
def __init__(self, filename):
self.filename = filename
self.logfile = None
self.observer = None
def _signal_handler(self, sig, frame):
reactor.callFromThread(self.logfile.reopen)
def startService(self):
Service.startService(self)
if self.filename != '-':
self.logfile = LogFile.fromFullPath(
self.filename, rotateLength=None, defaultMode=0o644)
self.__previous_signal_handler = signal.signal(
signal.SIGUSR1, self._signal_handler)
else:
self.logfile = sys.stdout
self.observer = FileLogObserver(self.logfile)
self.observer.start()
def stopService(self):
Service.stopService(self)
if self.filename != '-':
signal.signal(signal.SIGUSR1, self.__previous_signal_handler)
del self.__previous_signal_handler
self.observer.stop()
self.observer = None
self.logfile.close()
self.logfile = None
else:
self.observer.stop()
self.observer = None
# Don't close stdout.
self.logfile = None
class OOPSService(Service):
name = "oops"
def __init__(self, log_service, oops_dir, oops_reporter):
self.config = None
self.log_service = log_service
self.oops_dir = oops_dir
self.oops_reporter = oops_reporter
def startService(self):
Service.startService(self)
self.config = oops_config()
# Add the oops publisher that writes files in the configured place if
# the command line option was set.
if self.oops_dir:
repo = DateDirRepo(self.oops_dir)
self.config.publishers.append(
defer_publisher(oops.publish_new_only(repo.publish)))
if self.oops_reporter:
self.config.template['reporter'] = self.oops_reporter
self.observer = OOPSObserver(
self.config, self.log_service.observer.emit)
addObserver(self.observer.emit)
def stopService(self):
Service.stopService(self)
removeObserver(self.observer.emit)
self.observer = None
self.config = None
|