Revision 47462eda snf-pithos-backend/pithos/backends/util.py
b/snf-pithos-backend/pithos/backends/util.py | ||
---|---|---|
43 | 43 |
class PithosBackendPool(ObjectPool): |
44 | 44 |
def __init__(self, size=None, db_module=None, db_connection=None, |
45 | 45 |
block_module=None, block_path=None, block_umask=None, |
46 |
queue_module=None, queue_connection=None): |
|
46 |
queue_module=None, queue_connection=None, |
|
47 |
block_params=None): |
|
47 | 48 |
super(PithosBackendPool, self).__init__(size=size) |
48 | 49 |
self.db_module = db_module |
49 | 50 |
self.db_connection = db_connection |
... | ... | |
52 | 53 |
self.block_umask = block_umask |
53 | 54 |
self.queue_module = queue_module |
54 | 55 |
self.queue_connection = queue_connection |
56 |
self.block_params = block_params |
|
55 | 57 |
|
56 | 58 |
def _pool_create(self): |
57 | 59 |
backend = connect_backend(db_module=self.db_module, |
... | ... | |
60 | 62 |
block_path=self.block_path, |
61 | 63 |
block_umask=self.block_umask, |
62 | 64 |
queue_module=self.queue_module, |
63 |
queue_connection=self.queue_connection) |
|
65 |
queue_connection=self.queue_connection, |
|
66 |
block_params=self.block_params) |
|
64 | 67 |
|
65 | 68 |
backend._real_close = backend.close |
66 | 69 |
backend.close = instancemethod(_pooled_backend_close, backend, |
Also available in: Unified diff