| 514 | } |
| 515 | |
| 516 | static void |
| 517 | vdev_queue_io_add(vdev_queue_t *vq, zio_t *zio) |
| 518 | { |
| 519 | spa_t *spa = zio->io_spa; |
| 520 | spa_history_kstat_t *shk = &spa->spa_stats.io_history; |
| 521 | |
| 522 | ASSERT3U(zio->io_priority, <, ZIO_PRIORITY_NUM_QUEUEABLE); |
| 523 | avl_add(vdev_queue_class_tree(vq, zio->io_priority), zio); |
| 524 | avl_add(vdev_queue_type_tree(vq, zio->io_type), zio); |
| 525 | |
| 526 | if (shk->kstat != NULL) { |
| 527 | mutex_enter(&shk->lock); |
| 528 | kstat_waitq_enter(shk->kstat->ks_data); |
| 529 | mutex_exit(&shk->lock); |
| 530 | } |
| 531 | } |
| 532 | |
| 533 | static void |
| 534 | vdev_queue_io_remove(vdev_queue_t *vq, zio_t *zio) |
no test coverage detected