ENH: Python 3 tracer.

Author: llllllllll

qdb/comm.py

@@ -12,6 +12,8 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+from __future__ import print_function
+
 from abc import ABCMeta, abstractmethod
 import atexit
 from bdb import Breakpoint
@@ -110,6 +112,7 @@ class CommandManager(object):
 
     def __init__(self, tracer):
         self.tracer = tracer
+
         if gevent is not None:
             import gipc  # Only use gipc if we are running in gevent.
             self._pipe = gipc.pipe

qdb/compat.py

@@ -24,9 +24,13 @@
 
 PY3 = not PY2
 
-
 gevent = sys.modules.get('gevent')
 
+try:
+    import gevent
+except ImportError:
+    gevent = None
+
 
 if PY2:
     try:
@@ -35,7 +39,6 @@
         from StringIO import StringIO
 
     from contextlib2 import ExitStack
-
     import itertools
 
     filter = itertools.ifilter
@@ -90,6 +93,7 @@ def with_metaclass(metaclass, *bases):
     'StringIO',
     'gevent',
     'items',
+    'keys',
     'range',
     'reduce',
     'zip',

qdb/tracer.py

@@ -23,7 +23,7 @@
 from logbook import Logger, FileHandler
 
 from qdb.comm import RemoteCommandManager, fmt_msg
-from qdb.compat import map, items, ExitStack
+from qdb.compat import map, items
 from qdb.config import QdbConfig
 from qdb.errors import QdbUnreachableBreakpoint, QdbQuit, QdbExecutionTimeout
 from qdb.output import RemoteOutput, OutputTee

setup.py

@@ -67,6 +67,7 @@
         'Topic :: Software Development :: Debuggers',
     ],
     install_requires=[
+        'contextlib2',
         'Logbook',
         'websocket-client',
     ] + py2_requires,

tests/test_cmd_manager.py

@@ -253,6 +253,7 @@ def send_stack(self):
             host=self.tracer_host,
             port=self.tracer_port,
             redirect_output=False,
+            green=True,
         )
         sleep(0.01)
         if direction == 'down':
@@ -301,6 +302,7 @@ def pause_handler(signal, stackframe):
             cmd_manager=self.cmd_manager,
             host=self.tracer_host,
             port=self.tracer_port,
+            green=True,
         )
         signal.signal(db.pause_signal, pause_handler)
         self.server.session_store.send_to_tracer(
@@ -341,6 +343,7 @@ def send_print(self, input_, exc, output):
             host=self.tracer_host,
             port=self.tracer_port,
             redirect_output=False,
+            green=True,
         )
         sleep(0.01)
         self.server.session_store.send_to_tracer(
@@ -427,6 +430,7 @@ def test_eval_state_update(self):
             host=self.tracer_host,
             port=self.tracer_port,
             redirect_output=False,
+            green=True,
         )
         sleep(0.01)
         self.server.session_store.send_to_tracer(
@@ -472,6 +476,7 @@ def send_print(self, input_, exc, output):
             port=self.tracer_port,
             redirect_output=False,
             execution_timeout=1,
+            green=True,
         )
         sleep(0.01)
         self.server.session_store.send_to_tracer(
@@ -511,6 +516,7 @@ def send_disabled(self):
             host=self.tracer_host,
             port=self.tracer_port,
             redirect_output=False,
+            green=True,
         )
         sleep(0.01)
         db.set_trace(stop=False)
@@ -550,6 +556,7 @@ def send_stack(self):
             port=self.tracer_port,
             redirect_output=False,
             skip_fn=skip_fn if use_skip_fn else None,
+            green=True,
         )
         sleep(0.01)
         self.server.session_store.send_to_tracer(