Hc @ s d d d d d d d d d d d
d d d
d d d d d d d d d d d d d d d g Z d d k l Z l Z l Z l Z l Z l Z d d k l Z l
Z
l Z l Z l
Z
l Z l Z l Z d d k l Z d d! k Z d d! k Z d d! k Z d d! k Z y e Z e Z WnI e j
o= d d" k l Z d d# k l Z d$ e f d% YZ n Xy
e Z Wn e j
o d! d& Z n Xe Z e i i! Z" e d] d! d! d' Z# e d! d^ d_ d! d( Z$ d) Z% d* Z& d+ Z' e g e( d, Z) d- Z* d. Z+ d/ Z, d0 Z- d1 Z. d2 Z/ d e0 f d3 YZ1 e1 i2 d d4 Z3 d
e4 f d5 YZ5 d e5 f d6 YZ6 d e5 f d7 YZ7 d e0 f d8 YZ8 d9 Z9 d! d: Z: d e f d; YZ; d e0 f d< YZ< d= e< f d> YZ= d? Z> d@ Z? dA Z@ dB ZA dC ZB dD ZC dE ZD e3 eD e) eE e) eE f dF ZF d dG kG lH ZH lI ZI e3 eD eJ eJ f eK e3 eD eH eH f eK e3 eD eJ eH f eK e3 eD eJ e) f dH e3 eD e) e) f dI e3 eD e) eJ f dJ e3 eD eH eJ f dK ZL e; eD iM iN e3 eB e1 e1 f dL ZO d e1 f dM YZP eP i2 d ZQ e. eP e1 d e1 f dN YZR e/ eR e: dO ZS eQ eS e0 e0 f dP ZT e3 eD eU eU f dQ e3 eD eU e0 f dR e3 eD e0 eU f dS d eR f dT YZV eV i2 d ZW e/ eV d eR f dU YZX eX i2 d ZY e/ eX e. eP eV e. eV eX e. eX e1 e/ e5 e3 eB e1 e6 f e, e3 eB e6 e1 f e- e; eB iM iN e3 eB e7 e1 f dV ZZ e3 eB e1 e7 f dW Z[ e/ e7 e3 e& e= e\ f dX Z] e3 e9 eJ eX i dY e: dZ Z^ e3 e^ eU f e i_ e3 e^ e) f d[ d\ Z` d! S(` t Rulet RuleSett Dispatchingt Enginet rules_fort Methodt Aroundt Beforet Aftert
MethodListt
DispatchErrort AmbiguousMethodst NoApplicableMethodst abstractt whent beforet aftert aroundt istypet
parse_rulet impliest dominant_signaturest combine_actionst overridest always_overridest merge_by_defaultt intersectt disjunctst negatei( t decorate_assignmentt decoratet structt synchronizedt frameinfot decorate_class( t Codet Constt Callt Localt Getattrt TryExceptt Suitet with_name( t AddOnN( t Set( t ImmutableSett frozensetc B s& e Z d Z d d Z d d Z RS( s; Kludge to fix the abomination that is ImmutableSet.__init__c C s& t i | | } t i | | | S( N( R- t __new__t __init__( t clst iterablet self( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR/ s c C s d S( N( ( R3 R2 ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR0 s N( t __name__t
__module__t __doc__t NoneR/ R0 ( ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR. s c C s} | o1 g } | D] } | | | | f q ~ } n
t | } | i | o$ g } | D] } | | d q` ~ S| S( Ni ( t listt sort( t seqt keyt _[1]t vt dt _[2]( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt sorted s 1
$c C s* | d j o
t } n | | | | f S( N( R7 t
next_sequence( t bodyt predicatet
actiontypet sequence( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR - s
c C s9 | d j o
t } n | | t | t | | f S( s, Hold information needed to parse a predicateN( R7 RA t dict( RB RD t localdictt
globaldictRE ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt ParseContext3 s
c C s | t j o g S| g S( s3 Return a *list* of the logical disjunctions of `ob`( t False( t ob( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR ; s
c C sM | d j o$ t | t j o | f | } n t | i | | i | i S( sC Hook for pre-processing predicates, e.g. parsing string expressionsN( R7 t typet tupleR RB RD RE ( t engineRC t contextR1 ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR A s c C s( t i | i | i | i | i | i S( N( t newt functiont func_codet func_globalst func_namet
func_defaultst func_closure( t f( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt clone_functionG s c C s
| | f S( N( ( RL t match( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR T s c C sD t | t t f o | St | t j o | i o | i Sd S( N( t
isinstanceRL t ClassTypeR RY ( t arg( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt type_keyW s c c sG t | t j o d St t t | } d | j o | Vn d S( N( RL RM t mapR] R7 ( t sigR; ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt type_keys] s
c C s t S( N( t True( t s1t s2( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt YESd s c C s t S( N( RJ ( Rb Rc ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt NOe s c C s[ t | t | } } t t | | f t t t | | f t h } g } x t t D] } | i } t | t j p# t | d j p | i
t j o qd n d | | <| d | j o | i | | d f n | d | j o | i | d | f qd qd Wx> | D]6 \ } } | | f | j o t | i | i q q Wd S( sE `a` instances always override `b`s; `b` instances never override `a`si i i N(
R R R Rd Re R RC RL RM t lenRB t appendR ( t at bt pairst to_addt ruleR_ t p1t p2( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR g s&
6
c C s t t | | f t d S( s3 instances of `t` never imply other instances of `t`N( R R Re ( t t( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR x s c B s| e Z d Z d
d d d Z e e d d d Z d Z d Z d Z
d Z d Z e e d d Z
RS(
s# A simple method w/optional chainingi c C s | | _ | | _ | | _ | | _ t | _ y t i | d } Wn t j
o nD X| o; | d d j o* t | d d d j o
t | _ q n d S( Ni t next_methodt im_self( RB t signaturet
precedencet tailRJ t can_tailt inspectt
getargspect TypeErrort getattrR7 Ra ( R3 RB Rr Rs Rt t args( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR0 s c C s | | | | S( N( ( R1 RB Rr Rs ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt make s c C s2 | i | i | i | i f } | i i t | S( N( RB Rr Rs Rt t __class__R4 t repr( R3 t data( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt __repr__ s c O s1 | i o | i | i | | S| i | | S( N( Ru RB Rt ( R3 Rz t kw( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt __call__ s
c C s( | i p | S| i t | i | S( N( Ru t tail_withR Rt ( R3 t other( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt override s
c C s | i | i | i | i | S( N( R| RB Rr Rs ( R3 Rt ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s c C s t | | g S( N( R ( R3 R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt merge s c sr | d j o d | i } n | t j o
d n
| i d d d f d } t | | } | | _ | S( Ns6 Extend a generic function with a method of type ``%s``i c s% f d } t | | | S( Nc s t t i t | \ } } } } t | | | f d } | d j o t | d | n | d | i | f j o S| S( Nc s i t | | S( N( t addR ( R1 ( RN t rulest predRO ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt register_for_class s t classt frame( R R RN R! RI R" R7 t get( R t namet funct
old_localst kindt modulet locals_t globals_R ( RW R t maker( RN RO R s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt callback s
( R ( RW R t depthR R ( R ( RW R s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s ( ( R7 R4 R R{ R* R6 ( R1 R t docR ( ( R s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt make_decorator s
( N( ( R4 R5 R6 R7 R0 R t classmethodR{ R R R R R R ( ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR | s
s+ Extend a generic function with a new actionc B s e Z d Z d Z d Z RS( s A dispatch error has occurredc O s | i | i | | f d S( N( R| Rz ( R3 Rz R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s c C s | i i t | i S( N( R| R4 R} Rz ( R3 ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s ( R4 R5 R6 R R ( ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR
s c B s e Z d Z d Z RS( s= No applicable action has been defined for the given argumentsc C s t | | g S( N( R ( R3 R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s ( R4 R5 R6 R ( ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s c B s2 e Z d Z d Z d Z d Z d Z RS( s* More than one choice of action is possiblec G sf t i | | | g } | _ x? | D]7 } t | t o | i | i q' | i | q' Wd S( N( R
R0 t methodsRZ R t extendRg ( R3 R Rz t minet m( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR0 s
c C s t | i | g S( N( R R ( R3 R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s c C s | S( N( ( R3 R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s c C s d | i S( Ns AmbiguousMethods(%s)( R ( R3 ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s ( R4 R5 R6 R0 R R R ( ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s
c B s e Z d Z e Z e Z d Z d d Z e
d Z e
d Z e
d Z
e e d Z e
d Z d Z e
d Z e
d
Z RS( s1 An observable, stably-ordered collection of rulesi c C s9 g | _ h | _ g | _ | d j o
| | _ n d S( N( R t
actiondefst listenersR7 t __lock__( R3 t lock( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR0 s
c C sF t | i | } | i i | | | i | <| i d | d S( Nt added( R. t _actions_forR Rg R t _notify( R3 Rl R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s
c C s6 | i i | } | i i | | i d | d S( Nt removed( R t popR t removeR ( R3 Rl R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s c C s4 t | } | i 2| i i | i d | d S( NR ( R. R R t clearR ( R3 R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s
c C s) x" | i D] } | i | | q Wd S( N( R t actions_changed( R3 R R t listener( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s c C sB | i } t g } | i D] } | | D]
} | | q( q ~ S( N( R t iterR ( R3 t adR< Rl Rh ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt __iter__! s c c sT | \ } } } } } | p | i } x( t | D] } t | | | | Vq2 Wd S( N( t default_actiontypeR R ( R3 t .1t naRB RC RD R: Rr ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR % s
c C s8 | i i | | i o | i t | t n d S( N( R Rg R R R. t empty( R3 R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt subscribe+ s
c C s | i i | d S( N( R R ( R3 R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt unsubscribe1 s N( R4 R5 R6 R t default_actionR R t counterR7 R0 R R R R R R R R R R ( ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s&
c C sI t i | p, t | } | i i t t | n t | i S( s5 Return the initialized ruleset for a generic function( R t
exists_forR R R RX ( RW R> ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR 5 s c C s/ | d j o t d St | i Sd S( s! Declare a function to be abstractc S s t | i S( ( R t as_abstract( RW t nR t old( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt @ s N( R7 R R R ( R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR
< s
c B so e Z d Z d Z d Z e d Z d Z e d Z d Z
e d Z e d Z RS( s5 Hold the dispatching attributes of a generic functionc C sG | | _ | i | _ t | i | _ d | _ | i t d S( N(
RQ t _regen_codet _regenR t get_lockR R7 t backupt
create_enginet
TypeEngine( R3 R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR0 L s
c C s | i S( N( R ( R3 ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR T s c C sS | i d j o- | i | i i j o | i i | i n | | | _ | i S( s7 Create a new engine of `engine_type`, unsubscribing oldN( RN R7 R R R ( R3 t engine_type( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR W s &c C s6 | i d j o" | i i | _ | i | i _ n d S( s< Ensure code regeneration occurs on next call of the functionN( R R7 RQ RR R ( R3 ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyt request_regeneration_ s c
C sk t i | i d t } | i t | i t t t t t t | i f d t
d | i S( Nt copy_linenot foldt _regenerate( R# t
from_functionRQ Ra t return_t call_thruR% R' R$ R RJ t code( R3 t c( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR e s $c C s x | i D] } t d q
Wt i | i d t } | i t | i t | i i | i
d j o | i | i _
n | i | _
| i S( Ns( Can't make abstract: rules already existR ( R t AssertionErrorR# R RQ Ra R R R$ R R R7 R RR ( R3 t actionR ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s s
%c C sU | i } | i | _ y | i i | _ Wn | i | _ n Xd | _ | Sd S( N( RQ R RR RN t _generate_codeR R7 ( R3 R ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s N(
R4 R5 R6 R7 RN R0 R R R R R R R ( ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR I s
c B sZ e Z d Z e Z d Z e d Z d Z d Z d Z
d Z d Z RS( s% Abstract base for dispatching enginesc C sr | i | _ h | _ | i | _ | i | _ t t t d t i
| i d | _ | i i | d S( Ni (
RQ t registryR R R R8 t flattent filterR7 Rv Rw t argnamesR ( R3 t disp( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR0 s +c C s | o | i o | i Sx! | D] } | i | i | q# Wx! | D] } | i | i | qG W| p | o | i n d S( N( t reset_on_removet _full_resett _remove_methodRC t _add_methodt _changed( R3 R R Rl ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s c C s t | i i d S( s% Some change to the rules has occurredN( R RQ R ( R3 ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s c C s7 | i i | i | i d t | i i d S( s* Regenerate any code, caches, indexes, etc.N( ( R R R R R RQ R ( R3 ( ( s3 /usr/lib/python2.6/site-packages/peak/rules/core.pyR s
c C sZ | i } | i | i | | i } | | j o t | | | | | | i i D]- \ } } x t | D] } | | | } | | j o+ t | | o t | | | | | s .:0
R
>
RR?
;