Revision df8debbb
b/snf-pithos-backend/pithos/backends/lib/hashfiler/radosblocker.py | ||
---|---|---|
55 | 55 |
rados = Rados(conffile=CEPH_CONF_FILE) |
56 | 56 |
rados.connect() |
57 | 57 |
if not rados.pool_exists(blockpool): |
58 |
rados.pool_create(blockpool)
|
|
58 |
rados.create_pool(blockpool)
|
|
59 | 59 |
|
60 | 60 |
ioctx = rados.open_ioctx(blockpool) |
61 | 61 |
|
b/snf-pithos-backend/pithos/backends/lib/hashfiler/radosmapper.py | ||
---|---|---|
54 | 54 |
rados = Rados(conffile=CEPH_CONF_FILE) |
55 | 55 |
rados.connect() |
56 | 56 |
if not rados.pool_exists(mappool): |
57 |
rados.pool_create(mappool)
|
|
57 |
rados.create_pool(mappool)
|
|
58 | 58 |
|
59 | 59 |
ioctx = rados.open_ioctx(mappool) |
60 | 60 |
|
b/snf-pithos-backend/pithos/backends/lib/hashfiler/store.py | ||
---|---|---|
57 | 57 |
p = {'blocksize': params['block_size'], |
58 | 58 |
'blockpath': os.path.join(path + '/blocks'), |
59 | 59 |
'hashtype': params['hash_algorithm'], |
60 |
'blockpool': params['blockpool']}
|
|
60 |
'blockpool': params['blockpool']}
|
|
61 | 61 |
self.blocker = Blocker(**p) |
62 | 62 |
p = {'mappath': os.path.join(path + '/maps'), |
63 | 63 |
'namelen': self.blocker.hashlen, |
64 |
'mappool': params['mappool']}
|
|
64 |
'mappool': params['mappool']}
|
|
65 | 65 |
self.mapper = Mapper(**p) |
66 | 66 |
|
67 | 67 |
def map_get(self, name): |
Also available in: Unified diff