rados = Rados(conffile=CEPH_CONF_FILE)
rados.connect()
if not rados.pool_exists(blockpool):
- rados.pool_create(blockpool)
+ rados.create_pool(blockpool)
ioctx = rados.open_ioctx(blockpool)
rados = Rados(conffile=CEPH_CONF_FILE)
rados.connect()
if not rados.pool_exists(mappool):
- rados.pool_create(mappool)
+ rados.create_pool(mappool)
ioctx = rados.open_ioctx(mappool)
p = {'blocksize': params['block_size'],
'blockpath': os.path.join(path + '/blocks'),
'hashtype': params['hash_algorithm'],
- 'blockpool': params['blockpool']}
+ 'blockpool': params['blockpool']}
self.blocker = Blocker(**p)
p = {'mappath': os.path.join(path + '/maps'),
'namelen': self.blocker.hashlen,
- 'mappool': params['mappool']}
+ 'mappool': params['mappool']}
self.mapper = Mapper(**p)
def map_get(self, name):