mirror of
https://github.com/qemu/qemu.git
synced 2024-11-30 07:13:38 +08:00
107 lines
2.2 KiB
C
107 lines
2.2 KiB
C
/*
|
|
* event queue implementation.
|
|
*
|
|
* This code is licensed under the GNU LGPL, version 2.1 or later.
|
|
* See the COPYING.LIB file in the top-level directory.
|
|
*/
|
|
|
|
#include "qemu-common.h"
|
|
#include "qemu/thread.h"
|
|
|
|
#include "vcard.h"
|
|
#include "vreader.h"
|
|
#include "vevent.h"
|
|
|
|
VEvent *
|
|
vevent_new(VEventType type, VReader *reader, VCard *card)
|
|
{
|
|
VEvent *new_vevent;
|
|
|
|
new_vevent = (VEvent *)g_malloc(sizeof(VEvent));
|
|
new_vevent->next = NULL;
|
|
new_vevent->type = type;
|
|
new_vevent->reader = vreader_reference(reader);
|
|
new_vevent->card = vcard_reference(card);
|
|
|
|
return new_vevent;
|
|
}
|
|
|
|
void
|
|
vevent_delete(VEvent *vevent)
|
|
{
|
|
if (vevent == NULL) {
|
|
return;
|
|
}
|
|
vreader_free(vevent->reader);
|
|
vcard_free(vevent->card);
|
|
g_free(vevent);
|
|
}
|
|
|
|
/*
|
|
* VEvent queue management
|
|
*/
|
|
|
|
static VEvent *vevent_queue_head;
|
|
static VEvent *vevent_queue_tail;
|
|
static QemuMutex vevent_queue_lock;
|
|
static QemuCond vevent_queue_condition;
|
|
|
|
void vevent_queue_init(void)
|
|
{
|
|
qemu_mutex_init(&vevent_queue_lock);
|
|
qemu_cond_init(&vevent_queue_condition);
|
|
vevent_queue_head = vevent_queue_tail = NULL;
|
|
}
|
|
|
|
void
|
|
vevent_queue_vevent(VEvent *vevent)
|
|
{
|
|
vevent->next = NULL;
|
|
qemu_mutex_lock(&vevent_queue_lock);
|
|
if (vevent_queue_head) {
|
|
assert(vevent_queue_tail);
|
|
vevent_queue_tail->next = vevent;
|
|
} else {
|
|
vevent_queue_head = vevent;
|
|
}
|
|
vevent_queue_tail = vevent;
|
|
qemu_cond_signal(&vevent_queue_condition);
|
|
qemu_mutex_unlock(&vevent_queue_lock);
|
|
}
|
|
|
|
/* must have lock */
|
|
static VEvent *
|
|
vevent_dequeue_vevent(void)
|
|
{
|
|
VEvent *vevent = NULL;
|
|
if (vevent_queue_head) {
|
|
vevent = vevent_queue_head;
|
|
vevent_queue_head = vevent->next;
|
|
vevent->next = NULL;
|
|
}
|
|
return vevent;
|
|
}
|
|
|
|
VEvent *vevent_wait_next_vevent(void)
|
|
{
|
|
VEvent *vevent;
|
|
|
|
qemu_mutex_lock(&vevent_queue_lock);
|
|
while ((vevent = vevent_dequeue_vevent()) == NULL) {
|
|
qemu_cond_wait(&vevent_queue_condition, &vevent_queue_lock);
|
|
}
|
|
qemu_mutex_unlock(&vevent_queue_lock);
|
|
return vevent;
|
|
}
|
|
|
|
VEvent *vevent_get_next_vevent(void)
|
|
{
|
|
VEvent *vevent;
|
|
|
|
qemu_mutex_lock(&vevent_queue_lock);
|
|
vevent = vevent_dequeue_vevent();
|
|
qemu_mutex_unlock(&vevent_queue_lock);
|
|
return vevent;
|
|
}
|
|
|