From c3bdb1d4c6c4491afdf1ba26bb0d6204270cc058 Mon Sep 17 00:00:00 2001 From: Amar Tumballi Date: Tue, 20 Dec 2011 14:54:35 +0530 Subject: glusterd: bring in feature to use syncop for mgmt ops * new sycnop routines added to mgmt program * one should not use 'glusterd_op_begin()', instead can use the synctask framework, 'glusterd_op_begin_synctask()' * currently using for below operations: 'volume start', 'volume rebalance', 'volume quota', 'volume replace-brick' and 'volume add-brick' Change-Id: I0bee76d06790d5c5bb5db15d443b44af0e21f1c0 BUG: 762935 Signed-off-by: Amar Tumballi Reviewed-on: http://review.gluster.com/479 Tested-by: Gluster Build System Reviewed-by: Anand Avati --- xlators/mgmt/glusterd/src/glusterd-syncop.h | 54 +++++++++++++++++++++++++++++ 1 file changed, 54 insertions(+) create mode 100644 xlators/mgmt/glusterd/src/glusterd-syncop.h (limited to 'xlators/mgmt/glusterd/src/glusterd-syncop.h') diff --git a/xlators/mgmt/glusterd/src/glusterd-syncop.h b/xlators/mgmt/glusterd/src/glusterd-syncop.h new file mode 100644 index 000000000..ccaf794ea --- /dev/null +++ b/xlators/mgmt/glusterd/src/glusterd-syncop.h @@ -0,0 +1,54 @@ +/* + Copyright (c) 2012 Red Hat, Inc. + This file is part of GlusterFS. + + GlusterFS is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published + by the Free Software Foundation; either version 3 of the License, + or (at your option) any later version. + + GlusterFS is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program. If not, see + . +*/ + +#ifndef __RPC_SYNCOP_H +#define __RPC_SYNCOP_H + +#include "syncop.h" + + +/* gd_syncop_* */ +#define GD_SYNCOP(rpc, stb, cbk, req, prog, procnum, xdrproc) do { \ + int ret = 0; \ + ret = gd_syncop_submit_request (rpc, req, stb, \ + prog, procnum, cbk, \ + (xdrproc_t)xdrproc); \ + if (!ret) \ + __yield (stb); \ + } while (0) + + +int gd_syncop_submit_request (struct rpc_clnt *rpc, void *req, + void *cookie, rpc_clnt_prog_t *prog, + int procnum, fop_cbk_fn_t cbkfn, + xdrproc_t xdrproc); + + +int gd_syncop_mgmt_lock (struct rpc_clnt *rpc, uuid_t my_uuid, + uuid_t recv_uuid); +int gd_syncop_mgmt_unlock (struct rpc_clnt *rpc, uuid_t my_uuid, + uuid_t recv_uuid); +int gd_syncop_mgmt_stage_op (struct rpc_clnt *rpc, uuid_t my_uuid, + uuid_t recv_uuid, int op, dict_t *dict_out, + dict_t **dict_in, char **errstr); +int gd_syncop_mgmt_commit_op (struct rpc_clnt *rpc, uuid_t my_uuid, + uuid_t recv_uuid, int op, dict_t *dict_out, + dict_t **dict_in, char **errstr); + +#endif /* __RPC_SYNCOP_H */ -- cgit