RetroArch/message_queue.c

160 lines
4.0 KiB
C
Raw Normal View History

2012-04-21 21:13:50 +00:00
/* RetroArch - A frontend for libretro.
2014-01-01 00:50:59 +00:00
* Copyright (C) 2010-2014 - Hans-Kristian Arntzen
2011-01-23 00:59:49 +00:00
*
2012-04-21 21:13:50 +00:00
* RetroArch is free software: you can redistribute it and/or modify it under the terms
2011-01-23 00:59:49 +00:00
* of the GNU General Public License as published by the Free Software Found-
* ation, either version 3 of the License, or (at your option) any later version.
*
2012-04-21 21:13:50 +00:00
* RetroArch is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
2011-01-23 00:59:49 +00:00
* without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
* PURPOSE. See the GNU General Public License for more details.
*
2012-04-21 21:31:57 +00:00
* You should have received a copy of the GNU General Public License along with RetroArch.
2011-01-23 00:59:49 +00:00
* If not, see <http://www.gnu.org/licenses/>.
*/
#include <stdlib.h>
#include <string.h>
#include <stddef.h>
#include "message_queue.h"
2011-12-24 12:46:12 +00:00
#include "boolean.h"
2012-03-16 22:26:57 +00:00
#include "compat/posix_string.h"
2011-01-23 00:59:49 +00:00
struct queue_elem
{
unsigned duration;
unsigned prio;
char *msg;
};
struct msg_queue
{
struct queue_elem **elems;
size_t ptr;
size_t size;
char *tmp_msg;
};
msg_queue_t *msg_queue_new(size_t size)
{
2011-12-24 12:46:12 +00:00
msg_queue_t *queue = (msg_queue_t*)calloc(1, sizeof(*queue));
2011-01-23 00:59:49 +00:00
if (!queue)
return NULL;
queue->size = size + 1;
2011-12-24 12:46:12 +00:00
queue->elems = (struct queue_elem**)calloc(queue->size, sizeof(struct queue_elem*));
2011-01-23 00:59:49 +00:00
if (!queue->elems)
{
free(queue);
return NULL;
}
queue->ptr = 1;
return queue;
}
void msg_queue_free(msg_queue_t *queue)
{
msg_queue_clear(queue);
2011-01-23 00:59:49 +00:00
free(queue->elems);
free(queue);
}
void msg_queue_push(msg_queue_t *queue, const char *msg, unsigned prio, unsigned duration)
{
2011-01-23 01:04:56 +00:00
if (queue->ptr >= queue->size)
return;
struct queue_elem *new_elem = (struct queue_elem*)calloc(1, sizeof(struct queue_elem));
2011-01-23 00:59:49 +00:00
new_elem->prio = prio;
new_elem->duration = duration;
new_elem->msg = msg ? strdup(msg) : NULL;
queue->elems[queue->ptr] = new_elem;
size_t tmp_ptr = queue->ptr++;
while (tmp_ptr > 1)
{
struct queue_elem *parent = queue->elems[tmp_ptr >> 1];
struct queue_elem *child = queue->elems[tmp_ptr];
if (child->prio <= parent->prio)
break;
else
2011-01-23 00:59:49 +00:00
{
queue->elems[tmp_ptr >> 1] = child;
queue->elems[tmp_ptr] = parent;
2011-01-23 00:59:49 +00:00
}
tmp_ptr >>= 1;
2011-01-23 00:59:49 +00:00
}
}
void msg_queue_clear(msg_queue_t *queue)
{
size_t i;
for (i = 1; i < queue->ptr; i++)
{
if (queue->elems[i])
{
free(queue->elems[i]->msg);
free(queue->elems[i]);
queue->elems[i] = NULL;
}
}
queue->ptr = 1;
free(queue->tmp_msg);
queue->tmp_msg = NULL;
}
2011-01-23 00:59:49 +00:00
const char *msg_queue_pull(msg_queue_t *queue)
{
if (queue->ptr == 1) // Nothing in queue. :(
return NULL;
struct queue_elem *front = queue->elems[1];
front->duration--;
if (front->duration > 0)
return front->msg;
else
{
free(queue->tmp_msg);
queue->tmp_msg = front->msg;
front->msg = NULL;
struct queue_elem *front = queue->elems[1];
struct queue_elem *last = queue->elems[--queue->ptr];
queue->elems[1] = last;
free(front);
2011-01-23 00:59:49 +00:00
size_t tmp_ptr = 1;
for (;;)
{
bool left = (tmp_ptr * 2 <= queue->ptr) && (queue->elems[tmp_ptr] < queue->elems[tmp_ptr * 2]);
bool right = (tmp_ptr * 2 + 1 <= queue->ptr) && (queue->elems[tmp_ptr] < queue->elems[tmp_ptr * 2 + 1]);
if (!left && !right)
break;
size_t switch_index = tmp_ptr;
if (left && !right)
2011-01-23 00:59:49 +00:00
switch_index <<= 1;
else if (right && !left)
switch_index += switch_index + 1;
else
{
if (queue->elems[tmp_ptr * 2] >= queue->elems[tmp_ptr * 2 + 1])
switch_index <<= 1;
else
switch_index += switch_index + 1;
}
struct queue_elem *parent = queue->elems[tmp_ptr];
struct queue_elem *child = queue->elems[switch_index];
queue->elems[tmp_ptr] = child;
queue->elems[switch_index] = parent;
tmp_ptr = switch_index;
2011-01-23 00:59:49 +00:00
}
return queue->tmp_msg;
2011-01-23 00:59:49 +00:00
}
}