cli/glusterd: Changes to quota command Quota feature

 re-work.

Following are the cli commands that are new/re-worked:
======================================================

volume quota <VOLNAME> {enable|disable|list [<path> ...]|remove <path>| default-soft-limit <percent>} |
volume quota <VOLNAME> {limit-usage <path> <size> [<percent>]} |
volume quota <VOLNAME> {alert-time|soft-timeout|hard-timeout} {<time>}
volume status [all | <VOLNAME> [nfs|shd|<BRICK>|quotad]] [detail|clients|mem|inode|fd|callpool]
volume statedump <VOLNAME> [nfs|quotad] [all|mem|iobuf|callpool|priv|fd|inode|history]

glusterd changes:
=================
* Quota limits are now set as extended attributes by glusterd from
  the aux mount created by the cli.
* The gfids of the directories on which quota limits are set
  for a given volume are stored in
  /var/lib/glusterd/vols/<volname>/quota.conf file in binary format,
  and whose cksum and version is stored in
  /var/lib/glusterd/vols/<volname>/quota.cksum.

Original-author: Krutika Dhananjay <kdhananj@redhat.com>
Original-author: Krishnan Parthasarathi <kparthas@redhat.com>

BUG: 969461
Change-Id: If32bba36c67f9c2a30417af9c6389045b2b7c13b
Signed-off-by: Krutika Dhananjay <kdhananj@redhat.com>
Signed-off-by: Raghavendra G <rgowdapp@redhat.com>
Reviewed-on: http://review.gluster.org/6003
Tested-by: Gluster Build System <jenkins@build.gluster.com>
Reviewed-by: Anand Avati <avati@redhat.com>

1 files changed, 46 insertions, 2 deletions

diff --git a/cli/src/cli.c b/cli/src/cli.c
index 91b315ff169..67f1ad25793 100644
--- a/cli/src/cli.c
+++ b/cli/src/cli.c
@@ -45,6 +45,7 @@
 #endif
 
 #include "cli.h"
+#include "cli-quotad-client.h"
 #include "cli-cmd.h"
 #include "cli-mem-types.h"
 
@@ -82,6 +83,7 @@ const char *argp_program_bug_address = "<" PACKAGE_BUGREPORT ">";
 
 
 
+struct rpc_clnt *global_quotad_rpc;
 struct rpc_clnt *global_rpc;
 
 rpc_clnt_prog_t *cli_rpc_prog;
@@ -184,7 +186,7 @@ logging_init (glusterfs_ctx_t *ctx, struct cli_state *state)
 }
 
 int
-cli_submit_request (void *req, call_frame_t *frame,
+cli_submit_request (struct rpc_clnt *rpc, void *req, call_frame_t *frame,
                     rpc_clnt_prog_t *prog,
                     int procnum, struct iobref *iobref,
                     xlator_t *this, fop_cbk_fn_t cbkfn, xdrproc_t xdrproc)
@@ -229,8 +231,10 @@ cli_submit_request (void *req, call_frame_t *frame,
                 count = 1;
         }
 
+        if (!rpc)
+                rpc = global_rpc;
         /* Send the msg */
-        ret = rpc_clnt_submit (global_rpc, prog, procnum, cbkfn,
+        ret = rpc_clnt_submit (rpc, prog, procnum, cbkfn,
                                &iov, count,
                                NULL, 0, iobref, frame, NULL, 0, NULL, 0, NULL);
         ret = 0;
@@ -491,6 +495,42 @@ _cli_out (const char *fmt, ...)
 }
 
 struct rpc_clnt *
+cli_quotad_clnt_rpc_init (void)
+{
+        struct rpc_clnt *rpc = NULL;
+        dict_t          *rpc_opts = NULL;
+        int             ret = -1;
+
+        rpc_opts = dict_new ();
+        if (!rpc_opts) {
+                        ret = -1;
+                        goto out;
+                }
+
+        ret = dict_set_str (rpc_opts, "transport.address-family", "unix");
+        if (ret)
+                goto out;
+
+        ret = dict_set_str (rpc_opts, "transport-type", "socket");
+        if (ret)
+                goto out;
+
+        ret = dict_set_str (rpc_opts, "transport.socket.connect-path",
+                                            "/tmp/quotad.socket");
+        if (ret)
+                goto out;
+
+        rpc = cli_quotad_clnt_init (THIS, rpc_opts);
+        if (!rpc)
+                goto out;
+
+        global_quotad_rpc = rpc;
+out:
+        dict_unref (rpc_opts);
+        return rpc;
+}
+
+struct rpc_clnt *
 cli_rpc_init (struct cli_state *state)
 {
         struct rpc_clnt         *rpc = NULL;
@@ -634,6 +674,10 @@ main (int argc, char *argv[])
         if (!global_rpc)
                 goto out;
 
+        global_quotad_rpc = cli_quotad_clnt_rpc_init ();
+        if (!global_quotad_rpc)
+                goto out;
+
         ret = cli_cmds_register (&state);
         if (ret)
                 goto out;