port_fifo.c
3.97 KB
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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
/*
The oSIP library implements the Session Initiation Protocol (SIP -rfc3261-)
Copyright (C) 2001-2020 Aymeric MOIZARD amoizard@antisip.com
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.
This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
#include <osip2/internal.h>
#include <osipparser2/osip_port.h>
#include <osip2/osip_fifo.h>
/* always use this method to initiate osip_fifo_t.
*/
void osip_fifo_init(osip_fifo_t *ff) {
#ifndef OSIP_MONOTHREAD
ff->qislocked = osip_mutex_init();
/*INIT SEMA TO BLOCK ON GET() WHEN QUEUE IS EMPTY */
ff->qisempty = osip_sem_init(0);
#endif
osip_list_init(&ff->queue);
/* ff->nb_elt = 0; */
ff->state = osip_empty;
}
int osip_fifo_add(osip_fifo_t *ff, void *el) {
#ifndef OSIP_MONOTHREAD
osip_mutex_lock(ff->qislocked);
#endif
osip_list_add(&ff->queue, el, -1); /* insert at end of queue */
ff->state = osip_ok;
#ifndef OSIP_MONOTHREAD
osip_sem_post(ff->qisempty);
osip_mutex_unlock(ff->qislocked);
#endif
return OSIP_SUCCESS;
}
int osip_fifo_insert(osip_fifo_t *ff, void *el) {
#ifndef OSIP_MONOTHREAD
osip_mutex_lock(ff->qislocked);
#endif
osip_list_add(&ff->queue, el, 0); /* insert at end of queue */
ff->state = osip_ok;
#ifndef OSIP_MONOTHREAD
osip_sem_post(ff->qisempty);
osip_mutex_unlock(ff->qislocked);
#endif
return OSIP_SUCCESS;
}
int osip_fifo_size(osip_fifo_t *ff) {
int i;
#ifndef OSIP_MONOTHREAD
osip_mutex_lock(ff->qislocked);
#endif
i = osip_list_size(&ff->queue);
#ifndef OSIP_MONOTHREAD
osip_mutex_unlock(ff->qislocked);
#endif
return i;
}
void *osip_fifo_get(osip_fifo_t *ff) {
void *el = NULL;
#ifndef OSIP_MONOTHREAD
int i = osip_sem_wait(ff->qisempty);
if (i != 0)
return NULL;
osip_mutex_lock(ff->qislocked);
#endif
if (ff->state != osip_empty) {
el = osip_list_get(&ff->queue, 0);
osip_list_remove(&ff->queue, 0);
/* ff->nb_elt--; */
} else {
OSIP_TRACE(osip_trace(__FILE__, __LINE__, OSIP_ERROR, NULL, "no element in fifo.\n"));
#ifndef OSIP_MONOTHREAD
osip_mutex_unlock(ff->qislocked);
#endif
return OSIP_SUCCESS; /* pile vide */
}
/* if (ff->nb_elt <= 0) */
if (osip_list_size(&ff->queue) <= 0)
ff->state = osip_empty;
else
ff->state = osip_ok;
#ifndef OSIP_MONOTHREAD
osip_mutex_unlock(ff->qislocked);
#endif
return el;
}
void *osip_fifo_tryget(osip_fifo_t *ff) {
void *el = NULL;
#ifndef OSIP_MONOTHREAD
if (0 != osip_sem_trywait(ff->qisempty)) { /* no elements... */
return NULL;
}
osip_mutex_lock(ff->qislocked);
#else
if (ff->state == osip_empty)
return NULL;
#endif
if (ff->state != osip_empty) {
el = osip_list_get(&ff->queue, 0);
osip_list_remove(&ff->queue, 0);
/* ff->nb_elt--; */
}
#ifndef OSIP_MONOTHREAD
else { /* this case MUST never happen... */
OSIP_TRACE(osip_trace(__FILE__, __LINE__, OSIP_INFO4, NULL, "no element in fifo.\n"));
osip_mutex_unlock(ff->qislocked);
return OSIP_SUCCESS;
}
#endif
/* if (ff->nb_elt <= 0) */
if (osip_list_size(&ff->queue) <= 0)
ff->state = osip_empty;
else
ff->state = osip_ok;
#ifndef OSIP_MONOTHREAD
osip_mutex_unlock(ff->qislocked);
#endif
return el;
}
void osip_fifo_free(osip_fifo_t *ff) {
if (ff == NULL)
return;
#ifndef OSIP_MONOTHREAD
osip_mutex_destroy(ff->qislocked);
/* seems that pthread_mutex_destroy does not free space by itself */
osip_sem_destroy(ff->qisempty);
#endif
osip_free(ff);
}