Set timestamps properly when creating missing entries.

In AFR self-heal set timestamp of a freshly created missing entry
to that of the source entry.

Signed-off-by: Anand V. Avati <avati@dev.gluster.com>

1 files changed, 37 insertions, 3 deletions

diff --git a/xlators/cluster/afr/src/afr-self-heal-common.c b/xlators/cluster/afr/src/afr-self-heal-common.c
index 5f08fb007..99e6503ac 100644
--- a/xlators/cluster/afr/src/afr-self-heal-common.c
+++ b/xlators/cluster/afr/src/afr-self-heal-common.c
@@ -810,7 +810,18 @@ static int
 sh_destroy_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
 		int32_t op_ret, int op_errno, struct stat *stbuf)
 {
-	STACK_DESTROY (frame->root);
+        afr_local_t *local = NULL;
+
+        int call_count = 0;
+
+        local = frame->local;
+
+        call_count = afr_frame_return (frame);
+        
+        if (call_count == 0) {
+                STACK_DESTROY (frame->root);
+        }
+        
 	return 0;
 }
 
@@ -829,16 +840,33 @@ sh_missing_entries_newentry_cbk (call_frame_t *frame, void *cookie,
 	int              child_index = 0;
 	struct stat     *buf = NULL;
 
+        struct timespec ts[2];
 
 	local = frame->local;
-	sh = &local->self_heal;
-	priv = this->private;
+	sh    = &local->self_heal;
+	priv  = this->private;
 
 	buf = &sh->buf[sh->source];
 	child_index = (long) cookie;
 
+#ifdef HAVE_STRUCT_STAT_ST_ATIM_TV_NSEC
+	ts[0] = sh->buf[sh->source].st_atim;
+	ts[1] = sh->buf[sh->source].st_mtim;
+        
+#elif HAVE_STRUCT_STAT_ST_ATIMESPEC_TV_NSEC
+	ts[0] = sh->buf[sh->source].st_atimespec;
+	ts[1] = sh->buf[sh->source].st_mtimespec;
+#else
+	ts[0].tv_sec = sh->buf[sh->source].st_atime;
+	ts[1].tv_sec = sh->buf[sh->source].st_mtime;
+#endif
+
 	if (op_ret == 0) {
 		chown_frame = copy_frame (frame);
+                
+                chown_frame->local = CALLOC (1, sizeof (afr_local_t));
+
+                ((afr_local_t *)chown_frame->local)->call_count = 2;
 
 		gf_log (this->name, GF_LOG_TRACE,
 			"chown %s to %d %d on subvolume %s",
@@ -850,6 +878,12 @@ sh_missing_entries_newentry_cbk (call_frame_t *frame, void *cookie,
 			    priv->children[child_index]->fops->chown,
 			    &local->loc,
 			    buf->st_uid, buf->st_gid);
+                
+                STACK_WIND (chown_frame, sh_destroy_cbk,
+                            priv->children[child_index],
+                            priv->children[child_index]->fops->utimens,
+                            &local->loc, ts);
+                            
 	}
 
 	LOCK (&frame->lock);