github-mirror/linux
1
0
Fork 0
mirror of https://github.com/torvalds/linux.git synced 2026-07-27 09:36:22 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity Graph

thunderbolt: Add tb_ring_flush()

Browse Source 
This allows the caller to wait for the ring to be empty. We are going to
need this in the upcoming userspace tunneling support.

Signed-off-by: Mika Westerberg <mika.westerberg@linux.intel.com>
This commit is contained in:
Mika Westerberg 2025-06-27 20:25:42 +03:00
parent d614113c10
commit 94a11cd5dd
2 changed files with 31 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
drivers/thunderbolt/nhi.c
View File

@ -325,6 +325,8 @@ static void ring_work(struct work_struct *work)
if (frame->callback)
frame->callback(ring, frame, canceled);
}
wake_up(&ring->wait);
}
int __tb_ring_enqueue(struct tb_ring *ring, struct ring_frame *frame)
@ -601,6 +603,7 @@ static struct tb_ring *tb_ring_alloc(struct tb_nhi *nhi, u32 hop, int size,
INIT_LIST_HEAD(&ring->queue);
INIT_LIST_HEAD(&ring->in_flight);
INIT_WORK(&ring->work, ring_work);
init_waitqueue_head(&ring->wait);
ring->nhi = nhi;
ring->hop = hop;
@ -760,6 +763,31 @@ void tb_ring_start(struct tb_ring *ring)
}
EXPORT_SYMBOL_GPL(tb_ring_start);
static bool tb_ring_empty(struct tb_ring *ring)
{
guard(spinlock_irqsave)(&ring->lock);
return list_empty(&ring->in_flight);
}
/**
* tb_ring_flush() - Waits for a ring to be empty
* @ring: Ring to wait
* @timeout_msec: Timeout in ms how long to wait.
*
* This can be called before stopping a ring to make sure all the frames
* submitted prior have been completed.
*
* Return: %true if the ring is empty now, %false otherwise.
*/
bool tb_ring_flush(struct tb_ring *ring, unsigned int timeout_msec)
{
if (!wait_event_timeout(ring->wait, tb_ring_empty(ring),
msecs_to_jiffies(timeout_msec)))
return false;
return tb_ring_empty(ring);
}
EXPORT_SYMBOL_GPL(tb_ring_flush);
/**
* tb_ring_stop() - shutdown a ring
* @ring: Ring to stop

3
include/linux/thunderbolt.h
View File

@ -556,6 +556,7 @@ struct tb_nhi {
* @poll_data: Data passed to @start_poll
* @interval_nsec: Interval counter if interrupt throttling is to be
* used with this ring (in ns)
* @wait: Used to signal that the ring may be empty now
*/
struct tb_ring {
spinlock_t lock;
@ -580,6 +581,7 @@ struct tb_ring {
void (*start_poll)(void *data);
void *poll_data;
unsigned int interval_nsec;
wait_queue_head_t wait;
};
/* Leave ring interrupt enabled on suspend */
@ -653,6 +655,7 @@ struct tb_ring *tb_ring_alloc_rx(struct tb_nhi *nhi, int hop, int size,
u16 sof_mask, u16 eof_mask,
void (*start_poll)(void *), void *poll_data);
void tb_ring_start(struct tb_ring *ring);
bool tb_ring_flush(struct tb_ring *ring, unsigned int timeout_msec);
void tb_ring_stop(struct tb_ring *ring);
void tb_ring_free(struct tb_ring *ring);