luchianmihai/walnux
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

virtio/virtio.h: add virtqueue lock api for better use

Browse source 
Later, we will change all virtio driver to use the new api

Signed-off-by: Bowen Wang <wangbowen6@xiaomi.com>
This commit is contained in:
Bowen Wang 2024-06-20 21:07:21 +08:00 • committed by Xiang Xiao
parent 377f184019
commit 280538adc6
1 changed files with 127 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

127
include/nuttx/virtio/virtio.h
View file

@ -31,6 +31,7 @@
#include <nuttx/compiler.h>
#include <nuttx/list.h>
#include <nuttx/spinlock.h>
#ifdef CONFIG_DRIVERS_VIRTIO
@ -69,6 +70,132 @@ struct virtio_driver
CODE void (*remove)(FAR struct virtio_device *vdev);
};
/****************************************************************************
* Inline functions
****************************************************************************/
/****************************************************************************
* Name: virtqueue_add_buffer_lock
****************************************************************************/
static inline_function int
virtqueue_add_buffer_lock(FAR struct virtqueue *vq,
FAR struct virtqueue_buf *buf_list,
int readable, int writable,
FAR void *cookie,
FAR spinlock_t *lock)
{
irqstate_t flags;
int ret;
flags = spin_lock_irqsave(lock);
ret = virtqueue_add_buffer(vq, buf_list, readable, writable, cookie);
spin_unlock_irqrestore(lock, flags);
return ret;
}
/****************************************************************************
* Name: virtqueue_get_buffer_lock
****************************************************************************/
static inline_function FAR void *
virtqueue_get_buffer_lock(FAR struct virtqueue *vq, FAR uint32_t *len,
FAR uint16_t *idx, FAR spinlock_t *lock)
{
irqstate_t flags;
FAR void *ret;
flags = spin_lock_irqsave(lock);
ret = virtqueue_get_buffer(vq, len, idx);
spin_unlock_irqrestore(lock, flags);
return ret;
}
/****************************************************************************
* Name: virtqueue_get_available_buffer_lock
****************************************************************************/
static inline_function FAR void *
virtqueue_get_available_buffer_lock(FAR struct virtqueue *vq,
FAR uint16_t *avail_idx,
FAR uint32_t *len, FAR spinlock_t *lock)
{
irqstate_t flags;
FAR void *ret;
flags = spin_lock_irqsave(lock);
ret = virtqueue_get_available_buffer(vq, avail_idx, len);
spin_unlock_irqrestore(lock, flags);
return ret;
}
/****************************************************************************
* Name: virtqueue_add_consumed_buffer_lock
****************************************************************************/
static inline_function int
virtqueue_add_consumed_buffer_lock(FAR struct virtqueue *vq,
uint16_t head_idx, uint32_t len,
FAR spinlock_t *lock)
{
irqstate_t flags;
int ret;
flags = spin_lock_irqsave(lock);
ret = virtqueue_add_consumed_buffer(vq, head_idx, len);
spin_unlock_irqrestore(lock, flags);
return ret;
}
/****************************************************************************
* Name: virtqueue_disable_cb_lock
****************************************************************************/
static inline_function void
virtqueue_disable_cb_lock(FAR struct virtqueue *vq, FAR spinlock_t *lock)
{
irqstate_t flags;
flags = spin_lock_irqsave(lock);
virtqueue_disable_cb(vq);
spin_unlock_irqrestore(lock, flags);
}
/****************************************************************************
* Name: virtqueue_enable_cb_lock
****************************************************************************/
static inline_function int virtqueue_enable_cb_lock(FAR struct virtqueue *vq,
FAR spinlock_t *lock)
{
irqstate_t flags;
int ret;
flags = spin_lock_irqsave(lock);
ret = virtqueue_enable_cb(vq);
spin_unlock_irqrestore(lock, flags);
return ret;
}
/****************************************************************************
* Name: virtqueue_kick_lock
****************************************************************************/
static inline_function void virtqueue_kick_lock(FAR struct virtqueue *vq,
FAR spinlock_t *lock)
{
irqstate_t flags;
flags = spin_lock_irqsave(lock);
virtqueue_kick(vq);
spin_unlock_irqrestore(lock, flags);
}
/****************************************************************************
* Public Function Prototypes
****************************************************************************/