debug.py

import os


class DebugHook(object):
    def on_eval(self, val, env, cont):
        return val, env, cont
    def on_plug_reduce(self, val, cont):
        pass
    def on_abnormal_pass(self,
                         val_tree,
                         src_cont,
                         dst_cont,
                         exiting,
                         entering):
        pass

def is_user_source(source_pos):
    return (source_pos is not None
            and source_pos.source_file.path != 'kernel.k'
            and source_pos.source_file.path != 'extension.k')

class StepHook(DebugHook):
    def on_eval(self, val, env, cont):
        if is_user_source(val.source_pos):
            val.source_pos.print_()
            return debug_interaction(env, cont)
        else:
            return val, env, cont
    def on_plug_reduce(self, val, cont):
        if is_user_source(cont.source_pos):
            cont.source_pos.print_("        ")
            print "        return", val.tostring()
            print
    def on_abnormal_pass(self,
                         val_tree,
                         src_cont,
                         dst_cont,
                         exiting,
                         entering):
        print "*** ABNORMAL PASS of %s from %s to %s" % (
                val_tree.tostring(),
                src_cont.tostring(),
                dst_cont.tostring())

class ResumeContHook(DebugHook):
    def __init__(self, cont):
        self.cont = cont
    def on_plug_reduce(self, val, cont):
        if is_user_source(cont.source_pos):
            cont.source_pos.print_("        ")
            print "        return", val.tostring()
            print
        if cont is self.cont:
            start_stepping()
    def on_abnormal_pass(self,
                         val_tree,
                         src_cont,
                         dst_cont,
                         exiting,
                         entering):
        #XXX: interact?
        for cont, interceptor in exiting:
            if cont is self.cont:
                print "*** EXITED THROUGH ABNORMAL PASS of %s from %s to %s" % (
                        val_tree.tostring(),
                        src_cont.tostring(),
                        dst_cont.tostring())
                break
        else:
            for cont, interceptor in entering:
                if cont is self.cont:
                    print "*** ENTERED THROUGH ABNORMAL PASS of %s from %s to %s" % (
                            val_tree.tostring(),
                            src_cont.tostring(),
                            dst_cont.tostring())
                break

class DebugState(object):
    def __init__(self):
        self.latest_command = None
        self.step_hook = None
        self.breakpoints = []  #XXX
    def on_eval(self, val, env, cont):
        if self.step_hook is None:
            return val, env, cont
        else:
            return self.step_hook.on_eval(val, env, cont)
    def on_plug_reduce(self, val, cont):
        if self.step_hook is not None:
            self.step_hook.on_plug_reduce(val, cont)
    def on_abnormal_pass(self,
                         val_tree,
                         src_cont,
                         dst_cont,
                         exiting,
                         entering):
        if self.step_hook is not None:
            self.step_hook.on_abnormal_pass(val_tree,
                                            src_cont,
                                            dst_cont,
                                            exiting,
                                            entering)
    def on_error(self, e):
        print "Trying to evaluate %s" % e.val.tostring()
        if e.val.source_pos:
            e.val.source_pos.print_()
        while True:
            val, env, cont = debug_interaction(e.env, e.src_cont)
            if val is None:
                print "You must provide some value to the error continuation,"
                print "or ,q to exit."
            else:
                return val, env, cont

def guarded_ad_hoc_cont(cont):
    from parse import parse
    import primitive
    import kernel_type as kt
    s = primitive.standard_value
    env = primitive.standard_environment()
    env.set(kt.get_interned('cont'), primitive.AdHocCont(cont))
    return primitive.kernel_eval(
        kt.Pair(primitive.standard_value("$sequence"),
                parse("""(guard-continuation
                           ()
                           cont
                           (list (list error-continuation
                                       ($lambda (val divert)
                                         (println val)
                                         (apply divert #inert)))))""")),
        env)

def debug_interaction(env, cont):
    import kernel_type as kt
    import parse
    import primitive
    try:
        while True:
            os.write(1, "> ")
            cmd = readline()
            if cmd == "":
                if _state.latest_command is not None:
                    cmd = _state.latest_command
                else:
                    continue
            _state.latest_command = cmd
            if cmd.startswith(",c"):
                expr_src = cmd[2:].strip()
                if expr_src:
                    dbgexprs = parse.parse(expr_src)
                    assert isinstance(dbgexprs, kt.Pair)
                    assert kt.is_nil(kt.cdr(dbgexprs))
                    expr = kt.car(dbgexprs)
                    return expr, env, cont
                else:
                    stop_stepping()
                    break
            elif cmd == ",s":
                start_stepping()
                break
            elif cmd == ",n":
                _state.step_hook = ResumeContHook(cont)
                break
            elif cmd == ",r":
                prev = cont.prev
                while prev is not None and prev.source_pos is None:
                    prev = prev.prev
                if prev is None:
                    stop_stepping()
                else:
                    _state.step_hook = ResumeContHook(prev)
                break
            elif cmd == ",e":
                print_bindings(env, recursive=False)
            elif cmd == ",E":
                print_bindings(env, recursive=True)
            elif cmd == ",q":
                raise kt.KernelExit
            else:
                dbgexprs = parse.parse(cmd)
                assert isinstance(dbgexprs, kt.Pair)
                assert kt.is_nil(kt.cdr(dbgexprs))
                expr = kt.car(dbgexprs)
                old = _state.step_hook
                _state.step_hook = None
                try:
                    dbgval = primitive.kernel_eval(expr,
                                                   env,
                                                   guarded_ad_hoc_cont(cont))
                    print dbgval.tostring()
                finally:
                    _state.step_hook = old
    except EOFError:
        stop_stepping()
    return None, None, None

#XXX Adapted from Mariano Guerra's plang; research whether there's equivalent
#    functionality in rlib.
#    Also try and get libreadline-like goodies.
def readline():
    result = []
    while True:
        s = os.read(0, 1)
        if s == '\n':
            break
        if s == '':
            if len(result) > 0:
                break
            else:
                raise EOFError
        result.append(s)
    return "".join(result)

def print_bindings(env, recursive=False, indent=0):
    for k, v in env.bindings.iteritems():
        print "    " * indent, k, ":", v.tostring()
    if recursive:
        for parent in env.parents:
            print " ---"
            print_bindings(parent, True, indent+1)

def start_stepping():
    _state.step_hook = step_hook

def stop_stepping():
    _state.step_hook = None

_state = DebugState()
on_eval = _state.on_eval
on_plug_reduce = _state.on_plug_reduce
on_abnormal_pass = _state.on_abnormal_pass
on_error = _state.on_error

step_hook = StepHook()