diff options
Diffstat (limited to 'apps/plugins/pdbox/pdbox-net.c')
-rw-r--r-- | apps/plugins/pdbox/pdbox-net.c | 118 |
1 files changed, 0 insertions, 118 deletions
diff --git a/apps/plugins/pdbox/pdbox-net.c b/apps/plugins/pdbox/pdbox-net.c index 5767226de3..83d9bd3b7d 100644 --- a/apps/plugins/pdbox/pdbox-net.c +++ b/apps/plugins/pdbox/pdbox-net.c | |||
@@ -117,122 +117,4 @@ void net_destroy(void) | |||
117 | rb->queue_delete(&gui_to_core); | 117 | rb->queue_delete(&gui_to_core); |
118 | rb->queue_delete(&core_to_gui); | 118 | rb->queue_delete(&core_to_gui); |
119 | } | 119 | } |
120 | /*************************************************************************** | ||
121 | * __________ __ ___. | ||
122 | * Open \______ \ ____ ____ | | _\_ |__ _______ ___ | ||
123 | * Source | _// _ \_/ ___\| |/ /| __ \ / _ \ \/ / | ||
124 | * Jukebox | | ( <_> ) \___| < | \_\ ( <_> > < < | ||
125 | * Firmware |____|_ /\____/ \___ >__|_ \|___ /\____/__/\_ \ | ||
126 | * \/ \/ \/ \/ \/ | ||
127 | * $Id$ | ||
128 | * | ||
129 | * Copyright (C) 2009 Wincent Balin | ||
130 | * | ||
131 | * This program is free software; you can redistribute it and/or | ||
132 | * modify it under the terms of the GNU General Public License | ||
133 | * as published by the Free Software Foundation; either version 2 | ||
134 | * of the License, or (at your option) any later version. | ||
135 | * | ||
136 | * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY | ||
137 | * KIND, either express or implied. | ||
138 | * | ||
139 | ****************************************************************************/ | ||
140 | |||
141 | #include "plugin.h" | ||
142 | #include "pdbox.h" | ||
143 | |||
144 | /* Datagram pool will contains 16 datagrams. */ | ||
145 | #define MAX_DATAGRAMS 16 | ||
146 | |||
147 | /* Datagram pool. */ | ||
148 | struct datagram datagrams[MAX_DATAGRAMS]; | ||
149 | |||
150 | /* UDP message queues. */ | ||
151 | struct event_queue gui_to_core; | ||
152 | struct event_queue core_to_gui; | ||
153 | |||
154 | /* Initialize net infrastructure. */ | ||
155 | void net_init(void) | ||
156 | { | ||
157 | unsigned int i; | ||
158 | |||
159 | /* Initialize message pool. */ | ||
160 | for(i = 0; i < MAX_DATAGRAMS; i++) | ||
161 | datagrams[i].used = false; | ||
162 | |||
163 | /* Initialize and register message queues. */ | ||
164 | rb->queue_init(&gui_to_core, true); | ||
165 | rb->queue_init(&core_to_gui, true); | ||
166 | } | ||
167 | |||
168 | /* Send datagram. */ | ||
169 | bool send_datagram(struct event_queue* route, | ||
170 | int port, | ||
171 | char* data, | ||
172 | size_t size) | ||
173 | { | ||
174 | unsigned int i; | ||
175 | |||
176 | /* If datagram too long, abort. */ | ||
177 | if(size > MAX_DATAGRAM_SIZE) | ||
178 | return false; | ||
179 | 120 | ||
180 | /* Find free datagram buffer. */ | ||
181 | for(i = 0; i < MAX_DATAGRAMS; i++) | ||
182 | if(!datagrams[i].used) | ||
183 | break; | ||
184 | |||
185 | /* If no free buffer found, abort. */ | ||
186 | if(i == MAX_DATAGRAMS) | ||
187 | return false; | ||
188 | |||
189 | /* Copy datagram to the buffer. */ | ||
190 | rb->memcpy(datagrams[i].data, data, size); | ||
191 | datagrams[i].size = size; | ||
192 | |||
193 | /* Mark datagram buffer as used. */ | ||
194 | datagrams[i].used = true; | ||
195 | |||
196 | /* Send event via route. */ | ||
197 | rb->queue_post(route, port, (intptr_t) &datagrams[i]); | ||
198 | |||
199 | /* Everything went ok. */ | ||
200 | return true; | ||
201 | } | ||
202 | |||
203 | /* Receive datagram. */ | ||
204 | bool receive_datagram(struct event_queue* route, | ||
205 | int port, | ||
206 | struct datagram* buffer) | ||
207 | { | ||
208 | struct queue_event event; | ||
209 | |||
210 | /* If route queue empty, abort. */ | ||
211 | if(rb->queue_empty(route)) | ||
212 | return false; | ||
213 | |||
214 | /* Receive event. */ | ||
215 | rb->queue_wait(route, &event); | ||
216 | |||
217 | /* If wrong port, abort. | ||
218 | NOTE: Event is removed from the queue in any case! */ | ||
219 | if(event.id != port) | ||
220 | return false; | ||
221 | |||
222 | /* Copy datagram. */ | ||
223 | rb->memcpy(buffer, (struct datagram*) event.data, sizeof(struct datagram)); | ||
224 | |||
225 | /* Free datagram buffer. */ | ||
226 | ((struct datagram*) event.data)->used = false; | ||
227 | |||
228 | /* Everything went ok. */ | ||
229 | return true; | ||
230 | } | ||
231 | |||
232 | /* Destroy net infrastructure. */ | ||
233 | void net_destroy(void) | ||
234 | { | ||
235 | /* Remove message queues. */ | ||
236 | rb->queue_delete(&gui_to_core); | ||
237 | rb->queue_delete(&core_to_gui); | ||
238 | } | ||