File: fifo.c

package info (click to toggle)
libmypaint 1.6.0-4
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid, trixie
  • size: 5,904 kB
  • sloc: ansic: 5,953; sh: 4,418; makefile: 292; python: 210
file content (114 lines) | stat: -rw-r--r-- 2,432 bytes parent folder | download | duplicates (2)
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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
/*
 *
 * Based on fifo.c from syslog-win32 by Alexander Yaworsky
 * http://syslog-win32.svn.sourceforge.net/viewvc/syslog-win32/tags/syslog-win32-0-3/daemon/fifo.c
 *
 * THIS SOFTWARE IS NOT COPYRIGHTED
 *
 * This source code is offered for use in the public domain. You may
 * use, modify or distribute it freely.
 *
 * This code is distributed in the hope that it will be useful but
 * WITHOUT ANY WARRANTY. ALL WARRANTIES, EXPRESS OR IMPLIED ARE HEREBY
 * DISCLAIMED. This includes but is not limited to warranties of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 *
 */

#include "config.h"

#include <stdlib.h>
#include "fifo.h"

struct fifo_item
{
    struct fifo_item *next;  /* queue is a single-linked list */
    void *payload;
};

struct fifo
{
    struct fifo_item *first;  /* first pushed item */
    struct fifo_item *last;   /* last pushed item */
    int item_count;
};

/*
 * fifo_new:
 *
 * Allocate and initialize fifo structure. Add an empty item to the fifo.
 */
struct fifo* fifo_new(void)
{
    struct fifo *ret = (struct fifo *) malloc(sizeof(struct fifo));
    ret->first = NULL;
    ret->last = NULL;
    ret->item_count = 0;
    return ret;
}

/*
 * fifo_free:
 *
 * Delete all items and free fifo structure.
 */
void fifo_free(struct fifo* queue, FifoUserFreeFunction user_free)
{
    struct fifo_item *item;

    while ((item = queue->first) != NULL)
    {
        queue->first = item->next;
        user_free(item);
    }
    free(queue);
}

/*
 * fifo_push:
 *
 * Add item to queue.
 */
void fifo_push(struct fifo* queue, void* data)
{
    struct fifo_item *item = (struct fifo_item*) malloc(sizeof(struct fifo_item));
    item->next = NULL;
    item->payload = data;
    if (!queue->last)
        queue->first = item;
    else
        queue->last->next = item;
    queue->last = item;
}

/*
 * fifo_pop:
 *
 * Extract item from queue. Returns NULL on empty queue.
 */
void* fifo_pop(struct fifo* queue)
{
    struct fifo_item *item;
    void *data;

    item = queue->first;
    if (!item)
        return NULL;

    queue->first = item->next;
    if (!queue->first)
        queue->last = NULL;

    data = item->payload;
    free(item);
    queue->item_count--;
    return data;
}

void* fifo_peek_first(struct fifo *queue) {
    return (!queue->first) ? NULL : queue->first->payload;
}

void* fifo_peek_last(struct fifo *queue) {
    return (!queue->last) ? NULL : queue->last->payload;
}