Commit bbbc13c2 authored by Chrysostomos Nanakos's avatar Chrysostomos Nanakos
Browse files

pithos: Expose Archipelago pool to modular backend

parent e288b3c0
......@@ -56,7 +56,7 @@ class ArchipelagoBlocker(object):
emptyhash = hasher.digest()
self.blocksize = blocksize
self.ioctx_pool = glue.WorkerGlue().ioctx_pool
self.ioctx_pool = glue.WorkerGlue.ioctx_pool
self.dst_port = int(cfg.getint('mapperd', 'blockerb_port'))
self.hashtype = hashtype
self.hashlen = len(emptyhash)
......
......@@ -49,7 +49,7 @@ class ArchipelagoMapper(object):
self.namelen = params['namelen']
cfg = ConfigParser.ConfigParser()
cfg.readfp(open(params['archipelago_cfile']))
self.ioctx_pool = glue.WorkerGlue().ioctx_pool
self.ioctx_pool = glue.WorkerGlue.ioctx_pool
self.dst_port = int(cfg.getint('mapperd', 'blockerm_port'))
self.mapperd_port = int(cfg.getint('vlmcd', 'mapper_port'))
......
......@@ -302,6 +302,8 @@ class ModularBackend(BaseBackend):
glue.WorkerGlue.setupXsegPool(ObjectPool, Segment, Xseg_ctx,
cfile=archipelago_conf_file,
pool_size=xseg_pool_size)
self.ioctx_pool = glue.WorkerGlue.ioctx_pool
self.block_module = load_module(block_module)
self.block_params = block_params
params = {'path': block_path,
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment