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 de3a730534e..b3b14fa7478 100644 --- a/xlators/features/changelog/src/changelog-rpc-common.c +++ b/xlators/features/changelog/src/changelog-rpc-common.c @@ -52,7 +52,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 067db6d4b76..10bd24f3916 100644 --- a/xlators/features/quota/src/quota-enforcer-client.c +++ b/xlators/features/quota/src/quota-enforcer-client.c @@ -453,7 +453,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 0fe3687e204..4b6132629db 100644 --- a/xlators/features/snapview-server/src/snapview-server-mgmt.c +++ b/xlators/features/snapview-server/src/snapview-server-mgmt.c @@ -85,7 +85,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 38d93725d96..3768a875af7 100644 --- a/xlators/mgmt/glusterd/src/glusterd-handler.c +++ b/xlators/mgmt/glusterd/src/glusterd-handler.c @@ -3295,7 +3295,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 a1127a30695..ac45b4f9350 100644 --- a/xlators/nfs/server/src/nlm4.c +++ b/xlators/nfs/server/src/nlm4.c @@ -1055,7 +1055,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 db7a07a4fb8..ccb26dd76aa 100644 --- a/xlators/protocol/client/src/client.c +++ b/xlators/protocol/client/src/client.c @@ -2286,7 +2286,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"); |