1 files changed, 35 insertions, 19 deletions

diff --git a/fs/9p/mux.c b/fs/9p/mux.c
index ea1134eb47c8..3e5b124a7212 100644
--- a/fs/9p/mux.c
+++ b/fs/9p/mux.c
@@ -7,9 +7,8 @@
  *  Copyright (C) 2004-2005 by Latchesar Ionkov <lucho@ionkov.net>
  *
  *  This program is free software; you can redistribute it and/or modify
- *  it under the terms of the GNU General Public License as published by
- *  the Free Software Foundation; either version 2 of the License, or
- *  (at your option) any later version.
+ *  it under the terms of the GNU General Public License version 2
+ *  as published by the Free Software Foundation.
  *
  *  This program is distributed in the hope that it will be useful,
  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
@@ -31,6 +30,7 @@
 #include <linux/poll.h>
 #include <linux/kthread.h>
 #include <linux/idr.h>
+#include <linux/mutex.h>
 
 #include "debug.h"
 #include "v9fs.h"
@@ -69,7 +69,7 @@ struct v9fs_mux_data {
         int msize;
         unsigned char *extended;
         struct v9fs_transport *trans;
-        struct v9fs_idpool tidpool;
+        struct v9fs_idpool tagpool;
         int err;
         wait_queue_head_t equeue;
         struct list_head req_list;
@@ -110,7 +110,7 @@ static void v9fs_pollwait(struct file *filp, wait_queue_head_t * wait_address,
 static u16 v9fs_mux_get_tag(struct v9fs_mux_data *);
 static void v9fs_mux_put_tag(struct v9fs_mux_data *, u16);
 
-static DECLARE_MUTEX(v9fs_mux_task_lock);
+static DEFINE_MUTEX(v9fs_mux_task_lock);
 static struct workqueue_struct *v9fs_mux_wq;
 
 static int v9fs_mux_num;
@@ -142,7 +142,7 @@ void v9fs_mux_global_exit(void)
  *
  * The current implementation returns sqrt of the number of mounts.
  */
-inline int v9fs_mux_calc_poll_procs(int muxnum)
+static int v9fs_mux_calc_poll_procs(int muxnum)
 {
         int n;
 
@@ -166,7 +166,7 @@ static int v9fs_mux_poll_start(struct v9fs_mux_data *m)
 
         dprintk(DEBUG_MUX, "mux %p muxnum %d procnum %d\n", m, v9fs_mux_num,
                 v9fs_mux_poll_task_num);
-        up(&v9fs_mux_task_lock);
+        mutex_lock(&v9fs_mux_task_lock);
 
         n = v9fs_mux_calc_poll_procs(v9fs_mux_num + 1);
         if (n > v9fs_mux_poll_task_num) {
@@ -225,7 +225,7 @@ static int v9fs_mux_poll_start(struct v9fs_mux_data *m)
         }
 
         v9fs_mux_num++;
-        down(&v9fs_mux_task_lock);
+        mutex_unlock(&v9fs_mux_task_lock);
 
         return 0;
 }
@@ -235,7 +235,7 @@ static void v9fs_mux_poll_stop(struct v9fs_mux_data *m)
         int i;
         struct v9fs_mux_poll_task *vpt;
 
-        up(&v9fs_mux_task_lock);
+        mutex_lock(&v9fs_mux_task_lock);
         vpt = m->poll_task;
         list_del(&m->mux_list);
         for(i = 0; i < ARRAY_SIZE(m->poll_waddr); i++) {
@@ -252,7 +252,7 @@ static void v9fs_mux_poll_stop(struct v9fs_mux_data *m)
                 v9fs_mux_poll_task_num--;
         }
         v9fs_mux_num--;
-        down(&v9fs_mux_task_lock);
+        mutex_unlock(&v9fs_mux_task_lock);
 }
 
 /**
@@ -279,8 +279,8 @@ struct v9fs_mux_data *v9fs_mux_init(struct v9fs_transport *trans, int msize,
         m->msize = msize;
         m->extended = extended;
         m->trans = trans;
-        idr_init(&m->tidpool.pool);
-        init_MUTEX(&m->tidpool.lock);
+        idr_init(&m->tagpool.pool);
+        init_MUTEX(&m->tagpool.lock);
         m->err = 0;
         init_waitqueue_head(&m->equeue);
         INIT_LIST_HEAD(&m->req_list);
@@ -383,7 +383,7 @@ v9fs_pollwait(struct file *filp, wait_queue_head_t * wait_address,
 /**
  * v9fs_poll_mux - polls a mux and schedules read or write works if necessary
  */
-static inline void v9fs_poll_mux(struct v9fs_mux_data *m)
+static void v9fs_poll_mux(struct v9fs_mux_data *m)
 {
         int n;
 
@@ -634,6 +634,14 @@ static void v9fs_read_work(void *a)
                         goto error;
                 }
 
+                if ((v9fs_debug_level&DEBUG_FCALL) == DEBUG_FCALL) {
+                        char buf[150];
+
+                        v9fs_printfcall(buf, sizeof(buf), m->rcall,
+                                *m->extended);
+                        printk(KERN_NOTICE ">>> %p %s\n", m, buf);
+                }
+
                 rcall = m->rcall;
                 rbuf = m->rbuf;
                 if (m->rpos > n) {
@@ -739,6 +747,13 @@ static struct v9fs_req *v9fs_send_request(struct v9fs_mux_data *m,
 
         v9fs_set_tag(tc, n);
 
+        if ((v9fs_debug_level&DEBUG_FCALL) == DEBUG_FCALL) {
+                char buf[150];
+
+                v9fs_printfcall(buf, sizeof(buf), tc, *m->extended);
+                printk(KERN_NOTICE "<<< %p %s\n", m, buf);
+        }
+
         req->tag = n;
         req->tcall = tc;
         req->rcall = NULL;
@@ -761,9 +776,8 @@ static struct v9fs_req *v9fs_send_request(struct v9fs_mux_data *m,
         return req;
 }
 
-static inline void
-v9fs_mux_flush_cb(void *a, struct v9fs_fcall *tc, struct v9fs_fcall *rc,
-                  int err)
+static void v9fs_mux_flush_cb(void *a, struct v9fs_fcall *tc,
+                              struct v9fs_fcall *rc, int err)
 {
         v9fs_mux_req_callback cb;
         int tag;
@@ -901,6 +915,7 @@ v9fs_mux_rpc(struct v9fs_mux_data *m, struct v9fs_fcall *tc,
         return err;
 }
 
+#if 0
 /**
  * v9fs_mux_rpcnb - sends 9P request without waiting for response.
  * @m: mux data
@@ -924,6 +939,7 @@ int v9fs_mux_rpcnb(struct v9fs_mux_data *m, struct v9fs_fcall *tc,
         dprintk(DEBUG_MUX, "mux %p tc %p tag %d\n", m, tc, req->tag);
         return 0;
 }
+#endif  /*  0  */
 
 /**
  * v9fs_mux_cancel - cancel all pending requests with error
@@ -963,7 +979,7 @@ static u16 v9fs_mux_get_tag(struct v9fs_mux_data *m)
 {
         int tag;
 
-        tag = v9fs_get_idpool(&m->tidpool);
+        tag = v9fs_get_idpool(&m->tagpool);
         if (tag < 0)
                 return V9FS_NOTAG;
         else
@@ -972,6 +988,6 @@ static u16 v9fs_mux_get_tag(struct v9fs_mux_data *m)
 
 static void v9fs_mux_put_tag(struct v9fs_mux_data *m, u16 tag)
 {
-        if (tag != V9FS_NOTAG && v9fs_check_idpool(tag, &m->tidpool))
-                v9fs_put_idpool(tag, &m->tidpool);
+        if (tag != V9FS_NOTAG && v9fs_check_idpool(tag, &m->tagpool))
+                v9fs_put_idpool(tag, &m->tagpool);
 }