wiimote-quiz/rqueue.c at master · bsl/wiimote-quiz · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
#include <stdio.h>
#include <stdlib.h>

#include <pthread.h>

#include "rqueue.h"
#include "queue.h"

/* - - - - - - - - - - - - - - - - - - - - */

struct rqueue {
  queue_t q;
  pthread_mutex_t m;
};

/* - - - - - - - - - - - - - - - - - - - - */

rqueue_t
rqueue_new(void)
{
  rqueue_t rq;

  rq = malloc(sizeof(*rq));

  rq->q = queue_new();
  pthread_mutex_init(&rq->m, NULL);

  return rq;
}

bool
rqueue_is_empty(rqueue_t rq)
{
  bool b;

  pthread_mutex_lock(&rq->m);
  b = queue_is_empty(rq->q);
  pthread_mutex_unlock(&rq->m);

  return b;
}

void
rqueue_add(rqueue_t rq, void *v)
{
  pthread_mutex_lock(&rq->m);
  queue_add(rq->q, v);
  pthread_mutex_unlock(&rq->m);
}

void *
rqueue_remove(rqueue_t rq)
{
  void *v;

  pthread_mutex_lock(&rq->m);
  v = queue_remove(rq->q);
  pthread_mutex_unlock(&rq->m);

  return v;
}

void
rqueue_free(rqueue_t rq)
{
  queue_free(rq->q);
  pthread_mutex_destroy(&rq->m);
  free(rq);
}