Skip to content
Find file
Fetching contributors…
Cannot retrieve contributors at this time
837 lines (752 sloc) 23.5 KB
# Import PyObjC here. This is because the first import of PyObjC *must* be
# in the main thread. Otherwise, the NSAutoreleasePool created automatically
# by PyObjC on the first import would be released at exit by the main thread
# which would crash (because it was created in a different thread).
import objc
except ImportError:
# probably not MacOSX. doesn't matter
from collections import deque
from threading import Condition, Thread, currentThread, Lock, RLock
import sys, os
import better_exchook
class Id:
"When you need some unique object with maybe some name, use this"
name = None
def __init__(self, name=None): = name
def __repr__(self):
if return "<Id %s>" %
return "<Id %i>" % id(self)
class OnRequestQueue:
class QueueEnd:
def __init__(self, listType=deque):
self.q = listType()
self.cond = Condition()
self.cancel = False
def put(self, item):
with self.cond:
if self.cancel: return False
def setCancel(self):
with self.cond:
self.cancel = True
def __init__(self):
self.queues = set()
def put(self, item):
for q in list(self.queues):
def cancelAll(self):
for q in list(self.queues):
def read(self, *otherQueues, **kwargs):
q = self.QueueEnd(**kwargs)
thread = currentThread()
thread.waitQueue = q
if thread.cancel:
# This is to avoid a small race condition for the case
# that the thread which wants to join+cancel us was faster
# and didn't got the waitQueue. In that case, it would
# have set the cancel already to True.
for reqqu in otherQueues: assert(isinstance(reqqu, OnRequestQueue))
reqQueues = (self,) + otherQueues
for reqqu in reqQueues: reqqu.queues.add(q)
while True:
with q.cond:
l = list(q.q)
cancel = q.cancel
if not l and not cancel:
for item in l:
yield item
if cancel: break
for reqqu in reqQueues: reqqu.queues.remove(q)
class EventCallback:
def __init__(self, targetQueue, name=None, extraCall=None):
self.targetQueue = targetQueue = name
self.extraCall = extraCall
def __call__(self, *args, **kwargs):
if self.extraCall:
self.extraCall(*args, **kwargs)
self.targetQueue.put((self, args, kwargs))
def __repr__(self):
return "<EventCallback %s>" %
class Event:
def __init__(self):
self.lock = RLock()
self.targets = []
def push(self, *args):
with self.lock:
targets = self.targets
for weakt in targets:
t = weakt() # resolve weakref
if t: t(*args)
else: self.targets.remove(weakt)
def register(self, target):
assert sys.getrefcount(target) > 1, "target will be weakrefed, thus we need more references to it"
import weakref
with self.lock:
class initBy(object):
def __init__(self, initFunc):
self.initFunc = initFunc = initFunc.func_name
def load(self, inst):
if not hasattr(self, "value"):
self.value = self.initFunc(inst)
def __get__(self, inst, type=None):
if inst is None: # access through class
return self
if hasattr(self.value, "__get__"):
return self.value.__get__(inst, type)
return self.value
def __set__(self, inst, value):
if hasattr(self.value, "__set__"):
return self.value.__set__(inst, value)
self.value = value
class oneOf(object):
def __init__(self, *consts):
assert len(consts) > 0
self.consts = consts
self.value = consts[0]
def __get__(self, inst, type=None):
if inst is None: # access through class
return self
return self
def __set__(self, inst, value):
assert value in self.consts
self.value = value
class UserAttrib(object):
""" The idea/plan for this attrib type is:
Use it in the GUI and display it nicely. Store every GUI related info here.
I.e. this should say whether it is read-only to the user (if not visible to user at all ->
don't use this class), if it should be represented as a list, string, etc.
(this is the type, right now all Traits.TraitTypes), some other GUI decoration stuff,
Note that this lays in the utils module because it is completely decoupled
from the GUI. It only stores information which might be useful for a GUI.
staticCounter = 0
def __init__(self, name=None, type=None, writeable=False, updateHandler=None,
spaceX=None, spaceY=None,
width=None, height=None,
variableWidth=None, variableHeight=False,
highlight=False, lowlight=False,
): = name
self.type = type
self.writeable = writeable
self.updateHandler = updateHandler
self.alignRight = alignRight
self.spaceX = spaceX
self.spaceY = spaceY
self.width = width
self.height = height
self.variableWidth = variableWidth
self.variableHeight = variableHeight
self.autosizeWidth = autosizeWidth
self.highlight = highlight
self.lowlight = lowlight
self.canHaveFocus = canHaveFocus
self.withBorder = withBorder
self.searchLook = searchLook
self.autoScrolldown = autoScrolldown
self.dragHandler = dragHandler
self.__class__.staticCounter += 1
# Keep an index. This is so that we know the order of initialization later on.
# This is better for the GUI representation so we can order it the same way
# as it is defined in the class.
# iterUserAttribs() uses this.
self.index = self.__class__.staticCounter
def getTypeClass(self):
import inspect
if inspect.isclass(self.type): return self.type
return self.type.__class__
def isType(self, T):
return issubclass(self.getTypeClass(), T)
def _getUserAttribDict(inst):
if not hasattr(inst, "__userAttribs"):
setattr(inst, "__userAttribs", {})
return inst.__userAttribs
def _get(cls, name, inst):
return cls._getUserAttribDict(inst)[name]
def get(self, inst):
try: return self._get(, inst)
except KeyError: return self.value
def __get__(self, inst, type=None):
if inst is None: # access through class
return self
if hasattr(self.value, "__get__"):
return self.value.__get__(inst, type)
return self.get(inst)
def callDeco(self):
class Wrapper:
def __getattr__(_self, item):
f = getattr(self.value, item)
def wrappedFunc(arg): # a decorator expects a single arg
value = f(arg)
return self(value)
return wrappedFunc
return Wrapper()
def setUpdateEvent(self, updateProp):
self._updates = updateProp
return updateProp
def hasUpdateEvent(self):
return getattr(self, "_updates", None)
def updateEvent(self, inst, type=None):
return self._updates.__get__(inst, type)
def _set(cls, name, inst, value):
cls._getUserAttribDict(inst)[name] = value
def set(self, inst, value):
self._set(, inst, value)
def __set__(self, inst, value):
if inst is None: # access through class
self.value = value
if hasattr(self.value, "__set__"):
return self.value.__set__(inst, value)
self.set(inst, value)
def _getName(cls, obj):
if hasattr(obj, "name"): return
elif hasattr(obj, "func_name"): return obj.func_name
elif hasattr(obj, "fget"): return cls._getName(obj.fget)
return None
def __call__(self, attrib):
if not = self._getName(attrib)
self.value = attrib
return self
def __repr__(self):
return "<UserAttrib %s, %r>" % (, self.type)
def iterUserAttribs(obj):
attribs = []
for attrib in dir(obj.__class__):
attrib = getattr(obj.__class__, attrib)
if attrib.__class__.__name__ == "UserAttrib":
attribs += [attrib]
attribs.sort(key = lambda attr: attr.index)
return attribs
class safe_property(object):
def __init__(self, prop):
self.prop = prop
def __get__(self, instance, owner):
if instance is None: return self
return self.prop.__get__(instance, owner)
except AttributeError:
# We should never reraise this particular exception. Thus catch it here.
return None # The best we can do.
def __set__(self, inst, value):
self.prop.__set__(inst, value)
except AttributeError:
# We should never reraise this particular exception. Thus catch it here.
def __getattr__(self, attr):
# forward prop.setter, prop.deleter, etc.
return getattr(self.prop, attr)
def formatTime(t):
if t is None: return "?"
t = round(t)
mins = long(t // 60)
t -= mins * 60
hours = mins // 60
mins -= hours * 60
if hours: return "%02i:%02i:%02.0f" % (hours,mins,t)
return "%02i:%02.0f" % (mins,t)
def formatFilesize(s):
L = 800
Symbols = ["byte", "KB", "MB", "GB", "TB"]
i = 0
while True:
if s < L: break
if i == len(Symbols) - 1: break
s /= 1024.
i += 1
return "%.3g %s" % (s, Symbols[i])
def doAsync(f, name=None):
from threading import Thread
if name is None: name = repr(f)
t = Thread(target = f, name = name)
def betterRepr(o):
# the main difference: this one is deterministic
# the orig dict.__repr__ has the order undefined.
if isinstance(o, list):
return "[\n" + "".join(map(lambda v: betterRepr(v) + ",\n", o)) + "]"
if isinstance(o, deque):
return "deque([\n" + "".join(map(lambda v: betterRepr(v) + ",\n", o)) + "])"
if isinstance(o, tuple):
return "(" + ", ".join(map(betterRepr, o)) + ")"
if isinstance(o, dict):
return "{\n" + "".join(map(lambda (k,v): betterRepr(k) + ": " + betterRepr(v) + ",\n", sorted(o.iteritems()))) + "}"
# fallback
return repr(o)
def takeN(iterator, n):
i = 0
l = [None] * n
while i < n:
l[i] = next(iterator)
except StopIteration:
l = l[0:i]
i += 1
return l
def attrChain(base, *attribs, **kwargs):
default = kwargs.get("default", None)
obj = base
for attr in attribs:
if obj is None: return default
obj = getattr(obj, attr, None)
if obj is None: return default
return obj
def ObjectProxy(lazyLoader, custom_attribs={}, baseType=object):
class Value: pass
obj = Value()
attribs = custom_attribs.copy()
def load():
if not hasattr(obj, "value"):
obj.value = lazyLoader()
def obj_getattribute(self, key):
try: return getattr(obj.value, key)
except AttributeError:
return object.__getattribute__(self, key)
def obj_setattr(self, key, value):
return setattr(obj.value, key, value)
def obj_desc_get(self, inst, type=None):
if inst is None:
return obj.value
return self
def obj_desc_set(self, inst, value):
if hasattr(value, "__get__"):
# In case the value is itself some sort of ObjectProxy, try to get its
# underlying object and use our proxy instead.
obj.value = value.__get__(None)
obj.value = value
"__getattribute__": obj_getattribute,
"__setattr__": obj_setattr,
"__get__": obj_desc_get,
"__set__": obj_desc_set,
# just set them so that we have them in the class. needed for __len__, __str__, etc.
for a in dir(baseType):
if a == "__new__": continue
if a == "__init__": continue
if a in attribs.keys(): continue
class WrapProp(object):
def __get__(self, inst, type=None, attrib=a):
return object.__getattribute__(obj.value, attrib)
attribs[a] = WrapProp()
LazyObject = type("LazyObject", (object,), attribs)
return LazyObject()
def PersistentObject(baseType, filename, defaultArgs=(), persistentRepr = False, namespace = None):
import appinfo
fullfn = appinfo.userdir + "/" + filename
def load():
f = open(fullfn)
except IOError: # e.g. file-not-found. that's ok
return baseType(*defaultArgs)
# some common types
g = {baseType.__name__: baseType} # the baseType itself
if namespace is None:
g.update(globals()) # all what we have here
if baseType.__module__:
# the module of the basetype
import sys
m = sys.modules[baseType.__module__]
g.update([(varname,getattr(m,varname)) for varname in dir(m)])
obj = eval(, g)
# Try to convert.
if not isinstance(obj, baseType):
obj = baseType(obj)
return obj
def save(obj):
s = betterRepr(obj.__get__(None))
f = open(fullfn, "w")
def obj_repr(obj):
if persistentRepr:
return "PersistentObject(%s, %r)" % (baseType.__name__, filename)
return betterRepr(obj.__get__(None))
def obj_del(obj):
return ObjectProxy(load, baseType=baseType,
"save": save,
"__repr__": obj_repr,
"__del__": obj_del,
class DictObj(dict):
def __getattr__(self, item): return self[item]
def __setattr__(self, key, value): self[key] = value
class Module:
def __init__(self, name): = name
self.thread = None
self.module = None
def mainFuncName(self): return + "Main"
def moduleName(self): return
def start(self):
self.thread = Thread(target = self.threadMain, name = + " main")
self.thread.waitQueue = None
self.thread.cancel = False
self.thread.reload = False
def threadMain(self):
thread = currentThread()
while True:
if self.module:
except Exception:
print "couldn't reload module", self.module
# continue anyway, maybe it still works and maybe the mainFunc does sth good/important
self.module = __import__(self.moduleName)
mainFunc = getattr(self.module, self.mainFuncName)
except Exception:
print "Exception in thread",
if not thread.reload: break
sys.stdout.write("reloading module %s\n" %
thread.cancel = False
thread.reload = False
thread.waitQueue = None
def stop(self, join=True):
if not self.thread: return
waitQueue = self.thread.waitQueue # save a ref in case the other thread already removes it
self.thread.cancel = True
if waitQueue: waitQueue.setCancel()
if join:
timeout = 1
while True:
if not self.thread.isAlive(): break
sys.stdout.write("\n\nWARNING: module %s thread is hanging at stop\n" %
timeout *= 2
if timeout > 60: timeout = 60
def reload(self):
if self.thread and self.thread.isAlive():
self.thread.reload = True
def __str__(self):
return "Module %s" %
def objc_disposeClassPair(className):
# Be careful using this!
# Any objects holding refs to the old class will be invalid
# and will probably crash!
# Creating a new class after it will not make them valid because
# the new class will be at a different address.
# some discussion / example:
import ctypes
ctypes.pythonapi.objc_lookUpClass.restype = ctypes.c_void_p
ctypes.pythonapi.objc_lookUpClass.argtypes = (ctypes.c_char_p,)
addr = ctypes.pythonapi.objc_lookUpClass(className)
if not addr: return False
ctypes.pythonapi.objc_disposeClassPair.restype = None
ctypes.pythonapi.objc_disposeClassPair.argtypes = (ctypes.c_void_p,)
def objc_setClass(obj, clazz):
objAddr = objc.pyobjc_id(obj) # returns the addr and also ensures that it is an objc object
assert objAddr != 0
import ctypes
ctypes.pythonapi.objc_lookUpClass.restype = ctypes.c_void_p
ctypes.pythonapi.objc_lookUpClass.argtypes = (ctypes.c_char_p,)
className = clazz.__name__ # this should be correct I guess
classAddr = ctypes.pythonapi.objc_lookUpClass(className)
assert classAddr != 0
# Class object_setClass(id object, Class cls)
ctypes.pythonapi.object_setClass.restype = ctypes.c_void_p
ctypes.pythonapi.object_setClass.argtypes = (ctypes.c_void_p,ctypes.c_void_p)
ctypes.pythonapi.object_setClass(objAddr, classAddr)
obj.__class__ = clazz
def do_in_mainthread(f, wait=True):
# Note: We don't need/want the NSThread.isMainThread() check and extra handling.
# The `performSelectorOnMainThread:withObject:waitUntilDone:` does the right thing
# in case we are the main thread: if wait is True, it is executed from here,
# otherwise it is queued and executed in the next frame.
NSObject = objc.lookUpClass("NSObject")
class PyAsyncCallHelper(NSObject):
def initWithArgs_(self, f):
self.f = f
self.ret = None
self.exc = None
return self
def call_(self, o):
self.ret = self.f()
except (KeyboardInterrupt,SystemExit) as exc:
self.exc = exc
print "Exception in PyAsyncCallHelper call"
except Exception:
PyAsyncCallHelper = objc.lookUpClass("PyAsyncCallHelper") # already defined earlier
helper = PyAsyncCallHelper.alloc().initWithArgs_(f)
helper.performSelectorOnMainThread_withObject_waitUntilDone_(helper.call_, None, wait)
if wait and helper.exc:
raise helper.exc
return helper.ret
def ObjCClassAutorenamer(name, bases, dict):
def lookUpClass(name):
try: return objc.lookUpClass(name)
except objc.nosuchclass_error: return None
if lookUpClass(name):
numPostfix = 1
while lookUpClass("%s_%i" % (name, numPostfix)):
numPostfix += 1
name = "%s_%i" % (name, numPostfix)
return type(name, bases, dict)
def getMusicPathsFromDirectory(dir):
import os, appinfo
matches = []
for root, dirnames, filenames in os.walk(dir):
for filename in filenames:
if filename.endswith(tuple(appinfo.formats)):
matches.append(os.path.join(root, filename))
return matches
def getSongsFromDirectory(dir):
songs = []
files = getMusicPathsFromDirectory(dir)
from Song import Song
for file in files:
return songs
# A fuzzy set is a dict of values to [0,1] numbers.
def unionFuzzySets(*fuzzySets):
resultSet = {}
for key in set.union(*map(set, fuzzySets)):
value = max(map(lambda x: x.get(key, 0), fuzzySets))
if value > 0:
resultSet[key] = value
return resultSet
def intersectFuzzySets(*fuzzySets):
resultSet = {}
for key in set.intersection(*map(set, fuzzySets)):
value = min(map(lambda x: x[key], fuzzySets))
if value > 0:
resultSet[key] = value
return resultSet
def convertToUnicode(value):
if isinstance(value, unicode): return value
assert isinstance(value, str)
value = value.decode("utf-8")
except UnicodeError:
value = value.decode() # default
except UnicodeError:
value = value.decode("iso-8859-1")
except UnicodeError:
value = value.decode("utf-8", "replace")
#value = value.replace(u"\ufffd", "?")
assert isinstance(value, unicode)
return value
def fixValue(value):
if isinstance(value, str): return convertToUnicode(value)
return value
def iterGlobalsUsedInFunc(f, fast=False, loadsOnly=True):
if hasattr(f, "func_code"): code = f.func_code
elif hasattr(f, "im_func"): code = f.im_func.func_code
else: code = f
if fast:
# co_names is the list of all names which are used.
# These are mostly the globals. These are also attrib names, so these are more...
for name in code.co_names:
yield name
# Use the disassembly. Note that this will still not
# find dynamic lookups to `globals()`
# (which is anyway not possible to detect always).
import dis
ops = ["LOAD_GLOBAL"]
if not loadsOnly:
ops = map(dis.opmap.__getitem__, ops)
i = 0
while i < len(code.co_code):
op = ord(code.co_code[i])
i += 1
if op >= dis.HAVE_ARGUMENT:
oparg = ord(code.co_code[i]) + ord(code.co_code[i+1])*256
i += 2
oparg = None
if op in ops:
name = code.co_names[oparg]
yield name
# iterate through sub code objects
import types
for subcode in code.co_consts:
if isinstance(subcode, types.CodeType):
for g in iterGlobalsUsedInFunc(subcode, fast=fast, loadsOnly=loadsOnly):
yield g
def iterGlobalsUsedInClass(clazz, module=None):
import types
for attrName in dir(clazz):
attr = getattr(clazz, attrName)
while True: # resolve props
if isinstance(attr, safe_property):
attr = attr.prop
if isinstance(attr, property):
attr = attr.fget
if isinstance(attr, (types.FunctionType, types.MethodType)):
if module:
if attr.__module__ != module:
for g in iterGlobalsUsedInFunc(attr): yield g
# This is needed in some cases to avoid pickling problems with bounded funcs.
def funcCall(attrChainArgs, args=()):
f = attrChain(*attrChainArgs)
return f(*args)
class AsyncTask:
def __init__(self, func, name=None):
from multiprocessing import Process, Pipe, Queue = name or "unnamed"
self.func = func
self.parent_conn, self.child_conn = Pipe()
self.parent_pid = os.getpid()
self.proc = Process(
target = self._asyncCall,
args = (self,),
name = + " worker process")
self.proc.daemon = True
self.child_pid =
assert self.child_pid
self.conn = self.parent_conn
def _asyncCall(self):
assert self.isChild
self.conn = self.child_conn # we are the child
print "Exception in AsyncTask",
def put(self, value):
def get(self):
thread = currentThread()
thread.waitQueue = self
res = self.conn.recv()
thread.waitQueue = None
return res
def isParent(self):
return self.parent_pid == os.getpid()
def isChild(self):
if self.isParent: return False
assert self.parent_pid == os.getppid()
return True
# This might be called from the module code.
# See OnRequestQueue which implements the same interface.
def setCancel(self):
if self.isParent and self.child_pid:
import signal
os.kill(self.child_pid, signal.SIGINT)
self.child_pid = None
def test(cls):
def asyncCall(func, name=None):
def doCall(queue):
res = None
res = func()
except BaseException as exc:
print "Exception in asyncCall", name
task = AsyncTask(func=doCall, name=name)
# If there is an unhandled exception in doCall or the process got killed/segfaulted or so,
# this will raise an EOFError here.
# However, normally, we should catch all exceptions and just reraise them here.
exc,res = task.get()
if exc is not None:
raise exc
return res
def killMeHard():
import sys, os, signal
os.kill(0, signal.SIGKILL)
def dumpAllThreads():
import threading, sys, traceback
id2name = dict([(th.ident, for th in threading.enumerate()])
code = []
for threadId, stack in sys._current_frames().items():
code.append("\n# Thread: %s(%d)" % (id2name.get(threadId,""), threadId))
for filename, lineno, name, line in traceback.extract_stack(stack):
code.append('File: "%s", line %d, in %s' % (filename, lineno, name))
if line:
code.append(" %s" % (line.strip()))
print "\n".join(code)
def dumpThread(threadId):
import threading, sys, traceback
if threadId not in sys._current_frames():
print "Thread", threadId, "not found"
code = []
stack = sys._current_frames()[threadId]
for filename, lineno, name, line in traceback.extract_stack(stack):
code.append('File: "%s", line %d, in %s' % (filename, lineno, name))
if line:
code.append(" %s" % (line.strip()))
print "\n".join(code)
def test():
Something went wrong with that request. Please try again.