diff options
Diffstat (limited to 'xlators')
| -rw-r--r-- | xlators/features/changelog/src/changelog-rpc-common.c | 2 | ||||
| -rw-r--r-- | xlators/features/quota/src/quota-enforcer-client.c | 2 | ||||
| -rw-r--r-- | xlators/features/snapview-server/src/snapview-server-mgmt.c | 2 | ||||
| -rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-conn-mgmt.c | 2 | ||||
| -rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-handler.c | 2 | ||||
| -rw-r--r-- | xlators/nfs/server/src/nlm4.c | 2 | ||||
| -rw-r--r-- | xlators/protocol/client/src/client.c | 2 |
7 files changed, 7 insertions, 7 deletions
diff --git a/xlators/features/changelog/src/changelog-rpc-common.c b/xlators/features/changelog/src/changelog-rpc-common.c index 7d2ec1de988..e8905a87f62 100644 --- a/xlators/features/changelog/src/changelog-rpc-common.c +++ b/xlators/features/changelog/src/changelog-rpc-common.c @@ -53,7 +53,7 @@ changelog_rpc_client_init (xlator_t *this, void *cbkdata, goto dealloc_dict; } - rpc = rpc_clnt_new (options, this->ctx, this->name, 16); + rpc = rpc_clnt_new (options, this, this->name, 16); if (!rpc) goto dealloc_dict; diff --git a/xlators/features/quota/src/quota-enforcer-client.c b/xlators/features/quota/src/quota-enforcer-client.c index 09df3534a75..6f36c081dbc 100644 --- a/xlators/features/quota/src/quota-enforcer-client.c +++ b/xlators/features/quota/src/quota-enforcer-client.c @@ -448,7 +448,7 @@ quota_enforcer_init (xlator_t *this, dict_t *options) if (ret) goto out; - rpc = rpc_clnt_new (options, this->ctx, this->name, 16); + rpc = rpc_clnt_new (options, this, this->name, 16); if (!rpc) { ret = -1; goto out; diff --git a/xlators/features/snapview-server/src/snapview-server-mgmt.c b/xlators/features/snapview-server/src/snapview-server-mgmt.c index 53dd6ff44af..fc2ff2ab10d 100644 --- a/xlators/features/snapview-server/src/snapview-server-mgmt.c +++ b/xlators/features/snapview-server/src/snapview-server-mgmt.c @@ -80,7 +80,7 @@ svs_mgmt_init (xlator_t *this) goto out; } - priv->rpc = rpc_clnt_new (options, this->ctx, this->name, 8); + priv->rpc = rpc_clnt_new (options, this, this->name, 8); if (!priv->rpc) { gf_log (this->name, GF_LOG_ERROR, "failed to initialize RPC"); goto out; diff --git a/xlators/mgmt/glusterd/src/glusterd-conn-mgmt.c b/xlators/mgmt/glusterd/src/glusterd-conn-mgmt.c index fca9323a180..607a0655432 100644 --- a/xlators/mgmt/glusterd/src/glusterd-conn-mgmt.c +++ b/xlators/mgmt/glusterd/src/glusterd-conn-mgmt.c @@ -46,7 +46,7 @@ glusterd_conn_init (glusterd_conn_t *conn, char *sockpath, goto out; /* @options is free'd by rpc_transport when destroyed */ - rpc = rpc_clnt_new (options, this->ctx, (char *)svc->name, 16); + rpc = rpc_clnt_new (options, this, (char *)svc->name, 16); if (!rpc) { ret = -1; goto out; diff --git a/xlators/mgmt/glusterd/src/glusterd-handler.c b/xlators/mgmt/glusterd/src/glusterd-handler.c index 7ead1f5ab70..085a63b4592 100644 --- a/xlators/mgmt/glusterd/src/glusterd-handler.c +++ b/xlators/mgmt/glusterd/src/glusterd-handler.c @@ -3291,7 +3291,7 @@ glusterd_rpc_create (struct rpc_clnt **rpc, GF_ASSERT (options); /* TODO: is 32 enough? or more ? */ - new_rpc = rpc_clnt_new (options, this->ctx, this->name, 16); + new_rpc = rpc_clnt_new (options, this, this->name, 16); if (!new_rpc) goto out; diff --git a/xlators/nfs/server/src/nlm4.c b/xlators/nfs/server/src/nlm4.c index 7343fea8cd6..26c45e089b0 100644 --- a/xlators/nfs/server/src/nlm4.c +++ b/xlators/nfs/server/src/nlm4.c @@ -1050,7 +1050,7 @@ nlm4_establish_callback (void *csarg) } /* TODO: is 32 frames in transit enough ? */ - rpc_clnt = rpc_clnt_new (options, cs->nfsx->ctx, "NLM-client", 32); + rpc_clnt = rpc_clnt_new (options, cs->nfsx, "NLM-client", 32); if (rpc_clnt == NULL) { gf_msg (GF_NLM, GF_LOG_ERROR, EINVAL, NFS_MSG_INVALID_ENTRY, "rpc_clnt NULL"); diff --git a/xlators/protocol/client/src/client.c b/xlators/protocol/client/src/client.c index fcf6e375af8..b8f467622d5 100644 --- a/xlators/protocol/client/src/client.c +++ b/xlators/protocol/client/src/client.c @@ -2281,7 +2281,7 @@ client_init_rpc (xlator_t *this) goto out; } - conf->rpc = rpc_clnt_new (this->options, this->ctx, this->name, 0); + conf->rpc = rpc_clnt_new (this->options, this, this->name, 0); if (!conf->rpc) { gf_msg (this->name, GF_LOG_ERROR, 0, PC_MSG_RPC_INIT_FAILED, "failed to initialize RPC"); |