posix/ctime: posix hook to set ctime xattr in relevant fops

This patch uses the ctime posix APIs to set consistent
time across replica on disk. It also stores the time
attributes in the inode context.

Credits: Rafi KC <rkavunga@redhat.com>
Updates: #208
Change-Id: I1a8d74d1e251f1d6d142f066fc99258025c0bcdd
Signed-off-by: Kotresh HR <khiremat@redhat.com>

1 files changed, 121 insertions, 21 deletions

diff --git a/xlators/storage/posix/src/posix-metadata.c b/xlators/storage/posix/src/posix-metadata.c
index 57f32f9359c..90030ff28bd 100644
--- a/xlators/storage/posix/src/posix-metadata.c
+++ b/xlators/storage/posix/src/posix-metadata.c
@@ -345,10 +345,10 @@ posix_compare_timespec (struct timespec *first, struct timespec *second)
                 return first->tv_sec - second->tv_sec;
 }
 
-/* posix_update_mdata_xattr updates the posix_mdata_t based on the flag
+/* posix_set_mdata_xattr updates the posix_mdata_t based on the flag
  * in inode context and stores it on disk
  */
-int
+static int
 posix_set_mdata_xattr (xlator_t *this, const char *real_path, int fd,
                        inode_t *inode, struct timespec *time,
                        struct iatt *stbuf, posix_mdata_flag_t *flag)
@@ -474,12 +474,12 @@ out:
 /* posix_update_utime_in_mdata updates the posix_mdata_t when mtime/atime
  * is modified using syscall
  */
-int
+void
 posix_update_utime_in_mdata (xlator_t *this, const char *real_path, int fd,
                              inode_t *inode,
                              struct iatt *stbuf, int valid)
 {
-        int32_t ret = -1;
+        int32_t ret = 0;
 #if defined(HAVE_UTIMENSAT)
         struct timespec tv    = {0, };
 #else
@@ -487,26 +487,39 @@ posix_update_utime_in_mdata (xlator_t *this, const char *real_path, int fd,
 #endif
         posix_mdata_flag_t       flag            = {0, };
 
-        if ((valid & GF_SET_ATTR_ATIME) == GF_SET_ATTR_ATIME) {
-                tv.tv_sec  = stbuf->ia_atime;
-                SET_TIMESPEC_NSEC_OR_TIMEVAL_USEC(tv, stbuf->ia_atime_nsec);
+        if (inode && is_ctime_enabled()) {
+                if ((valid & GF_SET_ATTR_ATIME) == GF_SET_ATTR_ATIME) {
+                        tv.tv_sec  = stbuf->ia_atime;
+                        SET_TIMESPEC_NSEC_OR_TIMEVAL_USEC(tv, stbuf->ia_atime_nsec);
 
-                flag.ctime = 0;
-                flag.mtime = 0;
-                flag.atime = 1;
-        }
+                        flag.ctime = 0;
+                        flag.mtime = 0;
+                        flag.atime = 1;
+                }
 
-        if ((valid & GF_SET_ATTR_MTIME) == GF_SET_ATTR_MTIME) {
-                tv.tv_sec  = stbuf->ia_mtime;
-                SET_TIMESPEC_NSEC_OR_TIMEVAL_USEC(tv, stbuf->ia_mtime_nsec);
-                flag.ctime = 1;
-                flag.mtime = 1;
-                flag.atime = 0;
-        }
+                if ((valid & GF_SET_ATTR_MTIME) == GF_SET_ATTR_MTIME) {
+                        tv.tv_sec  = stbuf->ia_mtime;
+                        SET_TIMESPEC_NSEC_OR_TIMEVAL_USEC(tv, stbuf->ia_mtime_nsec);
 
-        ret = posix_set_mdata_xattr (this, real_path, -1, inode, &tv, NULL,
-                                     &flag);
-        return ret;
+                        flag.ctime = 1;
+                        flag.mtime = 1;
+                        flag.atime = 0;
+                }
+
+                ret = posix_set_mdata_xattr (this, real_path, -1, inode, &tv, NULL,
+                                             &flag);
+                if (ret) {
+                        gf_msg (this->name, GF_LOG_WARNING, errno,
+                                P_MSG_SETMDATA_FAILED,
+                                "posix set mdata failed on file: %s gfid:%s",
+                                real_path, uuid_utoa (inode->gfid));
+                }
+        } else {
+                gf_msg (this->name, GF_LOG_WARNING, errno,
+                        P_MSG_SETMDATA_FAILED,
+                        "posix utime set mdata failed on file");
+        }
+        return;
 }
 
 gf_boolean_t
@@ -516,3 +529,90 @@ is_ctime_enabled () {
  *                   */
         return _gf_false;
 }
+
+static void
+posix_get_mdata_flag (uint64_t flags, posix_mdata_flag_t *flag)
+{
+        if (!flag)
+                return;
+
+        flag->ctime = 0;
+        flag->atime = 0;
+        flag->mtime = 0;
+
+        if (flags & MDATA_CTIME)
+                flag->ctime = 1;
+        if (flags & MDATA_MTIME)
+                flag->mtime = 1;
+        if (flags & MDATA_ATIME)
+                flag->atime = 1;
+}
+
+static void
+posix_get_parent_mdata_flag (uint64_t flags, posix_mdata_flag_t *flag)
+{
+        if (!flag)
+                return;
+
+        flag->ctime = 0;
+        flag->atime = 0;
+        flag->mtime = 0;
+
+        if (flags & MDATA_PAR_CTIME)
+                flag->ctime = 1;
+        if (flags & MDATA_PAR_MTIME)
+                flag->mtime = 1;
+        if (flags & MDATA_PAR_ATIME)
+                flag->atime = 1;
+}
+
+void
+posix_set_ctime (call_frame_t *frame, xlator_t *this, const char* real_path,
+                 int fd, inode_t *inode, struct iatt *stbuf)
+{
+        posix_mdata_flag_t    flag            = {0,};
+        int                   ret             = 0;
+
+        if (inode && is_ctime_enabled()) {
+                (void) posix_get_mdata_flag (frame->root->flags, &flag);
+                ret = posix_set_mdata_xattr (this, real_path, fd, inode,
+                                             &frame->root->ctime, stbuf, &flag);
+                if (ret) {
+                        gf_msg (this->name, GF_LOG_WARNING, errno,
+                                P_MSG_SETMDATA_FAILED,
+                                "posix set mdata failed on file: %s gfid:%s",
+                                real_path, uuid_utoa (inode->gfid));
+                }
+        } else {
+                gf_msg (this->name, GF_LOG_WARNING, errno,
+                        P_MSG_SETMDATA_FAILED,
+                        "posix set mdata failed on file");
+        }
+        return;
+}
+
+void
+posix_set_parent_ctime (call_frame_t *frame, xlator_t *this,
+                        const char* real_path, int fd, inode_t *inode,
+                        struct iatt *stbuf)
+{
+        posix_mdata_flag_t    flag            = {0,};
+        int                   ret             = 0;
+
+        if (inode && is_ctime_enabled()) {
+                (void) posix_get_parent_mdata_flag (frame->root->flags, &flag);
+                ret = posix_set_mdata_xattr (this, real_path, fd, inode,
+                                             &frame->root->ctime, stbuf, &flag);
+                if (ret) {
+                        gf_msg (this->name, GF_LOG_WARNING, errno,
+                                P_MSG_SETMDATA_FAILED,
+                                "posix set mdata failed on file: %s gfid:%s",
+                                real_path, uuid_utoa (inode->gfid));
+                }
+        } else {
+                gf_msg (this->name, GF_LOG_WARNING, errno,
+                        P_MSG_SETMDATA_FAILED,
+                        "posix parent set mdata failed on file");
+        }
+        return;
+}