IntenseWebs/freeipa
3
0
Fork 0
mirror of https://salsa.debian.org/freeipa-team/freeipa.git synced 2025-01-26 16:16:31 -06:00
Code Issues Packages Projects Releases Wiki Activity

Allow creation of new connections by unshared instances of backend.Connectible.

Browse Source
This commit is contained in:
Pavel Zuna 2010-01-05 13:38:20 +01:00 committed by Rob Crittenden
parent 49fb5ad493
commit 314fe71787
2 changed files with 22 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
ipalib/backend.py
View File

@ -44,52 +44,60 @@ class Connectible(Backend):
`request.destroy_context()` can properly close all open connections.
"""
def __init__(self, shared_instance=True):
Backend.__init__(self)
if shared_instance:
self.id = self.name
else:
self.id = '%s_%s' % (self.name, str(id(self)))
def connect(self, *args, **kw):
"""
Create thread-local connection.
"""
if hasattr(context, self.name):
if hasattr(context, self.id):
raise StandardError(
"connect: 'context.%s' already exists in thread %r" % (
self.name, threading.currentThread().getName()
self.id, threading.currentThread().getName()
)
)
conn = self.create_connection(*args, **kw)
setattr(context, self.name, Connection(conn, self.disconnect))
setattr(context, self.id, Connection(conn, self.disconnect))
assert self.conn is conn
self.info('Created connection context.%s' % self.name)
self.info('Created connection context.%s' % self.id)
def create_connection(self, *args, **kw):
raise NotImplementedError('%s.create_connection()' % self.name)
raise NotImplementedError('%s.create_connection()' % self.id)
def disconnect(self):
if not hasattr(context, self.name):
if not hasattr(context, self.id):
raise StandardError(
"disconnect: 'context.%s' does not exist in thread %r" % (
self.name, threading.currentThread().getName()
self.id, threading.currentThread().getName()
)
)
self.destroy_connection()
self.info('Destroyed connection context.%s' % self.name)
delattr(context, self.id)
self.info('Destroyed connection context.%s' % self.id)
def destroy_connection(self):
raise NotImplementedError('%s.destroy_connection()' % self.name)
raise NotImplementedError('%s.destroy_connection()' % self.id)
def isconnected(self):
"""
Return ``True`` if thread-local connection on `request.context` exists.
"""
return hasattr(context, self.name)
return hasattr(context, self.id)
def __get_conn(self):
"""
Return thread-local connection.
"""
if not hasattr(context, self.name):
if not hasattr(context, self.id):
raise AttributeError('no context.%s in thread %r' % (
self.name, threading.currentThread().getName())
self.id, threading.currentThread().getName())
)
return getattr(context, self.name).conn
return getattr(context, self.id).conn
conn = property(__get_conn)

2
ipalib/request.py
View File

@ -52,10 +52,10 @@ def destroy_context():
"""
Delete all attributes on thread-local `request.context`.
"""
# need to use .items(), 'cos value.disconnect modifies the dict
for (name, value) in context.__dict__.items():
if isinstance(value, Connection):
value.disconnect()
delattr(context, name)
def ugettext(message):