diff options
Diffstat (limited to 'libglusterfs/src/transport.c')
-rw-r--r-- | libglusterfs/src/transport.c | 37 |
1 files changed, 20 insertions, 17 deletions
diff --git a/libglusterfs/src/transport.c b/libglusterfs/src/transport.c index aee809117..d460d0209 100644 --- a/libglusterfs/src/transport.c +++ b/libglusterfs/src/transport.c @@ -52,7 +52,8 @@ transport_load (dict_t *options, GF_VALIDATE_OR_GOTO("transport", options, fail); GF_VALIDATE_OR_GOTO("transport", xl, fail); - trans = CALLOC (1, sizeof (struct transport)); + trans = GF_CALLOC (1, sizeof (struct transport), + gf_common_mt_transport); GF_VALIDATE_OR_GOTO("transport", trans, fail); trans->xl = xl; @@ -107,14 +108,14 @@ transport_load (dict_t *options, ret = dict_get_str (options, "transport-type", &type); if (ret < 0) { - FREE (trans); + GF_FREE (trans); gf_log ("transport", GF_LOG_ERROR, "'option transport-type <xx>' missing in volume '%s'", xl->name); goto fail; } - ret = asprintf (&name, "%s/%s.so", TRANSPORTDIR, type); + ret = gf_asprintf (&name, "%s/%s.so", TRANSPORTDIR, type); if (-1 == ret) { gf_log ("transport", GF_LOG_ERROR, "asprintf failed"); goto fail; @@ -129,17 +130,17 @@ transport_load (dict_t *options, "volume '%s': transport-type '%s' is not valid or " "not found on this machine", xl->name, type); - FREE (name); - FREE (trans); + GF_FREE (name); + GF_FREE (trans); goto fail; } - FREE (name); + GF_FREE (name); trans->ops = dlsym (handle, "tops"); if (trans->ops == NULL) { gf_log ("transport", GF_LOG_ERROR, "dlsym (transport_ops) on %s", dlerror ()); - FREE (trans); + GF_FREE (trans); goto fail; } @@ -147,7 +148,7 @@ transport_load (dict_t *options, if (trans->init == NULL) { gf_log ("transport", GF_LOG_ERROR, "dlsym (gf_transport_init) on %s", dlerror ()); - FREE (trans); + GF_FREE (trans); goto fail; } @@ -155,11 +156,12 @@ transport_load (dict_t *options, if (trans->fini == NULL) { gf_log ("transport", GF_LOG_ERROR, "dlsym (gf_transport_fini) on %s", dlerror ()); - FREE (trans); + GF_FREE (trans); goto fail; } - vol_opt = CALLOC (1, sizeof (volume_opt_list_t)); + vol_opt = GF_CALLOC (1, sizeof (volume_opt_list_t), + gf_common_mt_volume_opt_list_t); vol_opt->given_opt = dlsym (handle, "options"); if (vol_opt->given_opt == NULL) { gf_log ("transport", GF_LOG_DEBUG, @@ -171,7 +173,7 @@ transport_load (dict_t *options, vol_opt->given_opt)) { gf_log ("transport", GF_LOG_ERROR, "volume option validation failed"); - FREE (trans); + GF_FREE (trans); goto fail; } } @@ -180,7 +182,7 @@ transport_load (dict_t *options, if (ret != 0) { gf_log ("transport", GF_LOG_ERROR, "'%s' initialization failed", type); - FREE (trans); + GF_FREE (trans); goto fail; } @@ -204,7 +206,8 @@ transport_submit (transport_t *this, char *buf, int32_t len, if (this->peer_trans) { peer_trans = this->peer_trans; - msg = CALLOC (1, sizeof (*msg)); + msg = GF_CALLOC (1, sizeof (*msg), + gf_common_mt_transport_msg); if (!msg) { return -ENOMEM; } @@ -215,8 +218,8 @@ transport_submit (transport_t *this, char *buf, int32_t len, if (vector) { iobuf = iobuf_get (this->xl->ctx->iobuf_pool); if (!iobuf) { - FREE (msg->hdr); - FREE (msg); + GF_FREE (msg->hdr); + GF_FREE (msg); return -ENOMEM; } @@ -293,7 +296,7 @@ transport_destroy (transport_t *this) this->fini (this); pthread_mutex_destroy (&this->lock); - FREE (this); + GF_FREE (this); fail: return ret; } @@ -391,7 +394,7 @@ transport_peerproc (void *trans_data) xlator_notify (trans->xl, GF_EVENT_POLLIN, trans); - FREE (msg); + GF_FREE (msg); } } |