diff options
author | Avra Sengupta <asengupt@redhat.com> | 2013-10-08 21:36:06 +0530 |
---|---|---|
committer | shishir gowda <sgowda@redhat.com> | 2013-11-15 12:37:58 +0530 |
commit | 7f8480fa85347d37b4dfd2adef71599f70119ace (patch) | |
tree | 79d7a2e2bc3717df5d44ad7786afca3f88d9e339 /xlators/mgmt/glusterd/src/glusterd-syncop.c | |
parent | f8a158134d89b25063b059cd4241ffc84c48f469 (diff) |
glusterd/mgmt_v3: Initating complete synctask on glusterd
glusterd mgmt_v3 is nothing but a complete synctask approach
for glusterd to function. The commands making use of this
won't be using the op-state machine to inject events and
will be using the synctask framework to perform operations
across all nodes in the cluster. This patch defines the
program and the handlers used.
Change-Id: Ibff2c62b0187c40cdea7254c85786297bba60372
Signed-off-by: Avra Sengupta <asengupt@redhat.com>
Diffstat (limited to 'xlators/mgmt/glusterd/src/glusterd-syncop.c')
-rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-syncop.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-syncop.c b/xlators/mgmt/glusterd/src/glusterd-syncop.c index dbd086feb..e765d28ee 100644 --- a/xlators/mgmt/glusterd/src/glusterd-syncop.c +++ b/xlators/mgmt/glusterd/src/glusterd-syncop.c @@ -417,7 +417,7 @@ _gd_syncop_mgmt_volume_lock_cbk (struct rpc_req *req, struct iovec *iov, int ret = -1; struct syncargs *args = NULL; glusterd_peerinfo_t *peerinfo = NULL; - gd1_mgmt_volume_lock_rsp rsp = {{0},}; + gd1_mgmt_v3_vol_lock_rsp rsp = {{0},}; call_frame_t *frame = NULL; int op_ret = -1; int op_errno = -1; @@ -438,7 +438,7 @@ _gd_syncop_mgmt_volume_lock_cbk (struct rpc_req *req, struct iovec *iov, } ret = xdr_to_generic (*iov, &rsp, - (xdrproc_t)xdr_gd1_mgmt_volume_lock_rsp); + (xdrproc_t)xdr_gd1_mgmt_v3_vol_lock_rsp); if (ret < 0) goto out; @@ -470,7 +470,7 @@ gd_syncop_mgmt_volume_lock (glusterd_op_t op, dict_t *op_ctx, uuid_t recv_uuid, uuid_t txn_id) { int ret = -1; - gd1_mgmt_volume_lock_req req = {{0},}; + gd1_mgmt_v3_vol_lock_req req = {{0},}; glusterd_conf_t *conf = THIS->private; GF_ASSERT(op_ctx); @@ -491,7 +491,7 @@ gd_syncop_mgmt_volume_lock (glusterd_op_t op, dict_t *op_ctx, &gd_mgmt_v3_prog, GLUSTERD_MGMT_V3_VOLUME_LOCK, gd_syncop_mgmt_volume_lock_cbk, - (xdrproc_t) xdr_gd1_mgmt_volume_lock_req); + (xdrproc_t) xdr_gd1_mgmt_v3_vol_lock_req); synclock_lock (&conf->big_lock); out: gf_log ("", GF_LOG_DEBUG, "Returning %d", ret); @@ -505,7 +505,7 @@ _gd_syncop_mgmt_volume_unlock_cbk (struct rpc_req *req, struct iovec *iov, int ret = -1; struct syncargs *args = NULL; glusterd_peerinfo_t *peerinfo = NULL; - gd1_mgmt_volume_unlock_rsp rsp = {{0},}; + gd1_mgmt_v3_vol_unlock_rsp rsp = {{0},}; call_frame_t *frame = NULL; int op_ret = -1; int op_errno = -1; @@ -526,7 +526,7 @@ _gd_syncop_mgmt_volume_unlock_cbk (struct rpc_req *req, struct iovec *iov, } ret = xdr_to_generic (*iov, &rsp, - (xdrproc_t)xdr_gd1_mgmt_volume_unlock_rsp); + (xdrproc_t)xdr_gd1_mgmt_v3_vol_unlock_rsp); if (ret < 0) goto out; @@ -560,7 +560,7 @@ gd_syncop_mgmt_volume_unlock (dict_t *op_ctx, glusterd_peerinfo_t *peerinfo, uuid_t recv_uuid, uuid_t txn_id) { int ret = -1; - gd1_mgmt_volume_unlock_req req = {{0},}; + gd1_mgmt_v3_vol_unlock_req req = {{0},}; glusterd_conf_t *conf = THIS->private; GF_ASSERT(op_ctx); @@ -580,7 +580,7 @@ gd_syncop_mgmt_volume_unlock (dict_t *op_ctx, glusterd_peerinfo_t *peerinfo, &gd_mgmt_v3_prog, GLUSTERD_MGMT_V3_VOLUME_UNLOCK, gd_syncop_mgmt_volume_unlock_cbk, - (xdrproc_t) xdr_gd1_mgmt_volume_unlock_req); + (xdrproc_t) xdr_gd1_mgmt_v3_vol_unlock_req); synclock_lock (&conf->big_lock); out: gf_log ("", GF_LOG_DEBUG, "Returning %d", ret); |