| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231 |
- """Undocumented Module"""
- __all__ = ['enumerate', 'unique', 'indent', 'nonRepeatingRandomList',
- 'writeFsmTree', 'StackTrace', 'traceFunctionCall', 'traceParentCall',
- 'printThisCall', 'tron', 'trace', 'troff', 'getClassLineage', 'pdir',
- '_pdir', '_is_variadic', '_has_keywordargs', '_varnames', '_getcode',
- 'Signature', 'doc', 'adjust', 'difference', 'intersection', 'union',
- 'sameElements', 'makeList', 'makeTuple', 'list2dict', 'invertDict',
- 'invertDictLossless', 'uniqueElements', 'disjoint', 'contains',
- 'replace', 'reduceAngle', 'fitSrcAngle2Dest', 'fitDestAngle2Src',
- 'closestDestAngle2', 'closestDestAngle', 'binaryRepr', 'profile',
- 'profiled', 'startProfile', 'printProfile', 'getSetterName',
- 'getSetter', 'Functor', 'Stack', 'Queue', 'ParamObj',
- 'POD', 'bound', 'lerp', 'average', 'addListsByValue',
- 'boolEqual', 'lineupPos', 'formatElapsedSeconds', 'solveQuadratic',
- 'stackEntryInfo', 'lineInfo', 'callerInfo', 'lineTag',
- 'findPythonModule', 'describeException', 'mostDerivedLast',
- 'clampScalar', 'weightedChoice', 'randFloat', 'normalDistrib',
- 'weightedRand', 'randUint31', 'randInt32', 'randUint32',
- 'SerialNumGen', 'serialNum', 'uniqueName', 'Enum', 'Singleton',
- 'SingletonError', 'printListEnum', 'gcDebugOn', 'safeRepr',
- 'fastRepr', 'tagRepr', 'tagWithCaller', 'isDefaultValue', 'set_trace', 'pm',
- 'ScratchPad', 'Sync', 'RefCounter', 'itype', 'getNumberedTypedString',
- 'getNumberedTypedSortedString', 'getNumberedTypedSortedStringWithReferrers',
- 'getNumberedTypedSortedStringWithReferrersGen',
- 'printNumberedTyped', 'DelayedCall', 'DelayedFunctor',
- 'FrameDelayedCall', 'SubframeCall', 'ArgumentEater', 'ClassTree', 'getBase',
- 'superFlattenShip','HotkeyBreaker','logMethodCalls','GoldenRatio',
- 'GoldenRectangle', 'pivotScalar', 'rad90', 'rad180', 'rad270', 'rad360',
- 'nullGen', 'loopGen', 'makeFlywheelGen', 'flywheel', 'choice', ]
- import types
- import string
- import re
- import math
- import operator
- import inspect
- import os
- import sys
- import random
- import time
- import new
- import gc
- #if __debug__:
- import traceback
- from direct.directutil import Verify
- # Don't import libpandaexpressModules, which doesn't get built until
- # genPyCode.
- from libpandaexpress import ConfigVariableBool
- ScalarTypes = (types.FloatType, types.IntType, types.LongType)
- def enumerate(L):
- """Returns (0, L[0]), (1, L[1]), etc., allowing this syntax:
- for i, item in enumerate(L):
- ...
- enumerate is a built-in feature in Python 2.3, which implements it
- using an iterator. For now, we can use this quick & dirty
- implementation that returns a list of tuples that is completely
- constructed every time enumerate() is called.
- """
- return zip(xrange(len(L)), L)
- import __builtin__
- if not hasattr(__builtin__, 'enumerate'):
- __builtin__.enumerate = enumerate
- def unique(L1, L2):
- """Return a list containing all items in 'L1' that are not in 'L2'"""
- L2 = dict([(k, None) for k in L2])
- return [item for item in L1 if item not in L2]
- def indent(stream, numIndents, str):
- """
- Write str to stream with numIndents in front of it
- """
- # To match emacs, instead of a tab character we will use 4 spaces
- stream.write(' ' * numIndents + str)
- def nonRepeatingRandomList(vals, max):
- random.seed(time.time())
- #first generate a set of random values
- valueList=range(max)
- finalVals=[]
- for i in range(vals):
- index=int(random.random()*len(valueList))
- finalVals.append(valueList[index])
- valueList.remove(valueList[index])
- return finalVals
- def writeFsmTree(instance, indent = 0):
- if hasattr(instance, 'parentFSM'):
- writeFsmTree(instance.parentFSM, indent-2)
- elif hasattr(instance, 'fsm'):
- name = ''
- if hasattr(instance.fsm, 'state'):
- name = instance.fsm.state.name
- print "%s: %s"%(instance.fsm.name, name)
- #if __debug__: #RAU accdg to Darren its's ok that StackTrace is not protected by __debug__
- # DCR: if somebody ends up using StackTrace in production, either
- # A) it will be OK because it hardly ever gets called, or
- # B) it will be easy to track it down (grep for StackTrace)
- class StackTrace:
- def __init__(self, label="", start=0, limit=None):
- """
- label is a string (or anything that be be a string)
- that is printed as part of the trace back.
- This is just to make it easier to tell what the
- stack trace is referring to.
- start is an integer number of stack frames back
- from the most recent. (This is automatically
- bumped up by one to skip the __init__ call
- to the StackTrace).
- limit is an integer number of stack frames
- to record (or None for unlimited).
- """
- self.label = label
- if limit is not None:
- self.trace = traceback.extract_stack(sys._getframe(1+start),
- limit=limit)
- else:
- self.trace = traceback.extract_stack(sys._getframe(1+start))
-
- def compact(self):
- r = ''
- comma = ','
- for filename, lineNum, funcName, text in self.trace:
- r += '%s.%s:%s%s' % (filename[:filename.rfind('.py')][filename.rfind('\\')+1:], funcName, lineNum, comma)
- if len(r):
- r = r[:-len(comma)]
- return r
- def __str__(self):
- r = "Debug stack trace of %s (back %s frames):\n"%(
- self.label, len(self.trace),)
- for i in traceback.format_list(self.trace):
- r+=i
- r+="***** NOTE: This is not a crash. This is a debug stack trace. *****"
- return r
- def printStack():
- print StackTrace(start=1).compact()
- return True
- def printVerboseStack():
- print StackTrace(start=1)
- return True
- #-----------------------------------------------------------------------------
- def traceFunctionCall(frame):
- """
- return a string that shows the call frame with calling arguments.
- e.g.
- foo(x=234, y=135)
- """
- f = frame
- co = f.f_code
- dict = f.f_locals
- n = co.co_argcount
- if co.co_flags & 4: n = n+1
- if co.co_flags & 8: n = n+1
- r=''
- if dict.has_key('self'):
- r = '%s.'%(dict['self'].__class__.__name__,)
- r+="%s("%(f.f_code.co_name,)
- comma=0 # formatting, whether we should type a comma.
- for i in range(n):
- name = co.co_varnames[i]
- if name=='self':
- continue
- if comma:
- r+=', '
- else:
- # ok, we skipped the first one, the rest get commas:
- comma=1
- r+=name
- r+='='
- if dict.has_key(name):
- v=str(dict[name])
- if len(v)>2000:
- # r+="<too big for debug>"
- r += (str(dict[name])[:2000] + "...")
- else:
- r+=str(dict[name])
- else: r+="*** undefined ***"
- return r+')'
- def traceParentCall():
- return traceFunctionCall(sys._getframe(2))
- def printThisCall():
- print traceFunctionCall(sys._getframe(1))
- return 1 # to allow "assert printThisCall()"
- if __debug__:
- def lineage(obj, verbose=0, indent=0):
- """
- return instance or class name in as a multiline string.
- Usage: print lineage(foo)
- (Based on getClassLineage())
- """
- r=""
- if type(obj) == types.ListType:
- r+=(" "*indent)+"python list\n"
- elif type(obj) == types.DictionaryType:
- r+=(" "*indent)+"python dictionary\n"
- elif type(obj) == types.ModuleType:
- r+=(" "*indent)+str(obj)+"\n"
- elif type(obj) == types.InstanceType:
- r+=lineage(obj.__class__, verbose, indent)
- elif type(obj) == types.ClassType:
- r+=(" "*indent)
- if verbose:
- r+=obj.__module__+"."
- r+=obj.__name__+"\n"
- for c in obj.__bases__:
- r+=lineage(c, verbose, indent+2)
- return r
- def tron():
- sys.settrace(trace)
- def trace(frame, event, arg):
- if event == 'line':
- pass
- elif event == 'call':
- print traceFunctionCall(sys._getframe(1))
- elif event == 'return':
- print "returning"
- elif event == 'exception':
- print "exception"
- return trace
- def troff():
- sys.settrace(None)
- #-----------------------------------------------------------------------------
- def getClassLineage(obj):
- """
- print object inheritance list
- """
- if type(obj) == types.DictionaryType:
- # Just a dictionary, return dictionary
- return [obj]
- elif (type(obj) == types.InstanceType):
- # Instance, make a list with the instance and its class interitance
- return [obj] + getClassLineage(obj.__class__)
- elif ((type(obj) == types.ClassType) or
- (type(obj) == types.TypeType)):
- # Class or type, see what it derives from
- lineage = [obj]
- for c in obj.__bases__:
- lineage = lineage + getClassLineage(c)
- return lineage
- # New FFI objects are types that are not defined.
- # but they still act like classes
- elif hasattr(obj, '__class__'):
- # Instance, make a list with the instance and its class interitance
- return [obj] + getClassLineage(obj.__class__)
- else:
- # Not what I'm looking for
- return []
- def pdir(obj, str = None, width = None,
- fTruncate = 1, lineWidth = 75, wantPrivate = 0):
- # Remove redundant class entries
- uniqueLineage = []
- for l in getClassLineage(obj):
- if type(l) == types.ClassType:
- if l in uniqueLineage:
- break
- uniqueLineage.append(l)
- # Pretty print out directory info
- uniqueLineage.reverse()
- for obj in uniqueLineage:
- _pdir(obj, str, width, fTruncate, lineWidth, wantPrivate)
- print
- def _pdir(obj, str = None, width = None,
- fTruncate = 1, lineWidth = 75, wantPrivate = 0):
- """
- Print out a formatted list of members and methods of an instance or class
- """
- def printHeader(name):
- name = ' ' + name + ' '
- length = len(name)
- if length < 70:
- padBefore = int((70 - length)/2.0)
- padAfter = max(0, 70 - length - padBefore)
- header = '*' * padBefore + name + '*' * padAfter
- print header
- print
- def printInstanceHeader(i, printHeader = printHeader):
- printHeader(i.__class__.__name__ + ' INSTANCE INFO')
- def printClassHeader(c, printHeader = printHeader):
- printHeader(c.__name__ + ' CLASS INFO')
- def printDictionaryHeader(d, printHeader = printHeader):
- printHeader('DICTIONARY INFO')
- # Print Header
- if type(obj) == types.InstanceType:
- printInstanceHeader(obj)
- elif type(obj) == types.ClassType:
- printClassHeader(obj)
- elif type (obj) == types.DictionaryType:
- printDictionaryHeader(obj)
- # Get dict
- if type(obj) == types.DictionaryType:
- dict = obj
- # FFI objects are builtin types, they have no __dict__
- elif not hasattr(obj, '__dict__'):
- dict = {}
- else:
- dict = obj.__dict__
- # Adjust width
- if width:
- maxWidth = width
- else:
- maxWidth = 10
- keyWidth = 0
- aproposKeys = []
- privateKeys = []
- remainingKeys = []
- for key in dict.keys():
- if not width:
- keyWidth = len(key)
- if str:
- if re.search(str, key, re.I):
- aproposKeys.append(key)
- if (not width) and (keyWidth > maxWidth):
- maxWidth = keyWidth
- else:
- if key[:1] == '_':
- if wantPrivate:
- privateKeys.append(key)
- if (not width) and (keyWidth > maxWidth):
- maxWidth = keyWidth
- else:
- remainingKeys.append(key)
- if (not width) and (keyWidth > maxWidth):
- maxWidth = keyWidth
- # Sort appropriate keys
- if str:
- aproposKeys.sort()
- else:
- privateKeys.sort()
- remainingKeys.sort()
- # Print out results
- if wantPrivate:
- keys = aproposKeys + privateKeys + remainingKeys
- else:
- keys = aproposKeys + remainingKeys
- format = '%-' + `maxWidth` + 's'
- for key in keys:
- value = dict[key]
- if callable(value):
- strvalue = `Signature(value)`
- else:
- strvalue = `value`
- if fTruncate:
- # Cut off line (keeping at least 1 char)
- strvalue = strvalue[:max(1, lineWidth - maxWidth)]
- print (format % key)[:maxWidth] + '\t' + strvalue
- # Magic numbers: These are the bit masks in func_code.co_flags that
- # reveal whether or not the function has a *arg or **kw argument.
- _POS_LIST = 4
- _KEY_DICT = 8
- def _is_variadic(function):
- return function.func_code.co_flags & _POS_LIST
- def _has_keywordargs(function):
- return function.func_code.co_flags & _KEY_DICT
- def _varnames(function):
- return function.func_code.co_varnames
- def _getcode(f):
- """
- _getcode(f)
- This function returns the name and function object of a callable
- object.
- """
- def method_get(f):
- return f.__name__, f.im_func
- def function_get(f):
- return f.__name__, f
- def instance_get(f):
- if hasattr(f, '__call__'):
- method = f.__call__
- if (type(method) == types.MethodType):
- func = method.im_func
- else:
- func = method
- return ("%s%s" % (f.__class__.__name__, '__call__'), func)
- else:
- s = ("Instance %s of class %s does not have a __call__ method" %
- (f, f.__class__.__name__))
- raise TypeError, s
- def class_get(f):
- if hasattr(f, '__init__'):
- return f.__name__, f.__init__.im_func
- else:
- return f.__name__, lambda: None
- codedict = { types.UnboundMethodType: method_get,
- types.MethodType: method_get,
- types.FunctionType: function_get,
- types.InstanceType: instance_get,
- types.ClassType: class_get,
- }
- try:
- return codedict[type(f)](f)
- except KeyError:
- if callable(f): # eg, built-in functions and methods
- # raise ValueError, "type %s not supported yet." % type(f)
- return f.__name__, None
- else:
- raise TypeError, ("object %s of type %s is not callable." %
- (f, type(f)))
- class Signature:
- def __init__(self, func):
- self.type = type(func)
- self.name, self.func = _getcode(func)
- def ordinary_args(self):
- n = self.func.func_code.co_argcount
- return _varnames(self.func)[0:n]
- def special_args(self):
- n = self.func.func_code.co_argcount
- x = {}
- #
- if _is_variadic(self.func):
- x['positional'] = _varnames(self.func)[n]
- if _has_keywordargs(self.func):
- x['keyword'] = _varnames(self.func)[n+1]
- elif _has_keywordargs(self.func):
- x['keyword'] = _varnames(self.func)[n]
- else:
- pass
- return x
- def full_arglist(self):
- base = list(self.ordinary_args())
- x = self.special_args()
- if x.has_key('positional'):
- base.append(x['positional'])
- if x.has_key('keyword'):
- base.append(x['keyword'])
- return base
- def defaults(self):
- defargs = self.func.func_defaults
- args = self.ordinary_args()
- mapping = {}
- if defargs is not None:
- for i in range(-1, -(len(defargs)+1), -1):
- mapping[args[i]] = defargs[i]
- else:
- pass
- return mapping
- def __repr__(self):
- if self.func:
- defaults = self.defaults()
- specials = self.special_args()
- l = []
- for arg in self.ordinary_args():
- if defaults.has_key(arg):
- l.append(arg + '=' + str(defaults[arg]))
- else:
- l.append(arg)
- if specials.has_key('positional'):
- l.append('*' + specials['positional'])
- if specials.has_key('keyword'):
- l.append('**' + specials['keyword'])
- return "%s(%s)" % (self.name, string.join(l, ', '))
- else:
- return "%s(?)" % self.name
- def doc(obj):
- if (isinstance(obj, types.MethodType)) or \
- (isinstance(obj, types.FunctionType)):
- print obj.__doc__
- def adjust(command = None, dim = 1, parent = None, **kw):
- """
- adjust(command = None, parent = None, **kw)
- Popup and entry scale to adjust a parameter
- Accepts any Slider keyword argument. Typical arguments include:
- command: The one argument command to execute
- min: The min value of the slider
- max: The max value of the slider
- resolution: The resolution of the slider
- text: The label on the slider
- These values can be accessed and/or changed after the fact
- >>> vg = adjust()
- >>> vg['min']
- 0.0
- >>> vg['min'] = 10.0
- >>> vg['min']
- 10.0
- """
- # Make sure we enable Tk
- from direct.tkwidgets import Valuator
- # Set command if specified
- if command:
- kw['command'] = lambda x: apply(command, x)
- if parent is None:
- kw['title'] = command.__name__
- kw['dim'] = dim
- # Create toplevel if needed
- if not parent:
- vg = apply(Valuator.ValuatorGroupPanel, (parent,), kw)
- else:
- vg = apply(Valuator.ValuatorGroup, (parent,), kw)
- vg.pack(expand = 1, fill = 'x')
- return vg
- def difference(a, b):
- """
- difference(list, list):
- """
- if not a: return b
- if not b: return a
- d = []
- for i in a:
- if (i not in b) and (i not in d):
- d.append(i)
- for i in b:
- if (i not in a) and (i not in d):
- d.append(i)
- return d
- def intersection(a, b):
- """
- intersection(list, list):
- """
- if not a: return []
- if not b: return []
- d = []
- for i in a:
- if (i in b) and (i not in d):
- d.append(i)
- for i in b:
- if (i in a) and (i not in d):
- d.append(i)
- return d
- def union(a, b):
- """
- union(list, list):
- """
- # Copy a
- c = a[:]
- for i in b:
- if (i not in c):
- c.append(i)
- return c
- def sameElements(a, b):
- if len(a) != len(b):
- return 0
- for elem in a:
- if elem not in b:
- return 0
- for elem in b:
- if elem not in a:
- return 0
- return 1
- def makeList(x):
- """returns x, converted to a list"""
- if type(x) is types.ListType:
- return x
- elif type(x) is types.TupleType:
- return list(x)
- else:
- return [x,]
- def makeTuple(x):
- """returns x, converted to a tuple"""
- if type(x) is types.ListType:
- return tuple(x)
- elif type(x) is types.TupleType:
- return x
- else:
- return (x,)
- def list2dict(L, value=None):
- """creates dict using elements of list, all assigned to same value"""
- return dict([(k, value) for k in L])
- def invertDict(D, lossy=False):
- """creates a dictionary by 'inverting' D; keys are placed in the new
- dictionary under their corresponding value in the old dictionary.
- It is an error if D contains any duplicate values.
- >>> old = {'key1':1, 'key2':2}
- >>> invertDict(old)
- {1: 'key1', 2: 'key2'}
- """
- n = {}
- for key, value in D.items():
- if not lossy and value in n:
- raise 'duplicate key in invertDict: %s' % value
- n[value] = key
- return n
- def invertDictLossless(D):
- """similar to invertDict, but values of new dict are lists of keys from
- old dict. No information is lost.
- >>> old = {'key1':1, 'key2':2, 'keyA':2}
- >>> invertDictLossless(old)
- {1: ['key1'], 2: ['key2', 'keyA']}
- """
- n = {}
- for key, value in D.items():
- n.setdefault(value, [])
- n[value].append(key)
- return n
- def uniqueElements(L):
- """are all elements of list unique?"""
- return len(L) == len(list2dict(L))
- def disjoint(L1, L2):
- """returns non-zero if L1 and L2 have no common elements"""
- used = dict([(k, None) for k in L1])
- for k in L2:
- if k in used:
- return 0
- return 1
- def contains(whole, sub):
- """
- Return 1 if whole contains sub, 0 otherwise
- """
- if (whole == sub):
- return 1
- for elem in sub:
- # The first item you find not in whole, return 0
- if elem not in whole:
- return 0
- # If you got here, whole must contain sub
- return 1
- def replace(list, old, new, all=0):
- """
- replace 'old' with 'new' in 'list'
- if all == 0, replace first occurrence
- otherwise replace all occurrences
- returns the number of items replaced
- """
- if old not in list:
- return 0
- if not all:
- i = list.index(old)
- list[i] = new
- return 1
- else:
- numReplaced = 0
- for i in xrange(len(list)):
- if list[i] == old:
- numReplaced += 1
- list[i] = new
- return numReplaced
- rad90 = math.pi / 2.
- rad180 = math.pi
- rad270 = 1.5 * math.pi
- rad360 = 2. * math.pi
- def reduceAngle(deg):
- """
- Reduces an angle (in degrees) to a value in [-180..180)
- """
- return (((deg + 180.) % 360.) - 180.)
- def fitSrcAngle2Dest(src, dest):
- """
- given a src and destination angle, returns an equivalent src angle
- that is within [-180..180) of dest
- examples:
- fitSrcAngle2Dest(30, 60) == 30
- fitSrcAngle2Dest(60, 30) == 60
- fitSrcAngle2Dest(0, 180) == 0
- fitSrcAngle2Dest(-1, 180) == 359
- fitSrcAngle2Dest(-180, 180) == 180
- """
- return dest + reduceAngle(src - dest)
- def fitDestAngle2Src(src, dest):
- """
- given a src and destination angle, returns an equivalent dest angle
- that is within [-180..180) of src
- examples:
- fitDestAngle2Src(30, 60) == 60
- fitDestAngle2Src(60, 30) == 30
- fitDestAngle2Src(0, 180) == -180
- fitDestAngle2Src(1, 180) == 180
- """
- return src + (reduceAngle(dest - src))
- def closestDestAngle2(src, dest):
- # The function above didn't seem to do what I wanted. So I hacked
- # this one together. I can't really say I understand it. It's more
- # from impirical observation... GRW
- diff = src - dest
- if diff > 180:
- # if the difference is greater that 180 it's shorter to go the other way
- return dest - 360
- elif diff < -180:
- # or perhaps the OTHER other way...
- return dest + 360
- else:
- # otherwise just go to the original destination
- return dest
- def closestDestAngle(src, dest):
- # The function above didn't seem to do what I wanted. So I hacked
- # this one together. I can't really say I understand it. It's more
- # from impirical observation... GRW
- diff = src - dest
- if diff > 180:
- # if the difference is greater that 180 it's shorter to go the other way
- return src - (diff - 360)
- elif diff < -180:
- # or perhaps the OTHER other way...
- return src - (360 + diff)
- else:
- # otherwise just go to the original destination
- return dest
- def binaryRepr(number, max_length = 32):
- # This will only work reliably for relatively small numbers.
- # Increase the value of max_length if you think you're going
- # to use long integers
- assert number < 2L << max_length
- shifts = map (operator.rshift, max_length * [number], \
- range (max_length - 1, -1, -1))
- digits = map (operator.mod, shifts, max_length * [2])
- if not digits.count (1): return 0
- digits = digits [digits.index (1):]
- return string.join (map (repr, digits), '')
- # constant profile defaults
- PyUtilProfileDefaultFilename = 'profiledata'
- PyUtilProfileDefaultLines = 80
- PyUtilProfileDefaultSorts = ['cumulative', 'time', 'calls']
- def profile(callback, name, terse):
- import __builtin__
- if 'globalProfileFunc' in __builtin__.__dict__:
- # rats. Python profiler is not re-entrant...
- base.notify.warning(
- 'PythonUtil.profileStart(%s): aborted, already profiling %s'
- #'\nStack Trace:\n%s'
- % (name, __builtin__.globalProfileFunc,
- #StackTrace()
- ))
- return
- __builtin__.globalProfileFunc = callback
- print '***** START PROFILE: %s *****' % name
- startProfile(cmd='globalProfileFunc()', callInfo=(not terse))
- print '***** END PROFILE: %s *****' % name
- del __builtin__.__dict__['globalProfileFunc']
- def profiled(category=None, terse=False):
- """ decorator for profiling functions
- turn categories on and off via "want-profile-categoryName 1"
-
- e.g.
- @profiled('particles')
- def loadParticles():
- ...
- want-profile-particles 1
- """
- assert type(category) in (types.StringType, types.NoneType), "must provide a category name for @profiled"
- try:
- null = not __dev__
- except:
- null = not __debug__
- if null:
- # if we're not in __dev__, just return the function itself. This
- # results in zero runtime overhead, since decorators are evaluated
- # at module-load.
- def nullDecorator(f):
- return f
- return nullDecorator
- def profileDecorator(f):
- def _profiled(*args, **kArgs):
- name = '(%s) %s from %s' % (category, f.func_name, f.__module__)
- # showbase might not be loaded yet, so don't use
- # base.config. Instead, query the ConfigVariableBool.
- if (category is None) or ConfigVariableBool('want-profile-%s' % category, 0).getValue():
- return profile(Functor(f, *args, **kArgs), name, terse)
- else:
- return f(*args, **kArgs)
- _profiled.__doc__ = f.__doc__
- return _profiled
- return profileDecorator
- # call this from the prompt, and break back out to the prompt
- # to stop profiling
- #
- # OR to do inline profiling, you must make a globally-visible
- # function to be profiled, i.e. to profile 'self.load()', do
- # something like this:
- #
- # def func(self=self):
- # self.load()
- # import __builtin__
- # __builtin__.func = func
- # PythonUtil.startProfile(cmd='func()', filename='profileData')
- # del __builtin__.func
- #
- def startProfile(filename=PyUtilProfileDefaultFilename,
- lines=PyUtilProfileDefaultLines,
- sorts=PyUtilProfileDefaultSorts,
- silent=0,
- callInfo=1,
- cmd='run()'):
- # uniquify the filename to allow multiple processes to profile simultaneously
- filename = '%s.%s' % (filename, randUint31())
- import profile
- profile.run(cmd, filename)
- if not silent:
- printProfile(filename, lines, sorts, callInfo)
- import os
- os.remove(filename)
- # call this to see the results again
- def printProfile(filename=PyUtilProfileDefaultFilename,
- lines=PyUtilProfileDefaultLines,
- sorts=PyUtilProfileDefaultSorts,
- callInfo=1):
- import pstats
- s = pstats.Stats(filename)
- s.strip_dirs()
- for sort in sorts:
- s.sort_stats(sort)
- s.print_stats(lines)
- if callInfo:
- s.print_callees(lines)
- s.print_callers(lines)
- def getSetterName(valueName, prefix='set'):
- # getSetterName('color') -> 'setColor'
- # getSetterName('color', 'get') -> 'getColor'
- return '%s%s%s' % (prefix, string.upper(valueName[0]), valueName[1:])
- def getSetter(targetObj, valueName, prefix='set'):
- # getSetter(smiley, 'pos') -> smiley.setPos
- return getattr(targetObj, getSetterName(valueName, prefix))
- """
- # with one integer positional arg, this uses about 4/5 of the memory of the Functor class below
- def Functor(function, *args, **kArgs):
- argsCopy = args[:]
- def functor(*cArgs, **ckArgs):
- kArgs.update(ckArgs)
- return function(*(argsCopy + cArgs), **kArgs)
- return functor
- """
- class Functor:
- def __init__(self, function, *args, **kargs):
- assert callable(function), "function should be a callable obj"
- self._function = function
- self._args = args
- self._kargs = kargs
- self.__name__ = self._function.__name__
- self.__doc__ = self._function.__doc__
- def destroy(self):
- del self._function
- del self._args
- del self._kargs
- del self.__name__
- del self.__doc__
-
- def __call__(self, *args, **kargs):
- _kargs = self._kargs.copy()
- _kargs.update(kargs)
- return self._function(*(self._args + args), **_kargs)
- def __repr__(self):
- s = 'Functor(%s' % self._function.__name__
- for arg in self._args:
- try:
- argStr = repr(arg)
- except:
- argStr = 'bad repr: %s' % arg.__class__
- s += ', %s' % argStr
- for karg, value in self._kargs.items():
- s += ', %s=%s' % (karg, repr(value))
- s += ')'
- return s
- class Stack:
- def __init__(self):
- self.__list = []
- def push(self, item):
- self.__list.append(item)
- def top(self):
- # return the item on the top of the stack without popping it off
- return self.__list[-1]
- def pop(self):
- return self.__list.pop()
- def clear(self):
- self.__list = []
- def isEmpty(self):
- return len(self.__list) == 0
- def __len__(self):
- return len(self.__list)
- class Queue:
- # FIFO queue
- # interface is intentionally identical to Stack (LIFO)
- def __init__(self):
- self.__list = []
- def push(self, item):
- self.__list.append(item)
- def top(self):
- # return the next item at the front of the queue without popping it off
- return self.__list[0]
- def front(self):
- return self.__list[0]
- def back(self):
- return self.__list[-1]
- def pop(self):
- return self.__list.pop(0)
- def clear(self):
- self.__list = []
- def isEmpty(self):
- return len(self.__list) == 0
- def __len__(self):
- return len(self.__list)
- if __debug__:
- q = Queue()
- assert q.isEmpty()
- q.clear()
- assert q.isEmpty()
- q.push(10)
- assert not q.isEmpty()
- q.push(20)
- assert not q.isEmpty()
- assert len(q) == 2
- assert q.front() == 10
- assert q.back() == 20
- assert q.top() == 10
- assert q.top() == 10
- assert q.pop() == 10
- assert len(q) == 1
- assert not q.isEmpty()
- assert q.pop() == 20
- assert len(q) == 0
- assert q.isEmpty()
- def mostDerivedLast(classList):
- """pass in list of classes. sorts list in-place, with derived classes
- appearing after their bases"""
- def compare(a, b):
- if issubclass(a, b):
- result=1
- elif issubclass(b, a):
- result=-1
- else:
- result=0
- #print a, b, result
- return result
- classList.sort(compare)
- """
- ParamObj/ParamSet
- =================
- These two classes support you in the definition of a formal set of
- parameters for an object type. The parameters may be safely queried/set on
- an object instance at any time, and the object will react to newly-set
- values immediately.
- ParamSet & ParamObj also provide a mechanism for atomically setting
- multiple parameter values before allowing the object to react to any of the
- new values--useful when two or more parameters are interdependent and there
- is risk of setting an illegal combination in the process of applying a new
- set of values.
- To make use of these classes, derive your object from ParamObj. Then define
- a 'ParamSet' subclass that derives from the parent class' 'ParamSet' class,
- and define the object's parameters within its ParamSet class. (see examples
- below)
- The ParamObj base class provides 'get' and 'set' functions for each
- parameter if they are not defined. These default implementations
- respectively set the parameter value directly on the object, and expect the
- value to be available in that location for retrieval.
- Classes that derive from ParamObj can optionally declare a 'get' and 'set'
- function for each parameter. The setter should simply store the value in a
- location where the getter can find it; it should not do any further
- processing based on the new parameter value. Further processing should be
- implemented in an 'apply' function. The applier function is optional, and
- there is no default implementation.
- NOTE: the previous value of a parameter is available inside an apply
- function as 'self.getPriorValue()'
- The ParamSet class declaration lists the parameters and defines a default
- value for each. ParamSet instances represent a complete set of parameter
- values. A ParamSet instance created with no constructor arguments will
- contain the default values for each parameter. The defaults may be
- overriden by passing keyword arguments to the ParamSet's constructor. If a
- ParamObj instance is passed to the constructor, the ParamSet will extract
- the object's current parameter values.
- ParamSet.applyTo(obj) sets all of its parameter values on 'obj'.
- SETTERS AND APPLIERS
- ====================
- Under normal conditions, a call to a setter function, i.e.
- cam.setFov(90)
- will actually result in the following calls being made:
- cam.setFov(90)
- cam.applyFov()
- Calls to several setter functions, i.e.
- cam.setFov(90)
- cam.setViewType('cutscene')
- will result in this call sequence:
- cam.setFov(90)
- cam.applyFov()
- cam.setViewType('cutscene')
- cam.applyViewType()
- Suppose that you desire the view type to already be set to 'cutscene' at
- the time when applyFov() is called. You could reverse the order of the set
- calls, but suppose that you also want the fov to be set properly at the
- time when applyViewType() is called.
- In this case, you can 'lock' the params, i.e.
- cam.lockParams()
- cam.setFov(90)
- cam.setViewType('cutscene')
- cam.unlockParams()
- This will result in the following call sequence:
- cam.setFov(90)
- cam.setViewType('cutscene')
- cam.applyFov()
- cam.applyViewType()
- NOTE: Currently the order of the apply calls following an unlock is not
- guaranteed.
- EXAMPLE CLASSES
- ===============
- Here is an example of a class that uses ParamSet/ParamObj to manage its
- parameters:
- class Camera(ParamObj):
- class ParamSet(ParamObj.ParamSet):
- Params = {
- 'viewType': 'normal',
- 'fov': 60,
- }
- ...
- def getViewType(self):
- return self.viewType
- def setViewType(self, viewType):
- self.viewType = viewType
- def applyViewType(self):
- if self.viewType == 'normal':
- ...
- def getFov(self):
- return self.fov
- def setFov(self, fov):
- self.fov = fov
- def applyFov(self):
- base.camera.setFov(self.fov)
- ...
- EXAMPLE USAGE
- =============
- cam = Camera()
- ...
- # set up for the cutscene
- savedSettings = cam.ParamSet(cam)
- cam.setViewType('closeup')
- cam.setFov(90)
- ...
- # cutscene is over, set the camera back
- savedSettings.applyTo(cam)
- del savedSettings
- """
- class ParamObj:
- # abstract base for classes that want to support a formal parameter
- # set whose values may be queried, changed, 'bulk' changed (defer reaction
- # to changes until multiple changes have been performed), and
- # extracted/stored/applied all at once (see documentation above)
- # ParamSet subclass: container of parameter values. Derived class must
- # derive a new ParamSet class if they wish to define new params. See
- # documentation above.
- class ParamSet:
- Params = {
- # base class does not define any parameters, but they would
- # appear here as 'name': defaultValue,
- #
- # WARNING: default values of mutable types that do not copy by
- # value (dicts, lists etc.) will be shared by all class instances
- # if default value is callable, it will be called to get actual
- # default value
- #
- # for example:
- #
- # class MapArea(ParamObj):
- # class ParamSet(ParamObj.ParamSet):
- # Params = {
- # 'spawnIndices': Functor(list, [1,5,22]),
- # }
- #
- }
- def __init__(self, *args, **kwArgs):
- self.__class__._compileDefaultParams()
- if len(args) == 1 and len(kwArgs) == 0:
- # extract our params from an existing ParamObj instance
- obj = args[0]
- self.paramVals = {}
- for param in self.getParams():
- self.paramVals[param] = getSetter(obj, param, 'get')()
- else:
- assert len(args) == 0
- if __debug__:
- for arg in kwArgs.keys():
- assert arg in self.getParams()
- self.paramVals = dict(kwArgs)
- def getValue(self, param):
- if param in self.paramVals:
- return self.paramVals[param]
- return self._Params[param]
- def applyTo(self, obj):
- # Apply our entire set of params to a ParamObj
- obj.lockParams()
- for param in self.getParams():
- getSetter(obj, param)(self.getValue(param))
- obj.unlockParams()
- def extractFrom(self, obj):
- # Extract our entire set of params from a ParamObj
- obj.lockParams()
- for param in self.getParams():
- self.paramVals[param] = getSetter(obj, param, 'get')()
- obj.unlockParams()
- @classmethod
- def getParams(cls):
- # returns safely-mutable list of param names
- cls._compileDefaultParams()
- return cls._Params.keys()
- @classmethod
- def getDefaultValue(cls, param):
- cls._compileDefaultParams()
- dv = cls._Params[param]
- if callable(dv):
- dv = dv()
- return dv
- @classmethod
- def _compileDefaultParams(cls):
- if cls.__dict__.has_key('_Params'):
- # we've already compiled the defaults for this class
- return
- bases = list(cls.__bases__)
- # bring less-derived classes to the front
- mostDerivedLast(bases)
- cls._Params = {}
- for c in (bases + [cls]):
- # make sure this base has its dict of param defaults
- c._compileDefaultParams()
- if c.__dict__.has_key('Params'):
- # apply this class' default param values to our dict
- cls._Params.update(c.Params)
- def __repr__(self):
- argStr = ''
- for param in self.getParams():
- argStr += '%s=%s,' % (param,
- repr(self.getValue(param)))
- return '%s.%s(%s)' % (
- self.__class__.__module__, self.__class__.__name__, argStr)
- # END PARAMSET SUBCLASS
- def __init__(self, *args, **kwArgs):
- assert issubclass(self.ParamSet, ParamObj.ParamSet)
- # If you pass in a ParamSet obj, its values will be applied to this
- # object in the constructor.
- params = None
- if len(args) == 1 and len(kwArgs) == 0:
- # if there's one argument, assume that it's a ParamSet
- params = args[0]
- elif len(kwArgs) > 0:
- assert len(args) == 0
- # if we've got keyword arguments, make a ParamSet out of them
- params = self.ParamSet(**kwArgs)
- self._paramLockRefCount = 0
- # these hold the current value of parameters while they are being set to
- # a new value, to support getPriorValue()
- self._curParamStack = []
- self._priorValuesStack = []
- # insert stub funcs for param setters, to handle locked params
- for param in self.ParamSet.getParams():
- # set the default value on the object
- setattr(self, param, self.ParamSet.getDefaultValue(param))
-
- setterName = getSetterName(param)
- getterName = getSetterName(param, 'get')
- # is there a setter defined?
- if not hasattr(self, setterName):
- # no; provide the default
- def defaultSetter(self, value, param=param):
- #print '%s=%s for %s' % (param, value, id(self))
- setattr(self, param, value)
- self.__class__.__dict__[setterName] = defaultSetter
- # is there a getter defined?
- if not hasattr(self, getterName):
- # no; provide the default. If there is no value set, return
- # the default
- def defaultGetter(self, param=param,
- default=self.ParamSet.getDefaultValue(param)):
- return getattr(self, param, default)
- self.__class__.__dict__[getterName] = defaultGetter
- # have we already installed a setter stub?
- origSetterName = '%s_ORIG' % (setterName,)
- if not hasattr(self, origSetterName):
- # move the original setter aside
- origSetterFunc = getattr(self.__class__, setterName)
- setattr(self.__class__, origSetterName, origSetterFunc)
- """
- # if the setter is a direct member of this instance, move the setter
- # aside
- if setterName in self.__dict__:
- self.__dict__[setterName + '_MOVED'] = self.__dict__[setterName]
- setterFunc = self.__dict__[setterName]
- """
- # install a setter stub that will a) call the real setter and
- # then the applier, or b) call the setter and queue the
- # applier, depending on whether our params are locked
- """
- setattr(self, setterName, new.instancemethod(
- Functor(setterStub, param, setterFunc), self, self.__class__))
- """
- def setterStub(self, value, param=param, origSetterName=origSetterName):
- # should we apply the value now or should we wait?
- # if this obj's params are locked, we track which values have
- # been set, and on unlock, we'll call the applyers for those
- # values
- if self._paramLockRefCount > 0:
- priorValues = self._priorValuesStack[-1]
- if param not in priorValues:
- try:
- priorValue = getSetter(self, param, 'get')()
- except:
- priorValue = None
- priorValues[param] = priorValue
- self._paramsSet[param] = None
- getattr(self, origSetterName)(value)
- else:
- # prepare for call to getPriorValue
- try:
- priorValue = getSetter(self, param, 'get')()
- except:
- priorValue = None
- self._priorValuesStack.append({
- param: priorValue,
- })
- getattr(self, origSetterName)(value)
- # call the applier, if there is one
- applier = getattr(self, getSetterName(param, 'apply'), None)
- if applier is not None:
- self._curParamStack.append(param)
- applier()
- self._curParamStack.pop()
- self._priorValuesStack.pop()
- if hasattr(self, 'handleParamChange'):
- self.handleParamChange((param,))
- setattr(self.__class__, setterName, setterStub)
- if params is not None:
- params.applyTo(self)
- def destroy(self):
- """
- for param in self.ParamSet.getParams():
- setterName = getSetterName(param)
- self.__dict__[setterName].destroy()
- del self.__dict__[setterName]
- """
- pass
-
- def setDefaultParams(self):
- # set all the default parameters on ourself
- self.ParamSet().applyTo(self)
- def getCurrentParams(self):
- params = self.ParamSet()
- params.extractFrom(self)
- return params
- def lockParams(self):
- self._paramLockRefCount += 1
- if self._paramLockRefCount == 1:
- self._handleLockParams()
- def unlockParams(self):
- if self._paramLockRefCount > 0:
- self._paramLockRefCount -= 1
- if self._paramLockRefCount == 0:
- self._handleUnlockParams()
- def _handleLockParams(self):
- # this will store the names of the parameters that are modified
- self._paramsSet = {}
- # this will store the values of modified params (from prior to
- # the lock).
- self._priorValuesStack.append({})
- def _handleUnlockParams(self):
- for param in self._paramsSet:
- # call the applier, if there is one
- applier = getattr(self, getSetterName(param, 'apply'), None)
- if applier is not None:
- self._curParamStack.append(param)
- applier()
- self._curParamStack.pop()
- self._priorValuesStack.pop()
- if hasattr(self, 'handleParamChange'):
- self.handleParamChange(tuple(self._paramsSet.keys()))
- del self._paramsSet
- def paramsLocked(self):
- return self._paramLockRefCount > 0
- def getPriorValue(self):
- # call this within an apply function to find out what the prior value
- # of the param was
- return self._priorValuesStack[-1][self._curParamStack[-1]]
- def __repr__(self):
- argStr = ''
- for param in self.ParamSet.getParams():
- try:
- value = getSetter(self, param, 'get')()
- except:
- value = '<unknown>'
- argStr += '%s=%s,' % (param, repr(value))
- return '%s(%s)' % (self.__class__.__name__, argStr)
- if __debug__:
- class ParamObjTest(ParamObj):
- class ParamSet(ParamObj.ParamSet):
- Params = {
- 'num': 0,
- }
- def applyNum(self):
- self.priorValue = self.getPriorValue()
- pto = ParamObjTest()
- assert pto.getNum() == 0
- pto.setNum(1)
- assert pto.priorValue == 0
- assert pto.getNum() == 1
- pto.lockParams()
- pto.setNum(2)
- # make sure applyNum is not called until we call unlockParams
- assert pto.priorValue == 0
- assert pto.getNum() == 2
- pto.unlockParams()
- assert pto.priorValue == 1
- assert pto.getNum() == 2
- """
- POD (Plain Ol' Data)
- Like ParamObj/ParamSet, but without lock/unlock/getPriorValue and without
- appliers. Similar to a C++ struct, but with auto-generated setters and
- getters.
- Use POD when you want the generated getters and setters of ParamObj, but
- efficiency is a concern and you don't need the bells and whistles provided
- by ParamObj.
- POD.__init__ *MUST* be called. You should NOT define your own data getters
- and setters. Data values may be read, set, and modified directly. You will
- see no errors if you define your own getters/setters, but there is no
- guarantee that they will be called--and they will certainly be bypassed by
- POD internally.
- EXAMPLE CLASSES
- ===============
- Here is an example of a class heirarchy that uses POD to manage its data:
- class Enemy(POD):
- DataSet = {
- 'faction': 'navy',
- }
- class Sailor(Enemy):
- DataSet = {
- 'build': HUSKY,
- 'weapon': Cutlass(scale=.9),
- }
- EXAMPLE USAGE
- =============
- s = Sailor(faction='undead', build=SKINNY)
- # make two copies of s
- s2 = s.makeCopy()
- s3 = Sailor(s)
- # example sets
- s2.setWeapon(Musket())
- s3.build = TALL
- # example gets
- faction2 = s2.getFaction()
- faction3 = s3.faction
- """
- class POD:
- DataSet = {
- # base class does not define any data items, but they would
- # appear here as 'name': defaultValue,
- #
- # WARNING: default values of mutable types that do not copy by
- # value (dicts, lists etc.) will be shared by all class instances.
- # if default value is callable, it will be called to get actual
- # default value
- #
- # for example:
- #
- # class MapData(POD):
- # DataSet = {
- # 'spawnIndices': Functor(list, [1,5,22]),
- # }
- }
- def __init__(self, **kwArgs):
- self.__class__._compileDefaultDataSet()
- if __debug__:
- # make sure all of the keyword arguments passed in
- # are present in our data set
- for arg in kwArgs.keys():
- assert arg in self.getDataNames(), (
- "unknown argument for %s: '%s'" % (
- self.__class__, arg))
- # assign each of our data items directly to self
- for name in self.getDataNames():
- # if a value has been passed in for a data item, use
- # that value, otherwise use the default value
- if name in kwArgs:
- getSetter(self, name)(kwArgs[name])
- else:
- getSetter(self, name)(self.getDefaultValue(name))
- def setDefaultValues(self):
- # set all the default data values on ourself
- for name in self.getDataNames():
- getSetter(self, name)(self.getDefaultValue(name))
- # this functionality used to be in the constructor, triggered by a single
- # positional argument; that was conflicting with POD subclasses that wanted
- # to define different behavior for themselves when given a positional
- # constructor argument
- def copyFrom(self, other, strict=False):
- # if 'strict' is true, other must have a value for all of our data items
- # otherwise we'll use the defaults
- for name in self.getDataNames():
- if hasattr(other, getSetterName(name, 'get')):
- setattr(self, name, getSetter(other, name, 'get')())
- else:
- if strict:
- raise "object '%s' doesn't have value '%s'" % (other, name)
- else:
- setattr(self, name, self.getDefaultValue(name))
- # support 'p = POD.POD().copyFrom(other)' syntax
- return self
- def makeCopy(self):
- # returns a duplicate of this object
- return self.__class__().copyFrom(self)
- def applyTo(self, obj):
- # Apply our entire set of data to another POD
- for name in self.getDataNames():
- getSetter(obj, name)(getSetter(self, name, 'get')())
- def getValue(self, name):
- return getSetter(self, name, 'get')()
- @classmethod
- def getDataNames(cls):
- # returns safely-mutable list of datum names
- cls._compileDefaultDataSet()
- return cls._DataSet.keys()
- @classmethod
- def getDefaultValue(cls, name):
- cls._compileDefaultDataSet()
- dv = cls._DataSet[name]
- # this allows us to create a new mutable object every time we ask
- # for its default value, i.e. if the default value is dict, this
- # method will return a new empty dictionary object every time. This
- # will cause problems if the intent is to store a callable object
- # as the default value itself; we need a way to specify that the
- # callable *is* the default value and not a default-value creation
- # function
- if callable(dv):
- dv = dv()
- return dv
- @classmethod
- def _compileDefaultDataSet(cls):
- if cls.__dict__.has_key('_DataSet'):
- # we've already compiled the defaults for this class
- return
- # create setters & getters for this class
- if cls.__dict__.has_key('DataSet'):
- for name in cls.DataSet:
- setterName = getSetterName(name)
- if not hasattr(cls, setterName):
- def defaultSetter(self, value, name=name):
- setattr(self, name, value)
- cls.__dict__[setterName] = defaultSetter
- getterName = getSetterName(name, 'get')
- if not hasattr(cls, getterName):
- def defaultGetter(self, name=name):
- return getattr(self, name)
- cls.__dict__[getterName] = defaultGetter
- # this dict will hold all of the aggregated default data values for
- # this particular class, including values from its base classes
- cls._DataSet = {}
- bases = list(cls.__bases__)
- # process in reverse of inheritance order, so that base classes listed first
- # will take precedence over later base classes
- bases.reverse()
- for curBase in bases:
- # skip multiple-inheritance base classes that do not derive from POD
- if issubclass(curBase, POD):
- # make sure this base has its dict of data defaults
- curBase._compileDefaultDataSet()
- # grab all inherited data default values
- cls._DataSet.update(curBase._DataSet)
- # pull in our own class' default values if any are specified
- if 'DataSet' in cls.__dict__:
- cls._DataSet.update(cls.DataSet)
- def __repr__(self):
- argStr = ''
- for name in self.getDataNames():
- argStr += '%s=%s,' % (name, repr(getSetter(self, name, 'get')()))
- return '%s(%s)' % (self.__class__.__name__, argStr)
- if __debug__:
- class PODtest(POD):
- DataSet = {
- 'foo': dict,
- }
- p1 = PODtest()
- p2 = PODtest()
- assert hasattr(p1, 'foo')
- # make sure the getter is working
- assert p1.getFoo() is p1.foo
- p1.getFoo()[1] = 2
- assert p1.foo[1] == 2
- # make sure that each instance gets its own copy of a mutable
- # data item
- assert p1.foo is not p2.foo
- assert len(p1.foo) == 1
- assert len(p2.foo) == 0
- # make sure the setter is working
- p2.setFoo({10:20})
- assert p2.foo[10] == 20
- # make sure modifications to mutable data items don't affect other
- # instances
- assert p1.foo[1] == 2
- class DerivedPOD(PODtest):
- DataSet = {
- 'bar': list,
- }
- d1 = DerivedPOD()
- # make sure that derived instances get their own copy of mutable
- # data items
- assert hasattr(d1, 'foo')
- assert len(d1.foo) == 0
- # make sure derived instances get their own items
- assert hasattr(d1, 'bar')
- assert len(d1.bar) == 0
- def bound(value, bound1, bound2):
- """
- returns value if value is between bound1 and bound2
- otherwise returns bound that is closer to value
- """
- if bound1 > bound2:
- return min(max(value, bound2), bound1)
- else:
- return min(max(value, bound1), bound2)
- def lerp(v0, v1, t):
- """
- returns a value lerped between v0 and v1, according to t
- t == 0 maps to v0, t == 1 maps to v1
- """
- return v0 + ((v1 - v0) * t)
- def average(*args):
- """ returns simple average of list of values """
- val = 0.
- for arg in args:
- val += arg
- return val / len(args)
- def addListsByValue(a, b):
- """
- returns a new array containing the sums of the two array arguments
- (c[0] = a[0 + b[0], etc.)
- """
- c = []
- for x, y in zip(a, b):
- c.append(x + y)
- return c
- def boolEqual(a, b):
- """
- returns true if a and b are both true or both false.
- returns false otherwise
- (a.k.a. xnor -- eXclusive Not OR).
- """
- return (a and b) or not (a or b)
- def lineupPos(i, num, spacing):
- """
- use to line up a series of 'num' objects, in one dimension,
- centered around zero
- 'i' is the index of the object in the lineup
- 'spacing' is the amount of space between objects in the lineup
- """
- assert num >= 1
- assert i >= 0 and i < num
- pos = float(i) * spacing
- return pos - ((float(spacing) * (num-1))/2.)
- def formatElapsedSeconds(seconds):
- """
- Returns a string of the form "mm:ss" or "hh:mm:ss" or "n days",
- representing the indicated elapsed time in seconds.
- """
- sign = ''
- if seconds < 0:
- seconds = -seconds
- sign = '-'
- # We use math.floor() instead of casting to an int, so we avoid
- # problems with numbers that are too large to represent as
- # type int.
- seconds = math.floor(seconds)
- hours = math.floor(seconds / (60 * 60))
- if hours > 36:
- days = math.floor((hours + 12) / 24)
- return "%s%d days" % (sign, days)
- seconds -= hours * (60 * 60)
- minutes = (int)(seconds / 60)
- seconds -= minutes * 60
- if hours != 0:
- return "%s%d:%02d:%02d" % (sign, hours, minutes, seconds)
- else:
- return "%s%d:%02d" % (sign, minutes, seconds)
- def solveQuadratic(a, b, c):
- # quadratic equation: ax^2 + bx + c = 0
- # quadratic formula: x = [-b +/- sqrt(b^2 - 4ac)] / 2a
- # returns None, root, or [root1, root2]
- # a cannot be zero.
- if a == 0.:
- return None
- # calculate the determinant (b^2 - 4ac)
- D = (b * b) - (4. * a * c)
- if D < 0:
- # there are no solutions (sqrt(negative number) is undefined)
- return None
- elif D == 0:
- # only one root
- return (-b) / (2. * a)
- else:
- # OK, there are two roots
- sqrtD = math.sqrt(D)
- twoA = 2. * a
- root1 = ((-b) - sqrtD) / twoA
- root2 = ((-b) + sqrtD) / twoA
- return [root1, root2]
- def stackEntryInfo(depth=0, baseFileName=1):
- """
- returns the sourcefilename, line number, and function name of
- an entry in the stack.
- 'depth' is how far back to go in the stack; 0 is the caller of this
- function, 1 is the function that called the caller of this function, etc.
- by default, strips off the path of the filename; override with baseFileName
- returns (fileName, lineNum, funcName) --> (string, int, string)
- returns (None, None, None) on error
- """
- try:
- stack = None
- frame = None
- try:
- stack = inspect.stack()
- # add one to skip the frame associated with this function
- frame = stack[depth+1]
- filename = frame[1]
- if baseFileName:
- filename = os.path.basename(filename)
- lineNum = frame[2]
- funcName = frame[3]
- result = (filename, lineNum, funcName)
- finally:
- del stack
- del frame
- except:
- result = (None, None, None)
- return result
- def lineInfo(baseFileName=1):
- """
- returns the sourcefilename, line number, and function name of the
- code that called this function
- (answers the question: 'hey lineInfo, where am I in the codebase?')
- see stackEntryInfo, above, for info on 'baseFileName' and return types
- """
- return stackEntryInfo(1, baseFileName)
- def callerInfo(baseFileName=1, howFarBack=0):
- """
- returns the sourcefilename, line number, and function name of the
- caller of the function that called this function
- (answers the question: 'hey callerInfo, who called me?')
- see stackEntryInfo, above, for info on 'baseFileName' and return types
- """
- return stackEntryInfo(2+howFarBack, baseFileName)
- def lineTag(baseFileName=1, verbose=0, separator=':'):
- """
- returns a string containing the sourcefilename and line number
- of the code that called this function
- (equivalent to lineInfo, above, with different return type)
- see stackEntryInfo, above, for info on 'baseFileName'
- if 'verbose' is false, returns a compact string of the form
- 'fileName:lineNum:funcName'
- if 'verbose' is true, returns a longer string that matches the
- format of Python stack trace dumps
- returns empty string on error
- """
- fileName, lineNum, funcName = callerInfo(baseFileName)
- if fileName is None:
- return ''
- if verbose:
- return 'File "%s", line %s, in %s' % (fileName, lineNum, funcName)
- else:
- return '%s%s%s%s%s' % (fileName, separator, lineNum, separator,
- funcName)
- def findPythonModule(module):
- # Look along the python load path for the indicated filename.
- # Returns the located pathname, or None if the filename is not
- # found.
- filename = module + '.py'
- for dir in sys.path:
- pathname = os.path.join(dir, filename)
- if os.path.exists(pathname):
- return pathname
- return None
- def describeException(backTrace = 4):
- # When called in an exception handler, returns a string describing
- # the current exception.
- def byteOffsetToLineno(code, byte):
- # Returns the source line number corresponding to the given byte
- # offset into the indicated Python code module.
- import array
- lnotab = array.array('B', code.co_lnotab)
- line = code.co_firstlineno
- for i in range(0, len(lnotab), 2):
- byte -= lnotab[i]
- if byte <= 0:
- return line
- line += lnotab[i+1]
- return line
- infoArr = sys.exc_info()
- exception = infoArr[0]
- exceptionName = getattr(exception, '__name__', None)
- extraInfo = infoArr[1]
- trace = infoArr[2]
- stack = []
- while trace.tb_next:
- # We need to call byteOffsetToLineno to determine the true
- # line number at which the exception occurred, even though we
- # have both trace.tb_lineno and frame.f_lineno, which return
- # the correct line number only in non-optimized mode.
- frame = trace.tb_frame
- module = frame.f_globals.get('__name__', None)
- lineno = byteOffsetToLineno(frame.f_code, frame.f_lasti)
- stack.append("%s:%s, " % (module, lineno))
- trace = trace.tb_next
- frame = trace.tb_frame
- module = frame.f_globals.get('__name__', None)
- lineno = byteOffsetToLineno(frame.f_code, frame.f_lasti)
- stack.append("%s:%s, " % (module, lineno))
- description = ""
- for i in range(len(stack) - 1, max(len(stack) - backTrace, 0) - 1, -1):
- description += stack[i]
- description += "%s: %s" % (exceptionName, extraInfo)
- return description
- def clampScalar(value, a, b):
- # calling this ought to be faster than calling both min and max
- if a < b:
- if value < a:
- return a
- elif value > b:
- return b
- else:
- return value
- else:
- if value < b:
- return b
- elif value > a:
- return a
- else:
- return value
- def pivotScalar(scalar, pivot):
- # reflect scalar about pivot; see tests below
- return pivot + (pivot - scalar)
- if __debug__:
- assert pivotScalar(1, 0) == -1
- assert pivotScalar(-1, 0) == 1
- assert pivotScalar(3, 5) == 7
- assert pivotScalar(10, 1) == -8
- def weightedChoice(choiceList, rng=random.random, sum=None):
- """given a list of (weight, item) pairs, chooses an item based on the
- weights. rng must return 0..1. if you happen to have the sum of the
- weights, pass it in 'sum'."""
- # TODO: add support for dicts
- if sum is None:
- sum = 0.
- for weight, item in choiceList:
- sum += weight
- rand = rng()
- accum = rand * sum
- for weight, item in choiceList:
- accum -= weight
- if accum <= 0.:
- return item
- # rand is ~1., and floating-point error prevented accum from hitting 0.
- # Or you passed in a 'sum' that was was too large.
- # Return the last item.
- return item
- def randFloat(a, b=0., rng=random.random):
- """returns a random float in [a, b]
- call with single argument to generate random float between arg and zero
- """
- return lerp(a, b, rng())
- def normalDistrib(a, b, gauss=random.gauss):
- """
- NOTE: assumes a < b
- Returns random number between a and b, using gaussian distribution, with
- mean=avg(a, b), and a standard deviation that fits ~99.7% of the curve
- between a and b. Outlying results are clipped to a and b.
- ------------------------------------------------------------------------
- http://www-stat.stanford.edu/~naras/jsm/NormalDensity/NormalDensity.html
- The 68-95-99.7% Rule
- ====================
- All normal density curves satisfy the following property which is often
- referred to as the Empirical Rule:
- 68% of the observations fall within 1 standard deviation of the mean.
- 95% of the observations fall within 2 standard deviations of the mean.
- 99.7% of the observations fall within 3 standard deviations of the mean.
- Thus, for a normal distribution, almost all values lie within 3 standard
- deviations of the mean.
- ------------------------------------------------------------------------
- In calculating our standard deviation, we divide (b-a) by 6, since the
- 99.7% figure includes 3 standard deviations _on_either_side_ of the mean.
- """
- return max(a, min(b, gauss((a+b)*.5, (b-a)/6.)))
- def weightedRand(valDict, rng=random.random):
- """
- pass in a dictionary with a selection -> weight mapping. Eg.
- {"Choice 1": 10,
- "Choice 2": 30,
- "bear": 100}
- -Weights need not add up to any particular value.
- -The actual selection will be returned.
- """
- selections = valDict.keys()
- weights = valDict.values()
- totalWeight = 0
- for weight in weights:
- totalWeight += weight
- # get a random value between 0 and the total of the weights
- randomWeight = rng() * totalWeight
- # find the index that corresponds with this weight
- for i in range(len(weights)):
- totalWeight -= weights[i]
- if totalWeight <= randomWeight:
- return selections[i]
- assert True, "Should never get here"
- return selections[-1]
- def randUint31(rng=random.random):
- """returns a random integer in [0..2^31).
- rng must return float in [0..1]"""
- return int(rng() * 0x7FFFFFFF)
- def randInt32(rng=random.random):
- """returns a random integer in [-2147483648..2147483647].
- rng must return float in [0..1]
- """
- i = int(rng() * 0x7FFFFFFF)
- if rng() < .5:
- i *= -1
- return i
- def randUint32(rng=random.random):
- """returns a random integer in [0..2^32).
- rng must return float in [0..1]"""
- return long(rng() * 0xFFFFFFFFL)
- class SerialNumGen:
- """generates serial numbers"""
- def __init__(self, start=None):
- if start is None:
- start = 0
- self.__counter = start-1
- def next(self):
- self.__counter += 1
- return self.__counter
- _serialGen = SerialNumGen()
- def serialNum():
- global _serialGen
- return _serialGen.next()
- def uniqueName(name):
- global _serialGen
- return '%s-%s' % (name, _serialGen.next())
- class EnumIter:
- def __init__(self, enum):
- self._values = enum._stringTable.keys()
- self._index = 0
- def __iter__(self):
- return self
- def next(self):
- if self._index >= len(self._values):
- raise StopIteration
- self._index += 1
- return self._values[self._index-1]
- class Enum:
- """Pass in list of strings or string of comma-separated strings.
- Items are accessible as instance.item, and are assigned unique,
- increasing integer values. Pass in integer for 'start' to override
- starting value.
- Example:
- >>> colors = Enum('red, green, blue')
- >>> colors.red
- 0
- >>> colors.green
- 1
- >>> colors.blue
- 2
- >>> colors.getString(colors.red)
- 'red'
- """
- if __debug__:
- # chars that cannot appear within an item string.
- InvalidChars = string.whitespace
- def _checkValidIdentifier(item):
- invalidChars = string.whitespace+string.punctuation
- invalidChars = invalidChars.replace('_','')
- invalidFirstChars = invalidChars+string.digits
- if item[0] in invalidFirstChars:
- raise SyntaxError, ("Enum '%s' contains invalid first char" %
- item)
- if not disjoint(item, invalidChars):
- for char in item:
- if char in invalidChars:
- raise SyntaxError, (
- "Enum\n'%s'\ncontains illegal char '%s'" %
- (item, char))
- return 1
- _checkValidIdentifier = staticmethod(_checkValidIdentifier)
- def __init__(self, items, start=0):
- if type(items) == types.StringType:
- items = items.split(',')
- self._stringTable = {}
- # make sure we don't overwrite an existing element of the class
- assert self._checkExistingMembers(items)
- assert uniqueElements(items)
- i = start
- for item in items:
- # remove leading/trailing whitespace
- item = string.strip(item)
- # is there anything left?
- if len(item) == 0:
- continue
- # make sure there are no invalid characters
- assert Enum._checkValidIdentifier(item)
- self.__dict__[item] = i
- self._stringTable[i] = item
- i += 1
- def __iter__(self):
- return EnumIter(self)
- def getString(self, value):
- return self._stringTable[value]
- def __contains__(self, value):
- return value in self._stringTable
- def __len__(self):
- return len(self._stringTable)
- def copyTo(self, obj):
- # copies all members onto obj
- for name, value in self._stringTable:
- setattr(obj, name, value)
- if __debug__:
- def _checkExistingMembers(self, items):
- for item in items:
- if hasattr(self, item):
- return 0
- return 1
- ############################################################
- # class: Singleton
- # Purpose: This provides a base metaclass for all classes
- # that require one and only one instance.
- #
- # Example: class mySingleton:
- # __metaclass__ = PythonUtil.Singleton
- # def __init__(self, ...):
- # ...
- #
- # Note: This class is based on Python's New-Style Class
- # design. An error will occur if a defined class
- # attemps to inherit from a Classic-Style Class only,
- # ie: class myClassX:
- # def __init__(self, ...):
- # ...
- #
- # class myNewClassX(myClassX):
- # __metaclass__ = PythonUtil.Singleton
- # def __init__(self, ...):
- # myClassX.__init__(self, ...)
- # ...
- #
- # This causes problems because myNewClassX is a
- # New-Style class that inherits from only a
- # Classic-Style base class. There are two ways
- # simple ways to resolve this issue.
- #
- # First, if possible, make myClassX a
- # New-Style class by inheriting from object
- # object. IE: class myClassX(object):
- #
- # If for some reason that is not an option, make
- # myNewClassX inherit from object and myClassX.
- # IE: class myNewClassX(object, myClassX):
- ############################################################
- class Singleton(type):
- def __init__(cls, name, bases, dic):
- super(Singleton, cls).__init__(name, bases, dic)
- cls.instance=None
- def __call__(cls, *args, **kw):
- if cls.instance is None:
- cls.instance=super(Singleton, cls).__call__(*args, **kw)
- return cls.instance
- class SingletonError(ValueError):
- """ Used to indicate an inappropriate value for a Singleton."""
- def printListEnumGen(l):
- # log each individual item with a number in front of it
- digits = 0
- n = len(l)
- while n > 0:
- digits += 1
- n /= 10
- format = '%0' + '%s' % digits + 'i:%s'
- for i in range(len(l)):
- print format % (i, l[i])
- yield None
- def printListEnum(l):
- for result in printListEnumGen(l):
- pass
- def gcDebugOn():
- import gc
- return (gc.get_debug() & gc.DEBUG_SAVEALL) == gc.DEBUG_SAVEALL
- def safeRepr(obj):
- try:
- return repr(obj)
- except:
- return '<** FAILED REPR OF %s **>' % obj.__class__.__name__
- def fastRepr(obj, maxLen=200, strFactor=10, _visitedIds=None):
- """ caps the length of iterable types, so very large objects will print faster.
- also prevents infinite recursion """
- try:
- if _visitedIds is None:
- _visitedIds = set()
- if id(obj) in _visitedIds:
- return '<ALREADY-VISITED %s>' % itype(obj)
- if type(obj) in (types.TupleType, types.ListType):
- s = ''
- s += {types.TupleType: '(',
- types.ListType: '[',}[type(obj)]
- if len(obj) > maxLen:
- o = obj[:maxLen]
- ellips = '...'
- else:
- o = obj
- ellips = ''
- _visitedIds.add(id(obj))
- for item in o:
- s += fastRepr(item, maxLen, _visitedIds=_visitedIds)
- s += ', '
- _visitedIds.remove(id(obj))
- s += ellips
- s += {types.TupleType: ')',
- types.ListType: ']',}[type(obj)]
- return s
- elif type(obj) is types.DictType:
- s = '{'
- if len(obj) > maxLen:
- o = obj.keys()[:maxLen]
- ellips = '...'
- else:
- o = obj.keys()
- ellips = ''
- _visitedIds.add(id(obj))
- for key in o:
- value = obj[key]
- s += '%s: %s, ' % (fastRepr(key, maxLen, _visitedIds=_visitedIds),
- fastRepr(value, maxLen, _visitedIds=_visitedIds))
- _visitedIds.remove(id(obj))
- s += ellips
- s += '}'
- return s
- elif type(obj) is types.StringType:
- maxLen *= strFactor
- if len(obj) > maxLen:
- return safeRepr(obj[:maxLen])
- else:
- return safeRepr(obj)
- else:
- return safeRepr(obj)
- except:
- return '<** FAILED REPR OF %s **>' % obj.__class__.__name__
- def tagRepr(obj, tag):
- """adds a string onto the repr output of an instance"""
- def reprWithTag(oldRepr, tag, self):
- return oldRepr() + '::<TAG=' + tag + '>'
- oldRepr = getattr(obj, '__repr__', None)
- if oldRepr is None:
- def stringer(s):
- return s
- oldRepr = Functor(stringer, repr(obj))
- stringer = None
- obj.__repr__ = new.instancemethod(Functor(reprWithTag, oldRepr, tag), obj, obj.__class__)
- reprWithTag = None
- return obj
- def tagWithCaller(obj):
- """add info about the caller of the caller"""
- tagRepr(obj, str(callerInfo(howFarBack=1)))
- def isDefaultValue(x):
- return x == type(x)()
- def notNone(A, B):
- # returns A if not None, B otherwise
- if A is None:
- return B
- return A
- def appendStr(obj, st):
- """adds a string onto the __str__ output of an instance"""
- def appendedStr(oldStr, st, self):
- return oldStr() + st
- oldStr = getattr(obj, '__str__', None)
- if oldStr is None:
- def stringer(s):
- return s
- oldStr = Functor(stringer, str(obj))
- stringer = None
- obj.__str__ = new.instancemethod(Functor(appendedStr, oldStr, st), obj, obj.__class__)
- appendedStr = None
- return obj
- # convenience shortcuts for __dev__ debugging
- # we don't have the __dev__ flag at this point
- try:
- import pdb
- set_trace = pdb.set_trace
- # set_trace that can be asserted
- def setTrace():
- set_trace()
- return True
- pm = pdb.pm
- except:
- # we're in production, there is no pdb module. assign these to something so that the
- # __builtin__ exports will work
- # references in the code should either be if __dev__'d or asserted
- set_trace = None
- setTrace = None
- pm = None
- class ScratchPad:
- """empty class to stick values onto"""
- def __init__(self, **kArgs):
- for key, value in kArgs.items():
- setattr(self, key, value)
- self._keys = kArgs.keys()
- def destroy(self):
- for key in self._keys:
- delattr(self, key)
- class Sync:
- _SeriesGen = SerialNumGen()
- def __init__(self, name, other=None):
- self._name = name
- if other is None:
- self._series = self._SeriesGen.next()
- self._value = 0
- else:
- self._series = other._series
- self._value = other._value
- def invalidate(self):
- self._value = None
- def change(self):
- self._value += 1
- def sync(self, other):
- if (self._series != other._series) or (self._value != other._value):
- self._series = other._series
- self._value = other._value
- return True
- else:
- return False
- def isSynced(self, other):
- return ((self._series == other._series) and
- (self._value == other._value))
- def __repr__(self):
- return '%s(%s)<family=%s,value=%s>' % (self.__class__.__name__,
- self._name, self._series, self._value)
- class RefCounter:
- def __init__(self, byId=False):
- self._byId = byId
- self._refCounts = {}
- def _getKey(self, item):
- if self._byId:
- key = id(item)
- else:
- key = item
- def inc(self, item):
- key = self._getKey(item)
- self._refCounts.setdefault(key, 0)
- self._refCounts[key] += 1
- def dec(self, item):
- """returns True if ref count has hit zero"""
- key = self._getKey(item)
- self._refCounts[key] -= 1
- result = False
- if self._refCounts[key] == 0:
- result = True
- del self._refCounts[key]
- return result
- def itype(obj):
- t = type(obj)
- if t is types.InstanceType:
- return '%s of <class %s>' % (repr(types.InstanceType),
- str(obj.__class__))
- else:
- return t
- def getNumberedTypedString(items, maxLen=5000, numPrefix=''):
- """get a string that has each item of the list on its own line,
- and each item is numbered on the left from zero"""
- digits = 0
- n = len(items)
- while n > 0:
- digits += 1
- n /= 10
- digits = digits
- format = numPrefix + '%0' + '%s' % digits + 'i:%s \t%s'
- first = True
- s = ''
- snip = '<SNIP>'
- for i in xrange(len(items)):
- if not first:
- s += '\n'
- first = False
- objStr = fastRepr(items[i])
- if len(objStr) > maxLen:
- objStr = '%s%s' % (objStr[:(maxLen-len(snip))], snip)
- s += format % (i, itype(items[i]), objStr)
- return s
- def getNumberedTypedSortedString(items, maxLen=5000, numPrefix=''):
- """get a string that has each item of the list on its own line,
- the items are stringwise-sorted, and each item is numbered on
- the left from zero"""
- digits = 0
- n = len(items)
- while n > 0:
- digits += 1
- n /= 10
- digits = digits
- format = numPrefix + '%0' + '%s' % digits + 'i:%s \t%s'
- snip = '<SNIP>'
- strs = []
- for item in items:
- objStr = fastRepr(item)
- if len(objStr) > maxLen:
- objStr = '%s%s' % (objStr[:(maxLen-len(snip))], snip)
- strs.append(objStr)
- first = True
- s = ''
- strs.sort()
- for i in xrange(len(strs)):
- if not first:
- s += '\n'
- first = False
- objStr = strs[i]
- s += format % (i, itype(items[i]), strs[i])
- return s
- def getNumberedTypedSortedStringWithReferrersGen(items, maxLen=10000, numPrefix=''):
- """get a string that has each item of the list on its own line,
- the items are stringwise-sorted, the object's referrers are shown,
- and each item is numbered on the left from zero"""
- digits = 0
- n = len(items)
- while n > 0:
- digits += 1
- n /= 10
- digits = digits
- format = numPrefix + '%0' + '%s' % digits + 'i:%s @ %s \t%s'
- snip = '<SNIP>'
- strs = []
- for item in items:
- strs.append(fastRepr(item))
- strs.sort()
- for i in xrange(len(strs)):
- item = items[i]
- objStr = strs[i]
- objStr += ', \tREFERRERS=['
- referrers = gc.get_referrers(item)
- for ref in referrers:
- objStr += '%s@%s, ' % (itype(ref), id(ref))
- objStr += ']'
- if len(objStr) > maxLen:
- objStr = '%s%s' % (objStr[:(maxLen-len(snip))], snip)
- yield format % (i, itype(items[i]), id(items[i]), objStr)
- def getNumberedTypedSortedStringWithReferrers(items, maxLen=10000, numPrefix=''):
- """get a string that has each item of the list on its own line,
- the items are stringwise-sorted, the object's referrers are shown,
- and each item is numbered on the left from zero"""
- s = ''
- for line in getNumberedTypedSortedStringWithReferrersGen(items, maxLen, numPrefix):
- s += '%s\n' % line
- return s
- def printNumberedTyped(items, maxLen=5000):
- """print out each item of the list on its own line,
- with each item numbered on the left from zero"""
- digits = 0
- n = len(items)
- while n > 0:
- digits += 1
- n /= 10
- digits = digits
- format = '%0' + '%s' % digits + 'i:%s \t%s'
- for i in xrange(len(items)):
- objStr = fastRepr(items[i])
- if len(objStr) > maxLen:
- snip = '<SNIP>'
- objStr = '%s%s' % (objStr[:(maxLen-len(snip))], snip)
- print format % (i, itype(items[i]), objStr)
- def printNumberedTypesGen(items, maxLen=5000):
- digits = 0
- n = len(items)
- while n > 0:
- digits += 1
- n /= 10
- digits = digits
- format = '%0' + '%s' % digits + 'i:%s'
- for i in xrange(len(items)):
- print format % (i, itype(items[i]))
- yield None
- def printNumberedTypes(items, maxLen=5000):
- """print out the type of each item of the list on its own line,
- with each item numbered on the left from zero"""
- for result in printNumberedTypesGen(items, maxLen):
- yield result
- class DelayedCall:
- """ calls a func after a specified delay """
- def __init__(self, func, name=None, delay=None):
- if name is None:
- name = 'anonymous'
- if delay is None:
- delay = .01
- self._func = func
- taskMgr.doMethodLater(delay, self._doCallback, 'DelayedCallback-%s' % name)
- def _doCallback(self, task):
- func = self._func
- del self._func
- func()
- class FrameDelayedCall:
- """ calls a func after N frames """
- def __init__(self, name, callback, frames=None, cancelFunc=None):
- # checkFunc is optional; called every frame, if returns True, FrameDelay is cancelled
- # and callback is not called
- if frames is None:
- frames = 1
- self._name = name
- self._frames = frames
- self._callback = callback
- self._cancelFunc = cancelFunc
- self._taskName = uniqueName('%s-%s' % (self.__class__.__name__, self._name))
- self._startTask()
- def destroy(self):
- self._stopTask()
- def finish(self):
- self._callback()
- self.destroy()
- def _startTask(self):
- taskMgr.add(self._frameTask, self._taskName)
- self._counter = 0
- def _stopTask(self):
- taskMgr.remove(self._taskName)
- def _frameTask(self, task):
- if self._cancelFunc and self._cancelFunc():
- self.destroy()
- return task.done
- self._counter += 1
- if self._counter >= self._frames:
- self.finish()
- return task.done
- return task.cont
- class DelayedFunctor:
- """ Waits for this object to be called, then calls supplied functor after a delay.
- Effectively inserts a time delay between the caller and the functor. """
- def __init__(self, functor, name=None, delay=None):
- self._functor = functor
- self._name = name
- # FunctionInterval requires __name__
- self.__name__ = self._name
- self._delay = delay
- def _callFunctor(self):
- cb = Functor(self._functor, *self._args, **self._kwArgs)
- del self._functor
- del self._name
- del self._delay
- del self._args
- del self._kwArgs
- del self._delayedCall
- del self.__name__
- cb()
- def __call__(self, *args, **kwArgs):
- self._args = args
- self._kwArgs = kwArgs
- self._delayedCall = DelayedCall(self._callFunctor, self._name, self._delay)
- class SubframeCall:
- """Calls a callback at a specific time during the frame using the
- task system"""
- def __init__(self, functor, taskPriority, name=None):
- self._functor = functor
- self._name = name
- self._taskName = uniqueName('SubframeCall-%s' % self._name)
- taskMgr.add(self._doCallback,
- self._taskName,
- priority=taskPriority)
- def _doCallback(self, task):
- functor = self._functor
- del self._functor
- functor()
- del self._name
- self._taskName = None
- return task.done
- def cleanup(self):
- if (self._taskName):
- taskMgr.remove(self._taskName)
- self._taskName = None
- class ArgumentEater:
- def __init__(self, numToEat, func):
- self._numToEat = numToEat
- self._func = func
- def __call__(self, *args, **kwArgs):
- self._func(*args[self._numToEat:], **kwArgs)
- class ClassTree:
- def __init__(self, instanceOrClass):
- if type(instanceOrClass) in (types.ClassType, types.TypeType):
- cls = instanceOrClass
- else:
- cls = instanceOrClass.__class__
- self._cls = cls
- self._bases = []
- for base in self._cls.__bases__:
- if base not in (types.ObjectType, types.TypeType):
- self._bases.append(ClassTree(base))
- def getAllClasses(self):
- # returns set of this class and all base classes
- classes = set()
- classes.add(self._cls)
- for base in self._bases:
- classes.update(base.getAllClasses())
- return classes
- def _getStr(self, indent=None, clsLeftAtIndent=None):
- # indent is how far to the right to indent (i.e. how many levels
- # deep in the hierarchy from the most-derived)
- #
- # clsLeftAtIndent is an array of # of classes left to be
- # printed at each level of the hierarchy; most-derived is
- # at index 0
- if indent is None:
- indent = 0
- clsLeftAtIndent = [1]
- s = ''
- if (indent > 1):
- for i in range(1, indent):
- # if we have not printed all base classes at
- # this indent level, keep printing the vertical
- # column
- if clsLeftAtIndent[i] > 0:
- s += ' |'
- else:
- s += ' '
- if (indent > 0):
- s += ' +'
- s += self._cls.__name__
- clsLeftAtIndent[indent] -= 1
- """
- ### show the module to the right of the class name
- moduleIndent = 48
- if len(s) >= moduleIndent:
- moduleIndent = (len(s) % 4) + 4
- padding = moduleIndent - len(s)
- s += padding * ' '
- s += self._cls.__module__
- ###
- """
- if len(self._bases):
- newList = list(clsLeftAtIndent)
- newList.append(len(self._bases))
- bases = self._bases
- # print classes with fewer bases first
- bases.sort(lambda x,y: len(x._bases)-len(y._bases))
- for base in bases:
- s += '\n%s' % base._getStr(indent+1, newList)
- return s
- def __repr__(self):
- return self._getStr()
- def report(types = [], prefix = '', xform = None, notifyFunc = None, dConfigParam = []):
- """
- This is a decorator generating function. Use is similar to
- a @decorator, except you must be sure to call it as a function.
- It actually returns the decorator which is then used to transform
- your decorated function. Confusing at first, I know.
- Decoration occurs at function definition time.
- If __dev__ is not defined, or resolves to False, this function
- has no effect and no wrapping/transform occurs. So in production,
- it's as if the report has been asserted out.
-
- Parameters::
- types : A subset list of ['timeStamp', 'frameCount', 'avLocation']
- This allows you to specify certain useful bits of info.
- module: Prints the module that this report statement
- can be found in.
- args: Prints the arguments as they were passed to
- this function.
- timeStamp: Adds the current frame time to the output.
- deltaStamp: Adds the current AI synched frame time to
- the output
- frameCount: Adds the current frame count to the output.
- Usually cleaner than the timeStamp output.
- avLocation: Adds the localAvatar's network location
- to the output. Useful for interest debugging.
- interests: Prints the current interest state after the
- report.
- stackTrace: Prints a stack trace after the report.
-
- prefix: Optional string to prepend to output, just before the function.
- Allows for easy grepping and is useful when merging AI/Client
- reports into a single file.
-
- notifyFunc: A notify function such as info, debug, warning, etc.
- By default the report will be printed to stdout. This
- will allow you send the report to a designated 'notify'
- output.
-
- dConfigParam: A list of Config.prc string variables.
- By default the report will always print. If you
- specify this param, it will only print if one of the
- specified config strings resolve to True.
- """
- def decorator(f):
- return f
- try:
- if not (__dev__ or config.GetBool('force-reports', 0)):
- return decorator
- # determine whether we should use the decorator
- # based on the value of dConfigParam.
- doPrint = False
- if not dConfigParam:
- doPrint = True
- else:
- if not isinstance(dConfigParam, (list,tuple)):
- dConfigParamList = (dConfigParam,)
- else:
- dConfigParamList = dConfigParam
- for param in dConfigParamList:
- if(config.GetBool(param, 0)):
- doPrint = True
- break
- if not doPrint:
- return decorator
-
- except NameError,e:
- return decorator
- from direct.distributed.ClockDelta import globalClockDelta
- def decorator(f):
- def wrap(*args,**kwargs):
- if args:
- rArgs = [args[0].__class__.__name__ + ', ']
- else:
- rArgs = []
- if 'args' in types:
- rArgs += [`x`+', ' for x in args[1:]] + \
- [ x + ' = ' + '%s, ' % `y` for x,y in kwargs.items()]
-
- if not rArgs:
- rArgs = '()'
- else:
- rArgs = '(' + reduce(str.__add__,rArgs)[:-2] + ')'
-
- outStr = '%s%s' % (f.func_name, rArgs)
- if prefix:
- outStr = '%s %s' % (prefix, outStr)
- preStr = ''
- if 'module' in types:
- outStr = '%s {M:%s}' % (outStr, f.__module__.split('.')[-1])
-
- if 'frameCount' in types:
- outStr = '%8d : %s' % (globalClock.getFrameCount(), outStr)
-
- if 'timeStamp' in types:
- outStr = '%8.3f : %s' % (globalClock.getFrameTime(), outStr)
- if 'deltaStamp' in types:
- outStr = '%8.2f : %s' % (globalClock.getRealTime() - \
- globalClockDelta.delta, outStr)
- if 'avLocation' in types:
- outStr = '%s : %s' % (outStr, str(localAvatar.getLocation()))
- if xform:
- outStr = '%s : %s' % (outStr, xform(args[0]))
-
- if notifyFunc:
- notifyFunc(outStr)
- else:
- print outStr
- if 'interests' in types:
- base.cr.printInterestSets()
-
- if 'stackTrace' in types:
- print StackTrace()
- return f(*args,**kwargs)
- wrap.func_name = f.func_name
- wrap.func_dict = f.func_dict
- wrap.func_doc = f.func_doc
- return wrap
-
- return decorator
- def getBase():
- try:
- return base
- except:
- return simbase
- def superFlattenShip(ship):
- #PHASE 1: remove characters
- characterNodes=ship.findAllMatches("**/+Character")
- for i in range(characterNodes.getNumPaths()):
- character=characterNodes.getPath(i)
- children=character.getChildrenAsList()
- for child in children:
- child.copyTo(character.getParent())
- character.reparentTo(hidden)
- #PHASE 2: remove textures
- tex=ship.findAllTextures().getTexture(0)
- ship.setTexture(tex,1000)
- #PHASE 3: stop rocking task
- taskMgr.remove("shipRocking-%d"%(ship.getDoId()))
- #PHASE 4: kill lamp effects
- from pirates.shipparts.DistributedShipDecor import DistributedShipDecor
- for DO in base.cr.doId2do.values():
- if(type(DO) == DistributedShipDecor):
- if (hasattr(DO.prop, 'lanternGlowEffect')):
- DO.prop.lanternGlowEffect.destroy()
-
- #PHASE 5: flatten strong!
- return ship.flattenStrong()
- def exceptionLogged(append=True):
- """decorator that outputs the function name and all arguments
- if an exception passes back through the stack frame
- if append is true, string is appended to the __str__ output of
- the exception. if append is false, string is printed to the log
- directly. If the output will take up many lines, it's recommended
- to set append to False so that the exception stack is not hidden
- by the output of this decorator.
- """
- try:
- null = not __dev__
- except:
- null = not __debug__
- if null:
- # if we're not in __dev__, just return the function itself. This
- # results in zero runtime overhead, since decorators are evaluated
- # at module-load.
- def nullDecorator(f):
- return f
- return nullDecorator
-
- def _decoratorFunc(f, append=append):
- def _exceptionLogged(*args, **kArgs):
- try:
- return f(*args, **kArgs)
- except Exception, e:
- try:
- s = 'STACK UNWIND: %s(' % f.func_name
- for arg in args:
- s += '%s, ' % arg
- for key, value in kArgs.items():
- s += '%s=%s, ' % (key, value)
- if len(args) or len(kArgs):
- s = s[:-2]
- s += ')'
- if append:
- appendStr(e, '\n%s' % s)
- else:
- print s
- except:
- print 'exceptionLogged(%s): ERROR IN PRINTING' % f.func_name
- raise
- _exceptionLogged.__doc__ = f.__doc__
- return _exceptionLogged
- return _decoratorFunc
- # class 'decorator' that records the stack at the time of creation
- # be careful with this, it creates a StackTrace, and that can take a
- # lot of CPU
- def recordCreationStack(cls):
- if not hasattr(cls, '__init__'):
- raise 'recordCreationStack: class \'%s\' must define __init__' % cls.__name__
- cls.__moved_init__ = cls.__init__
- def __recordCreationStack_init__(self, *args, **kArgs):
- self._creationStackTrace = StackTrace(start=1)
- return self.__moved_init__(*args, **kArgs)
- def getCreationStackTrace(self):
- return self._creationStackTrace
- cls.__init__ = __recordCreationStack_init__
- cls.getCreationStackTrace = getCreationStackTrace
- return cls
- # class 'decorator' that logs all method calls for a particular class
- def logMethodCalls(cls):
- if not hasattr(cls, 'notify'):
- raise 'logMethodCalls: class \'%s\' must have a notify' % cls.__name__
- for name in dir(cls):
- method = getattr(cls, name)
- if callable(method):
- def getLoggedMethodCall(method):
- def __logMethodCall__(obj, *args, **kArgs):
- s = '%s(' % method.__name__
- for arg in args:
- try:
- argStr = repr(arg)
- except:
- argStr = 'bad repr: %s' % arg.__class__
- s += '%s, ' % argStr
- for karg, value in kArgs.items():
- s += '%s=%s, ' % (karg, repr(value))
- if len(args) or len(kArgs):
- s = s[:-2]
- s += ')'
- obj.notify.info(s)
- return method(obj, *args, **kArgs)
- return __logMethodCall__
- setattr(cls, name, getLoggedMethodCall(method))
- __logMethodCall__ = None
- return cls
- # http://en.wikipedia.org/wiki/Golden_ratio
- GoldenRatio = (1. + math.sqrt(5.)) / 2.
- class GoldenRectangle:
- @staticmethod
- def getLongerEdge(shorter):
- return shorter * GoldenRatio
- @staticmethod
- def getShorterEdge(longer):
- return longer / GoldenRatio
- class HotkeyBreaker:
- def __init__(self,breakKeys = []):
- from direct.showbase.DirectObject import DirectObject
- self.do = DirectObject()
- self.breakKeys = {}
- if not isinstance(breakKeys, (list,tuple)):
- breakKeys = (breakKeys,)
- for key in breakKeys:
- self.addBreakKey(key)
-
- def addBreakKey(self,breakKey):
- if __dev__:
- self.do.accept(breakKey,self.breakFunc,extraArgs = [breakKey])
-
- def removeBreakKey(self,breakKey):
- if __dev__:
- self.do.ignore(breakKey)
- def breakFunc(self,breakKey):
- if __dev__:
- self.breakKeys[breakKey] = True
- def setBreakPt(self, breakKey = None, persistent = False):
- if __dev__:
- if not breakKey:
- import pdb;pdb.set_trace()
- return True
- else:
- if self.breakKeys.get(breakKey,False):
- if not persistent:
- self.breakKeys.pop(breakKey)
- import pdb;pdb.set_trace()
- return True
- return True
- def clearBreakPt(self, breakKey):
- if __dev__:
- return bool(self.breakKeys.pop(breakKey,None))
- def nullGen():
- # generator that ends immediately
- if False:
- # yield that never runs but still exists, making this func a generator
- yield None
- def loopGen(l):
- # generator that yields the items of an iterable object forever
- def _gen(l):
- while True:
- for item in l:
- yield item
- gen = _gen(l)
- # don't leak
- _gen = None
- return gen
- def makeFlywheelGen(objects, countList=None, countFunc=None, scale=None):
- # iterates and finally yields a flywheel generator object
- # the number of appearances for each object is controlled by passing in
- # a list of counts, or a functor that returns a count when called with
- # an object from the 'objects' list.
- # if scale is provided, all counts are scaled by the scale value and then int()'ed.
- def flywheel(index2objectAndCount):
- # generator to produce a sequence whose elements appear a specific number of times
- while len(index2objectAndCount):
- keyList = index2objectAndCount.keys()
- for key in keyList:
- if index2objectAndCount[key][1] > 0:
- yield index2objectAndCount[key][0]
- index2objectAndCount[key][1] -= 1
- if index2objectAndCount[key][1] <= 0:
- del index2objectAndCount[key]
- # if we were not given a list of counts, create it by calling countFunc
- if countList is None:
- countList = []
- for object in objects:
- yield None
- countList.append(countFunc(object))
- if scale is not None:
- # scale the counts if we've got a scale factor
- for i in xrange(len(countList)):
- yield None
- if countList[i] > 0:
- countList[i] = max(1, int(countList[i] * scale))
- # create a dict for the flywheel to use during its iteration to efficiently select
- # the objects for the sequence
- index2objectAndCount = {}
- for i in xrange(len(countList)):
- yield None
- index2objectAndCount[i] = [objects[i], countList[i]]
- # create the flywheel generator
- yield flywheel(index2objectAndCount)
- def flywheel(*args, **kArgs):
- # create a flywheel generator
- # see arguments and comments in flywheelGen above
- # example usage:
- """
- >>> for i in flywheel([1,2,3], countList=[10, 5, 1]):
- ... print i,
- ...
- 1 2 3 1 2 1 2 1 2 1 2 1 1 1 1 1
- """
- for flywheel in makeFlywheelGen(*args, **kArgs):
- pass
- return flywheel
- if __debug__:
- f = flywheel(['a','b','c','d'], countList=[11,20,3,4])
- obj2count = {}
- for obj in f:
- obj2count.setdefault(obj, 0)
- obj2count[obj] += 1
- assert obj2count['a'] == 11
- assert obj2count['b'] == 20
- assert obj2count['c'] == 3
- assert obj2count['d'] == 4
- f = flywheel([1,2,3,4], countFunc=lambda x: x*2)
- obj2count = {}
- for obj in f:
- obj2count.setdefault(obj, 0)
- obj2count[obj] += 1
- assert obj2count[1] == 2
- assert obj2count[2] == 4
- assert obj2count[3] == 6
- assert obj2count[4] == 8
- f = flywheel([1,2,3,4], countFunc=lambda x: x, scale = 3)
- obj2count = {}
- for obj in f:
- obj2count.setdefault(obj, 0)
- obj2count[obj] += 1
- assert obj2count[1] == 1 * 3
- assert obj2count[2] == 2 * 3
- assert obj2count[3] == 3 * 3
- assert obj2count[4] == 4 * 3
- def quickProfile(name="unnamed"):
- def profileDecorator(f):
- if(not config.GetBool("use-profiler",0)):
- return f
- def _profiled(*args, **kArgs):
- # must do this in here because we don't have base/simbase
- # at the time that PythonUtil is loaded
- if(not config.GetBool("profile-debug",0)):
- #dumb timings
- st=globalClock.getRealTime()
- f(*args,**kArgs)
- s=globalClock.getRealTime()-st
- print "Function %s.%s took %s seconds"%(f.__module__, f.__name__,s)
- else:
- import profile as prof, pstats
- #detailed profile, stored in base.stats under (
- if(not hasattr(base,"stats")):
- base.stats={}
- if(not base.stats.get(name)):
- base.stats[name]=[]
- prof.runctx('f(*args, **kArgs)', {'f':f,'args':args,'kArgs':kArgs},None,"t.prof")
- s=pstats.Stats("t.prof")
- #p=hotshot.Profile("t.prof")
- #p.runctx('f(*args, **kArgs)', {'f':f,'args':args,'kArgs':kArgs},None)
- #s = hotshot.stats.load("t.prof")
- s.strip_dirs()
- s.sort_stats("cumulative")
- base.stats[name].append(s)
-
- _profiled.__doc__ = f.__doc__
- return _profiled
- return profileDecorator
- def getTotalAnnounceTime():
- td=0
- for objs in base.stats.values():
- for stat in objs:
- td+=getAnnounceGenerateTime(stat)
- return td
- def getAnnounceGenerateTime(stat):
- val=0
- stats=stat.stats
- for i in stats.keys():
- if(i[2]=="announceGenerate"):
- newVal=stats[i][3]
- if(newVal>val):
- val=newVal
- return val
- def choice(condition, ifTrue, ifFalse):
- # equivalent of C++ (condition ? ifTrue : ifFalse)
- if condition:
- return ifTrue
- else:
- return ifFalse
- class MiniLog:
- def __init__(self, name):
- self.indent = 1
- self.name = name
- self.lines = []
- def __str__(self):
- return '%s\nMiniLog: %s\n%s\n%s\n%s' % \
- ('*'*50, self.name, '-'*50, '\n'.join(self.lines), '*'*50)
-
- def enterFunction(self, funcName, *args, **kw):
- if args:
- rArgs = [args[0].__class__.__name__ + ', ']
- else:
- rArgs = []
-
- rArgs += [`x`+', ' for x in args[1:]] + \
- [ x + ' = ' + '%s, ' % `y` for x,y in kw.items()]
-
- if not rArgs:
- rArgs = '()'
- else:
- rArgs = '(' + reduce(str.__add__,rArgs)[:-2] + ')'
- line = '%s%s' % (funcName, rArgs)
- self.appendFunctionCall(line)
- self.indent += 1
- return line
-
- def exitFunction(self):
- self.indent -= 1
- return self.indent
- def appendFunctionCall(self, line):
- self.lines.append(' '*(self.indent*2) + line)
- return line
-
- def appendLine(self, line):
- self.lines.append(' '*(self.indent*2) + '<< ' + line + ' >>')
- return line
- def flush(self):
- outStr = str(self)
- self.indent = 0
- self.lines = []
- return outStr
- class MiniLogSentry:
- def __init__(self, log, funcName, *args, **kw):
- self.log = log
- self.log.enterFunction(funcName, *args, **kw)
- def __del__(self):
- self.log.exitFunction()
- del self.log
-
- import __builtin__
- __builtin__.Functor = Functor
- __builtin__.Stack = Stack
- __builtin__.Queue = Queue
- __builtin__.Enum = Enum
- __builtin__.SerialNumGen = SerialNumGen
- __builtin__.ScratchPad = ScratchPad
- __builtin__.uniqueName = uniqueName
- __builtin__.serialNum = serialNum
- __builtin__.profiled = profiled
- __builtin__.set_trace = set_trace
- __builtin__.setTrace = setTrace
- __builtin__.pm = pm
- __builtin__.itype = itype
- __builtin__.exceptionLogged = exceptionLogged
- __builtin__.appendStr = appendStr
- __builtin__.bound = bound
- __builtin__.lerp = lerp
- __builtin__.notNone = notNone
- __builtin__.clampScalar = clampScalar
- __builtin__.makeList = makeList
- __builtin__.makeTuple = makeTuple
- __builtin__.printStack = printStack
- __builtin__.printVerboseStack = printVerboseStack
- __builtin__.DelayedCall = DelayedCall
- __builtin__.DelayedFunctor = DelayedFunctor
- __builtin__.FrameDelayedCall = FrameDelayedCall
- __builtin__.SubframeCall = SubframeCall
- __builtin__.ArgumentEater = ArgumentEater
- __builtin__.ClassTree = ClassTree
- __builtin__.invertDict = invertDict
- __builtin__.invertDictLossless = invertDictLossless
- __builtin__.getBase = getBase
- __builtin__.safeRepr = safeRepr
- __builtin__.fastRepr = fastRepr
- __builtin__.nullGen = nullGen
- __builtin__.flywheel = flywheel
- __builtin__.loopGen = loopGen
- __builtin__.StackTrace = StackTrace
- __builtin__.choice = choice
- __builtin__.report = report
- __builtin__.MiniLog = MiniLog
- __builtin__.MiniLogSentry = MiniLogSentry
|