summaryrefslogtreecommitdiffstats
path: root/build/lib/Bcfg2/Logger.py
diff options
context:
space:
mode:
Diffstat (limited to 'build/lib/Bcfg2/Logger.py')
-rw-r--r--build/lib/Bcfg2/Logger.py233
1 files changed, 0 insertions, 233 deletions
diff --git a/build/lib/Bcfg2/Logger.py b/build/lib/Bcfg2/Logger.py
deleted file mode 100644
index e8cdd492d..000000000
--- a/build/lib/Bcfg2/Logger.py
+++ /dev/null
@@ -1,233 +0,0 @@
-"""Bcfg2 logging support"""
-__revision__ = '$Revision$'
-
-import copy
-import fcntl
-import logging
-import logging.handlers
-import math
-import socket
-import struct
-import sys
-import termios
-
-logging.raiseExceptions = 0
-
-def print_attributes(attrib):
- """Add the attributes for an element."""
- return ' '.join(['%s="%s"' % data for data in list(attrib.items())])
-
-def print_text(text):
- """Add text to the output (which will need normalising."""
- charmap = {'<':'&lt;', '>':'&gt;', '&':'&amp;'}
- return ''.join([charmap.get(char, char) for char in text]) + '\n'
-
-def xml_print(element, running_indent=0, indent=4):
- """Add an element and its children to the return string."""
- if (len(element.getchildren()) == 0) and (not element.text):
- ret = (' ' * running_indent)
- ret += '<%s %s/>\n' % (element.tag, print_attributes(element.attrib))
- else:
- child_indent = running_indent + indent
- ret = (' ' * running_indent)
- ret += '<%s%s>\n' % (element.tag, print_attributes(element))
- if element.text:
- ret += (' '* child_indent) + print_text(element.text)
- for child in element.getchildren():
- ret += xml_print(child, child_indent, indent)
- ret += (' ' * running_indent) + '</%s>\n' % (element.tag)
- if element.tail:
- ret += (' ' * child_indent) + print_text(element.tail)
- return ret
-
-class TermiosFormatter(logging.Formatter):
- """The termios formatter displays output in a terminal-sensitive fashion."""
-
- def __init__(self, fmt=None, datefmt=None):
- logging.Formatter.__init__(self, fmt, datefmt)
- if sys.stdout.isatty():
- # now get termios info
- try:
- self.width = struct.unpack('hhhh', fcntl.ioctl(0, termios.TIOCGWINSZ,
- "\000"*8))[1]
- if self.width == 0:
- self.width = 80
- except:
- self.width = 80
- else:
- # output to a pipe
- self.width = 32768
-
- def format(self, record):
- '''format a record for display'''
- returns = []
- line_len = self.width
- if isinstance(record.msg, str):
- for line in record.msg.split('\n'):
- if len(line) <= line_len:
- returns.append(line)
- else:
- inner_lines = int(math.floor(float(len(line)) / line_len))+1
- for i in range(inner_lines):
- returns.append("%s" % (line[i*line_len:(i+1)*line_len]))
- elif isinstance(record.msg, list):
- if not record.msg:
- return ''
- record.msg.sort()
- msgwidth = self.width
- columnWidth = max([len(item) for item in record.msg])
- columns = int(math.floor(float(msgwidth) / (columnWidth+2)))
- lines = int(math.ceil(float(len(record.msg)) / columns))
- for lineNumber in range(lines):
- indices = [idx for idx in [(colNum * lines) + lineNumber
- for colNum in range(columns)] if idx < len(record.msg)]
- format = (len(indices) * (" %%-%ds " % columnWidth))
- returns.append(format % tuple([record.msg[idx] for idx in indices]))
- #elif type(record.msg) == lxml.etree._Element:
- # returns.append(str(xml_print(record.msg)))
- else:
- returns.append(str(record.msg))
- if record.exc_info:
- returns.append(self.formatException(record.exc_info))
- return '\n'.join(returns)
-
-class FragmentingSysLogHandler(logging.handlers.SysLogHandler):
- """
- This handler fragments messages into
- chunks smaller than 250 characters
- """
-
- def __init__(self, procname, path, facility):
- self.procname = procname
- self.unixsocket = False
- logging.handlers.SysLogHandler.__init__(self, path, facility)
-
- def emit(self, record):
- """Chunk and deliver records."""
- record.name = self.procname
- if str(record.msg) > 250:
- msgs = []
- error = record.exc_info
- record.exc_info = None
- msgdata = record.msg
- while msgdata:
- newrec = copy.deepcopy(record)
- newrec.msg = msgdata[:250]
- msgs.append(newrec)
- msgdata = msgdata[250:]
- msgs[0].exc_info = error
- else:
- msgs = [record]
- for newrec in msgs:
- msg = self.log_format_string % (self.encodePriority(self.facility,
- newrec.levelname.lower()), self.format(newrec))
- try:
- self.socket.send(msg)
- except socket.error:
- for i in xrange(10):
- try:
- if isinstance(self.address, tuple):
- self.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
- self.socket.connect(self.address)
- else:
- self._connect_unixsocket(self.address)
- break
- except socket.error:
- continue
- try:
- self.socket.send("Reconnected to syslog")
- self.socket.send(msg)
- except:
- """
- If we still fail then drop it. Running bcfg2-server as non-root can
- trigger permission denied exceptions.
- """
- pass
-
-def setup_logging(procname, to_console=True, to_syslog=True, syslog_facility='daemon', level=0, to_file=None):
- """Setup logging for Bcfg2 software."""
- if hasattr(logging, 'already_setup'):
- return
- # add the handler to the root logger
- if to_console:
- console = logging.StreamHandler(sys.stdout)
- console.setLevel(logging.DEBUG)
- # tell the handler to use this format
- console.setFormatter(TermiosFormatter())
- logging.root.addHandler(console)
- if to_syslog:
- try:
- try:
- syslog = FragmentingSysLogHandler(procname, '/dev/log', syslog_facility)
- except socket.error:
- syslog = FragmentingSysLogHandler(procname, ('localhost', 514), syslog_facility)
- syslog.setLevel(logging.DEBUG)
- syslog.setFormatter(logging.Formatter('%(name)s[%(process)d]: %(message)s'))
- logging.root.addHandler(syslog)
- except socket.error:
- logging.root.error("failed to activate syslogging")
- except:
- print("Failed to activate syslogging")
- if not to_file == None:
- filelog = logging.FileHandler(to_file)
- filelog.setLevel(logging.DEBUG)
- filelog.setFormatter(logging.Formatter('%(asctime)s %(name)s[%(process)d]: %(message)s'))
- logging.root.addHandler(filelog)
- logging.root.setLevel(level)
- logging.already_setup = True
-
-def trace_process(**kwargs):
- """Literally log every line of python code as it runs.
-
- Keyword arguments:
- log -- file (name) to log to (default stderr)
- scope -- base scope to log to (default Cobalt)
-
- """
-
- file_name = kwargs.get("log", None)
- if file_name is not None:
- log_file = open(file_name, "w")
- else:
- log_file = sys.stderr
-
- scope = kwargs.get("scope", "Cobalt")
-
- def traceit(frame, event, arg):
- if event == "line":
- lineno = frame.f_lineno
- filename = frame.f_globals["__file__"]
- if (filename.endswith(".pyc") or
- filename.endswith(".pyo")):
- filename = filename[:-1]
- name = frame.f_globals["__name__"]
- line = linecache.getline(filename, lineno)
- print >> log_file, "%s:%s: %s" % (name, lineno, line.rstrip())
- return traceit
-
- sys.settrace(traceit)
-
-def log_to_stderr(logger_name, level=logging.INFO):
- """Set up console logging."""
- try:
- logger = logging.getLogger(logger_name)
- except:
- # assume logger_name is already a logger
- logger = logger_name
- handler = logging.StreamHandler() # sys.stderr is the default stream
- handler.setLevel(level)
- handler.setFormatter(TermiosFormatter()) # investigate this formatter
- logger.addHandler(handler)
-
-def log_to_syslog(logger_name, level=logging.INFO, format='%(name)s[%(process)d]: %(message)s'):
- """Set up syslog logging."""
- try:
- logger = logging.getLogger(logger_name)
- except:
- # assume logger_name is already a logger
- logger = logger_name
- # anticipate an exception somewhere below
- handler = logging.handlers.SysLogHandler() # investigate FragmentingSysLogHandler
- handler.setLevel(level)
- handler.setFormatter(logging.Formatter(format))
- logger.addHandler(handler)
generated by cgit v1.2.3-1-g7c22 (git 2.25.1) at 2024-07-23 19:32:48 +0000