Protocol: Add lease fop

Change-Id: I64c361d3e4ae86d57dc18bb887758d044c861237
BUG: 1319992
Signed-off-by: Poornima G <pgurusid@redhat.com>
Reviewed-on: http://review.gluster.org/11597
Smoke: Gluster Build System <jenkins@build.gluster.com>
NetBSD-regression: NetBSD Build System <jenkins@build.gluster.org>
CentOS-regression: Gluster Build System <jenkins@build.gluster.com>
Reviewed-by: Rajesh Joseph <rjoseph@redhat.com>
Reviewed-by: Pranith Kumar Karampuri <pkarampu@redhat.com>

5 files changed, 200 insertions, 2 deletions

diff --git a/xlators/protocol/client/src/client-callback.c b/xlators/protocol/client/src/client-callback.c
index 7ee2113762a..4935ef5de7c 100644
--- a/xlators/protocol/client/src/client-callback.c
+++ b/xlators/protocol/client/src/client-callback.c
@@ -38,6 +38,45 @@ client_cbk_ino_flush (struct rpc_clnt *rpc, void *mydata, void *data)
 }
 
 int
+client_cbk_recall_lease (struct rpc_clnt *rpc, void *mydata, void *data)
+{
+        int                           ret          = -1;
+        struct iovec                 *iov          = NULL;
+        struct gf_upcall              upcall_data  = {0,};
+        uuid_t                        gfid;
+        struct gf_upcall_recall_lease rl_data      = {0,};
+        gfs3_recall_lease_req         recall_lease = {{0,},};
+
+        GF_VALIDATE_OR_GOTO ("client-callback", rpc, out);
+        GF_VALIDATE_OR_GOTO ("client-callback", mydata, out);
+        GF_VALIDATE_OR_GOTO ("client-callback", data, out);
+
+        iov = (struct iovec *)data;
+        ret =  xdr_to_generic (*iov, &recall_lease,
+                               (xdrproc_t)xdr_gfs3_recall_lease_req);
+
+        if (ret < 0) {
+                gf_msg (THIS->name, GF_LOG_WARNING, -ret,
+                        PC_MSG_RECALL_LEASE_FAIL,
+                        "XDR decode of recall lease failed.");
+                goto out;
+        }
+
+        upcall_data.data = &rl_data;
+        gf_proto_recall_lease_to_upcall (&recall_lease, &upcall_data);
+        upcall_data.event_type = GF_UPCALL_RECALL_LEASE;
+
+        gf_msg_trace (THIS->name, 0, "Upcall gfid = %s, ret = %d",
+                      recall_lease.gfid, ret);
+
+        default_notify (THIS, GF_EVENT_UPCALL, &upcall_data);
+
+out:
+        return ret;
+}
+
+
+int
 client_cbk_cache_invalidation (struct rpc_clnt *rpc, void *mydata, void *data)
 {
         int              ret                        = -1;
@@ -128,6 +167,7 @@ rpcclnt_cb_actor_t gluster_cbk_actors[GF_CBK_MAXVALUE] = {
         [GF_CBK_CACHE_INVALIDATION] = {"CACHE_INVALIDATION", GF_CBK_CACHE_INVALIDATION, client_cbk_cache_invalidation },
         [GF_CBK_CHILD_UP]           = {"CHILD_UP",           GF_CBK_CHILD_UP,           client_cbk_child_up },
         [GF_CBK_CHILD_DOWN]         = {"CHILD_DOWN",         GF_CBK_CHILD_DOWN,         client_cbk_child_down },
+        [GF_CBK_RECALL_LEASE]       = {"RECALL_LEASE",       GF_CBK_RECALL_LEASE,       client_cbk_recall_lease },
 };
 
 
diff --git a/xlators/protocol/client/src/client-messages.h b/xlators/protocol/client/src/client-messages.h
index db27661715b..082a7103674 100644
--- a/xlators/protocol/client/src/client-messages.h
+++ b/xlators/protocol/client/src/client-messages.h
@@ -45,7 +45,7 @@
  */
 
 #define GLFS_PC_BASE                GLFS_MSGID_COMP_PC
-#define GLFS_PC_NUM_MESSAGES        65
+#define GLFS_PC_NUM_MESSAGES        66
 #define GLFS_PC_MSGID_END           (GLFS_PC_BASE + GLFS_NUM_MESSAGES + 1)
 /* Messages with message IDs */
 #define glfs_msg_start_x GLFS_PC_BASE, "Invalid: Start of messages"
@@ -617,6 +617,7 @@
  * @recommendedaction
  *
  */
+
 #define PC_MSG_CHILD_STATUS                     (GLFS_PC_BASE + 64)
 
 /*!
@@ -625,7 +626,17 @@
  * @recommendedaction
  *
  */
-#define PC_MSG_GFID_NULL                       (GLFS_PC_BASE + 65)
+
+#define PC_MSG_RECALL_LEASE_FAIL                (GLFS_PC_BASE + 65)
+
+/*!
+ * @messageid
+ * @diagnosis
+ * @recommendedaction
+ *
+ */
+
+#define PC_MSG_GFID_NULL                       (GLFS_PC_BASE + 66)
 
 /*------------*/
 #define glfs_msg_end_x GLFS_MSGID_END, "Invalid: End of messages"
diff --git a/xlators/protocol/client/src/client-rpc-fops.c b/xlators/protocol/client/src/client-rpc-fops.c
index c95a973ec72..9e39ebd7242 100644
--- a/xlators/protocol/client/src/client-rpc-fops.c
+++ b/xlators/protocol/client/src/client-rpc-fops.c
@@ -2524,6 +2524,65 @@ out:
 }
 
 int
+client3_3_lease_cbk (struct rpc_req *req, struct iovec *iov, int count,
+                     void *myframe)
+{
+        call_frame_t     *frame      = NULL;
+        struct gf_lease   lease      = {0,};
+        gfs3_lease_rsp    rsp        = {0,};
+        int               ret        = 0;
+        xlator_t         *this       = NULL;
+        dict_t           *xdata      = NULL;
+
+        this = THIS;
+
+        frame = myframe;
+
+        if (-1 == req->rpc_status) {
+                gf_msg (this->name, GF_LOG_ERROR, ENOTCONN,
+                        PC_MSG_REMOTE_OP_FAILED, "Lease fop failed");
+                rsp.op_ret   = -1;
+                rsp.op_errno = ENOTCONN;
+                goto out;
+        }
+
+        ret = xdr_to_generic (*iov, &rsp, (xdrproc_t)xdr_gfs3_lease_rsp);
+        if (ret < 0) {
+                gf_msg (this->name, GF_LOG_ERROR, EINVAL,
+                        PC_MSG_XDR_DECODING_FAILED, "XDR decoding failed");
+                rsp.op_ret   = -1;
+                rsp.op_errno = EINVAL;
+                goto out;
+        }
+
+        if (rsp.op_ret >= 0) {
+                gf_proto_lease_to_lease (&rsp.lease, &lease);
+        }
+
+        GF_PROTOCOL_DICT_UNSERIALIZE (this, xdata, (rsp.xdata.xdata_val),
+                                      (rsp.xdata.xdata_len), ret,
+                                      rsp.op_errno, out);
+
+out:
+        if (rsp.op_ret == -1) {
+                gf_msg (this->name, GF_LOG_WARNING,
+                        gf_error_to_errno (rsp.op_errno),
+                        PC_MSG_REMOTE_OP_FAILED,
+                        "remote operation failed");
+        }
+
+        CLIENT_STACK_UNWIND (lease, frame, rsp.op_ret,
+                             gf_error_to_errno (rsp.op_errno), &lease, xdata);
+
+        free (rsp.xdata.xdata_val);
+
+        if (xdata)
+                dict_unref (xdata);
+
+        return 0;
+}
+
+int
 client3_3_lk_cbk (struct rpc_req *req, struct iovec *iov, int count,
                   void *myframe)
 {
@@ -5497,6 +5556,62 @@ unwind:
 }
 
 int32_t
+client3_3_lease (call_frame_t *frame, xlator_t *this,
+                 void *data)
+{
+        clnt_args_t     *args       = NULL;
+        gfs3_lease_req   req        = {{0,},};
+        int32_t          gf_cmd     = 0;
+        int32_t          gf_type    = 0;
+        int64_t          remote_fd  = -1;
+        clnt_conf_t     *conf       = NULL;
+        int              op_errno   = ESTALE;
+        int              ret        = 0;
+
+        GF_VALIDATE_OR_GOTO ("client", this, unwind);
+        GF_VALIDATE_OR_GOTO (this->name, frame, unwind);
+        GF_VALIDATE_OR_GOTO (this->name, data, unwind);
+
+        args = data;
+        conf = this->private;
+
+        if (!(args->loc && args->loc->inode))
+                goto unwind;
+
+        if (!gf_uuid_is_null (args->loc->inode->gfid))
+                memcpy (req.gfid, args->loc->inode->gfid, 16);
+        else
+                memcpy (req.gfid, args->loc->gfid, 16);
+
+        GF_ASSERT_AND_GOTO_WITH_ERROR (this->name,
+                                       !gf_uuid_is_null (*((uuid_t *)req.gfid)),
+                                       unwind, op_errno, EINVAL);
+
+        gf_proto_lease_from_lease (&req.lease, args->lease);
+
+        GF_PROTOCOL_DICT_SERIALIZE (this, args->xdata, (&req.xdata.xdata_val),
+                                    req.xdata.xdata_len, op_errno, unwind);
+
+        ret = client_submit_request (this, &req, frame, conf->fops, GFS3_OP_LEASE,
+                                     client3_3_lease_cbk, NULL,
+                                     NULL, 0, NULL, 0, NULL,
+                                     (xdrproc_t)xdr_gfs3_lease_req);
+        if (ret) {
+                gf_msg (this->name, GF_LOG_WARNING, 0, PC_MSG_FOP_SEND_FAILED,
+                        "failed to send the fop");
+        }
+
+        GF_FREE (req.xdata.xdata_val);
+
+        return 0;
+unwind:
+        CLIENT_STACK_UNWIND (lease, frame, -1, op_errno, NULL, NULL);
+        GF_FREE (req.xdata.xdata_val);
+
+        return 0;
+}
+
+int32_t
 client3_3_lk (call_frame_t *frame, xlator_t *this,
               void *data)
 {
@@ -6501,6 +6616,7 @@ rpc_clnt_procedure_t clnt3_3_fop_actors[GF_FOP_MAXVALUE] = {
         [GF_FOP_FREMOVEXATTR] = { "FREMOVEXATTR", client3_3_fremovexattr },
         [GF_FOP_IPC]          = { "IPC",          client3_3_ipc },
         [GF_FOP_SEEK]         = { "SEEK",         client3_3_seek },
+        [GF_FOP_LEASE]        = { "LEASE",        client3_3_lease },
 };
 
 /* Used From RPC-CLNT library to log proper name of procedure based on number */
@@ -6554,6 +6670,7 @@ char *clnt3_3_fop_names[GFS3_OP_MAXVALUE] = {
         [GFS3_OP_ZEROFILL]    = "ZEROFILL",
         [GFS3_OP_IPC]         = "IPC",
         [GFS3_OP_SEEK]        = "SEEK",
+        [GFS3_OP_LEASE]       = "LEASE",
 
 };
 
diff --git a/xlators/protocol/client/src/client.c b/xlators/protocol/client/src/client.c
index f1f58eb822e..aae712acd4b 100644
--- a/xlators/protocol/client/src/client.c
+++ b/xlators/protocol/client/src/client.c
@@ -1478,6 +1478,34 @@ out:
 }
 
 int32_t
+client_lease (call_frame_t *frame, xlator_t *this, loc_t *loc,
+              struct gf_lease *lease, dict_t *xdata)
+{
+        int                   ret  = -1;
+        clnt_conf_t          *conf = NULL;
+        rpc_clnt_procedure_t *proc = NULL;
+        clnt_args_t           args = {0,};
+
+        conf = this->private;
+        if (!conf || !conf->fops)
+                goto out;
+
+        args.loc = loc;
+        args.lease = lease;
+        args.xdata = xdata;
+
+        proc = &conf->fops->proctable[GF_FOP_LEASE];
+        if (proc->fn)
+                ret = proc->fn (frame, this, &args);
+out:
+        if (ret)
+                STACK_UNWIND_STRICT (lk, frame, -1, ENOTCONN, NULL, NULL);
+
+        return 0;
+}
+
+
+int32_t
 client_lk (call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t cmd,
            struct gf_flock *lock, dict_t *xdata)
 {
@@ -2720,6 +2748,7 @@ struct xlator_fops fops = {
         .getspec     = client_getspec,
         .ipc         = client_ipc,
         .seek        = client_seek,
+        .lease       = client_lease,
 };
 
 
diff --git a/xlators/protocol/client/src/client.h b/xlators/protocol/client/src/client.h
index a4d4d9f75a5..20a57a1f855 100644
--- a/xlators/protocol/client/src/client.h
+++ b/xlators/protocol/client/src/client.h
@@ -213,6 +213,7 @@ typedef struct client_args {
         int32_t             valid;
         int32_t             len;
         gf_seek_what_t      what;
+        struct gf_lease    *lease;
 
         mode_t              umask;
         dict_t             *xdata;