fix pool creation

diff --git a/snf-pithos-backend/pithos/backends/lib/hashfiler/radosblocker.py b/snf-pithos-backend/pithos/backends/lib/hashfiler/radosblocker.py
index d0e478d..4ddd784 100644 (file)
--- a/snf-pithos-backend/pithos/backends/lib/hashfiler/radosblocker.py
+++ b/snf-pithos-backend/pithos/backends/lib/hashfiler/radosblocker.py
@@ -55,7 +55,7 @@ class RadosBlocker(object):
         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)
 

diff --git a/snf-pithos-backend/pithos/backends/lib/hashfiler/radosmapper.py b/snf-pithos-backend/pithos/backends/lib/hashfiler/radosmapper.py
index b73b28b..244731a 100644 (file)
--- a/snf-pithos-backend/pithos/backends/lib/hashfiler/radosmapper.py
+++ b/snf-pithos-backend/pithos/backends/lib/hashfiler/radosmapper.py
@@ -54,7 +54,7 @@ class RadosMapper(object):
         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)
 

diff --git a/snf-pithos-backend/pithos/backends/lib/hashfiler/store.py b/snf-pithos-backend/pithos/backends/lib/hashfiler/store.py
index 36848aa..8e99032 100644 (file)
--- a/snf-pithos-backend/pithos/backends/lib/hashfiler/store.py
+++ b/snf-pithos-backend/pithos/backends/lib/hashfiler/store.py
@@ -57,11 +57,11 @@ class Store(object):
         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):