mirror of
https://github.com/clearlinux/kvmtool.git
synced 2026-06-16 02:15:47 +00:00
Sasha Levin
d3476f7d3b
We already have something to wrap pthread with mutex_[init,lock,unlock] calls. This patch creates a new struct mutex abstraction and moves everything to work with it. Signed-off-by: Sasha Levin <sasha.levin@oracle.com> Signed-off-by: Pekka Enberg <penberg@kernel.org>
115 lines
2.3 KiB
C
115 lines
2.3 KiB
C
#include "kvm/uip.h"
|
|
|
|
#include <linux/kernel.h>
|
|
#include <linux/list.h>
|
|
|
|
struct uip_buf *uip_buf_get_used(struct uip_info *info)
|
|
{
|
|
struct uip_buf *buf;
|
|
bool found = false;
|
|
|
|
mutex_lock(&info->buf_lock);
|
|
|
|
while (!(info->buf_used_nr > 0))
|
|
pthread_cond_wait(&info->buf_used_cond, &info->buf_lock.mutex);
|
|
|
|
list_for_each_entry(buf, &info->buf_head, list) {
|
|
if (buf->status == UIP_BUF_STATUS_USED) {
|
|
/*
|
|
* Set status to INUSE immediately to prevent
|
|
* someone from using this buf until we free it
|
|
*/
|
|
buf->status = UIP_BUF_STATUS_INUSE;
|
|
info->buf_used_nr--;
|
|
found = true;
|
|
break;
|
|
}
|
|
}
|
|
|
|
mutex_unlock(&info->buf_lock);
|
|
|
|
return found ? buf : NULL;
|
|
}
|
|
|
|
struct uip_buf *uip_buf_get_free(struct uip_info *info)
|
|
{
|
|
struct uip_buf *buf;
|
|
bool found = false;
|
|
|
|
mutex_lock(&info->buf_lock);
|
|
|
|
while (!(info->buf_free_nr > 0))
|
|
pthread_cond_wait(&info->buf_free_cond, &info->buf_lock.mutex);
|
|
|
|
list_for_each_entry(buf, &info->buf_head, list) {
|
|
if (buf->status == UIP_BUF_STATUS_FREE) {
|
|
/*
|
|
* Set status to INUSE immediately to prevent
|
|
* someone from using this buf until we free it
|
|
*/
|
|
buf->status = UIP_BUF_STATUS_INUSE;
|
|
info->buf_free_nr--;
|
|
found = true;
|
|
break;
|
|
}
|
|
}
|
|
|
|
mutex_unlock(&info->buf_lock);
|
|
|
|
return found ? buf : NULL;
|
|
}
|
|
|
|
struct uip_buf *uip_buf_set_used(struct uip_info *info, struct uip_buf *buf)
|
|
{
|
|
mutex_lock(&info->buf_lock);
|
|
|
|
buf->status = UIP_BUF_STATUS_USED;
|
|
info->buf_used_nr++;
|
|
pthread_cond_signal(&info->buf_used_cond);
|
|
|
|
mutex_unlock(&info->buf_lock);
|
|
|
|
return buf;
|
|
}
|
|
|
|
struct uip_buf *uip_buf_set_free(struct uip_info *info, struct uip_buf *buf)
|
|
{
|
|
mutex_lock(&info->buf_lock);
|
|
|
|
buf->status = UIP_BUF_STATUS_FREE;
|
|
info->buf_free_nr++;
|
|
pthread_cond_signal(&info->buf_free_cond);
|
|
|
|
mutex_unlock(&info->buf_lock);
|
|
|
|
return buf;
|
|
}
|
|
|
|
struct uip_buf *uip_buf_clone(struct uip_tx_arg *arg)
|
|
{
|
|
struct uip_buf *buf;
|
|
struct uip_eth *eth2;
|
|
struct uip_info *info;
|
|
|
|
info = arg->info;
|
|
|
|
/*
|
|
* Get buffer from device to guest
|
|
*/
|
|
buf = uip_buf_get_free(info);
|
|
|
|
/*
|
|
* Clone buffer
|
|
*/
|
|
memcpy(buf->vnet, arg->vnet, arg->vnet_len);
|
|
memcpy(buf->eth, arg->eth, arg->eth_len);
|
|
buf->vnet_len = arg->vnet_len;
|
|
buf->eth_len = arg->eth_len;
|
|
|
|
eth2 = (struct uip_eth *)buf->eth;
|
|
eth2->src = info->host_mac;
|
|
eth2->dst = arg->eth->src;
|
|
|
|
return buf;
|
|
}
|