1 /* 2 * The USB Monitor, inspired by Dave Harding's USBMon. 3 * 4 * This is a text format reader. 5 */ 6 7 #include <linux/kernel.h> 8 #include <linux/list.h> 9 #include <linux/usb.h> 10 #include <linux/time.h> 11 #include <linux/mutex.h> 12 #include <linux/debugfs.h> 13 #include <asm/uaccess.h> 14 15 #include "usb_mon.h" 16 17 /* 18 * No, we do not want arbitrarily long data strings. 19 * Use the binary interface if you want to capture bulk data! 20 */ 21 #define DATA_MAX 32 22 23 /* 24 * Defined by USB 2.0 clause 9.3, table 9.2. 25 */ 26 #define SETUP_MAX 8 27 28 /* 29 * This limit exists to prevent OOMs when the user process stops reading. 30 * If usbmon were available to unprivileged processes, it might be open 31 * to a local DoS. But we have to keep to root in order to prevent 32 * password sniffing from HID devices. 33 */ 34 #define EVENT_MAX (4*PAGE_SIZE / sizeof(struct mon_event_text)) 35 36 /* 37 * Potentially unlimited number; we limit it for similar allocations. 38 * The usbfs limits this to 128, but we're not quite as generous. 39 */ 40 #define ISODESC_MAX 5 41 42 #define PRINTF_DFL 250 /* with 5 ISOs segs */ 43 44 struct mon_iso_desc { 45 int status; 46 unsigned int offset; 47 unsigned int length; /* Unsigned here, signed in URB. Historic. */ 48 }; 49 50 struct mon_event_text { 51 struct list_head e_link; 52 int type; /* submit, complete, etc. */ 53 unsigned int pipe; /* Pipe */ 54 unsigned long id; /* From pointer, most of the time */ 55 unsigned int tstamp; 56 int busnum; 57 int length; /* Depends on type: xfer length or act length */ 58 int status; 59 int interval; 60 int start_frame; 61 int error_count; 62 char setup_flag; 63 char data_flag; 64 int numdesc; /* Full number */ 65 struct mon_iso_desc isodesc[ISODESC_MAX]; 66 unsigned char setup[SETUP_MAX]; 67 unsigned char data[DATA_MAX]; 68 }; 69 70 #define SLAB_NAME_SZ 30 71 struct mon_reader_text { 72 struct kmem_cache *e_slab; 73 int nevents; 74 struct list_head e_list; 75 struct mon_reader r; /* In C, parent class can be placed anywhere */ 76 77 wait_queue_head_t wait; 78 int printf_size; 79 char *printf_buf; 80 struct mutex printf_lock; 81 82 char slab_name[SLAB_NAME_SZ]; 83 }; 84 85 static struct dentry *mon_dir; /* Usually /sys/kernel/debug/usbmon */ 86 87 static void mon_text_ctor(void *, struct kmem_cache *, unsigned long); 88 89 struct mon_text_ptr { 90 int cnt, limit; 91 char *pbuf; 92 }; 93 94 static struct mon_event_text * 95 mon_text_read_wait(struct mon_reader_text *rp, struct file *file); 96 static void mon_text_read_head_t(struct mon_reader_text *rp, 97 struct mon_text_ptr *p, const struct mon_event_text *ep); 98 static void mon_text_read_head_u(struct mon_reader_text *rp, 99 struct mon_text_ptr *p, const struct mon_event_text *ep); 100 static void mon_text_read_statset(struct mon_reader_text *rp, 101 struct mon_text_ptr *p, const struct mon_event_text *ep); 102 static void mon_text_read_intstat(struct mon_reader_text *rp, 103 struct mon_text_ptr *p, const struct mon_event_text *ep); 104 static void mon_text_read_isostat(struct mon_reader_text *rp, 105 struct mon_text_ptr *p, const struct mon_event_text *ep); 106 static void mon_text_read_isodesc(struct mon_reader_text *rp, 107 struct mon_text_ptr *p, const struct mon_event_text *ep); 108 static void mon_text_read_data(struct mon_reader_text *rp, 109 struct mon_text_ptr *p, const struct mon_event_text *ep); 110 111 /* 112 * mon_text_submit 113 * mon_text_complete 114 * 115 * May be called from an interrupt. 116 * 117 * This is called with the whole mon_bus locked, so no additional lock. 118 */ 119 120 static inline char mon_text_get_setup(struct mon_event_text *ep, 121 struct urb *urb, char ev_type, struct mon_bus *mbus) 122 { 123 124 if (!usb_pipecontrol(urb->pipe) || ev_type != 'S') 125 return '-'; 126 127 if (urb->dev->bus->uses_dma && 128 (urb->transfer_flags & URB_NO_SETUP_DMA_MAP)) { 129 return mon_dmapeek(ep->setup, urb->setup_dma, SETUP_MAX); 130 } 131 if (urb->setup_packet == NULL) 132 return 'Z'; /* '0' would be not as pretty. */ 133 134 memcpy(ep->setup, urb->setup_packet, SETUP_MAX); 135 return 0; 136 } 137 138 static inline char mon_text_get_data(struct mon_event_text *ep, struct urb *urb, 139 int len, char ev_type, struct mon_bus *mbus) 140 { 141 int pipe = urb->pipe; 142 143 if (len <= 0) 144 return 'L'; 145 if (len >= DATA_MAX) 146 len = DATA_MAX; 147 148 if (usb_pipein(pipe)) { 149 if (ev_type != 'C') 150 return '<'; 151 } else { 152 if (ev_type != 'S') 153 return '>'; 154 } 155 156 /* 157 * The check to see if it's safe to poke at data has an enormous 158 * number of corner cases, but it seems that the following is 159 * more or less safe. 160 * 161 * We do not even try to look at transfer_buffer, because it can 162 * contain non-NULL garbage in case the upper level promised to 163 * set DMA for the HCD. 164 */ 165 if (urb->dev->bus->uses_dma && 166 (urb->transfer_flags & URB_NO_TRANSFER_DMA_MAP)) { 167 return mon_dmapeek(ep->data, urb->transfer_dma, len); 168 } 169 170 if (urb->transfer_buffer == NULL) 171 return 'Z'; /* '0' would be not as pretty. */ 172 173 memcpy(ep->data, urb->transfer_buffer, len); 174 return 0; 175 } 176 177 static inline unsigned int mon_get_timestamp(void) 178 { 179 struct timeval tval; 180 unsigned int stamp; 181 182 do_gettimeofday(&tval); 183 stamp = tval.tv_sec & 0xFFFF; /* 2^32 = 4294967296. Limit to 4096s. */ 184 stamp = stamp * 1000000 + tval.tv_usec; 185 return stamp; 186 } 187 188 static void mon_text_event(struct mon_reader_text *rp, struct urb *urb, 189 char ev_type) 190 { 191 struct mon_event_text *ep; 192 unsigned int stamp; 193 struct usb_iso_packet_descriptor *fp; 194 struct mon_iso_desc *dp; 195 int i, ndesc; 196 197 stamp = mon_get_timestamp(); 198 199 if (rp->nevents >= EVENT_MAX || 200 (ep = kmem_cache_alloc(rp->e_slab, GFP_ATOMIC)) == NULL) { 201 rp->r.m_bus->cnt_text_lost++; 202 return; 203 } 204 205 ep->type = ev_type; 206 ep->pipe = urb->pipe; 207 ep->id = (unsigned long) urb; 208 ep->busnum = urb->dev->bus->busnum; 209 ep->tstamp = stamp; 210 ep->length = (ev_type == 'S') ? 211 urb->transfer_buffer_length : urb->actual_length; 212 /* Collecting status makes debugging sense for submits, too */ 213 ep->status = urb->status; 214 215 if (usb_pipeint(urb->pipe)) { 216 ep->interval = urb->interval; 217 } else if (usb_pipeisoc(urb->pipe)) { 218 ep->interval = urb->interval; 219 ep->start_frame = urb->start_frame; 220 ep->error_count = urb->error_count; 221 } 222 ep->numdesc = urb->number_of_packets; 223 if (usb_pipeisoc(urb->pipe) && urb->number_of_packets > 0) { 224 if ((ndesc = urb->number_of_packets) > ISODESC_MAX) 225 ndesc = ISODESC_MAX; 226 fp = urb->iso_frame_desc; 227 dp = ep->isodesc; 228 for (i = 0; i < ndesc; i++) { 229 dp->status = fp->status; 230 dp->offset = fp->offset; 231 dp->length = (ev_type == 'S') ? 232 fp->length : fp->actual_length; 233 fp++; 234 dp++; 235 } 236 } 237 238 ep->setup_flag = mon_text_get_setup(ep, urb, ev_type, rp->r.m_bus); 239 ep->data_flag = mon_text_get_data(ep, urb, ep->length, ev_type, 240 rp->r.m_bus); 241 242 rp->nevents++; 243 list_add_tail(&ep->e_link, &rp->e_list); 244 wake_up(&rp->wait); 245 } 246 247 static void mon_text_submit(void *data, struct urb *urb) 248 { 249 struct mon_reader_text *rp = data; 250 mon_text_event(rp, urb, 'S'); 251 } 252 253 static void mon_text_complete(void *data, struct urb *urb) 254 { 255 struct mon_reader_text *rp = data; 256 mon_text_event(rp, urb, 'C'); 257 } 258 259 static void mon_text_error(void *data, struct urb *urb, int error) 260 { 261 struct mon_reader_text *rp = data; 262 struct mon_event_text *ep; 263 264 if (rp->nevents >= EVENT_MAX || 265 (ep = kmem_cache_alloc(rp->e_slab, GFP_ATOMIC)) == NULL) { 266 rp->r.m_bus->cnt_text_lost++; 267 return; 268 } 269 270 ep->type = 'E'; 271 ep->pipe = urb->pipe; 272 ep->id = (unsigned long) urb; 273 ep->busnum = 0; 274 ep->tstamp = 0; 275 ep->length = 0; 276 ep->status = error; 277 278 ep->setup_flag = '-'; 279 ep->data_flag = 'E'; 280 281 rp->nevents++; 282 list_add_tail(&ep->e_link, &rp->e_list); 283 wake_up(&rp->wait); 284 } 285 286 /* 287 * Fetch next event from the circular buffer. 288 */ 289 static struct mon_event_text *mon_text_fetch(struct mon_reader_text *rp, 290 struct mon_bus *mbus) 291 { 292 struct list_head *p; 293 unsigned long flags; 294 295 spin_lock_irqsave(&mbus->lock, flags); 296 if (list_empty(&rp->e_list)) { 297 spin_unlock_irqrestore(&mbus->lock, flags); 298 return NULL; 299 } 300 p = rp->e_list.next; 301 list_del(p); 302 --rp->nevents; 303 spin_unlock_irqrestore(&mbus->lock, flags); 304 return list_entry(p, struct mon_event_text, e_link); 305 } 306 307 /* 308 */ 309 static int mon_text_open(struct inode *inode, struct file *file) 310 { 311 struct mon_bus *mbus; 312 struct mon_reader_text *rp; 313 int rc; 314 315 mutex_lock(&mon_lock); 316 mbus = inode->i_private; 317 318 rp = kzalloc(sizeof(struct mon_reader_text), GFP_KERNEL); 319 if (rp == NULL) { 320 rc = -ENOMEM; 321 goto err_alloc; 322 } 323 INIT_LIST_HEAD(&rp->e_list); 324 init_waitqueue_head(&rp->wait); 325 mutex_init(&rp->printf_lock); 326 327 rp->printf_size = PRINTF_DFL; 328 rp->printf_buf = kmalloc(rp->printf_size, GFP_KERNEL); 329 if (rp->printf_buf == NULL) { 330 rc = -ENOMEM; 331 goto err_alloc_pr; 332 } 333 334 rp->r.m_bus = mbus; 335 rp->r.r_data = rp; 336 rp->r.rnf_submit = mon_text_submit; 337 rp->r.rnf_error = mon_text_error; 338 rp->r.rnf_complete = mon_text_complete; 339 340 snprintf(rp->slab_name, SLAB_NAME_SZ, "mon_text_%p", rp); 341 rp->e_slab = kmem_cache_create(rp->slab_name, 342 sizeof(struct mon_event_text), sizeof(long), 0, 343 mon_text_ctor); 344 if (rp->e_slab == NULL) { 345 rc = -ENOMEM; 346 goto err_slab; 347 } 348 349 mon_reader_add(mbus, &rp->r); 350 351 file->private_data = rp; 352 mutex_unlock(&mon_lock); 353 return 0; 354 355 // err_busy: 356 // kmem_cache_destroy(rp->e_slab); 357 err_slab: 358 kfree(rp->printf_buf); 359 err_alloc_pr: 360 kfree(rp); 361 err_alloc: 362 mutex_unlock(&mon_lock); 363 return rc; 364 } 365 366 /* 367 * For simplicity, we read one record in one system call and throw out 368 * what does not fit. This means that the following does not work: 369 * dd if=/dbg/usbmon/0t bs=10 370 * Also, we do not allow seeks and do not bother advancing the offset. 371 */ 372 static ssize_t mon_text_read_t(struct file *file, char __user *buf, 373 size_t nbytes, loff_t *ppos) 374 { 375 struct mon_reader_text *rp = file->private_data; 376 struct mon_event_text *ep; 377 struct mon_text_ptr ptr; 378 379 if (IS_ERR(ep = mon_text_read_wait(rp, file))) 380 return PTR_ERR(ep); 381 mutex_lock(&rp->printf_lock); 382 ptr.cnt = 0; 383 ptr.pbuf = rp->printf_buf; 384 ptr.limit = rp->printf_size; 385 386 mon_text_read_head_t(rp, &ptr, ep); 387 mon_text_read_statset(rp, &ptr, ep); 388 ptr.cnt += snprintf(ptr.pbuf + ptr.cnt, ptr.limit - ptr.cnt, 389 " %d", ep->length); 390 mon_text_read_data(rp, &ptr, ep); 391 392 if (copy_to_user(buf, rp->printf_buf, ptr.cnt)) 393 ptr.cnt = -EFAULT; 394 mutex_unlock(&rp->printf_lock); 395 kmem_cache_free(rp->e_slab, ep); 396 return ptr.cnt; 397 } 398 399 static ssize_t mon_text_read_u(struct file *file, char __user *buf, 400 size_t nbytes, loff_t *ppos) 401 { 402 struct mon_reader_text *rp = file->private_data; 403 struct mon_event_text *ep; 404 struct mon_text_ptr ptr; 405 406 if (IS_ERR(ep = mon_text_read_wait(rp, file))) 407 return PTR_ERR(ep); 408 mutex_lock(&rp->printf_lock); 409 ptr.cnt = 0; 410 ptr.pbuf = rp->printf_buf; 411 ptr.limit = rp->printf_size; 412 413 mon_text_read_head_u(rp, &ptr, ep); 414 if (ep->type == 'E') { 415 mon_text_read_statset(rp, &ptr, ep); 416 } else if (usb_pipeisoc(ep->pipe)) { 417 mon_text_read_isostat(rp, &ptr, ep); 418 mon_text_read_isodesc(rp, &ptr, ep); 419 } else if (usb_pipeint(ep->pipe)) { 420 mon_text_read_intstat(rp, &ptr, ep); 421 } else { 422 mon_text_read_statset(rp, &ptr, ep); 423 } 424 ptr.cnt += snprintf(ptr.pbuf + ptr.cnt, ptr.limit - ptr.cnt, 425 " %d", ep->length); 426 mon_text_read_data(rp, &ptr, ep); 427 428 if (copy_to_user(buf, rp->printf_buf, ptr.cnt)) 429 ptr.cnt = -EFAULT; 430 mutex_unlock(&rp->printf_lock); 431 kmem_cache_free(rp->e_slab, ep); 432 return ptr.cnt; 433 } 434 435 static struct mon_event_text *mon_text_read_wait(struct mon_reader_text *rp, 436 struct file *file) 437 { 438 struct mon_bus *mbus = rp->r.m_bus; 439 DECLARE_WAITQUEUE(waita, current); 440 struct mon_event_text *ep; 441 442 add_wait_queue(&rp->wait, &waita); 443 set_current_state(TASK_INTERRUPTIBLE); 444 while ((ep = mon_text_fetch(rp, mbus)) == NULL) { 445 if (file->f_flags & O_NONBLOCK) { 446 set_current_state(TASK_RUNNING); 447 remove_wait_queue(&rp->wait, &waita); 448 return ERR_PTR(-EWOULDBLOCK); 449 } 450 /* 451 * We do not count nwaiters, because ->release is supposed 452 * to be called when all openers are gone only. 453 */ 454 schedule(); 455 if (signal_pending(current)) { 456 remove_wait_queue(&rp->wait, &waita); 457 return ERR_PTR(-EINTR); 458 } 459 set_current_state(TASK_INTERRUPTIBLE); 460 } 461 set_current_state(TASK_RUNNING); 462 remove_wait_queue(&rp->wait, &waita); 463 return ep; 464 } 465 466 static void mon_text_read_head_t(struct mon_reader_text *rp, 467 struct mon_text_ptr *p, const struct mon_event_text *ep) 468 { 469 char udir, utype; 470 471 udir = usb_pipein(ep->pipe) ? 'i' : 'o'; 472 switch (usb_pipetype(ep->pipe)) { 473 case PIPE_ISOCHRONOUS: utype = 'Z'; break; 474 case PIPE_INTERRUPT: utype = 'I'; break; 475 case PIPE_CONTROL: utype = 'C'; break; 476 default: /* PIPE_BULK */ utype = 'B'; 477 } 478 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 479 "%lx %u %c %c%c:%03u:%02u", 480 ep->id, ep->tstamp, ep->type, 481 utype, udir, 482 usb_pipedevice(ep->pipe), usb_pipeendpoint(ep->pipe)); 483 } 484 485 static void mon_text_read_head_u(struct mon_reader_text *rp, 486 struct mon_text_ptr *p, const struct mon_event_text *ep) 487 { 488 char udir, utype; 489 490 udir = usb_pipein(ep->pipe) ? 'i' : 'o'; 491 switch (usb_pipetype(ep->pipe)) { 492 case PIPE_ISOCHRONOUS: utype = 'Z'; break; 493 case PIPE_INTERRUPT: utype = 'I'; break; 494 case PIPE_CONTROL: utype = 'C'; break; 495 default: /* PIPE_BULK */ utype = 'B'; 496 } 497 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 498 "%lx %u %c %c%c:%d:%03u:%u", 499 ep->id, ep->tstamp, ep->type, 500 utype, udir, 501 ep->busnum, usb_pipedevice(ep->pipe), usb_pipeendpoint(ep->pipe)); 502 } 503 504 static void mon_text_read_statset(struct mon_reader_text *rp, 505 struct mon_text_ptr *p, const struct mon_event_text *ep) 506 { 507 508 if (ep->setup_flag == 0) { /* Setup packet is present and captured */ 509 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 510 " s %02x %02x %04x %04x %04x", 511 ep->setup[0], 512 ep->setup[1], 513 (ep->setup[3] << 8) | ep->setup[2], 514 (ep->setup[5] << 8) | ep->setup[4], 515 (ep->setup[7] << 8) | ep->setup[6]); 516 } else if (ep->setup_flag != '-') { /* Unable to capture setup packet */ 517 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 518 " %c __ __ ____ ____ ____", ep->setup_flag); 519 } else { /* No setup for this kind of URB */ 520 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 521 " %d", ep->status); 522 } 523 } 524 525 static void mon_text_read_intstat(struct mon_reader_text *rp, 526 struct mon_text_ptr *p, const struct mon_event_text *ep) 527 { 528 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 529 " %d:%d", ep->status, ep->interval); 530 } 531 532 static void mon_text_read_isostat(struct mon_reader_text *rp, 533 struct mon_text_ptr *p, const struct mon_event_text *ep) 534 { 535 if (ep->type == 'S') { 536 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 537 " %d:%d:%d", ep->status, ep->interval, ep->start_frame); 538 } else { 539 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 540 " %d:%d:%d:%d", 541 ep->status, ep->interval, ep->start_frame, ep->error_count); 542 } 543 } 544 545 static void mon_text_read_isodesc(struct mon_reader_text *rp, 546 struct mon_text_ptr *p, const struct mon_event_text *ep) 547 { 548 int ndesc; /* Display this many */ 549 int i; 550 const struct mon_iso_desc *dp; 551 552 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 553 " %d", ep->numdesc); 554 ndesc = ep->numdesc; 555 if (ndesc > ISODESC_MAX) 556 ndesc = ISODESC_MAX; 557 if (ndesc < 0) 558 ndesc = 0; 559 dp = ep->isodesc; 560 for (i = 0; i < ndesc; i++) { 561 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 562 " %d:%u:%u", dp->status, dp->offset, dp->length); 563 dp++; 564 } 565 } 566 567 static void mon_text_read_data(struct mon_reader_text *rp, 568 struct mon_text_ptr *p, const struct mon_event_text *ep) 569 { 570 int data_len, i; 571 572 if ((data_len = ep->length) > 0) { 573 if (ep->data_flag == 0) { 574 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 575 " ="); 576 if (data_len >= DATA_MAX) 577 data_len = DATA_MAX; 578 for (i = 0; i < data_len; i++) { 579 if (i % 4 == 0) { 580 p->cnt += snprintf(p->pbuf + p->cnt, 581 p->limit - p->cnt, 582 " "); 583 } 584 p->cnt += snprintf(p->pbuf + p->cnt, 585 p->limit - p->cnt, 586 "%02x", ep->data[i]); 587 } 588 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 589 "\n"); 590 } else { 591 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, 592 " %c\n", ep->data_flag); 593 } 594 } else { 595 p->cnt += snprintf(p->pbuf + p->cnt, p->limit - p->cnt, "\n"); 596 } 597 } 598 599 static int mon_text_release(struct inode *inode, struct file *file) 600 { 601 struct mon_reader_text *rp = file->private_data; 602 struct mon_bus *mbus; 603 /* unsigned long flags; */ 604 struct list_head *p; 605 struct mon_event_text *ep; 606 607 mutex_lock(&mon_lock); 608 mbus = inode->i_private; 609 610 if (mbus->nreaders <= 0) { 611 printk(KERN_ERR TAG ": consistency error on close\n"); 612 mutex_unlock(&mon_lock); 613 return 0; 614 } 615 mon_reader_del(mbus, &rp->r); 616 617 /* 618 * In theory, e_list is protected by mbus->lock. However, 619 * after mon_reader_del has finished, the following is the case: 620 * - we are not on reader list anymore, so new events won't be added; 621 * - whole mbus may be dropped if it was orphaned. 622 * So, we better not touch mbus. 623 */ 624 /* spin_lock_irqsave(&mbus->lock, flags); */ 625 while (!list_empty(&rp->e_list)) { 626 p = rp->e_list.next; 627 ep = list_entry(p, struct mon_event_text, e_link); 628 list_del(p); 629 --rp->nevents; 630 kmem_cache_free(rp->e_slab, ep); 631 } 632 /* spin_unlock_irqrestore(&mbus->lock, flags); */ 633 634 kmem_cache_destroy(rp->e_slab); 635 kfree(rp->printf_buf); 636 kfree(rp); 637 638 mutex_unlock(&mon_lock); 639 return 0; 640 } 641 642 static const struct file_operations mon_fops_text_t = { 643 .owner = THIS_MODULE, 644 .open = mon_text_open, 645 .llseek = no_llseek, 646 .read = mon_text_read_t, 647 .release = mon_text_release, 648 }; 649 650 static const struct file_operations mon_fops_text_u = { 651 .owner = THIS_MODULE, 652 .open = mon_text_open, 653 .llseek = no_llseek, 654 .read = mon_text_read_u, 655 .release = mon_text_release, 656 }; 657 658 int mon_text_add(struct mon_bus *mbus, const struct usb_bus *ubus) 659 { 660 struct dentry *d; 661 enum { NAMESZ = 10 }; 662 char name[NAMESZ]; 663 int busnum = ubus? ubus->busnum: 0; 664 int rc; 665 666 if (ubus != NULL) { 667 rc = snprintf(name, NAMESZ, "%dt", busnum); 668 if (rc <= 0 || rc >= NAMESZ) 669 goto err_print_t; 670 d = debugfs_create_file(name, 0600, mon_dir, mbus, 671 &mon_fops_text_t); 672 if (d == NULL) 673 goto err_create_t; 674 mbus->dent_t = d; 675 } 676 677 rc = snprintf(name, NAMESZ, "%du", busnum); 678 if (rc <= 0 || rc >= NAMESZ) 679 goto err_print_u; 680 d = debugfs_create_file(name, 0600, mon_dir, mbus, &mon_fops_text_u); 681 if (d == NULL) 682 goto err_create_u; 683 mbus->dent_u = d; 684 685 rc = snprintf(name, NAMESZ, "%ds", busnum); 686 if (rc <= 0 || rc >= NAMESZ) 687 goto err_print_s; 688 d = debugfs_create_file(name, 0600, mon_dir, mbus, &mon_fops_stat); 689 if (d == NULL) 690 goto err_create_s; 691 mbus->dent_s = d; 692 693 return 1; 694 695 err_create_s: 696 err_print_s: 697 debugfs_remove(mbus->dent_u); 698 mbus->dent_u = NULL; 699 err_create_u: 700 err_print_u: 701 if (ubus != NULL) { 702 debugfs_remove(mbus->dent_t); 703 mbus->dent_t = NULL; 704 } 705 err_create_t: 706 err_print_t: 707 return 0; 708 } 709 710 void mon_text_del(struct mon_bus *mbus) 711 { 712 debugfs_remove(mbus->dent_u); 713 if (mbus->dent_t != NULL) 714 debugfs_remove(mbus->dent_t); 715 debugfs_remove(mbus->dent_s); 716 } 717 718 /* 719 * Slab interface: constructor. 720 */ 721 static void mon_text_ctor(void *mem, struct kmem_cache *slab, unsigned long sflags) 722 { 723 /* 724 * Nothing to initialize. No, really! 725 * So, we fill it with garbage to emulate a reused object. 726 */ 727 memset(mem, 0xe5, sizeof(struct mon_event_text)); 728 } 729 730 int __init mon_text_init(void) 731 { 732 struct dentry *mondir; 733 734 mondir = debugfs_create_dir("usbmon", NULL); 735 if (IS_ERR(mondir)) { 736 printk(KERN_NOTICE TAG ": debugfs is not available\n"); 737 return -ENODEV; 738 } 739 if (mondir == NULL) { 740 printk(KERN_NOTICE TAG ": unable to create usbmon directory\n"); 741 return -ENODEV; 742 } 743 mon_dir = mondir; 744 return 0; 745 } 746 747 void mon_text_exit(void) 748 { 749 debugfs_remove(mon_dir); 750 } 751