Source

pypy / pypy / module / pypyjit / interp_resop.py

Maciej Fijalkows… 0277ce1 
Alex Gaynor 6354270 

Alex Gaynor add21ab 
Maciej Fijalkows… a0e46ec 
Maciej Fijalkows… 0277ce1 
Maciej Fijalkows… 0002a1e 
Maciej Fijalkows… 51d2eea 
Maciej Fijalkows… f59c4f5 
Maciej Fijalkows… 0277ce1 
Maciej Fijalkows… a469f09 
Maciej Fijalkows… e7ce390 
Maciej Fijalkows… 51d2eea 
Maciej Fijalkows… b6bb3e8 
Maciej Fijalkows… c31e329 
Maciej Fijalkows… 1ef43f6 
Maciej Fijalkows… 032bbe1 
Maciej Fijalkows… e7ce390 

Maciej Fijalkows… b6bb3e8 
Maciej Fijalkows… e7ce390 



Maciej Fijalkows… 6014710 
Maciej Fijalkows… e7ce390 
Maciej Fijalkows… b6bb3e8 



Maciej Fijalkows… aed03c7 
Maciej Fijalkows… b53f0ac 
Maciej Fijalkows… d5efe4c 
Maciej Fijalkows… aed03c7 

Maciej Fijalkows… e7ce390 





Maciej Fijalkows… 45d0a03 
Maciej Fijalkows… e7ce390 
Maciej Fijalkows… aed03c7 
Maciej Fijalkows… e7ce390 





Maciej Fijalkows… b6bb3e8 

Maciej Fijalkows… f09f03b 
Maciej Fijalkows… e7ce390 







Maciej Fijalkows… 5ed435c 
Alex Gaynor 66f1a9f 
Maciej Fijalkows… 5ed435c 

Stefano Rivera 188d16c 
Maciej Fijalkows… 5ed435c 
Alex Gaynor 73c0184 
Maciej Fijalkows… b6bb3e8 

Maciej Fijalkows… f09f03b 
Maciej Fijalkows… 5ed435c 





Maciej Fijalkows… e7ce390 







Maciej Fijalkows… 4e98c87 

Maciej Fijalkows… e7ce390 




Maciej Fijalkows… aed03c7 
Maciej Fijalkows… b3dd81a 
Maciej Fijalkows… 1ef43f6 
Maciej Fijalkows… b3dd81a 




Maciej Fijalkows… 1ef43f6 

Alex Gaynor 73c0184 
Maciej Fijalkows… 1ef43f6 
Alex Gaynor 6354270 
Maciej Fijalkows… 1ef43f6 


Alex Gaynor 3242596 
Alex Gaynor 73c0184 
Alex Gaynor 6354270 
Maciej Fijalkows… 1ef43f6 


Maciej Fijalkows… b3dd81a 
Maciej Fijalkows… 51d2eea 
Maciej Fijalkows… 4628182 




















Maciej Fijalkows… 51d2eea 
Maciej Fijalkows… f59c4f5 
Maciej Fijalkows… 80d78ac 
Maciej Fijalkows… 4628182 



Maciej Fijalkows… 51d2eea 
Maciej Fijalkows… 0277ce1 
Alex Gaynor 73c0184 



Maciej Fijalkows… 0513eb2 


Maciej Fijalkows… 1ef43f6 

Alex Gaynor 73c0184 
Maciej Fijalkows… 0513eb2 
Maciej Fijalkows… b7cde06 

Maciej Fijalkows… 0277ce1 
Maciej Fijalkows… d8f5fca 
Maciej Fijalkows… b7cde06 
Maciej Fijalkows… 4e8f6da 
Maciej Fijalkows… d8f5fca 
Maciej Fijalkows… 0277ce1 

Maciej Fijalkows… 0002a1e 
Maciej Fijalkows… 0277ce1 
Maciej Fijalkows… 967f730 
Maciej Fijalkows… f59c4f5 







Maciej Fijalkows… 967f730 
Maciej Fijalkows… 4628182 






Maciej Fijalkows… 22a0d8f 

Maciej Fijalkows… 4628182 

Maciej Fijalkows… 0513eb2 
Maciej Fijalkows… 2902abf 



Alex Gaynor 73c0184 


Maciej Fijalkows… 0513eb2 
Alex Gaynor 3242596 

Alex Gaynor 73c0184 
Alex Gaynor 6354270 
Maciej Fijalkows… 1ef43f6 


Alex Gaynor 6354270 
Alex Gaynor b906e11 
Maciej Fijalkows… 0513eb2 

Maciej Fijalkows… 1ef43f6 
Alex Gaynor 6354270 
Alex Gaynor b906e11 
Maciej Fijalkows… 1ef43f6 
Alex Gaynor b906e11 
Maciej Fijalkows… 1ef43f6 
Maciej Fijalkows… 0513eb2 
Maciej Fijalkows… b7cde06 


Maciej Fijalkows… 51d2eea 
Maciej Fijalkows… b7cde06 
Maciej Fijalkows… 967f730 
Maciej Fijalkows… f59c4f5 

Maciej Fijalkows… 4628182 


Maciej Fijalkows… 0277ce1 
Maciej Fijalkows… 0002a1e 
Maciej Fijalkows… 0513eb2 



Maciej Fijalkows… 2902abf 




Maciej Fijalkows… 1ef43f6 
Maciej Fijalkows… 2902abf 








Maciej Fijalkows… 0513eb2 


Maciej Fijalkows… 2902abf 



























Maciej Fijalkows… c31e329 
Maciej Fijalkows… 2902abf 



Alex Gaynor 6354270 
Maciej Fijalkows… 2902abf 








Maciej Fijalkows… cdd3773 




Maciej Fijalkows… 1674d1d 
Maciej Fijalkows… ba6d7e7 
Maciej Fijalkows… 61fa3ac 
Maciej Fijalkows… c31e329 
Maciej Fijalkows… cdd3773 

Maciej Fijalkows… 47b39a4 
Maciej Fijalkows… ba36854 
Maciej Fijalkows… c31e329 



Maciej Fijalkows… 8bd2c52 
Maciej Fijalkows… b51ca3c 
Maciej Fijalkows… 61fa3ac 
Maciej Fijalkows… c31e329 

Maciej Fijalkows… 2902abf 


Maciej Fijalkows… f02b48a 
Maciej Fijalkows… 2902abf 

Maciej Fijalkows… b6bb3e8 
Maciej Fijalkows… 2902abf 


Maciej Fijalkows… b6bb3e8 



Maciej Fijalkows… cdd3773 



Maciej Fijalkows… 2902abf 


Maciej Fijalkows… b6bb3e8 








Maciej Fijalkows… 208ef00 
Maciej Fijalkows… b6bb3e8 
Maciej Fijalkows… 208ef00 
Maciej Fijalkows… b6bb3e8 

Maciej Fijalkows… 208ef00 
Maciej Fijalkows… b6bb3e8 









Maciej Fijalkows… e7975b1 
Maciej Fijalkows… b6bb3e8 

Maciej Fijalkows… cdd3773 


Maciej Fijalkows… b6bb3e8 


Maciej Fijalkows… e7975b1 
Maciej Fijalkows… b6bb3e8 

Maciej Fijalkows… e7975b1 
Maciej Fijalkows… b6bb3e8 
Maciej Fijalkows… e7975b1 
Maciej Fijalkows… b6bb3e8 







Maciej Fijalkows… e7975b1 
Maciej Fijalkows… b6bb3e8 




Maciej Fijalkows… e7975b1 

from pypy.interpreter.typedef import (TypeDef, GetSetProperty,
     interp_attrproperty, interp_attrproperty_w)
from pypy.interpreter.baseobjspace import Wrappable
from pypy.interpreter.gateway import unwrap_spec, interp2app
from pypy.interpreter.pycode import PyCode
from pypy.interpreter.error import OperationError
from pypy.rpython.lltypesystem import lltype, llmemory
from pypy.rpython.annlowlevel import cast_base_ptr_to_instance, hlstr
from pypy.rpython.lltypesystem.rclass import OBJECT
from pypy.jit.metainterp.resoperation import rop, AbstractResOp
from pypy.rlib.nonconst import NonConstant
from pypy.rlib import jit_hooks
from pypy.rlib.jit import Counters
from pypy.rlib.rarithmetic import r_uint
from pypy.module.pypyjit.interp_jit import pypyjitdriver

class Cache(object):
    in_recursion = False
    no = 0

    def __init__(self, space):
        self.w_compile_hook = space.w_None
        self.w_abort_hook = space.w_None
        self.w_optimize_hook = space.w_None

    def getno(self):
        self.no += 1
        return self.no - 1

def wrap_greenkey(space, jitdriver, greenkey, greenkey_repr):
    if greenkey is None:
        return space.w_None
    jitdriver_name = jitdriver.name
    if jitdriver_name == 'pypyjit':
        next_instr = greenkey[0].getint()
        is_being_profiled = greenkey[1].getint()
        ll_code = lltype.cast_opaque_ptr(lltype.Ptr(OBJECT),
                                         greenkey[2].getref_base())
        pycode = cast_base_ptr_to_instance(PyCode, ll_code)
        return space.newtuple([space.wrap(pycode), space.wrap(next_instr),
                               space.newbool(bool(is_being_profiled))])
    else:
        return space.wrap(greenkey_repr)

def set_compile_hook(space, w_hook):
    """ set_compile_hook(hook)

    Set a compiling hook that will be called each time a loop is compiled.

    The hook will be called with the pypyjit.JitLoopInfo object. Refer to it's
    docstring for details.

    Note that jit hook is not reentrant. It means that if the code
    inside the jit hook is itself jitted, it will get compiled, but the
    jit hook won't be called for that.
    """
    cache = space.fromcache(Cache)
    cache.w_compile_hook = w_hook
    cache.in_recursion = NonConstant(False)

def set_optimize_hook(space, w_hook):
    """ set_optimize_hook(hook)

    Set a compiling hook that will be called each time a loop is optimized,
    but before assembler compilation. This allows adding additional
    optimizations on Python level.

    The hook will be called with the pypyjit.JitLoopInfo object. Refer to it's
    docstring for details.

    Result value will be the resulting list of operations, or None
    """
    cache = space.fromcache(Cache)
    cache.w_optimize_hook = w_hook
    cache.in_recursion = NonConstant(False)

def set_abort_hook(space, w_hook):
    """ set_abort_hook(hook)

    Set a hook (callable) that will be called each time there is tracing
    aborted due to some reason.

    The hook will be called as in: hook(jitdriver_name, greenkey, reason)

    Reason is a string, the meaning of other arguments is the same
    as attributes on JitLoopInfo object
    """
    cache = space.fromcache(Cache)
    cache.w_abort_hook = w_hook
    cache.in_recursion = NonConstant(False)

def wrap_oplist(space, logops, operations, ops_offset=None):
    l_w = []
    jitdrivers_sd = logops.metainterp_sd.jitdrivers_sd
    for op in operations:
        if ops_offset is None:
            ofs = -1
        else:
            ofs = ops_offset.get(op, 0)
        if op.opnum == rop.DEBUG_MERGE_POINT:
            jd_sd = jitdrivers_sd[op.getarg(0).getint()]
            greenkey = op.getarglist()[3:]
            repr = jd_sd.warmstate.get_location_str(greenkey)
            w_greenkey = wrap_greenkey(space, jd_sd.jitdriver, greenkey, repr)
            l_w.append(DebugMergePoint(space, jit_hooks._cast_to_gcref(op),
                                       logops.repr_of_resop(op),
                                       jd_sd.jitdriver.name,
                                       op.getarg(1).getint(),
                                       op.getarg(2).getint(),
                                       w_greenkey))
        else:
            l_w.append(WrappedOp(jit_hooks._cast_to_gcref(op), ofs,
                                 logops.repr_of_resop(op)))
    return l_w

class WrappedBox(Wrappable):
    """ A class representing a single box
    """
    def __init__(self, llbox):
        self.llbox = llbox

    def descr_getint(self, space):
        return space.wrap(jit_hooks.box_getint(self.llbox))

@unwrap_spec(no=int)
def descr_new_box(space, w_tp, no):
    return WrappedBox(jit_hooks.boxint_new(no))

WrappedBox.typedef = TypeDef(
    'Box',
    __new__ = interp2app(descr_new_box),
    getint = interp2app(WrappedBox.descr_getint),
)

@unwrap_spec(num=int, offset=int, repr=str, res=WrappedBox)
def descr_new_resop(space, w_tp, num, w_args, res, offset=-1,
                    repr=''):
    args = [space.interp_w(WrappedBox, w_arg).llbox for w_arg in
            space.listview(w_args)]
    if res is None:
        llres = jit_hooks.emptyval()
    else:
        llres = res.llbox
    return WrappedOp(jit_hooks.resop_new(num, args, llres), offset, repr)

@unwrap_spec(repr=str, jd_name=str, call_depth=int, call_id=int)
def descr_new_dmp(space, w_tp, w_args, repr, jd_name, call_depth, call_id,
    w_greenkey):

    args = [space.interp_w(WrappedBox, w_arg).llbox for w_arg in
            space.listview(w_args)]
    num = rop.DEBUG_MERGE_POINT
    return DebugMergePoint(space,
                           jit_hooks.resop_new(num, args, jit_hooks.emptyval()),
                           repr, jd_name, call_depth, call_id, w_greenkey)

class WrappedOp(Wrappable):
    """ A class representing a single ResOperation, wrapped nicely
    """
    def __init__(self, op, offset, repr_of_resop):
        self.op = op
        self.offset = offset
        self.repr_of_resop = repr_of_resop

    def descr_repr(self, space):
        return space.wrap(self.repr_of_resop)

    def descr_num(self, space):
        return space.wrap(jit_hooks.resop_getopnum(self.op))

    def descr_name(self, space):
        return space.wrap(hlstr(jit_hooks.resop_getopname(self.op)))

    @unwrap_spec(no=int)
    def descr_getarg(self, space, no):
        return WrappedBox(jit_hooks.resop_getarg(self.op, no))

    @unwrap_spec(no=int, box=WrappedBox)
    def descr_setarg(self, space, no, box):
        jit_hooks.resop_setarg(self.op, no, box.llbox)

    def descr_getresult(self, space):
        return WrappedBox(jit_hooks.resop_getresult(self.op))

    def descr_setresult(self, space, w_box):
        box = space.interp_w(WrappedBox, w_box)
        jit_hooks.resop_setresult(self.op, box.llbox)

class DebugMergePoint(WrappedOp):
    """ A class representing Debug Merge Point - the entry point
    to a jitted loop.
    """
    
    def __init__(self, space, op, repr_of_resop, jd_name, call_depth, call_id,
        w_greenkey):

        WrappedOp.__init__(self, op, -1, repr_of_resop)
        self.jd_name = jd_name
        self.call_depth = call_depth
        self.call_id = call_id
        self.w_greenkey = w_greenkey

    def get_pycode(self, space):
        if self.jd_name == pypyjitdriver.name:
            return space.getitem(self.w_greenkey, space.wrap(0))
        raise OperationError(space.w_AttributeError, space.wrap("This DebugMergePoint doesn't belong to the main Python JitDriver"))

    def get_bytecode_no(self, space):
        if self.jd_name == pypyjitdriver.name:
            return space.getitem(self.w_greenkey, space.wrap(1))
        raise OperationError(space.w_AttributeError, space.wrap("This DebugMergePoint doesn't belong to the main Python JitDriver"))

    def get_jitdriver_name(self, space):
        return space.wrap(self.jd_name)

WrappedOp.typedef = TypeDef(
    'ResOperation',
    __doc__ = WrappedOp.__doc__,
    __new__ = interp2app(descr_new_resop),
    __repr__ = interp2app(WrappedOp.descr_repr),
    num = GetSetProperty(WrappedOp.descr_num),
    name = GetSetProperty(WrappedOp.descr_name),
    getarg = interp2app(WrappedOp.descr_getarg),
    setarg = interp2app(WrappedOp.descr_setarg),
    result = GetSetProperty(WrappedOp.descr_getresult,
                            WrappedOp.descr_setresult)
)
WrappedOp.acceptable_as_base_class = False

DebugMergePoint.typedef = TypeDef(
    'DebugMergePoint', WrappedOp.typedef,
    __new__ = interp2app(descr_new_dmp),
    __doc__ = DebugMergePoint.__doc__,
    greenkey = interp_attrproperty_w("w_greenkey", cls=DebugMergePoint,
               doc="Representation of place where the loop was compiled. "
                    "In the case of the main interpreter loop, it's a triplet "
                    "(code, ofs, is_profiled)"),
    pycode = GetSetProperty(DebugMergePoint.get_pycode),
    bytecode_no = GetSetProperty(DebugMergePoint.get_bytecode_no,
                                 doc="offset in the bytecode"),
    call_depth = interp_attrproperty("call_depth", cls=DebugMergePoint,
                                     doc="Depth of calls within this loop"),
    call_id = interp_attrproperty("call_id", cls=DebugMergePoint,
                     doc="Number of applevel function traced in this loop"),
    jitdriver_name = GetSetProperty(DebugMergePoint.get_jitdriver_name,
                     doc="Name of the jitdriver 'pypyjit' in the case "
                                    "of the main interpreter loop"),
)
DebugMergePoint.acceptable_as_base_class = False

class W_JitLoopInfo(Wrappable):
    """ Loop debug information
    """
    
    w_green_key = None
    bridge_no   = 0
    asmaddr     = 0
    asmlen      = 0
    
    def __init__(self, space, debug_info, is_bridge=False):
        logops = debug_info.logger._make_log_operations()
        if debug_info.asminfo is not None:
            ofs = debug_info.asminfo.ops_offset
        else:
            ofs = {}
        self.w_ops = space.newlist(
            wrap_oplist(space, logops, debug_info.operations, ofs))
        
        self.jd_name = debug_info.get_jitdriver().name
        self.type = debug_info.type
        if is_bridge:
            self.bridge_no = debug_info.fail_descr_no
            self.w_green_key = space.w_None
        else:
            self.w_green_key = wrap_greenkey(space,
                                             debug_info.get_jitdriver(),
                                             debug_info.greenkey,
                                             debug_info.get_greenkey_repr())
        self.loop_no = debug_info.looptoken.number
        asminfo = debug_info.asminfo
        if asminfo is not None:
            self.asmaddr = asminfo.asmaddr
            self.asmlen = asminfo.asmlen

    def descr_repr(self, space):
        lgt = space.int_w(space.len(self.w_ops))
        if self.type == "bridge":
            code_repr = 'bridge no %d' % self.bridge_no
        else:
            code_repr = space.str_w(space.repr(self.w_green_key))
        return space.wrap('<JitLoopInfo %s, %d operations, starting at <%s>>' %
                          (self.jd_name, lgt, code_repr))

    def descr_get_bridge_no(self, space):
        if space.is_none(self.w_green_key):
            return space.wrap(self.bridge_no)
        raise OperationError(space.w_TypeError, space.wrap("not a bridge"))


@unwrap_spec(loopno=int, asmaddr=int, asmlen=int, loop_no=int,
             type=str, jd_name=str, bridge_no=int)
def descr_new_jit_loop_info(space, w_subtype, w_greenkey, w_ops, loopno,
                            asmaddr, asmlen, loop_no, type, jd_name,
                            bridge_no=-1):
    w_info = space.allocate_instance(W_JitLoopInfo, w_subtype)
    w_info.w_green_key = w_greenkey
    w_info.w_ops = w_ops
    w_info.asmaddr = asmaddr
    w_info.asmlen = asmlen
    w_info.loop_no = loop_no
    w_info.type = type
    w_info.jd_name = jd_name
    w_info.bridge_no = bridge_no
    return w_info

W_JitLoopInfo.typedef = TypeDef(
    'JitLoopInfo',
    __doc__ = W_JitLoopInfo.__doc__,
    __new__ = interp2app(descr_new_jit_loop_info),
    jitdriver_name = interp_attrproperty('jd_name', cls=W_JitLoopInfo,
                       doc="Name of the JitDriver, pypyjit for the main one"),
    greenkey = interp_attrproperty_w('w_green_key', cls=W_JitLoopInfo,
               doc="Representation of place where the loop was compiled. "
                    "In the case of the main interpreter loop, it's a triplet "
                    "(code, ofs, is_profiled)"),
    operations = interp_attrproperty_w('w_ops', cls=W_JitLoopInfo, doc=
                                       "List of operations in this loop."),
    loop_no = interp_attrproperty('loop_no', cls=W_JitLoopInfo, doc=
                                  "Loop cardinal number"),
    bridge_no = GetSetProperty(W_JitLoopInfo.descr_get_bridge_no,
                               doc="bridge number (if a bridge)"),
    type = interp_attrproperty('type', cls=W_JitLoopInfo,
                               doc="Loop type"),
    __repr__ = interp2app(W_JitLoopInfo.descr_repr),
)
W_JitLoopInfo.acceptable_as_base_class = False

class W_JitInfoSnapshot(Wrappable):
    def __init__(self, space, w_times, w_counters, w_counter_times):
        self.w_loop_run_times = w_times
        self.w_counters = w_counters
        self.w_counter_times = w_counter_times

W_JitInfoSnapshot.typedef = TypeDef(
    "JitInfoSnapshot",
    loop_run_times = interp_attrproperty_w("w_loop_run_times",
                                             cls=W_JitInfoSnapshot),
    counters = interp_attrproperty_w("w_counters",
                                       cls=W_JitInfoSnapshot,
                                       doc="various JIT counters"),
    counter_times = interp_attrproperty_w("w_counter_times",
                                            cls=W_JitInfoSnapshot,
                                            doc="various JIT timers")
)
W_JitInfoSnapshot.acceptable_as_base_class = False

def get_stats_snapshot(space):
    """ Get the jit status in the specific moment in time. Note that this
    is eager - the attribute access is not lazy, if you need new stats
    you need to call this function again.
    """
    ll_times = jit_hooks.stats_get_loop_run_times(None)
    w_times = space.newdict()
    for i in range(len(ll_times)):
        w_key = space.newtuple([space.wrap(ll_times[i].type),
                                space.wrap(ll_times[i].number)])
        space.setitem(w_times, w_key,
                      space.wrap(ll_times[i].counter))
    w_counters = space.newdict()
    for i, counter_name in enumerate(Counters.counter_names):
        v = jit_hooks.stats_get_counter_value(None, i)
        space.setitem_str(w_counters, counter_name, space.wrap(v))
    w_counter_times = space.newdict()
    tr_time = jit_hooks.stats_get_times_value(None, Counters.TRACING)
    space.setitem_str(w_counter_times, 'TRACING', space.wrap(tr_time))
    b_time = jit_hooks.stats_get_times_value(None, Counters.BACKEND)
    space.setitem_str(w_counter_times, 'BACKEND', space.wrap(b_time))
    return space.wrap(W_JitInfoSnapshot(space, w_times, w_counters,
                                        w_counter_times))

def enable_debug(space):
    """ Set the jit debugging - completely necessary for some stats to work,
    most notably assembler counters.
    """
    jit_hooks.stats_set_debug(None, True)

def disable_debug(space):
    """ Disable the jit debugging. This means some very small loops will be
    marginally faster and the counters will stop working.
    """
    jit_hooks.stats_set_debug(None, False)