diff options
Diffstat (limited to 'drivers/s390/cio/qdio_main.c')
-rw-r--r-- | drivers/s390/cio/qdio_main.c | 62 |
1 files changed, 19 insertions, 43 deletions
diff --git a/drivers/s390/cio/qdio_main.c b/drivers/s390/cio/qdio_main.c index e53ac67e1e48..9e8a2914259b 100644 --- a/drivers/s390/cio/qdio_main.c +++ b/drivers/s390/cio/qdio_main.c | |||
@@ -570,29 +570,30 @@ static int qdio_inbound_q_done(struct qdio_q *q) | |||
570 | } | 570 | } |
571 | } | 571 | } |
572 | 572 | ||
573 | void qdio_kick_inbound_handler(struct qdio_q *q) | 573 | void qdio_kick_handler(struct qdio_q *q) |
574 | { | 574 | { |
575 | int count, start, end; | 575 | int start = q->first_to_kick; |
576 | 576 | int end = q->first_to_check; | |
577 | qdio_perf_stat_inc(&perf_stats.inbound_handler); | 577 | int count; |
578 | |||
579 | start = q->first_to_kick; | ||
580 | end = q->first_to_check; | ||
581 | if (end >= start) | ||
582 | count = end - start; | ||
583 | else | ||
584 | count = end + QDIO_MAX_BUFFERS_PER_Q - start; | ||
585 | |||
586 | DBF_DEV_EVENT(DBF_INFO, q->irq_ptr, "kih s:%3d c:%3d", start, count); | ||
587 | 578 | ||
588 | if (unlikely(q->irq_ptr->state != QDIO_IRQ_STATE_ACTIVE)) | 579 | if (unlikely(q->irq_ptr->state != QDIO_IRQ_STATE_ACTIVE)) |
589 | return; | 580 | return; |
590 | 581 | ||
591 | q->handler(q->irq_ptr->cdev, q->qdio_error, q->nr, | 582 | count = sub_buf(end, start); |
592 | start, count, q->irq_ptr->int_parm); | 583 | |
584 | if (q->is_input_q) { | ||
585 | qdio_perf_stat_inc(&perf_stats.inbound_handler); | ||
586 | DBF_DEV_EVENT(DBF_INFO, q->irq_ptr, "kih s:%3d c:%3d", start, count); | ||
587 | } else { | ||
588 | DBF_DEV_EVENT(DBF_INFO, q->irq_ptr, "koh: nr:%1d", q->nr); | ||
589 | DBF_DEV_EVENT(DBF_INFO, q->irq_ptr, "s:%3d c:%3d", start, count); | ||
590 | } | ||
591 | |||
592 | q->handler(q->irq_ptr->cdev, q->qdio_error, q->nr, start, count, | ||
593 | q->irq_ptr->int_parm); | ||
593 | 594 | ||
594 | /* for the next time */ | 595 | /* for the next time */ |
595 | q->first_to_kick = q->first_to_check; | 596 | q->first_to_kick = end; |
596 | q->qdio_error = 0; | 597 | q->qdio_error = 0; |
597 | } | 598 | } |
598 | 599 | ||
@@ -603,7 +604,7 @@ again: | |||
603 | if (!qdio_inbound_q_moved(q)) | 604 | if (!qdio_inbound_q_moved(q)) |
604 | return; | 605 | return; |
605 | 606 | ||
606 | qdio_kick_inbound_handler(q); | 607 | qdio_kick_handler(q); |
607 | 608 | ||
608 | if (!qdio_inbound_q_done(q)) | 609 | if (!qdio_inbound_q_done(q)) |
609 | /* means poll time is not yet over */ | 610 | /* means poll time is not yet over */ |
@@ -736,38 +737,13 @@ static int qdio_kick_outbound_q(struct qdio_q *q) | |||
736 | return cc; | 737 | return cc; |
737 | } | 738 | } |
738 | 739 | ||
739 | static void qdio_kick_outbound_handler(struct qdio_q *q) | ||
740 | { | ||
741 | int start, end, count; | ||
742 | |||
743 | start = q->first_to_kick; | ||
744 | end = q->last_move; | ||
745 | if (end >= start) | ||
746 | count = end - start; | ||
747 | else | ||
748 | count = end + QDIO_MAX_BUFFERS_PER_Q - start; | ||
749 | |||
750 | DBF_DEV_EVENT(DBF_INFO, q->irq_ptr, "kickouth: %1d", q->nr); | ||
751 | DBF_DEV_EVENT(DBF_INFO, q->irq_ptr, "s:%3d c:%3d", start, count); | ||
752 | |||
753 | if (unlikely(q->irq_ptr->state != QDIO_IRQ_STATE_ACTIVE)) | ||
754 | return; | ||
755 | |||
756 | q->handler(q->irq_ptr->cdev, q->qdio_error, q->nr, start, count, | ||
757 | q->irq_ptr->int_parm); | ||
758 | |||
759 | /* for the next time: */ | ||
760 | q->first_to_kick = q->last_move; | ||
761 | q->qdio_error = 0; | ||
762 | } | ||
763 | |||
764 | static void __qdio_outbound_processing(struct qdio_q *q) | 740 | static void __qdio_outbound_processing(struct qdio_q *q) |
765 | { | 741 | { |
766 | qdio_perf_stat_inc(&perf_stats.tasklet_outbound); | 742 | qdio_perf_stat_inc(&perf_stats.tasklet_outbound); |
767 | BUG_ON(atomic_read(&q->nr_buf_used) < 0); | 743 | BUG_ON(atomic_read(&q->nr_buf_used) < 0); |
768 | 744 | ||
769 | if (qdio_outbound_q_moved(q)) | 745 | if (qdio_outbound_q_moved(q)) |
770 | qdio_kick_outbound_handler(q); | 746 | qdio_kick_handler(q); |
771 | 747 | ||
772 | if (queue_type(q) == QDIO_ZFCP_QFMT) | 748 | if (queue_type(q) == QDIO_ZFCP_QFMT) |
773 | if (!pci_out_supported(q) && !qdio_outbound_q_done(q)) | 749 | if (!pci_out_supported(q) && !qdio_outbound_q_done(q)) |