From df8debbbfbe3b33ee0e821158a3fbd60a7dbcd9c Mon Sep 17 00:00:00 2001 From: Filippos Giannakos Date: Mon, 26 Nov 2012 15:30:52 +0200 Subject: [PATCH] fix pool creation --- snf-pithos-backend/pithos/backends/lib/hashfiler/radosblocker.py | 2 +- snf-pithos-backend/pithos/backends/lib/hashfiler/radosmapper.py | 2 +- snf-pithos-backend/pithos/backends/lib/hashfiler/store.py | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) 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 --- 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 --- 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 --- 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): -- 1.7.10.4