1*10465441SEvalZero /*
2*10465441SEvalZero * COPYRIGHT (C) 2006-2018, RT-Thread Development Team
3*10465441SEvalZero * All rights reserved.
4*10465441SEvalZero *
5*10465441SEvalZero * Redistribution and use in source and binary forms, with or without modification,
6*10465441SEvalZero * are permitted provided that the following conditions are met:
7*10465441SEvalZero *
8*10465441SEvalZero * 1. Redistributions of source code must retain the above copyright notice,
9*10465441SEvalZero * this list of conditions and the following disclaimer.
10*10465441SEvalZero * 2. Redistributions in binary form must reproduce the above copyright notice,
11*10465441SEvalZero * this list of conditions and the following disclaimer in the documentation
12*10465441SEvalZero * and/or other materials provided with the distribution.
13*10465441SEvalZero * 3. The name of the author may not be used to endorse or promote products
14*10465441SEvalZero * derived from this software without specific prior written permission.
15*10465441SEvalZero *
16*10465441SEvalZero * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
17*10465441SEvalZero * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
18*10465441SEvalZero * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT
19*10465441SEvalZero * SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
20*10465441SEvalZero * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT
21*10465441SEvalZero * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
22*10465441SEvalZero * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
23*10465441SEvalZero * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
24*10465441SEvalZero * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY
25*10465441SEvalZero * OF SUCH DAMAGE.
26*10465441SEvalZero *
27*10465441SEvalZero * Change Logs:
28*10465441SEvalZero * Date Author Notes
29*10465441SEvalZero * 2012-12-8 Bernard add file header
30*10465441SEvalZero * export bsd socket symbol for RT-Thread Application Module
31*10465441SEvalZero * 2017-11-15 Bernard add lock for init_done callback.
32*10465441SEvalZero * 2018-11-02 MurphyZhao port to lwip2.1.0
33*10465441SEvalZero */
34*10465441SEvalZero
35*10465441SEvalZero #include <rtthread.h>
36*10465441SEvalZero
37*10465441SEvalZero #include "lwip/sys.h"
38*10465441SEvalZero #include "lwip/opt.h"
39*10465441SEvalZero #include "lwip/stats.h"
40*10465441SEvalZero #include "lwip/err.h"
41*10465441SEvalZero #include "arch/sys_arch.h"
42*10465441SEvalZero #include "lwip/debug.h"
43*10465441SEvalZero #include "lwip/netif.h"
44*10465441SEvalZero #include "lwip/netifapi.h"
45*10465441SEvalZero #include "lwip/tcpip.h"
46*10465441SEvalZero #include "netif/ethernetif.h"
47*10465441SEvalZero #include "lwip/sio.h"
48*10465441SEvalZero #include "lwip/init.h"
49*10465441SEvalZero #include "lwip/dhcp.h"
50*10465441SEvalZero #include "lwip/inet.h"
51*10465441SEvalZero
52*10465441SEvalZero #include <string.h>
53*10465441SEvalZero #include <stdio.h>
54*10465441SEvalZero
55*10465441SEvalZero /*
56*10465441SEvalZero * Initialize the network interface device
57*10465441SEvalZero *
58*10465441SEvalZero * @return the operation status, ERR_OK on OK, ERR_IF on error
59*10465441SEvalZero */
netif_device_init(struct netif * netif)60*10465441SEvalZero static err_t netif_device_init(struct netif *netif)
61*10465441SEvalZero {
62*10465441SEvalZero struct eth_device *ethif;
63*10465441SEvalZero
64*10465441SEvalZero ethif = (struct eth_device *)netif->state;
65*10465441SEvalZero if (ethif != RT_NULL)
66*10465441SEvalZero {
67*10465441SEvalZero rt_device_t device;
68*10465441SEvalZero
69*10465441SEvalZero /* get device object */
70*10465441SEvalZero device = (rt_device_t) ethif;
71*10465441SEvalZero if (rt_device_init(device) != RT_EOK)
72*10465441SEvalZero {
73*10465441SEvalZero return ERR_IF;
74*10465441SEvalZero }
75*10465441SEvalZero
76*10465441SEvalZero /* copy device flags to netif flags */
77*10465441SEvalZero netif->flags = ethif->flags;
78*10465441SEvalZero
79*10465441SEvalZero return ERR_OK;
80*10465441SEvalZero }
81*10465441SEvalZero
82*10465441SEvalZero return ERR_IF;
83*10465441SEvalZero }
84*10465441SEvalZero /*
85*10465441SEvalZero * Initialize the ethernetif layer and set network interface device up
86*10465441SEvalZero */
tcpip_init_done_callback(void * arg)87*10465441SEvalZero static void tcpip_init_done_callback(void *arg)
88*10465441SEvalZero {
89*10465441SEvalZero rt_device_t device;
90*10465441SEvalZero struct eth_device *ethif;
91*10465441SEvalZero ip4_addr_t ipaddr, netmask, gw;
92*10465441SEvalZero struct rt_list_node* node;
93*10465441SEvalZero struct rt_object* object;
94*10465441SEvalZero struct rt_object_information *information;
95*10465441SEvalZero
96*10465441SEvalZero LWIP_ASSERT("invalid arg.\n",arg);
97*10465441SEvalZero
98*10465441SEvalZero IP4_ADDR(&gw, 0,0,0,0);
99*10465441SEvalZero IP4_ADDR(&ipaddr, 0,0,0,0);
100*10465441SEvalZero IP4_ADDR(&netmask, 0,0,0,0);
101*10465441SEvalZero
102*10465441SEvalZero /* enter critical */
103*10465441SEvalZero rt_enter_critical();
104*10465441SEvalZero
105*10465441SEvalZero /* for each network interfaces */
106*10465441SEvalZero information = rt_object_get_information(RT_Object_Class_Device);
107*10465441SEvalZero RT_ASSERT(information != RT_NULL);
108*10465441SEvalZero for (node = information->object_list.next;
109*10465441SEvalZero node != &(information->object_list);
110*10465441SEvalZero node = node->next)
111*10465441SEvalZero {
112*10465441SEvalZero object = rt_list_entry(node, struct rt_object, list);
113*10465441SEvalZero device = (rt_device_t)object;
114*10465441SEvalZero if (device->type == RT_Device_Class_NetIf)
115*10465441SEvalZero {
116*10465441SEvalZero ethif = (struct eth_device *)device;
117*10465441SEvalZero
118*10465441SEvalZero /* leave critical */
119*10465441SEvalZero rt_exit_critical();
120*10465441SEvalZero LOCK_TCPIP_CORE();
121*10465441SEvalZero
122*10465441SEvalZero netif_add(ethif->netif, &ipaddr, &netmask, &gw,
123*10465441SEvalZero ethif, netif_device_init, tcpip_input);
124*10465441SEvalZero
125*10465441SEvalZero if (netif_default == RT_NULL)
126*10465441SEvalZero netif_set_default(ethif->netif);
127*10465441SEvalZero
128*10465441SEvalZero #if LWIP_DHCP
129*10465441SEvalZero /* set interface up */
130*10465441SEvalZero netif_set_up(ethif->netif);
131*10465441SEvalZero /* if this interface uses DHCP, start the DHCP client */
132*10465441SEvalZero dhcp_start(ethif->netif);
133*10465441SEvalZero #else
134*10465441SEvalZero /* set interface up */
135*10465441SEvalZero netif_set_up(ethif->netif);
136*10465441SEvalZero #endif
137*10465441SEvalZero
138*10465441SEvalZero if (ethif->flags & ETHIF_LINK_PHYUP)
139*10465441SEvalZero {
140*10465441SEvalZero netif_set_link_up(ethif->netif);
141*10465441SEvalZero }
142*10465441SEvalZero
143*10465441SEvalZero UNLOCK_TCPIP_CORE();
144*10465441SEvalZero /* enter critical */
145*10465441SEvalZero rt_enter_critical();
146*10465441SEvalZero }
147*10465441SEvalZero }
148*10465441SEvalZero
149*10465441SEvalZero /* leave critical */
150*10465441SEvalZero rt_exit_critical();
151*10465441SEvalZero rt_sem_release((rt_sem_t)arg);
152*10465441SEvalZero }
153*10465441SEvalZero
154*10465441SEvalZero /**
155*10465441SEvalZero * LwIP system initialization
156*10465441SEvalZero */
157*10465441SEvalZero extern int eth_system_device_init_private(void);
lwip_system_init(void)158*10465441SEvalZero int lwip_system_init(void)
159*10465441SEvalZero {
160*10465441SEvalZero rt_err_t rc;
161*10465441SEvalZero struct rt_semaphore done_sem;
162*10465441SEvalZero static rt_bool_t init_ok = RT_FALSE;
163*10465441SEvalZero
164*10465441SEvalZero if (init_ok)
165*10465441SEvalZero {
166*10465441SEvalZero rt_kprintf("lwip system already init.\n");
167*10465441SEvalZero return 0;
168*10465441SEvalZero }
169*10465441SEvalZero
170*10465441SEvalZero eth_system_device_init_private();
171*10465441SEvalZero
172*10465441SEvalZero /* set default netif to NULL */
173*10465441SEvalZero netif_default = RT_NULL;
174*10465441SEvalZero
175*10465441SEvalZero rc = rt_sem_init(&done_sem, "done", 0, RT_IPC_FLAG_FIFO);
176*10465441SEvalZero
177*10465441SEvalZero if (rc != RT_EOK)
178*10465441SEvalZero {
179*10465441SEvalZero LWIP_ASSERT("Failed to create semaphore", 0);
180*10465441SEvalZero
181*10465441SEvalZero return -1;
182*10465441SEvalZero }
183*10465441SEvalZero
184*10465441SEvalZero tcpip_init(tcpip_init_done_callback, (void *)&done_sem);
185*10465441SEvalZero
186*10465441SEvalZero /* waiting for initialization done */
187*10465441SEvalZero if (rt_sem_take(&done_sem, RT_WAITING_FOREVER) != RT_EOK)
188*10465441SEvalZero {
189*10465441SEvalZero rt_sem_detach(&done_sem);
190*10465441SEvalZero
191*10465441SEvalZero return -1;
192*10465441SEvalZero }
193*10465441SEvalZero rt_sem_detach(&done_sem);
194*10465441SEvalZero
195*10465441SEvalZero /* set default ip address */
196*10465441SEvalZero #if !LWIP_DHCP
197*10465441SEvalZero if (netif_default != RT_NULL)
198*10465441SEvalZero {
199*10465441SEvalZero struct ip4_addr ipaddr, netmask, gw;
200*10465441SEvalZero
201*10465441SEvalZero ipaddr.addr = inet_addr(RT_LWIP_IPADDR);
202*10465441SEvalZero gw.addr = inet_addr(RT_LWIP_GWADDR);
203*10465441SEvalZero netmask.addr = inet_addr(RT_LWIP_MSKADDR);
204*10465441SEvalZero
205*10465441SEvalZero netifapi_netif_set_addr(netif_default, &ipaddr, &netmask, &gw);
206*10465441SEvalZero }
207*10465441SEvalZero #endif
208*10465441SEvalZero rt_kprintf("lwIP-%d.%d.%d initialized!\n", LWIP_VERSION_MAJOR, LWIP_VERSION_MINOR, LWIP_VERSION_REVISION);
209*10465441SEvalZero
210*10465441SEvalZero init_ok = RT_TRUE;
211*10465441SEvalZero
212*10465441SEvalZero return 0;
213*10465441SEvalZero }
214*10465441SEvalZero INIT_PREV_EXPORT(lwip_system_init);
215*10465441SEvalZero
sys_init(void)216*10465441SEvalZero void sys_init(void)
217*10465441SEvalZero {
218*10465441SEvalZero /* nothing on RT-Thread porting */
219*10465441SEvalZero }
220*10465441SEvalZero
lwip_sys_init(void)221*10465441SEvalZero void lwip_sys_init(void)
222*10465441SEvalZero {
223*10465441SEvalZero lwip_system_init();
224*10465441SEvalZero }
225*10465441SEvalZero
226*10465441SEvalZero /*
227*10465441SEvalZero * Create a new semaphore
228*10465441SEvalZero *
229*10465441SEvalZero * @return the operation status, ERR_OK on OK; others on error
230*10465441SEvalZero */
sys_sem_new(sys_sem_t * sem,u8_t count)231*10465441SEvalZero err_t sys_sem_new(sys_sem_t *sem, u8_t count)
232*10465441SEvalZero {
233*10465441SEvalZero static unsigned short counter = 0;
234*10465441SEvalZero char tname[RT_NAME_MAX];
235*10465441SEvalZero sys_sem_t tmpsem;
236*10465441SEvalZero
237*10465441SEvalZero RT_DEBUG_NOT_IN_INTERRUPT;
238*10465441SEvalZero
239*10465441SEvalZero rt_snprintf(tname, RT_NAME_MAX, "%s%d", SYS_LWIP_SEM_NAME, counter);
240*10465441SEvalZero counter ++;
241*10465441SEvalZero
242*10465441SEvalZero tmpsem = rt_sem_create(tname, count, RT_IPC_FLAG_FIFO);
243*10465441SEvalZero if (tmpsem == RT_NULL)
244*10465441SEvalZero return ERR_MEM;
245*10465441SEvalZero else
246*10465441SEvalZero {
247*10465441SEvalZero *sem = tmpsem;
248*10465441SEvalZero
249*10465441SEvalZero return ERR_OK;
250*10465441SEvalZero }
251*10465441SEvalZero }
252*10465441SEvalZero
253*10465441SEvalZero /*
254*10465441SEvalZero * Deallocate a semaphore
255*10465441SEvalZero */
sys_sem_free(sys_sem_t * sem)256*10465441SEvalZero void sys_sem_free(sys_sem_t *sem)
257*10465441SEvalZero {
258*10465441SEvalZero RT_DEBUG_NOT_IN_INTERRUPT;
259*10465441SEvalZero rt_sem_delete(*sem);
260*10465441SEvalZero }
261*10465441SEvalZero
262*10465441SEvalZero /*
263*10465441SEvalZero * Signal a semaphore
264*10465441SEvalZero */
sys_sem_signal(sys_sem_t * sem)265*10465441SEvalZero void sys_sem_signal(sys_sem_t *sem)
266*10465441SEvalZero {
267*10465441SEvalZero rt_sem_release(*sem);
268*10465441SEvalZero }
269*10465441SEvalZero
270*10465441SEvalZero /*
271*10465441SEvalZero * Block the thread while waiting for the semaphore to be signaled
272*10465441SEvalZero *
273*10465441SEvalZero * @return If the timeout argument is non-zero, it will return the number of milliseconds
274*10465441SEvalZero * spent waiting for the semaphore to be signaled; If the semaphore isn't signaled
275*10465441SEvalZero * within the specified time, it will return SYS_ARCH_TIMEOUT; If the thread doesn't
276*10465441SEvalZero * wait for the semaphore, it will return zero
277*10465441SEvalZero */
sys_arch_sem_wait(sys_sem_t * sem,u32_t timeout)278*10465441SEvalZero u32_t sys_arch_sem_wait(sys_sem_t *sem, u32_t timeout)
279*10465441SEvalZero {
280*10465441SEvalZero rt_err_t ret;
281*10465441SEvalZero s32_t t;
282*10465441SEvalZero u32_t tick;
283*10465441SEvalZero
284*10465441SEvalZero RT_DEBUG_NOT_IN_INTERRUPT;
285*10465441SEvalZero
286*10465441SEvalZero /* get the begin tick */
287*10465441SEvalZero tick = rt_tick_get();
288*10465441SEvalZero if (timeout == 0)
289*10465441SEvalZero t = RT_WAITING_FOREVER;
290*10465441SEvalZero else
291*10465441SEvalZero {
292*10465441SEvalZero /* convert msecond to os tick */
293*10465441SEvalZero if (timeout < (1000/RT_TICK_PER_SECOND))
294*10465441SEvalZero t = 1;
295*10465441SEvalZero else
296*10465441SEvalZero t = timeout / (1000/RT_TICK_PER_SECOND);
297*10465441SEvalZero }
298*10465441SEvalZero
299*10465441SEvalZero ret = rt_sem_take(*sem, t);
300*10465441SEvalZero
301*10465441SEvalZero if (ret == -RT_ETIMEOUT)
302*10465441SEvalZero return SYS_ARCH_TIMEOUT;
303*10465441SEvalZero else
304*10465441SEvalZero {
305*10465441SEvalZero if (ret == RT_EOK)
306*10465441SEvalZero ret = 1;
307*10465441SEvalZero }
308*10465441SEvalZero
309*10465441SEvalZero /* get elapse msecond */
310*10465441SEvalZero tick = rt_tick_get() - tick;
311*10465441SEvalZero
312*10465441SEvalZero /* convert tick to msecond */
313*10465441SEvalZero tick = tick * (1000 / RT_TICK_PER_SECOND);
314*10465441SEvalZero if (tick == 0)
315*10465441SEvalZero tick = 1;
316*10465441SEvalZero
317*10465441SEvalZero return tick;
318*10465441SEvalZero }
319*10465441SEvalZero
320*10465441SEvalZero #ifndef sys_sem_valid
321*10465441SEvalZero /** Check if a semaphore is valid/allocated:
322*10465441SEvalZero * return 1 for valid, 0 for invalid
323*10465441SEvalZero */
sys_sem_valid(sys_sem_t * sem)324*10465441SEvalZero int sys_sem_valid(sys_sem_t *sem)
325*10465441SEvalZero {
326*10465441SEvalZero return (int)(*sem);
327*10465441SEvalZero }
328*10465441SEvalZero #endif
329*10465441SEvalZero
330*10465441SEvalZero #ifndef sys_sem_set_invalid
331*10465441SEvalZero /** Set a semaphore invalid so that sys_sem_valid returns 0
332*10465441SEvalZero */
sys_sem_set_invalid(sys_sem_t * sem)333*10465441SEvalZero void sys_sem_set_invalid(sys_sem_t *sem)
334*10465441SEvalZero {
335*10465441SEvalZero *sem = RT_NULL;
336*10465441SEvalZero }
337*10465441SEvalZero #endif
338*10465441SEvalZero
339*10465441SEvalZero /* ====================== Mutex ====================== */
340*10465441SEvalZero
341*10465441SEvalZero /** Create a new mutex
342*10465441SEvalZero * @param mutex pointer to the mutex to create
343*10465441SEvalZero * @return a new mutex
344*10465441SEvalZero */
sys_mutex_new(sys_mutex_t * mutex)345*10465441SEvalZero err_t sys_mutex_new(sys_mutex_t *mutex)
346*10465441SEvalZero {
347*10465441SEvalZero static unsigned short counter = 0;
348*10465441SEvalZero char tname[RT_NAME_MAX];
349*10465441SEvalZero sys_mutex_t tmpmutex;
350*10465441SEvalZero
351*10465441SEvalZero RT_DEBUG_NOT_IN_INTERRUPT;
352*10465441SEvalZero
353*10465441SEvalZero rt_snprintf(tname, RT_NAME_MAX, "%s%d", SYS_LWIP_MUTEX_NAME, counter);
354*10465441SEvalZero counter ++;
355*10465441SEvalZero
356*10465441SEvalZero tmpmutex = rt_mutex_create(tname, RT_IPC_FLAG_FIFO);
357*10465441SEvalZero if (tmpmutex == RT_NULL)
358*10465441SEvalZero return ERR_MEM;
359*10465441SEvalZero else
360*10465441SEvalZero {
361*10465441SEvalZero *mutex = tmpmutex;
362*10465441SEvalZero
363*10465441SEvalZero return ERR_OK;
364*10465441SEvalZero }
365*10465441SEvalZero }
366*10465441SEvalZero
367*10465441SEvalZero /** Lock a mutex
368*10465441SEvalZero * @param mutex the mutex to lock
369*10465441SEvalZero */
sys_mutex_lock(sys_mutex_t * mutex)370*10465441SEvalZero void sys_mutex_lock(sys_mutex_t *mutex)
371*10465441SEvalZero {
372*10465441SEvalZero RT_DEBUG_NOT_IN_INTERRUPT;
373*10465441SEvalZero rt_mutex_take(*mutex, RT_WAITING_FOREVER);
374*10465441SEvalZero
375*10465441SEvalZero return;
376*10465441SEvalZero }
377*10465441SEvalZero
378*10465441SEvalZero /** Unlock a mutex
379*10465441SEvalZero * @param mutex the mutex to unlock
380*10465441SEvalZero */
sys_mutex_unlock(sys_mutex_t * mutex)381*10465441SEvalZero void sys_mutex_unlock(sys_mutex_t *mutex)
382*10465441SEvalZero {
383*10465441SEvalZero rt_mutex_release(*mutex);
384*10465441SEvalZero }
385*10465441SEvalZero
386*10465441SEvalZero /** Delete a semaphore
387*10465441SEvalZero * @param mutex the mutex to delete
388*10465441SEvalZero */
sys_mutex_free(sys_mutex_t * mutex)389*10465441SEvalZero void sys_mutex_free(sys_mutex_t *mutex)
390*10465441SEvalZero {
391*10465441SEvalZero RT_DEBUG_NOT_IN_INTERRUPT;
392*10465441SEvalZero
393*10465441SEvalZero rt_mutex_delete(*mutex);
394*10465441SEvalZero }
395*10465441SEvalZero
396*10465441SEvalZero #ifndef sys_mutex_valid
397*10465441SEvalZero /** Check if a mutex is valid/allocated:
398*10465441SEvalZero * return 1 for valid, 0 for invalid
399*10465441SEvalZero */
sys_mutex_valid(sys_mutex_t * mutex)400*10465441SEvalZero int sys_mutex_valid(sys_mutex_t *mutex)
401*10465441SEvalZero {
402*10465441SEvalZero return (int)(*mutex);
403*10465441SEvalZero }
404*10465441SEvalZero #endif
405*10465441SEvalZero
406*10465441SEvalZero #ifndef sys_mutex_set_invalid
407*10465441SEvalZero /** Set a mutex invalid so that sys_mutex_valid returns 0
408*10465441SEvalZero */
sys_mutex_set_invalid(sys_mutex_t * mutex)409*10465441SEvalZero void sys_mutex_set_invalid(sys_mutex_t *mutex)
410*10465441SEvalZero {
411*10465441SEvalZero *mutex = RT_NULL;
412*10465441SEvalZero }
413*10465441SEvalZero #endif
414*10465441SEvalZero
415*10465441SEvalZero /* ====================== Mailbox ====================== */
416*10465441SEvalZero
417*10465441SEvalZero /*
418*10465441SEvalZero * Create an empty mailbox for maximum "size" elements
419*10465441SEvalZero *
420*10465441SEvalZero * @return the operation status, ERR_OK on OK; others on error
421*10465441SEvalZero */
sys_mbox_new(sys_mbox_t * mbox,int size)422*10465441SEvalZero err_t sys_mbox_new(sys_mbox_t *mbox, int size)
423*10465441SEvalZero {
424*10465441SEvalZero static unsigned short counter = 0;
425*10465441SEvalZero char tname[RT_NAME_MAX];
426*10465441SEvalZero sys_mbox_t tmpmbox;
427*10465441SEvalZero
428*10465441SEvalZero RT_DEBUG_NOT_IN_INTERRUPT;
429*10465441SEvalZero
430*10465441SEvalZero rt_snprintf(tname, RT_NAME_MAX, "%s%d", SYS_LWIP_MBOX_NAME, counter);
431*10465441SEvalZero counter ++;
432*10465441SEvalZero
433*10465441SEvalZero tmpmbox = rt_mb_create(tname, size, RT_IPC_FLAG_FIFO);
434*10465441SEvalZero if (tmpmbox != RT_NULL)
435*10465441SEvalZero {
436*10465441SEvalZero *mbox = tmpmbox;
437*10465441SEvalZero
438*10465441SEvalZero return ERR_OK;
439*10465441SEvalZero }
440*10465441SEvalZero
441*10465441SEvalZero return ERR_MEM;
442*10465441SEvalZero }
443*10465441SEvalZero
444*10465441SEvalZero /*
445*10465441SEvalZero * Deallocate a mailbox
446*10465441SEvalZero */
sys_mbox_free(sys_mbox_t * mbox)447*10465441SEvalZero void sys_mbox_free(sys_mbox_t *mbox)
448*10465441SEvalZero {
449*10465441SEvalZero RT_DEBUG_NOT_IN_INTERRUPT;
450*10465441SEvalZero
451*10465441SEvalZero rt_mb_delete(*mbox);
452*10465441SEvalZero
453*10465441SEvalZero return;
454*10465441SEvalZero }
455*10465441SEvalZero
456*10465441SEvalZero /** Post a message to an mbox - may not fail
457*10465441SEvalZero * -> blocks if full, only used from tasks not from ISR
458*10465441SEvalZero * @param mbox mbox to posts the message
459*10465441SEvalZero * @param msg message to post (ATTENTION: can be NULL)
460*10465441SEvalZero */
sys_mbox_post(sys_mbox_t * mbox,void * msg)461*10465441SEvalZero void sys_mbox_post(sys_mbox_t *mbox, void *msg)
462*10465441SEvalZero {
463*10465441SEvalZero RT_DEBUG_NOT_IN_INTERRUPT;
464*10465441SEvalZero
465*10465441SEvalZero rt_mb_send_wait(*mbox, (rt_uint32_t)msg, RT_WAITING_FOREVER);
466*10465441SEvalZero
467*10465441SEvalZero return;
468*10465441SEvalZero }
469*10465441SEvalZero
470*10465441SEvalZero /*
471*10465441SEvalZero * Try to post the "msg" to the mailbox
472*10465441SEvalZero *
473*10465441SEvalZero * @return return ERR_OK if the "msg" is posted, ERR_MEM if the mailbox is full
474*10465441SEvalZero */
sys_mbox_trypost(sys_mbox_t * mbox,void * msg)475*10465441SEvalZero err_t sys_mbox_trypost(sys_mbox_t *mbox, void *msg)
476*10465441SEvalZero {
477*10465441SEvalZero if (rt_mb_send(*mbox, (rt_uint32_t)msg) == RT_EOK)
478*10465441SEvalZero return ERR_OK;
479*10465441SEvalZero
480*10465441SEvalZero return ERR_MEM;
481*10465441SEvalZero }
482*10465441SEvalZero
483*10465441SEvalZero err_t
sys_mbox_trypost_fromisr(sys_mbox_t * q,void * msg)484*10465441SEvalZero sys_mbox_trypost_fromisr(sys_mbox_t *q, void *msg)
485*10465441SEvalZero {
486*10465441SEvalZero return sys_mbox_trypost(q, msg);
487*10465441SEvalZero }
488*10465441SEvalZero
489*10465441SEvalZero /** Wait for a new message to arrive in the mbox
490*10465441SEvalZero * @param mbox mbox to get a message from
491*10465441SEvalZero * @param msg pointer where the message is stored
492*10465441SEvalZero * @param timeout maximum time (in milliseconds) to wait for a message
493*10465441SEvalZero * @return time (in milliseconds) waited for a message, may be 0 if not waited
494*10465441SEvalZero or SYS_ARCH_TIMEOUT on timeout
495*10465441SEvalZero * The returned time has to be accurate to prevent timer jitter!
496*10465441SEvalZero */
sys_arch_mbox_fetch(sys_mbox_t * mbox,void ** msg,u32_t timeout)497*10465441SEvalZero u32_t sys_arch_mbox_fetch(sys_mbox_t *mbox, void **msg, u32_t timeout)
498*10465441SEvalZero {
499*10465441SEvalZero rt_err_t ret;
500*10465441SEvalZero s32_t t;
501*10465441SEvalZero u32_t tick;
502*10465441SEvalZero
503*10465441SEvalZero RT_DEBUG_NOT_IN_INTERRUPT;
504*10465441SEvalZero
505*10465441SEvalZero /* get the begin tick */
506*10465441SEvalZero tick = rt_tick_get();
507*10465441SEvalZero
508*10465441SEvalZero if(timeout == 0)
509*10465441SEvalZero t = RT_WAITING_FOREVER;
510*10465441SEvalZero else
511*10465441SEvalZero {
512*10465441SEvalZero /* convirt msecond to os tick */
513*10465441SEvalZero if (timeout < (1000/RT_TICK_PER_SECOND))
514*10465441SEvalZero t = 1;
515*10465441SEvalZero else
516*10465441SEvalZero t = timeout / (1000/RT_TICK_PER_SECOND);
517*10465441SEvalZero }
518*10465441SEvalZero
519*10465441SEvalZero ret = rt_mb_recv(*mbox, (rt_uint32_t *)msg, t);
520*10465441SEvalZero
521*10465441SEvalZero if(ret == -RT_ETIMEOUT)
522*10465441SEvalZero return SYS_ARCH_TIMEOUT;
523*10465441SEvalZero else
524*10465441SEvalZero {
525*10465441SEvalZero LWIP_ASSERT("rt_mb_recv returned with error!", ret == RT_EOK);
526*10465441SEvalZero }
527*10465441SEvalZero
528*10465441SEvalZero /* get elapse msecond */
529*10465441SEvalZero tick = rt_tick_get() - tick;
530*10465441SEvalZero
531*10465441SEvalZero /* convert tick to msecond */
532*10465441SEvalZero tick = tick * (1000 / RT_TICK_PER_SECOND);
533*10465441SEvalZero if (tick == 0)
534*10465441SEvalZero tick = 1;
535*10465441SEvalZero
536*10465441SEvalZero return tick;
537*10465441SEvalZero }
538*10465441SEvalZero
539*10465441SEvalZero /** Wait for a new message to arrive in the mbox
540*10465441SEvalZero * @param mbox mbox to get a message from
541*10465441SEvalZero * @param msg pointer where the message is stored
542*10465441SEvalZero * @param timeout maximum time (in milliseconds) to wait for a message
543*10465441SEvalZero * @return 0 (milliseconds) if a message has been received
544*10465441SEvalZero * or SYS_MBOX_EMPTY if the mailbox is empty
545*10465441SEvalZero */
sys_arch_mbox_tryfetch(sys_mbox_t * mbox,void ** msg)546*10465441SEvalZero u32_t sys_arch_mbox_tryfetch(sys_mbox_t *mbox, void **msg)
547*10465441SEvalZero {
548*10465441SEvalZero int ret;
549*10465441SEvalZero
550*10465441SEvalZero ret = rt_mb_recv(*mbox, (rt_uint32_t *)msg, 0);
551*10465441SEvalZero
552*10465441SEvalZero if(ret == -RT_ETIMEOUT)
553*10465441SEvalZero return SYS_ARCH_TIMEOUT;
554*10465441SEvalZero else
555*10465441SEvalZero {
556*10465441SEvalZero if (ret == RT_EOK)
557*10465441SEvalZero ret = 1;
558*10465441SEvalZero }
559*10465441SEvalZero
560*10465441SEvalZero return ret;
561*10465441SEvalZero }
562*10465441SEvalZero
563*10465441SEvalZero #ifndef sys_mbox_valid
564*10465441SEvalZero /** Check if an mbox is valid/allocated:
565*10465441SEvalZero * return 1 for valid, 0 for invalid
566*10465441SEvalZero */
sys_mbox_valid(sys_mbox_t * mbox)567*10465441SEvalZero int sys_mbox_valid(sys_mbox_t *mbox)
568*10465441SEvalZero {
569*10465441SEvalZero return (int)(*mbox);
570*10465441SEvalZero }
571*10465441SEvalZero #endif
572*10465441SEvalZero
573*10465441SEvalZero #ifndef sys_mbox_set_invalid
574*10465441SEvalZero /** Set an mbox invalid so that sys_mbox_valid returns 0
575*10465441SEvalZero */
sys_mbox_set_invalid(sys_mbox_t * mbox)576*10465441SEvalZero void sys_mbox_set_invalid(sys_mbox_t *mbox)
577*10465441SEvalZero {
578*10465441SEvalZero *mbox = RT_NULL;
579*10465441SEvalZero }
580*10465441SEvalZero #endif
581*10465441SEvalZero
582*10465441SEvalZero /* ====================== System ====================== */
583*10465441SEvalZero
584*10465441SEvalZero /*
585*10465441SEvalZero * Start a new thread named "name" with priority "prio" that will begin
586*10465441SEvalZero * its execution in the function "thread()". The "arg" argument will be
587*10465441SEvalZero * passed as an argument to the thread() function
588*10465441SEvalZero */
sys_thread_new(const char * name,lwip_thread_fn thread,void * arg,int stacksize,int prio)589*10465441SEvalZero sys_thread_t sys_thread_new(const char *name,
590*10465441SEvalZero lwip_thread_fn thread,
591*10465441SEvalZero void *arg,
592*10465441SEvalZero int stacksize,
593*10465441SEvalZero int prio)
594*10465441SEvalZero {
595*10465441SEvalZero rt_thread_t t;
596*10465441SEvalZero
597*10465441SEvalZero RT_DEBUG_NOT_IN_INTERRUPT;
598*10465441SEvalZero
599*10465441SEvalZero /* create thread */
600*10465441SEvalZero t = rt_thread_create(name, thread, arg, stacksize, prio, 20);
601*10465441SEvalZero RT_ASSERT(t != RT_NULL);
602*10465441SEvalZero
603*10465441SEvalZero /* startup thread */
604*10465441SEvalZero rt_thread_startup(t);
605*10465441SEvalZero
606*10465441SEvalZero return t;
607*10465441SEvalZero }
608*10465441SEvalZero
sys_arch_protect(void)609*10465441SEvalZero sys_prot_t sys_arch_protect(void)
610*10465441SEvalZero {
611*10465441SEvalZero rt_base_t level;
612*10465441SEvalZero
613*10465441SEvalZero /* disable interrupt */
614*10465441SEvalZero level = rt_hw_interrupt_disable();
615*10465441SEvalZero
616*10465441SEvalZero return level;
617*10465441SEvalZero }
618*10465441SEvalZero
sys_arch_unprotect(sys_prot_t pval)619*10465441SEvalZero void sys_arch_unprotect(sys_prot_t pval)
620*10465441SEvalZero {
621*10465441SEvalZero /* enable interrupt */
622*10465441SEvalZero rt_hw_interrupt_enable(pval);
623*10465441SEvalZero
624*10465441SEvalZero return;
625*10465441SEvalZero }
626*10465441SEvalZero
sys_arch_assert(const char * file,int line)627*10465441SEvalZero void sys_arch_assert(const char *file, int line)
628*10465441SEvalZero {
629*10465441SEvalZero rt_kprintf("\nAssertion: %d in %s, thread %s\n",
630*10465441SEvalZero line, file, rt_thread_self()->name);
631*10465441SEvalZero RT_ASSERT(0);
632*10465441SEvalZero }
633*10465441SEvalZero
sys_jiffies(void)634*10465441SEvalZero u32_t sys_jiffies(void)
635*10465441SEvalZero {
636*10465441SEvalZero return rt_tick_get();
637*10465441SEvalZero }
638*10465441SEvalZero
sys_now(void)639*10465441SEvalZero u32_t sys_now(void)
640*10465441SEvalZero {
641*10465441SEvalZero return rt_tick_get() * (1000 / RT_TICK_PER_SECOND);
642*10465441SEvalZero }
643*10465441SEvalZero
644*10465441SEvalZero #if MEM_OVERFLOW_CHECK || MEMP_OVERFLOW_CHECK
645*10465441SEvalZero /**
646*10465441SEvalZero * Check if a mep element was victim of an overflow or underflow
647*10465441SEvalZero * (e.g. the restricted area after/before it has been altered)
648*10465441SEvalZero *
649*10465441SEvalZero * @param p the mem element to check
650*10465441SEvalZero * @param size allocated size of the element
651*10465441SEvalZero * @param descr1 description of the element source shown on error
652*10465441SEvalZero * @param descr2 description of the element source shown on error
653*10465441SEvalZero */
654*10465441SEvalZero void
mem_overflow_check_raw(void * p,size_t size,const char * descr1,const char * descr2)655*10465441SEvalZero mem_overflow_check_raw(void *p, size_t size, const char *descr1, const char *descr2)
656*10465441SEvalZero {
657*10465441SEvalZero #if MEM_SANITY_REGION_AFTER_ALIGNED || MEM_SANITY_REGION_BEFORE_ALIGNED
658*10465441SEvalZero u16_t k;
659*10465441SEvalZero u8_t *m;
660*10465441SEvalZero
661*10465441SEvalZero #if MEM_SANITY_REGION_AFTER_ALIGNED > 0
662*10465441SEvalZero m = (u8_t *)p + size;
663*10465441SEvalZero for (k = 0; k < MEM_SANITY_REGION_AFTER_ALIGNED; k++) {
664*10465441SEvalZero if (m[k] != 0xcd) {
665*10465441SEvalZero char errstr[128];
666*10465441SEvalZero snprintf(errstr, sizeof(errstr), "detected mem overflow in %s%s", descr1, descr2);
667*10465441SEvalZero LWIP_ASSERT(errstr, 0);
668*10465441SEvalZero }
669*10465441SEvalZero }
670*10465441SEvalZero #endif /* MEM_SANITY_REGION_AFTER_ALIGNED > 0 */
671*10465441SEvalZero
672*10465441SEvalZero #if MEM_SANITY_REGION_BEFORE_ALIGNED > 0
673*10465441SEvalZero m = (u8_t *)p - MEM_SANITY_REGION_BEFORE_ALIGNED;
674*10465441SEvalZero for (k = 0; k < MEM_SANITY_REGION_BEFORE_ALIGNED; k++) {
675*10465441SEvalZero if (m[k] != 0xcd) {
676*10465441SEvalZero char errstr[128];
677*10465441SEvalZero snprintf(errstr, sizeof(errstr), "detected mem underflow in %s%s", descr1, descr2);
678*10465441SEvalZero LWIP_ASSERT(errstr, 0);
679*10465441SEvalZero }
680*10465441SEvalZero }
681*10465441SEvalZero #endif /* MEM_SANITY_REGION_BEFORE_ALIGNED > 0 */
682*10465441SEvalZero #else
683*10465441SEvalZero LWIP_UNUSED_ARG(p);
684*10465441SEvalZero LWIP_UNUSED_ARG(desc);
685*10465441SEvalZero LWIP_UNUSED_ARG(descr);
686*10465441SEvalZero #endif
687*10465441SEvalZero }
688*10465441SEvalZero
689*10465441SEvalZero /**
690*10465441SEvalZero * Initialize the restricted area of a mem element.
691*10465441SEvalZero */
692*10465441SEvalZero void
mem_overflow_init_raw(void * p,size_t size)693*10465441SEvalZero mem_overflow_init_raw(void *p, size_t size)
694*10465441SEvalZero {
695*10465441SEvalZero #if MEM_SANITY_REGION_BEFORE_ALIGNED > 0 || MEM_SANITY_REGION_AFTER_ALIGNED > 0
696*10465441SEvalZero u8_t *m;
697*10465441SEvalZero #if MEM_SANITY_REGION_BEFORE_ALIGNED > 0
698*10465441SEvalZero m = (u8_t *)p - MEM_SANITY_REGION_BEFORE_ALIGNED;
699*10465441SEvalZero memset(m, 0xcd, MEM_SANITY_REGION_BEFORE_ALIGNED);
700*10465441SEvalZero #endif
701*10465441SEvalZero #if MEM_SANITY_REGION_AFTER_ALIGNED > 0
702*10465441SEvalZero m = (u8_t *)p + size;
703*10465441SEvalZero memset(m, 0xcd, MEM_SANITY_REGION_AFTER_ALIGNED);
704*10465441SEvalZero #endif
705*10465441SEvalZero #else /* MEM_SANITY_REGION_BEFORE_ALIGNED > 0 || MEM_SANITY_REGION_AFTER_ALIGNED > 0 */
706*10465441SEvalZero LWIP_UNUSED_ARG(p);
707*10465441SEvalZero LWIP_UNUSED_ARG(desc);
708*10465441SEvalZero #endif /* MEM_SANITY_REGION_BEFORE_ALIGNED > 0 || MEM_SANITY_REGION_AFTER_ALIGNED > 0 */
709*10465441SEvalZero }
710*10465441SEvalZero #endif /* MEM_OVERFLOW_CHECK || MEMP_OVERFLOW_CHECK */
711*10465441SEvalZero
712*10465441SEvalZero RT_WEAK
mem_init(void)713*10465441SEvalZero void mem_init(void)
714*10465441SEvalZero {
715*10465441SEvalZero }
716*10465441SEvalZero
mem_calloc(mem_size_t count,mem_size_t size)717*10465441SEvalZero void *mem_calloc(mem_size_t count, mem_size_t size)
718*10465441SEvalZero {
719*10465441SEvalZero return rt_calloc(count, size);
720*10465441SEvalZero }
721*10465441SEvalZero
mem_trim(void * mem,mem_size_t size)722*10465441SEvalZero void *mem_trim(void *mem, mem_size_t size)
723*10465441SEvalZero {
724*10465441SEvalZero // return rt_realloc(mem, size);
725*10465441SEvalZero /* not support trim yet */
726*10465441SEvalZero return mem;
727*10465441SEvalZero }
728*10465441SEvalZero
mem_malloc(mem_size_t size)729*10465441SEvalZero void *mem_malloc(mem_size_t size)
730*10465441SEvalZero {
731*10465441SEvalZero return rt_malloc(size);
732*10465441SEvalZero }
733*10465441SEvalZero
mem_free(void * mem)734*10465441SEvalZero void mem_free(void *mem)
735*10465441SEvalZero {
736*10465441SEvalZero rt_free(mem);
737*10465441SEvalZero }
738*10465441SEvalZero
739*10465441SEvalZero #ifdef RT_LWIP_PPP
sio_read(sio_fd_t fd,u8_t * buf,u32_t size)740*10465441SEvalZero u32_t sio_read(sio_fd_t fd, u8_t *buf, u32_t size)
741*10465441SEvalZero {
742*10465441SEvalZero u32_t len;
743*10465441SEvalZero
744*10465441SEvalZero RT_ASSERT(fd != RT_NULL);
745*10465441SEvalZero
746*10465441SEvalZero len = rt_device_read((rt_device_t)fd, 0, buf, size);
747*10465441SEvalZero if (len <= 0)
748*10465441SEvalZero return 0;
749*10465441SEvalZero
750*10465441SEvalZero return len;
751*10465441SEvalZero }
752*10465441SEvalZero
sio_write(sio_fd_t fd,u8_t * buf,u32_t size)753*10465441SEvalZero u32_t sio_write(sio_fd_t fd, u8_t *buf, u32_t size)
754*10465441SEvalZero {
755*10465441SEvalZero RT_ASSERT(fd != RT_NULL);
756*10465441SEvalZero
757*10465441SEvalZero return rt_device_write((rt_device_t)fd, 0, buf, size);
758*10465441SEvalZero }
759*10465441SEvalZero
sio_read_abort(sio_fd_t fd)760*10465441SEvalZero void sio_read_abort(sio_fd_t fd)
761*10465441SEvalZero {
762*10465441SEvalZero rt_kprintf("read_abort\n");
763*10465441SEvalZero }
764*10465441SEvalZero
ppp_trace(int level,const char * format,...)765*10465441SEvalZero void ppp_trace(int level, const char *format, ...)
766*10465441SEvalZero {
767*10465441SEvalZero va_list args;
768*10465441SEvalZero rt_size_t length;
769*10465441SEvalZero static char rt_log_buf[RT_CONSOLEBUF_SIZE];
770*10465441SEvalZero
771*10465441SEvalZero va_start(args, format);
772*10465441SEvalZero length = rt_vsprintf(rt_log_buf, format, args);
773*10465441SEvalZero rt_device_write((rt_device_t)rt_console_get_device(), 0, rt_log_buf, length);
774*10465441SEvalZero va_end(args);
775*10465441SEvalZero }
776*10465441SEvalZero #endif
777*10465441SEvalZero
778*10465441SEvalZero /*
779*10465441SEvalZero * export bsd socket symbol for RT-Thread Application Module
780*10465441SEvalZero */
781*10465441SEvalZero #if LWIP_SOCKET
782*10465441SEvalZero #include <lwip/sockets.h>
783*10465441SEvalZero RTM_EXPORT(lwip_accept);
784*10465441SEvalZero RTM_EXPORT(lwip_bind);
785*10465441SEvalZero RTM_EXPORT(lwip_shutdown);
786*10465441SEvalZero RTM_EXPORT(lwip_getpeername);
787*10465441SEvalZero RTM_EXPORT(lwip_getsockname);
788*10465441SEvalZero RTM_EXPORT(lwip_getsockopt);
789*10465441SEvalZero RTM_EXPORT(lwip_setsockopt);
790*10465441SEvalZero RTM_EXPORT(lwip_close);
791*10465441SEvalZero RTM_EXPORT(lwip_connect);
792*10465441SEvalZero RTM_EXPORT(lwip_listen);
793*10465441SEvalZero RTM_EXPORT(lwip_recv);
794*10465441SEvalZero RTM_EXPORT(lwip_read);
795*10465441SEvalZero RTM_EXPORT(lwip_recvfrom);
796*10465441SEvalZero RTM_EXPORT(lwip_send);
797*10465441SEvalZero RTM_EXPORT(lwip_sendto);
798*10465441SEvalZero RTM_EXPORT(lwip_socket);
799*10465441SEvalZero RTM_EXPORT(lwip_write);
800*10465441SEvalZero RTM_EXPORT(lwip_select);
801*10465441SEvalZero RTM_EXPORT(lwip_ioctl);
802*10465441SEvalZero RTM_EXPORT(lwip_fcntl);
803*10465441SEvalZero
804*10465441SEvalZero RTM_EXPORT(lwip_htons);
805*10465441SEvalZero RTM_EXPORT(lwip_htonl);
806*10465441SEvalZero
807*10465441SEvalZero #if LWIP_DNS
808*10465441SEvalZero #include <lwip/netdb.h>
809*10465441SEvalZero RTM_EXPORT(lwip_gethostbyname);
810*10465441SEvalZero RTM_EXPORT(lwip_gethostbyname_r);
811*10465441SEvalZero RTM_EXPORT(lwip_freeaddrinfo);
812*10465441SEvalZero RTM_EXPORT(lwip_getaddrinfo);
813*10465441SEvalZero #endif
814*10465441SEvalZero
815*10465441SEvalZero #endif
816*10465441SEvalZero
817*10465441SEvalZero #if LWIP_DHCP
818*10465441SEvalZero #include <lwip/dhcp.h>
819*10465441SEvalZero RTM_EXPORT(dhcp_start);
820*10465441SEvalZero RTM_EXPORT(dhcp_renew);
821*10465441SEvalZero RTM_EXPORT(dhcp_stop);
822*10465441SEvalZero #endif
823*10465441SEvalZero
824*10465441SEvalZero #if LWIP_NETIF_API
825*10465441SEvalZero #include <lwip/netifapi.h>
826*10465441SEvalZero RTM_EXPORT(netifapi_netif_set_addr);
827*10465441SEvalZero #endif
828*10465441SEvalZero
829*10465441SEvalZero #if LWIP_NETIF_LINK_CALLBACK
830*10465441SEvalZero RTM_EXPORT(netif_set_link_callback);
831*10465441SEvalZero #endif
832*10465441SEvalZero
833*10465441SEvalZero #if LWIP_NETIF_STATUS_CALLBACK
834*10465441SEvalZero RTM_EXPORT(netif_set_status_callback);
835*10465441SEvalZero #endif
836*10465441SEvalZero
837*10465441SEvalZero RTM_EXPORT(netif_find);
838*10465441SEvalZero RTM_EXPORT(netif_set_addr);
839*10465441SEvalZero RTM_EXPORT(netif_set_ipaddr);
840*10465441SEvalZero RTM_EXPORT(netif_set_gw);
841*10465441SEvalZero RTM_EXPORT(netif_set_netmask);
842