[tor-commits] [stem/master] Moving log handlers to log util

[atagar@xxxxxxxxxxxxxx]

commit 608a5371370796a3d6ace5deb54bc019783cf2c9
Author: Damian Johnson <atagar@xxxxxxxxxxxxxx>
Date:   Thu Jan 5 22:42:33 2012 -0800

    Moving log handlers to log util
    
    Adding a couple basic log handlers to the log util...
    log_to_stdout - sends further events to stdout (mostly intended for debugging
      at the interpretor)
    LogBuffer - simple handler used by the testing to buffer logged events so we
      can run over them later
---
 run_tests.py     |    2 +-
 stem/util/log.py |   75 +++++++++++++++++++++++++++++++++++++++++++++++------
 test/output.py   |   26 +------------------
 3 files changed, 68 insertions(+), 35 deletions(-)

diff --git a/run_tests.py b/run_tests.py
index 8b59710..1b252df 100755
--- a/run_tests.py
+++ b/run_tests.py
@@ -208,7 +208,7 @@ if __name__ == '__main__':
   )
   
   stem_logger = log.get_logger()
-  logging_buffer = test.output.LogBuffer(log.logging_level(logging_runlevel))
+  logging_buffer = log.LogBuffer(logging_runlevel)
   stem_logger.addHandler(logging_buffer)
   
   if run_unit_tests:
diff --git a/stem/util/log.py b/stem/util/log.py
index 5c5815e..65d5659 100644
--- a/stem/util/log.py
+++ b/stem/util/log.py
@@ -8,6 +8,25 @@ runlevels being used as follows...
   INFO   - high level library activity
   DEBUG  - low level library activity
   TRACE  - request/reply logging
+
+get_logger - provides the stem's Logger instance
+logging_level - converts a runlevel to its logging number
+escape - escapes special characters in a message in preparation for logging
+
+log - logs a message at the given runlevel
+log_once - logs a message, deduplicating if it has already been logged
+trace - logs a message at the TRACE runlevel
+debug - logs a message at the DEBUG runlevel
+info - logs a message at the INFO runlevel
+notice - logs a message at the NOTICE runlevel
+warn - logs a message at the WARN runlevel
+error - logs a message at the ERROR runlevel
+
+LogBuffer - Buffers logged events so they can be iterated over.
+  |- is_empty - checks if there's events in our buffer
+  +- __iter__ - iterates over and removes the buffered events
+
+log_to_stdout - reports further logged events to stdout
 """
 
 import logging
@@ -76,6 +95,22 @@ def logging_level(runlevel):
   if runlevel: return LOG_VALUES[runlevel]
   else: return logging.FATAL + 5
 
+def escape(message):
+  """
+  Escapes specific sequences for logging (newlines, tabs, carrage returns).
+  
+  Arguments:
+    message (str) - string to be escaped
+  
+  Returns:
+    str that is escaped
+  """
+  
+  for pattern, replacement in (("\n", "\\n"), ("\r", "\\r"), ("\t", "\\t")):
+    message = message.replace(pattern, replacement)
+  
+  return message
+
 def log(runlevel, message):
   """
   Logs a message at the given runlevel.
@@ -118,19 +153,41 @@ def notice(message): log(Runlevel.NOTICE, message)
 def warn(message):   log(Runlevel.WARN, message)
 def error(message):  log(Runlevel.ERROR, message)
 
-def escape(message):
+class LogBuffer(logging.Handler):
+  """
+  Basic log handler that listens for stem events and stores them so they can be
+  read later. Log entries are cleared as they are read.
   """
-  Escapes specific sequences for logging (newlines, tabs, carrage returns).
   
-  Arguments:
-    message (str) - string to be escaped
+  def __init__(self, runlevel):
+    logging.Handler.__init__(self, level = logging_level(runlevel))
+    self.formatter = logging.Formatter(
+      fmt = '%(asctime)s [%(levelname)s] %(message)s',
+      datefmt = '%D %H:%M:%S')
+    
+    self._buffer = []
   
-  Returns:
-    str that is escaped
+  def is_empty(self):
+    return not bool(self._buffer)
+  
+  def __iter__(self):
+    while self._buffer:
+      yield self.formatter.format(self._buffer.pop(0))
+  
+  def emit(self, record):
+    self._buffer.append(record)
+
+def log_to_stdout(runlevel):
   """
+  Logs further events to stdout.
   
-  for pattern, replacement in (("\n", "\\n"), ("\r", "\\r"), ("\t", "\\t")):
-    message = message.replace(pattern, replacement)
+  Arguments:
+    runlevel (Runlevel) - minimum runlevel a message needs to be to be logged
+  """
   
-  return message
+  logging.basicConfig(
+    level = logging_level(runlevel),
+    format = '%(asctime)s [%(levelname)s] %(message)s',
+    datefmt = '%D %H:%M:%S',
+  )
 
diff --git a/test/output.py b/test/output.py
index 3ebed9e..6c00d28 100644
--- a/test/output.py
+++ b/test/output.py
@@ -61,7 +61,7 @@ def apply_filters(testing_output, *filters):
     if line != None:
       results.append(line)
   
-  return "\n".join(results)
+  return "\n".join(results) + "\n"
 
 def colorize(line_type, line_content):
   """
@@ -134,27 +134,3 @@ class ErrorTracker:
     for error_line in self._errors:
       yield error_line
 
-class LogBuffer(logging.Handler):
-  """
-  Basic log handler that listens for all stem events and stores them so they
-  can be read later. Log entries are cleared as they are read.
-  """
-  
-  def __init__(self, runlevel):
-    logging.Handler.__init__(self, level = runlevel)
-    self.formatter = logging.Formatter(
-      fmt = '%(asctime)s [%(levelname)s] %(message)s',
-      datefmt = '%D %H:%M:%S')
-    
-    self._buffer = []
-  
-  def is_empty(self):
-    return not bool(self._buffer)
-  
-  def __iter__(self):
-    while self._buffer:
-      yield self.formatter.format(self._buffer.pop(0))
-  
-  def emit(self, record):
-    self._buffer.append(record)
-

_______________________________________________
tor-commits mailing list
tor-commits@xxxxxxxxxxxxxxxxxxxx
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits