Commit e6316920 authored by Alex Elder's avatar Alex Elder Committed by Jakub Kicinski

net: ipa: expand last transaction check

Transactions to send data for a network device can be allocated at
any time up until the point the TX queue is stopped.  It is possible
for ipa_start_xmit() to be called in one context just before a
the transmit queue is stopped in another.

Update gsi_channel_trans_last() so that for TX channels the
allocated and pending transaction lists are checked--in addition
to the completed and polled lists--to determine the "last"
transaction.  This means any transaction that has been allocated
before the TX queue is stopped will be allowed to complete before
we conclude the channel is quiesced.

Rework the function a bit to use a list pointer and gotos.
Signed-off-by: default avatarAlex Elder <elder@linaro.org>
Acked-by: default avatarWillem de Bruijn <willemb@google.com>
Signed-off-by: default avatarJakub Kicinski <kuba@kernel.org>
parent a65c0288
...@@ -725,22 +725,38 @@ static void gsi_evt_ring_program(struct gsi *gsi, u32 evt_ring_id) ...@@ -725,22 +725,38 @@ static void gsi_evt_ring_program(struct gsi *gsi, u32 evt_ring_id)
gsi_evt_ring_doorbell(gsi, evt_ring_id, 0); gsi_evt_ring_doorbell(gsi, evt_ring_id, 0);
} }
/* Return the last (most recent) transaction completed on a channel. */ /* Find the transaction whose completion indicates a channel is quiesced */
static struct gsi_trans *gsi_channel_trans_last(struct gsi_channel *channel) static struct gsi_trans *gsi_channel_trans_last(struct gsi_channel *channel)
{ {
struct gsi_trans_info *trans_info = &channel->trans_info; struct gsi_trans_info *trans_info = &channel->trans_info;
const struct list_head *list;
struct gsi_trans *trans; struct gsi_trans *trans;
spin_lock_bh(&trans_info->spinlock); spin_lock_bh(&trans_info->spinlock);
if (!list_empty(&trans_info->complete)) /* There is a small chance a TX transaction got allocated just
trans = list_last_entry(&trans_info->complete, * before we disabled transmits, so check for that.
struct gsi_trans, links); */
else if (!list_empty(&trans_info->polled)) if (channel->toward_ipa) {
trans = list_last_entry(&trans_info->polled, list = &trans_info->alloc;
struct gsi_trans, links); if (!list_empty(list))
else goto done;
trans = NULL; list = &trans_info->pending;
if (!list_empty(list))
goto done;
}
/* Otherwise (TX or RX) we want to wait for anything that
* has completed, or has been polled but not released yet.
*/
list = &trans_info->complete;
if (!list_empty(list))
goto done;
list = &trans_info->polled;
if (list_empty(list))
list = NULL;
done:
trans = list ? list_last_entry(list, struct gsi_trans, links) : NULL;
/* Caller will wait for this, so take a reference */ /* Caller will wait for this, so take a reference */
if (trans) if (trans)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment