diff options
Diffstat (limited to 'cli/src/cli-rpc-ops.c')
| -rw-r--r-- | cli/src/cli-rpc-ops.c | 80 | 
1 files changed, 80 insertions, 0 deletions
diff --git a/cli/src/cli-rpc-ops.c b/cli/src/cli-rpc-ops.c index a02761d5e6e..00ea6633bb6 100644 --- a/cli/src/cli-rpc-ops.c +++ b/cli/src/cli-rpc-ops.c @@ -1698,6 +1698,61 @@ out:          return ret;  } +int +gf_cli_ganesha_cbk (struct rpc_req *req, struct iovec *iov, +                        int count, void *myframe) +{ +        gf_cli_rsp           rsp   = {0,}; +        int                  ret   = -1; +        dict_t               *dict = NULL; +        char                 *help_str = NULL; +        char                 msg[1024] = {0,}; +        char                 tmp_str[512] = {0,}; + +        if (-1 == req->rpc_status) { +                goto out; +        } + +        ret = xdr_to_generic (*iov, &rsp, (xdrproc_t)xdr_gf_cli_rsp); +        if (ret < 0) { +                gf_log (((call_frame_t *) myframe)->this->name, GF_LOG_ERROR, +                        "Failed to decode xdr response"); +                goto out; +        } + +        gf_log ("cli", GF_LOG_DEBUG, "Received resp to ganesha"); + +        dict = dict_new (); + +        if (!dict) { +                ret = -1; +                goto out; +        } + +        ret = dict_unserialize (rsp.dict.dict_val, rsp.dict.dict_len, &dict); +        if (ret) +                goto out; + +        if (rsp.op_ret) { +                if (strcmp (rsp.op_errstr, "")) +                        cli_err ("ganesha enable: failed: %s", rsp.op_errstr); +                else +                        cli_err ("ganesha enable: failed"); +        } + +        else { +                cli_out("ganesha enable : success "); +        } + +        ret = rsp.op_ret; + +out: +        if (dict) +                dict_unref (dict); +        cli_cmd_broadcast_response (ret); +        return ret; +} +  char *  is_server_debug_xlator (void *myframe)  { @@ -3586,6 +3641,30 @@ out:  }  int32_t +gf_cli_ganesha (call_frame_t *frame, xlator_t *this, void *data) +{ +        gf_cli_req              req =  { {0,} } ; +        int                     ret = 0; +        dict_t                  *dict = NULL; + +        if (!frame || !this ||  !data) { +                ret = -1; +                goto out; +        } + +        dict = data; + +        ret = cli_to_glusterd (&req, frame, gf_cli_ganesha_cbk, +                               (xdrproc_t) xdr_gf_cli_req, dict, +                               GLUSTER_CLI_GANESHA, this, cli_rpc_prog, +                               NULL); +out: +        gf_log ("cli", GF_LOG_DEBUG, "Returning %d", ret); + +        return ret; +} + +int32_t  gf_cli_set_volume (call_frame_t *frame, xlator_t *this,                           void *data)  { @@ -9770,6 +9849,7 @@ struct rpc_clnt_procedure gluster_cli_actors[GLUSTER_CLI_MAXVALUE] = {          [GLUSTER_CLI_SYS_EXEC]         = {"SYS_EXEC", gf_cli_sys_exec},          [GLUSTER_CLI_SNAP]             = {"SNAP", gf_cli_snapshot},          [GLUSTER_CLI_BARRIER_VOLUME]   = {"BARRIER VOLUME", gf_cli_barrier_volume}, +        [GLUSTER_CLI_GANESHA]          = {"GANESHA", gf_cli_ganesha},          [GLUSTER_CLI_GET_VOL_OPT]      = {"GET_VOL_OPT", gf_cli_get_vol_opt},  };  | 
