Mikaela/Limnoria
1
0
Fork 0
mirror of https://github.com/Mikaela/Limnoria.git synced 2025-01-11 04:32:36 +01:00
Code Issues Projects Releases Wiki Activity

Fixed a bug in the way Synchronized was implemented.

Browse Source
This commit is contained in:
Jeremy Fincher 2005-05-16 00:23:44 +00:00
parent ce74fa825e
commit 79fc5b5994
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/utils/python.py
View File

@ -65,7 +65,13 @@ class Acquire(object):
class Synchronized(type):
def __new__(cls, name, bases, dict):
sync = set()
for base in bases:
if hasattr(base, '__synchronized__'):
sync.update(base.__synchronized__)
if '__synchronized__' in dict:
sync.update(dict['__synchronized__'])
if sync:
def synchronized(f):
def g(self, *args, **kwargs):
self._Synchronized_rlock.acquire()
@ -74,13 +80,9 @@ class Synchronized(type):
finally:
self._Synchronized_rlock.release()
return changeFunctionName(g, f.func_name, f.__doc__)
for attr in dict['__synchronized__']:
for attr in sync:
if attr in dict:
dict[attr] = synchronized(dict[attr])
else:
def f(self, *args, **kwargs):
getattr(super(newclass, self), attr)(args, kwargs)
dict[attr] = synchronized(changeFunctionName(f, attr))
original__init__ = dict.get('__init__')
def __init__(self, *args, **kwargs):
if not hasattr(self, '_Synchronized_rlock'):