diff options
Diffstat (limited to 'xlators/cluster/dht/src/dht-shared.c')
-rw-r--r-- | xlators/cluster/dht/src/dht-shared.c | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/xlators/cluster/dht/src/dht-shared.c b/xlators/cluster/dht/src/dht-shared.c index f8faecf6870..22a7260f829 100644 --- a/xlators/cluster/dht/src/dht-shared.c +++ b/xlators/cluster/dht/src/dht-shared.c @@ -218,6 +218,9 @@ dht_fini (xlator_t *this) GF_FREE (conf->subvolume_status); + if (conf->lock_pool) + mem_pool_destroy (conf->lock_pool); + GF_FREE (conf); } out: @@ -663,6 +666,14 @@ dht_init (xlator_t *this) GF_OPTION_INIT ("weighted-rebalance", conf->do_weighting, bool, err); + conf->lock_pool = mem_pool_new (dht_lock_t, 512); + if (!conf->lock_pool) { + gf_msg (this->name, GF_LOG_ERROR, 0, DHT_MSG_INIT_FAILED, + "failed to create lock mem_pool, failing " + "initialization"); + goto err; + } + this->private = conf; return 0; @@ -688,6 +699,9 @@ err: GF_FREE (conf->link_xattr_name); GF_FREE (conf->wild_xattr_name); + if (conf->lock_pool) + mem_pool_destroy (conf->lock_pool); + GF_FREE (conf); } |