send a lookup on root as soon as we get CHILD_UP to fuse.

send a lookup on root as soon as we get CHILD_UP to fuse. This fixes the
case where some of the fuse versions do not send a lookup on the root
directory when one of the "sub-dir" or "sub-file" is accessed just after mount.

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

1 files changed, 83 insertions, 12 deletions

diff --git a/xlators/mount/fuse/src/fuse-bridge.c b/xlators/mount/fuse/src/fuse-bridge.c
index 4affd40d51f..6cdba9ea6d1 100644
--- a/xlators/mount/fuse/src/fuse-bridge.c
+++ b/xlators/mount/fuse/src/fuse-bridge.c
@@ -73,6 +73,9 @@ struct fuse_private {
         uint32_t             direct_io_mode;
         double               entry_timeout;
         double               attribute_timeout;
+        pthread_cond_t       first_call_cond;
+        pthread_mutex_t      first_call_mutex;
+        char                 first_call;
         gf_boolean_t         strict_volfile_check;
 };
 typedef struct fuse_private fuse_private_t;
@@ -2417,17 +2420,7 @@ fuse_setlk (fuse_req_t req,
 static void 
 fuse_init (void *data, struct fuse_conn_info *conn)
 {
-        xlator_t *this_xl = NULL;
-        
-        if (data == NULL) {
-                return ;
-        }
-        
-        this_xl = data;
-        
-        this_xl->itable = inode_table_new (0, this_xl);
-        
-        return ;
+	return;
 }
 
 static void
@@ -2472,6 +2465,78 @@ static struct fuse_lowlevel_ops fuse_ops = {
         .setlk        = fuse_setlk
 };
 
+int
+fuse_root_lookup_cbk (call_frame_t *frame,
+		      void *cookie,
+		      xlator_t *this,
+		      int32_t op_ret,
+		      int32_t op_errno,
+		      inode_t *inode,
+		      struct stat *buf,
+		      dict_t *xattr)
+{
+        fuse_private_t *priv = this->private;
+
+	if (op_ret == 0) {
+		gf_log (this->name, GF_LOG_DEBUG, 
+			"first lookup on root succeeded.");
+		inode_lookup (inode);
+	} else {
+		gf_log (this->name, GF_LOG_DEBUG, 
+			"first lookup on root failed.");
+	}
+	STACK_DESTROY (frame->root);
+	pthread_mutex_lock (&priv->first_call_mutex);
+	{
+		priv->first_call = 0;
+		pthread_cond_broadcast (&priv->first_call_cond);
+	}
+	pthread_mutex_unlock (&priv->first_call_mutex);
+	return 0;
+}
+
+
+int
+fuse_root_lookup (xlator_t *this)
+{
+	fuse_private_t *priv = NULL;
+	loc_t loc;
+	call_frame_t *frame = NULL;
+	xlator_t *xl = NULL;
+	dict_t *dict = NULL;
+
+	priv = this->private;
+
+	pthread_cond_init (&priv->first_call_cond, NULL);
+	pthread_mutex_init (&priv->first_call_mutex, NULL);
+
+	loc.path = "/";
+	loc.name = "";
+	loc.ino = 1;
+	loc.inode = inode_search (this->itable, 1, NULL);
+	loc.parent = NULL;
+
+	dict = dict_new();
+	frame = create_frame (this, this->ctx->pool);
+	frame->root->type = GF_OP_TYPE_FOP_REQUEST;
+	xl = this->children->xlator;
+
+	STACK_WIND (frame, fuse_root_lookup_cbk, xl, xl->fops->lookup, 
+		    &loc, dict);
+	dict_unref (dict);
+
+	pthread_mutex_lock (&priv->first_call_mutex);
+	{
+		while (priv->first_call) {
+			pthread_cond_wait (&priv->first_call_cond, 
+					   &priv->first_call_mutex);
+		}
+	}
+	pthread_mutex_unlock (&priv->first_call_mutex);
+
+	return 0;
+}
+
 
 static void *
 fuse_thread_proc (void *data)
@@ -2488,11 +2553,14 @@ fuse_thread_proc (void *data)
 
         while (!fuse_session_exited (priv->se)) {
 
-
                 res = fuse_chan_receive (priv->ch,
                                          recvbuf,
                                          chan_size);
 
+		if (priv->first_call) {
+			fuse_root_lookup (this);
+		}
+
                 if (res == -1) {
                         if (errno != EINTR) {
                                 gf_log ("glusterfs-fuse", GF_LOG_ERROR,
@@ -2814,6 +2882,9 @@ init (xlator_t *this_xl)
         priv->buf = data_ref (data_from_dynptr (NULL, 0));
 
         this_xl->ctx->top = this_xl;
+
+	priv->first_call = 1;
+        this_xl->itable = inode_table_new (0, this_xl);
         return 0;
         
 umount_exit: