mirror of
https://github.com/tbsdtv/linux_media.git
synced 2025-07-23 12:43:29 +02:00
s390/qeth: fix notification for pending buffers during teardown
The cited commit reworked the state machine for pending TX buffers.
In qeth_iqd_tx_complete() it turned PENDING into a transient state, and
uses NEED_QAOB for buffers that get parked while waiting for their QAOB
completion.
But it missed to adjust the check in qeth_tx_complete_buf(). So if
qeth_tx_complete_pending_bufs() is called during teardown to drain
the parked TX buffers, we no longer raise a notification for af_iucv.
Instead of updating the checked state, just move this code into
qeth_tx_complete_pending_bufs() itself. This also gets rid of the
special-case in the common TX completion path.
Fixes: 8908f36d20
("s390/qeth: fix af_iucv notification race")
Signed-off-by: Julian Wiedmann <jwi@linux.ibm.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
committed by
David S. Miller
parent
3e83d467a0
commit
7eefda7f35
@@ -1390,9 +1390,6 @@ static void qeth_tx_complete_buf(struct qeth_qdio_out_buffer *buf, bool error,
|
|||||||
struct qeth_qdio_out_q *queue = buf->q;
|
struct qeth_qdio_out_q *queue = buf->q;
|
||||||
struct sk_buff *skb;
|
struct sk_buff *skb;
|
||||||
|
|
||||||
if (atomic_read(&buf->state) == QETH_QDIO_BUF_PENDING)
|
|
||||||
qeth_notify_skbs(queue, buf, TX_NOTIFY_GENERALERROR);
|
|
||||||
|
|
||||||
/* Empty buffer? */
|
/* Empty buffer? */
|
||||||
if (buf->next_element_to_fill == 0)
|
if (buf->next_element_to_fill == 0)
|
||||||
return;
|
return;
|
||||||
@@ -1465,6 +1462,9 @@ static void qeth_tx_complete_pending_bufs(struct qeth_card *card,
|
|||||||
QETH_CARD_TEXT(card, 5, "fp");
|
QETH_CARD_TEXT(card, 5, "fp");
|
||||||
QETH_CARD_TEXT_(card, 5, "%lx", (long) buf);
|
QETH_CARD_TEXT_(card, 5, "%lx", (long) buf);
|
||||||
|
|
||||||
|
if (drain)
|
||||||
|
qeth_notify_skbs(queue, buf,
|
||||||
|
TX_NOTIFY_GENERALERROR);
|
||||||
qeth_tx_complete_buf(buf, drain, 0);
|
qeth_tx_complete_buf(buf, drain, 0);
|
||||||
|
|
||||||
list_del(&buf->list_entry);
|
list_del(&buf->list_entry);
|
||||||
|
Reference in New Issue
Block a user