eric: comparison DebugClients/Python3/coverage/collector.py

-:dde24fc7f7ba
+:391dc0bc4ae5
 import sys, threading
 try:
 # Use the C extension code when we can, for speed.
-from tracer import Tracer
+from .tracer import Tracer
 except ImportError:
 # Couldn't import the C extension, maybe it isn't built.
+Tracer = None
-class Tracer:
-"""Python implementation of the raw data tracer."""
-def __init__(self):
+class PyTracer(object):
-self.data = None
+"""Python implementation of the raw data tracer."""
-self.should_trace = None
-self.should_trace_cache = None
+# Because of poor implementations of trace-function-manipulating tools,
-self.cur_filename = None
+# the Python trace function must be kept very simple.  In particular, there
-self.filename_stack = []
+# must be only one function ever set as the trace function, both through
+# sys.settrace, and as the return value from the trace function.  Put
+# another way, the trace function must always return itself.  It cannot
+# swap in other functions, or return None to avoid tracing a particular
+# frame.
+#
+# The trace manipulator that introduced this restriction is DecoratorTools,
+# which sets a trace function, and then later restores the pre-existing one
+# by calling sys.settrace with a function it found in the current frame.
+#
+# Systems that use DecoratorTools (or similar trace manipulations) must use
+# PyTracer to get accurate results.  The command-line --timid argument is
+# used to force the use of this tracer.
+def __init__(self):
+self.data = None
+self.should_trace = None
+self.should_trace_cache = None
+self.cur_file_data = None
+self.last_line = 0
+self.data_stack = []
+self.last_exc_back = None
+self.arcs = False
+def _trace(self, frame, event, arg_unused):
+"""The trace function passed to sys.settrace."""
+#print "trace event: %s %r @%d" % (
+#           event, frame.f_code.co_filename, frame.f_lineno)
+if self.last_exc_back:
+if frame == self.last_exc_back:
+# Someone forgot a return event.
+if self.arcs and self.cur_file_data:
+self.cur_file_data[(self.last_line, -1)] = None
+self.cur_file_data, self.last_line = self.data_stack.pop()
 self.last_exc_back = None
-def _global_trace(self, frame, event, arg_unused):
+if event == 'call':
-"""The trace function passed to sys.settrace."""
+# Entering a new function context.  Decide if we should trace
-if event == 'call':
+# in this file.
-# Entering a new function context.  Decide if we should trace
+self.data_stack.append((self.cur_file_data, self.last_line))
-# in this file.
+filename = frame.f_code.co_filename
-filename = frame.f_code.co_filename
+tracename = self.should_trace(filename, frame)
-tracename = self.should_trace_cache.get(filename)
+if tracename:
-if tracename is None:
+if tracename not in self.data:
-tracename = self.should_trace(filename, frame)
+self.data[tracename] = {}
-self.should_trace_cache[filename] = tracename
+self.cur_file_data = self.data[tracename]
-if tracename:
+else:
-# We need to trace.  Push the current filename on the stack
+self.cur_file_data = None
-# and record the new current filename.
+self.last_line = -1
-self.filename_stack.append(self.cur_filename)
+elif event == 'line':
-self.cur_filename = tracename
+# Record an executed line.
-# Use _local_trace for tracing within this function.
+if self.cur_file_data is not None:
-return self._local_trace
+if self.arcs:
+#print "lin", self.last_line, frame.f_lineno
+self.cur_file_data[(self.last_line, frame.f_lineno)] = None
 else:
-# No tracing in this function.
+#print "lin", frame.f_lineno
-return None
+self.cur_file_data[frame.f_lineno] = None
-return self._global_trace
+self.last_line = frame.f_lineno
+elif event == 'return':
-def _local_trace(self, frame, event, arg_unused):
+if self.arcs and self.cur_file_data:
-"""The trace function used within a function."""
+self.cur_file_data[(self.last_line, -1)] = None
-if self.last_exc_back:
+# Leaving this function, pop the filename stack.
-if frame == self.last_exc_back:
+self.cur_file_data, self.last_line = self.data_stack.pop()
-# Someone forgot a return event.
+elif event == 'exception':
-self.cur_filename = self.filename_stack.pop()
+#print "exc", self.last_line, frame.f_lineno
-self.last_exc_back = None
+self.last_exc_back = frame.f_back
+return self._trace
-if event == 'line':
-# Record an executed line.
+def start(self):
-self.data[(self.cur_filename, frame.f_lineno)] = True
+"""Start this Tracer."""
-elif event == 'return':
+sys.settrace(self._trace)
-# Leaving this function, pop the filename stack.
-self.cur_filename = self.filename_stack.pop()
+def stop(self):
-elif event == 'exception':
+"""Stop this Tracer."""
-self.last_exc_back = frame.f_back
+sys.settrace(None)
-return self._local_trace
+def get_stats(self):
-def start(self):
+"""Return a dictionary of statistics, or None."""
-"""Start this Tracer."""
+return None
-sys.settrace(self._global_trace)
-def stop(self):
+class Collector(object):
-"""Stop this Tracer."""
-sys.settrace(None)
-class Collector:
 """Collects trace data.
-Creates a Tracer object for each thread, since they track stack information.
+Creates a Tracer object for each thread, since they track stack
-Each Tracer points to the same shared data, contributing traced data points.
+information.  Each Tracer points to the same shared data, contributing
+traced data points.
 When the Collector is started, it creates a Tracer for the current thread,
 and installs a function to create Tracers for each new thread started.
 When the Collector is stopped, all active Tracers are stopped.
 Threads started while the Collector is stopped will never have Tracers
 associated with them.
 """
 # The stack of active Collectors.  Collectors are added here when started,
 # and popped when stopped.  Collectors on the stack are paused when not
 # the top, and resumed when they become the top again.
 _collectors = []
-def __init__(self, should_trace):
+def __init__(self, should_trace, timid, branch):
 """Create a collector.
 `should_trace` is a function, taking a filename, and returning a
 canonicalized filename, or False depending on whether the file should
 be traced or not.
+If `timid` is true, then a slower simpler trace function will be
+used.  This is important for some environments where manipulation of
+tracing functions make the faster more sophisticated trace function not
+operate properly.
+If `branch` is true, then branches will be measured.  This involves
+collecting data on which statements followed each other (arcs).  Use
+`get_arc_data` to get the arc data.
 """
 self.should_trace = should_trace
+self.branch = branch
 self.reset()
+if timid:
+# Being timid: use the simple Python trace function.
+self._trace_class = PyTracer
+else:
+# Being fast: use the C Tracer if it is available, else the Python
+# trace function.
+self._trace_class = Tracer or PyTracer
+def __repr__(self):
+return "<Collector at 0x%x>" % id(self)
+def tracer_name(self):
+"""Return the class name of the tracer we're using."""
+return self._trace_class.__name__
 def reset(self):
 """Clear collected data, and prepare to collect more."""
-# A dictionary with an entry for (Python source file name, line number
+# A dictionary mapping filenames to dicts with linenumber keys,
-# in that file) if that line has been executed.
+# or mapping filenames to dicts with linenumber pairs as keys.
 self.data = {}
 # A cache of the results from should_trace, the decision about whether
 # to trace execution in a file. A dict of filename to (filename or
 # False).
 self.should_trace_cache = {}
 # Our active Tracers.
 self.tracers = []
 def _start_tracer(self):
 """Start a new Tracer object, and store it in self.tracers."""
-tracer = Tracer()
+tracer = self._trace_class()
 tracer.data = self.data
+tracer.arcs = self.branch
 tracer.should_trace = self.should_trace
 tracer.should_trace_cache = self.should_trace_cache
 tracer.start()
 self.tracers.append(tracer)
 def start(self):
 """Start collecting trace information."""
 if self._collectors:
 self._collectors[-1].pause()
 self._collectors.append(self)
+#print >>sys.stderr, "Started: %r" % self._collectors
 # Install the tracer on this thread.
 self._start_tracer()
 # Install our installation tracer in threading, to jump start other
 # threads.
 threading.settrace(self._installation_trace)
 def stop(self):
 """Stop collecting trace information."""
+#print >>sys.stderr, "Stopping: %r" % self._collectors
 assert self._collectors
 assert self._collectors[-1] is self
-for tracer in self.tracers:
+self.pause()
-tracer.stop()
 self.tracers = []
-threading.settrace(None)
 # Remove this Collector from the stack, and resume the one underneath
 # (if any).
 self._collectors.pop()
 if self._collectors:
 self._collectors[-1].resume()
 def pause(self):
 """Pause tracing, but be prepared to `resume`."""
 for tracer in self.tracers:
 tracer.stop()
+stats = tracer.get_stats()
+if stats:
+print("\nCoverage.py tracer stats:")
+for k in sorted(stats.keys()):
+print("%16s: %s" % (k, stats[k]))
 threading.settrace(None)
 def resume(self):
 """Resume tracing after a `pause`."""
 for tracer in self.tracers:
 tracer.start()
 threading.settrace(self._installation_trace)
-def data_points(self):
+def get_line_data(self):
-"""Return the (filename, lineno) pairs collected."""
+"""Return the line data collected.
-return list(self.data.keys())
+Data is { filename: { lineno: None, ...}, ...}
+"""
+if self.branch:
+# If we were measuring branches, then we have to re-build the dict
+# to show line data.
+line_data = {}
+for f, arcs in self.data.items():
+line_data[f] = ldf = {}
+for l1, _ in arcs:
+if l1:
+ldf[l1] = None
+return line_data
+else:
+return self.data
+def get_arc_data(self):
+"""Return the arc data collected.
+Data is { filename: { (l1, l2): None, ...}, ...}
+Note that no data is collected or returned if the Collector wasn't
+created with `branch` true.
+"""
+if self.branch:
+return self.data
+else:
+return {}

Mercurial Repositories > eric / file comparison

comparison: DebugClients/Python3/coverage/collector.py

DebugClients/Python3/coverage/collector.py