include cleanup: Update gfp.h and slab.h includes to prepare for breaking implicit...
[safe/jmp/linux-2.6] / drivers / usb / mon / mon_text.c
index 9f9236b..4d0be13 100644 (file)
@@ -7,8 +7,11 @@
 #include <linux/kernel.h>
 #include <linux/list.h>
 #include <linux/usb.h>
+#include <linux/slab.h>
 #include <linux/time.h>
 #include <linux/mutex.h>
+#include <linux/debugfs.h>
+#include <linux/scatterlist.h>
 #include <asm/uaccess.h>
 
 #include "usb_mon.h"
  * to a local DoS. But we have to keep to root in order to prevent
  * password sniffing from HID devices.
  */
-#define EVENT_MAX  (2*PAGE_SIZE / sizeof(struct mon_event_text))
+#define EVENT_MAX  (4*PAGE_SIZE / sizeof(struct mon_event_text))
 
-#define PRINTF_DFL  160
+/*
+ * Potentially unlimited number; we limit it for similar allocations.
+ * The usbfs limits this to 128, but we're not quite as generous.
+ */
+#define ISODESC_MAX   5
+
+#define PRINTF_DFL  250   /* with 5 ISOs segs */
+
+struct mon_iso_desc {
+       int status;
+       unsigned int offset;
+       unsigned int length;    /* Unsigned here, signed in URB. Historic. */
+};
 
 struct mon_event_text {
        struct list_head e_link;
        int type;               /* submit, complete, etc. */
-       unsigned int pipe;      /* Pipe */
        unsigned long id;       /* From pointer, most of the time */
        unsigned int tstamp;
+       int busnum;
+       char devnum;
+       char epnum;
+       char is_in;
+       char xfertype;
        int length;             /* Depends on type: xfer length or act length */
        int status;
+       int interval;
+       int start_frame;
+       int error_count;
        char setup_flag;
        char data_flag;
+       int numdesc;            /* Full number */
+       struct mon_iso_desc isodesc[ISODESC_MAX];
        unsigned char setup[SETUP_MAX];
        unsigned char data[DATA_MAX];
 };
 
 #define SLAB_NAME_SZ  30
 struct mon_reader_text {
-       kmem_cache_t *e_slab;
+       struct kmem_cache *e_slab;
        int nevents;
        struct list_head e_list;
        struct mon_reader r;    /* In C, parent class can be placed anywhere */
@@ -63,8 +87,31 @@ struct mon_reader_text {
        char slab_name[SLAB_NAME_SZ];
 };
 
-static void mon_text_ctor(void *, kmem_cache_t *, unsigned long);
-static void mon_text_dtor(void *, kmem_cache_t *, unsigned long);
+static struct dentry *mon_dir;         /* Usually /sys/kernel/debug/usbmon */
+
+static void mon_text_ctor(void *);
+
+struct mon_text_ptr {
+       int cnt, limit;
+       char *pbuf;
+};
+
+static struct mon_event_text *
+    mon_text_read_wait(struct mon_reader_text *rp, struct file *file);
+static void mon_text_read_head_t(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep);
+static void mon_text_read_head_u(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep);
+static void mon_text_read_statset(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep);
+static void mon_text_read_intstat(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep);
+static void mon_text_read_isostat(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep);
+static void mon_text_read_isodesc(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep);
+static void mon_text_read_data(struct mon_reader_text *rp,
+    struct mon_text_ptr *p, const struct mon_event_text *ep);
 
 /*
  * mon_text_submit
@@ -76,14 +123,12 @@ static void mon_text_dtor(void *, kmem_cache_t *, unsigned long);
  */
 
 static inline char mon_text_get_setup(struct mon_event_text *ep,
-    struct urb *urb, char ev_type)
+    struct urb *urb, char ev_type, struct mon_bus *mbus)
 {
 
-       if (!usb_pipecontrol(urb->pipe) || ev_type != 'S')
+       if (ep->xfertype != USB_ENDPOINT_XFER_CONTROL || ev_type != 'S')
                return '-';
 
-       if (urb->transfer_flags & URB_NO_SETUP_DMA_MAP)
-               return mon_dmapeek(ep->setup, urb->setup_dma, SETUP_MAX);
        if (urb->setup_packet == NULL)
                return 'Z';     /* '0' would be not as pretty. */
 
@@ -92,39 +137,41 @@ static inline char mon_text_get_setup(struct mon_event_text *ep,
 }
 
 static inline char mon_text_get_data(struct mon_event_text *ep, struct urb *urb,
-    int len, char ev_type)
+    int len, char ev_type, struct mon_bus *mbus)
 {
-       int pipe = urb->pipe;
+       void *src;
 
        if (len <= 0)
                return 'L';
        if (len >= DATA_MAX)
                len = DATA_MAX;
 
-       if (usb_pipein(pipe)) {
-               if (ev_type == 'S')
+       if (ep->is_in) {
+               if (ev_type != 'C')
                        return '<';
        } else {
-               if (ev_type == 'C')
+               if (ev_type != 'S')
                        return '>';
        }
 
-       /*
-        * The check to see if it's safe to poke at data has an enormous
-        * number of corner cases, but it seems that the following is
-        * more or less safe.
-        *
-        * We do not even try to look at transfer_buffer, because it can
-        * contain non-NULL garbage in case the upper level promised to
-        * set DMA for the HCD.
-        */
-       if (urb->transfer_flags & URB_NO_TRANSFER_DMA_MAP)
-               return mon_dmapeek(ep->data, urb->transfer_dma, len);
+       if (urb->num_sgs == 0) {
+               src = urb->transfer_buffer;
+               if (src == NULL)
+                       return 'Z';     /* '0' would be not as pretty. */
+       } else {
+               struct scatterlist *sg = urb->sg->sg;
 
-       if (urb->transfer_buffer == NULL)
-               return 'Z';     /* '0' would be not as pretty. */
+               /* If IOMMU coalescing occurred, we cannot trust sg_page */
+               if (urb->sg->nents != urb->num_sgs ||
+                               PageHighMem(sg_page(sg)))
+                       return 'D';
 
-       memcpy(ep->data, urb->transfer_buffer, len);
+               /* For the text interface we copy only the first sg buffer */
+               len = min_t(int, sg->length, len);
+               src = sg_virt(sg);
+       }
+
+       memcpy(ep->data, src, len);
        return 0;
 }
 
@@ -134,36 +181,68 @@ static inline unsigned int mon_get_timestamp(void)
        unsigned int stamp;
 
        do_gettimeofday(&tval);
-       stamp = tval.tv_sec & 0xFFFF;   /* 2^32 = 4294967296. Limit to 4096s. */
+       stamp = tval.tv_sec & 0xFFF   /* 2^32 = 4294967296. Limit to 4096s. */
        stamp = stamp * 1000000 + tval.tv_usec;
        return stamp;
 }
 
 static void mon_text_event(struct mon_reader_text *rp, struct urb *urb,
-    char ev_type)
+    char ev_type, int status)
 {
        struct mon_event_text *ep;
        unsigned int stamp;
+       struct usb_iso_packet_descriptor *fp;
+       struct mon_iso_desc *dp;
+       int i, ndesc;
 
        stamp = mon_get_timestamp();
 
        if (rp->nevents >= EVENT_MAX ||
-           (ep = kmem_cache_alloc(rp->e_slab, SLAB_ATOMIC)) == NULL) {
+           (ep = kmem_cache_alloc(rp->e_slab, GFP_ATOMIC)) == NULL) {
                rp->r.m_bus->cnt_text_lost++;
                return;
        }
 
        ep->type = ev_type;
-       ep->pipe = urb->pipe;
        ep->id = (unsigned long) urb;
+       ep->busnum = urb->dev->bus->busnum;
+       ep->devnum = urb->dev->devnum;
+       ep->epnum = usb_endpoint_num(&urb->ep->desc);
+       ep->xfertype = usb_endpoint_type(&urb->ep->desc);
+       ep->is_in = usb_urb_dir_in(urb);
        ep->tstamp = stamp;
        ep->length = (ev_type == 'S') ?
            urb->transfer_buffer_length : urb->actual_length;
        /* Collecting status makes debugging sense for submits, too */
-       ep->status = urb->status;
+       ep->status = status;
+
+       if (ep->xfertype == USB_ENDPOINT_XFER_INT) {
+               ep->interval = urb->interval;
+       } else if (ep->xfertype == USB_ENDPOINT_XFER_ISOC) {
+               ep->interval = urb->interval;
+               ep->start_frame = urb->start_frame;
+               ep->error_count = urb->error_count;
+       }
+       ep->numdesc = urb->number_of_packets;
+       if (ep->xfertype == USB_ENDPOINT_XFER_ISOC &&
+                       urb->number_of_packets > 0) {
+               if ((ndesc = urb->number_of_packets) > ISODESC_MAX)
+                       ndesc = ISODESC_MAX;
+               fp = urb->iso_frame_desc;
+               dp = ep->isodesc;
+               for (i = 0; i < ndesc; i++) {
+                       dp->status = fp->status;
+                       dp->offset = fp->offset;
+                       dp->length = (ev_type == 'S') ?
+                           fp->length : fp->actual_length;
+                       fp++;
+                       dp++;
+               }
+       }
 
-       ep->setup_flag = mon_text_get_setup(ep, urb, ev_type);
-       ep->data_flag = mon_text_get_data(ep, urb, ep->length, ev_type);
+       ep->setup_flag = mon_text_get_setup(ep, urb, ev_type, rp->r.m_bus);
+       ep->data_flag = mon_text_get_data(ep, urb, ep->length, ev_type,
+                       rp->r.m_bus);
 
        rp->nevents++;
        list_add_tail(&ep->e_link, &rp->e_list);
@@ -173,13 +252,43 @@ static void mon_text_event(struct mon_reader_text *rp, struct urb *urb,
 static void mon_text_submit(void *data, struct urb *urb)
 {
        struct mon_reader_text *rp = data;
-       mon_text_event(rp, urb, 'S');
+       mon_text_event(rp, urb, 'S', -EINPROGRESS);
 }
 
-static void mon_text_complete(void *data, struct urb *urb)
+static void mon_text_complete(void *data, struct urb *urb, int status)
 {
        struct mon_reader_text *rp = data;
-       mon_text_event(rp, urb, 'C');
+       mon_text_event(rp, urb, 'C', status);
+}
+
+static void mon_text_error(void *data, struct urb *urb, int error)
+{
+       struct mon_reader_text *rp = data;
+       struct mon_event_text *ep;
+
+       if (rp->nevents >= EVENT_MAX ||
+           (ep = kmem_cache_alloc(rp->e_slab, GFP_ATOMIC)) == NULL) {
+               rp->r.m_bus->cnt_text_lost++;
+               return;
+       }
+
+       ep->type = 'E';
+       ep->id = (unsigned long) urb;
+       ep->busnum = urb->dev->bus->busnum;
+       ep->devnum = urb->dev->devnum;
+       ep->epnum = usb_endpoint_num(&urb->ep->desc);
+       ep->xfertype = usb_endpoint_type(&urb->ep->desc);
+       ep->is_in = usb_urb_dir_in(urb);
+       ep->tstamp = mon_get_timestamp();
+       ep->length = 0;
+       ep->status = error;
+
+       ep->setup_flag = '-';
+       ep->data_flag = 'E';
+
+       rp->nevents++;
+       list_add_tail(&ep->e_link, &rp->e_list);
+       wake_up(&rp->wait);
 }
 
 /*
@@ -208,13 +317,11 @@ static struct mon_event_text *mon_text_fetch(struct mon_reader_text *rp,
 static int mon_text_open(struct inode *inode, struct file *file)
 {
        struct mon_bus *mbus;
-       struct usb_bus *ubus;
        struct mon_reader_text *rp;
        int rc;
 
        mutex_lock(&mon_lock);
-       mbus = inode->u.generic_ip;
-       ubus = mbus->u_bus;
+       mbus = inode->i_private;
 
        rp = kzalloc(sizeof(struct mon_reader_text), GFP_KERNEL);
        if (rp == NULL) {
@@ -235,13 +342,13 @@ static int mon_text_open(struct inode *inode, struct file *file)
        rp->r.m_bus = mbus;
        rp->r.r_data = rp;
        rp->r.rnf_submit = mon_text_submit;
+       rp->r.rnf_error = mon_text_error;
        rp->r.rnf_complete = mon_text_complete;
 
-       snprintf(rp->slab_name, SLAB_NAME_SZ, "mon%dt_%lx", ubus->busnum,
-           (long)rp);
+       snprintf(rp->slab_name, SLAB_NAME_SZ, "mon_text_%p", rp);
        rp->e_slab = kmem_cache_create(rp->slab_name,
            sizeof(struct mon_event_text), sizeof(long), 0,
-           mon_text_ctor, mon_text_dtor);
+           mon_text_ctor);
        if (rp->e_slab == NULL) {
                rc = -ENOMEM;
                goto err_slab;
@@ -270,17 +377,75 @@ err_alloc:
  *   dd if=/dbg/usbmon/0t bs=10
  * Also, we do not allow seeks and do not bother advancing the offset.
  */
-static ssize_t mon_text_read(struct file *file, char __user *buf,
+static ssize_t mon_text_read_t(struct file *file, char __user *buf,
+                               size_t nbytes, loff_t *ppos)
+{
+       struct mon_reader_text *rp = file->private_data;
+       struct mon_event_text *ep;
+       struct mon_text_ptr ptr;
+
+       if (IS_ERR(ep = mon_text_read_wait(rp, file)))
+               return PTR_ERR(ep);
+       mutex_lock(&rp->printf_lock);
+       ptr.cnt = 0;
+       ptr.pbuf = rp->printf_buf;
+       ptr.limit = rp->printf_size;
+
+       mon_text_read_head_t(rp, &ptr, ep);
+       mon_text_read_statset(rp, &ptr, ep);
+       ptr.cnt += snprintf(ptr.pbuf + ptr.cnt, ptr.limit - ptr.cnt,
+           " %d", ep->length);
+       mon_text_read_data(rp, &ptr, ep);
+
+       if (copy_to_user(buf, rp->printf_buf, ptr.cnt))
+               ptr.cnt = -EFAULT;
+       mutex_unlock(&rp->printf_lock);
+       kmem_cache_free(rp->e_slab, ep);
+       return ptr.cnt;
+}
+
+static ssize_t mon_text_read_u(struct file *file, char __user *buf,
                                size_t nbytes, loff_t *ppos)
 {
        struct mon_reader_text *rp = file->private_data;
+       struct mon_event_text *ep;
+       struct mon_text_ptr ptr;
+
+       if (IS_ERR(ep = mon_text_read_wait(rp, file)))
+               return PTR_ERR(ep);
+       mutex_lock(&rp->printf_lock);
+       ptr.cnt = 0;
+       ptr.pbuf = rp->printf_buf;
+       ptr.limit = rp->printf_size;
+
+       mon_text_read_head_u(rp, &ptr, ep);
+       if (ep->type == 'E') {
+               mon_text_read_statset(rp, &ptr, ep);
+       } else if (ep->xfertype == USB_ENDPOINT_XFER_ISOC) {
+               mon_text_read_isostat(rp, &ptr, ep);
+               mon_text_read_isodesc(rp, &ptr, ep);
+       } else if (ep->xfertype == USB_ENDPOINT_XFER_INT) {
+               mon_text_read_intstat(rp, &ptr, ep);
+       } else {
+               mon_text_read_statset(rp, &ptr, ep);
+       }
+       ptr.cnt += snprintf(ptr.pbuf + ptr.cnt, ptr.limit - ptr.cnt,
+           " %d", ep->length);
+       mon_text_read_data(rp, &ptr, ep);
+
+       if (copy_to_user(buf, rp->printf_buf, ptr.cnt))
+               ptr.cnt = -EFAULT;
+       mutex_unlock(&rp->printf_lock);
+       kmem_cache_free(rp->e_slab, ep);
+       return ptr.cnt;
+}
+
+static struct mon_event_text *mon_text_read_wait(struct mon_reader_text *rp,
+    struct file *file)
+{
        struct mon_bus *mbus = rp->r.m_bus;
        DECLARE_WAITQUEUE(waita, current);
        struct mon_event_text *ep;
-       int cnt, limit;
-       char *pbuf;
-       char udir, utype;
-       int data_len, i;
 
        add_wait_queue(&rp->wait, &waita);
        set_current_state(TASK_INTERRUPTIBLE);
@@ -288,7 +453,7 @@ static ssize_t mon_text_read(struct file *file, char __user *buf,
                if (file->f_flags & O_NONBLOCK) {
                        set_current_state(TASK_RUNNING);
                        remove_wait_queue(&rp->wait, &waita);
-                       return -EWOULDBLOCK;    /* Same as EAGAIN in Linux */
+                       return ERR_PTR(-EWOULDBLOCK);
                }
                /*
                 * We do not count nwaiters, because ->release is supposed
@@ -297,32 +462,57 @@ static ssize_t mon_text_read(struct file *file, char __user *buf,
                schedule();
                if (signal_pending(current)) {
                        remove_wait_queue(&rp->wait, &waita);
-                       return -EINTR;
+                       return ERR_PTR(-EINTR);
                }
                set_current_state(TASK_INTERRUPTIBLE);
        }
        set_current_state(TASK_RUNNING);
        remove_wait_queue(&rp->wait, &waita);
+       return ep;
+}
 
-       mutex_lock(&rp->printf_lock);
-       cnt = 0;
-       pbuf = rp->printf_buf;
-       limit = rp->printf_size;
-
-       udir = usb_pipein(ep->pipe) ? 'i' : 'o';
-       switch (usb_pipetype(ep->pipe)) {
-       case PIPE_ISOCHRONOUS:  utype = 'Z'; break;
-       case PIPE_INTERRUPT:    utype = 'I'; break;
-       case PIPE_CONTROL:      utype = 'C'; break;
+static void mon_text_read_head_t(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep)
+{
+       char udir, utype;
+
+       udir = (ep->is_in ? 'i' : 'o');
+       switch (ep->xfertype) {
+       case USB_ENDPOINT_XFER_ISOC:    utype = 'Z'; break;
+       case USB_ENDPOINT_XFER_INT:     utype = 'I'; break;
+       case USB_ENDPOINT_XFER_CONTROL: utype = 'C'; break;
        default: /* PIPE_BULK */  utype = 'B';
        }
-       cnt += snprintf(pbuf + cnt, limit - cnt,
+       p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
            "%lx %u %c %c%c:%03u:%02u",
            ep->id, ep->tstamp, ep->type,
-           utype, udir, usb_pipedevice(ep->pipe), usb_pipeendpoint(ep->pipe));
+           utype, udir, ep->devnum, ep->epnum);
+}
+
+static void mon_text_read_head_u(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep)
+{
+       char udir, utype;
+
+       udir = (ep->is_in ? 'i' : 'o');
+       switch (ep->xfertype) {
+       case USB_ENDPOINT_XFER_ISOC:    utype = 'Z'; break;
+       case USB_ENDPOINT_XFER_INT:     utype = 'I'; break;
+       case USB_ENDPOINT_XFER_CONTROL: utype = 'C'; break;
+       default: /* PIPE_BULK */  utype = 'B';
+       }
+       p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
+           "%lx %u %c %c%c:%d:%03u:%u",
+           ep->id, ep->tstamp, ep->type,
+           utype, udir, ep->busnum, ep->devnum, ep->epnum);
+}
+
+static void mon_text_read_statset(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep)
+{
 
        if (ep->setup_flag == 0) {   /* Setup packet is present and captured */
-               cnt += snprintf(pbuf + cnt, limit - cnt,
+               p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
                    " s %02x %02x %04x %04x %04x",
                    ep->setup[0],
                    ep->setup[1],
@@ -330,40 +520,86 @@ static ssize_t mon_text_read(struct file *file, char __user *buf,
                    (ep->setup[5] << 8) | ep->setup[4],
                    (ep->setup[7] << 8) | ep->setup[6]);
        } else if (ep->setup_flag != '-') { /* Unable to capture setup packet */
-               cnt += snprintf(pbuf + cnt, limit - cnt,
+               p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
                    " %c __ __ ____ ____ ____", ep->setup_flag);
        } else {                     /* No setup for this kind of URB */
-               cnt += snprintf(pbuf + cnt, limit - cnt, " %d", ep->status);
+               p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
+                   " %d", ep->status);
        }
-       cnt += snprintf(pbuf + cnt, limit - cnt, " %d", ep->length);
+}
+
+static void mon_text_read_intstat(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep)
+{
+       p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
+           " %d:%d", ep->status, ep->interval);
+}
+
+static void mon_text_read_isostat(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep)
+{
+       if (ep->type == 'S') {
+               p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
+                   " %d:%d:%d", ep->status, ep->interval, ep->start_frame);
+       } else {
+               p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
+                   " %d:%d:%d:%d",
+                   ep->status, ep->interval, ep->start_frame, ep->error_count);
+       }
+}
+
+static void mon_text_read_isodesc(struct mon_reader_text *rp,
+       struct mon_text_ptr *p, const struct mon_event_text *ep)
+{
+       int ndesc;      /* Display this many */
+       int i;
+       const struct mon_iso_desc *dp;
+
+       p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
+           " %d", ep->numdesc);
+       ndesc = ep->numdesc;
+       if (ndesc > ISODESC_MAX)
+               ndesc = ISODESC_MAX;
+       if (ndesc < 0)
+               ndesc = 0;
+       dp = ep->isodesc;
+       for (i = 0; i < ndesc; i++) {
+               p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
+                   " %d:%u:%u", dp->status, dp->offset, dp->length);
+               dp++;
+       }
+}
+
+static void mon_text_read_data(struct mon_reader_text *rp,
+    struct mon_text_ptr *p, const struct mon_event_text *ep)
+{
+       int data_len, i;
 
        if ((data_len = ep->length) > 0) {
                if (ep->data_flag == 0) {
-                       cnt += snprintf(pbuf + cnt, limit - cnt, " =");
+                       p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
+                           " =");
                        if (data_len >= DATA_MAX)
                                data_len = DATA_MAX;
                        for (i = 0; i < data_len; i++) {
                                if (i % 4 == 0) {
-                                       cnt += snprintf(pbuf + cnt, limit - cnt,
+                                       p->cnt += snprintf(p->pbuf + p->cnt,
+                                           p->limit - p->cnt,
                                            " ");
                                }
-                               cnt += snprintf(pbuf + cnt, limit - cnt,
+                               p->cnt += snprintf(p->pbuf + p->cnt,
+                                   p->limit - p->cnt,
                                    "%02x", ep->data[i]);
                        }
-                       cnt += snprintf(pbuf + cnt, limit - cnt, "\n");
+                       p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
+                           "\n");
                } else {
-                       cnt += snprintf(pbuf + cnt, limit - cnt,
+                       p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt,
                            " %c\n", ep->data_flag);
                }
        } else {
-               cnt += snprintf(pbuf + cnt, limit - cnt, "\n");
+               p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, "\n");
        }
-
-       if (copy_to_user(buf, rp->printf_buf, cnt))
-               cnt = -EFAULT;
-       mutex_unlock(&rp->printf_lock);
-       kmem_cache_free(rp->e_slab, ep);
-       return cnt;
 }
 
 static int mon_text_release(struct inode *inode, struct file *file)
@@ -375,7 +611,7 @@ static int mon_text_release(struct inode *inode, struct file *file)
        struct mon_event_text *ep;
 
        mutex_lock(&mon_lock);
-       mbus = inode->u.generic_ip;
+       mbus = inode->i_private;
 
        if (mbus->nreaders <= 0) {
                printk(KERN_ERR TAG ": consistency error on close\n");
@@ -409,21 +645,86 @@ static int mon_text_release(struct inode *inode, struct file *file)
        return 0;
 }
 
-struct file_operations mon_fops_text = {
+static const struct file_operations mon_fops_text_t = {
        .owner =        THIS_MODULE,
        .open =         mon_text_open,
        .llseek =       no_llseek,
-       .read =         mon_text_read,
-       /* .write =     mon_text_write, */
-       /* .poll =              mon_text_poll, */
-       /* .ioctl =     mon_text_ioctl, */
+       .read =         mon_text_read_t,
        .release =      mon_text_release,
 };
 
+static const struct file_operations mon_fops_text_u = {
+       .owner =        THIS_MODULE,
+       .open =         mon_text_open,
+       .llseek =       no_llseek,
+       .read =         mon_text_read_u,
+       .release =      mon_text_release,
+};
+
+int mon_text_add(struct mon_bus *mbus, const struct usb_bus *ubus)
+{
+       struct dentry *d;
+       enum { NAMESZ = 10 };
+       char name[NAMESZ];
+       int busnum = ubus? ubus->busnum: 0;
+       int rc;
+
+       if (ubus != NULL) {
+               rc = snprintf(name, NAMESZ, "%dt", busnum);
+               if (rc <= 0 || rc >= NAMESZ)
+                       goto err_print_t;
+               d = debugfs_create_file(name, 0600, mon_dir, mbus,
+                                                            &mon_fops_text_t);
+               if (d == NULL)
+                       goto err_create_t;
+               mbus->dent_t = d;
+       }
+
+       rc = snprintf(name, NAMESZ, "%du", busnum);
+       if (rc <= 0 || rc >= NAMESZ)
+               goto err_print_u;
+       d = debugfs_create_file(name, 0600, mon_dir, mbus, &mon_fops_text_u);
+       if (d == NULL)
+               goto err_create_u;
+       mbus->dent_u = d;
+
+       rc = snprintf(name, NAMESZ, "%ds", busnum);
+       if (rc <= 0 || rc >= NAMESZ)
+               goto err_print_s;
+       d = debugfs_create_file(name, 0600, mon_dir, mbus, &mon_fops_stat);
+       if (d == NULL)
+               goto err_create_s;
+       mbus->dent_s = d;
+
+       return 1;
+
+err_create_s:
+err_print_s:
+       debugfs_remove(mbus->dent_u);
+       mbus->dent_u = NULL;
+err_create_u:
+err_print_u:
+       if (ubus != NULL) {
+               debugfs_remove(mbus->dent_t);
+               mbus->dent_t = NULL;
+       }
+err_create_t:
+err_print_t:
+       return 0;
+}
+
+void mon_text_del(struct mon_bus *mbus)
+{
+       debugfs_remove(mbus->dent_u);
+       if (mbus->dent_t != NULL)
+               debugfs_remove(mbus->dent_t);
+       debugfs_remove(mbus->dent_s);
+}
+
 /*
  * Slab interface: constructor.
  */
-static void mon_text_ctor(void *mem, kmem_cache_t *slab, unsigned long sflags)
+static void mon_text_ctor(void *mem)
 {
        /*
         * Nothing to initialize. No, really!
@@ -432,7 +733,24 @@ static void mon_text_ctor(void *mem, kmem_cache_t *slab, unsigned long sflags)
        memset(mem, 0xe5, sizeof(struct mon_event_text));
 }
 
-static void mon_text_dtor(void *mem, kmem_cache_t *slab, unsigned long sflags)
+int __init mon_text_init(void)
+{
+       struct dentry *mondir;
+
+       mondir = debugfs_create_dir("usbmon", usb_debug_root);
+       if (IS_ERR(mondir)) {
+               printk(KERN_NOTICE TAG ": debugfs is not available\n");
+               return -ENODEV;
+       }
+       if (mondir == NULL) {
+               printk(KERN_NOTICE TAG ": unable to create usbmon directory\n");
+               return -ENODEV;
+       }
+       mon_dir = mondir;
+       return 0;
+}
+
+void mon_text_exit(void)
 {
-       ;
+       debugfs_remove(mon_dir);
 }