新版的RL-TCPnet V7.X可以移植到各种RTOS下的net_rtos.h和net_rtos2.h接口文件

eric2013

默认是提供了CMSIS-RTOS V1封装层接口和V2封装层接口
下面是V1接口实现，不愿意用封装层，直接用其它RTOS的原始API就行

1. /*------------------------------------------------------------------------------
   
2. * MDK Middleware - Component ::Network
   
3. * Copyright (c) 2004-2018 ARM Germany GmbH. All rights reserved.
   
4. *------------------------------------------------------------------------------
   
5. * Name:    net_rtos.h
   
6. * Purpose: Network CMSIS-RTOS abstraction layer
   
7. * Rev.:    V7.7.1
   
8. *----------------------------------------------------------------------------*/
   
9. 
   
10. #include "cmsis_os.h"
    
11. #include "rl_net_lib.h"
    
12. 
    
13. /* Avoid syntax-checker errors in editor */
    
14. #ifndef NET_THREAD_STACK_SIZE
    
15.   #define NET_THREAD_STACK_SIZE 1024
    
16.   #define NET_THREAD_PRIORITY   osPriorityNormal
    
17. #endif
    
18. 
    
19. #if (osCMSIS < 0x20000U)
    
20.   #define STATIC        static
    
21. #else
    
22.   #define STATIC
    
23. #endif
    
24. 
    
25. extern const osMutexDef_t os_mutex_def_net_lock;
    
26. extern const osMutexDef_t os_mutex_def_mem_lock;
    
27. extern const osTimerDef_t os_timer_def_net_tick;
    
28. extern const osThreadDef_t os_thread_def_netCore_Thread;
    
29. extern const osThreadDef_t os_thread_def_netETH_Thread;
    
30. extern const osThreadDef_t os_thread_def_netPPP_Thread;
    
31. extern const osThreadDef_t os_thread_def_netSLIP_Thread;
    
32. extern const osSemaphoreDef_t os_semaphore_def_eth0_lock;
    
33. extern const osSemaphoreDef_t os_semaphore_def_ppp_lock;
    
34. extern const osSemaphoreDef_t os_semaphore_def_slip_lock;
    
35. 
    
36. /* Network core resources */
    
37. STATIC osMutexDef(net_lock);
    
38. STATIC osMutexDef(mem_lock);
    
39. STATIC osTimerDef(net_tick, net_sys_tick);
    
40.        osThreadDef(netCore_Thread, NET_THREAD_PRIORITY, 1, NET_THREAD_STACK_SIZE);
    
41. 
    
42. /* Ethernet interface resources */
    
43. #if (ETH0_ENABLE)
    
44. STATIC osSemaphoreDef(eth0_lock);
    
45.        osThreadDef(netETH_Thread, ETH0_THREAD_PRIORITY, 1, ETH0_THREAD_STACK_SIZE);
    
46. #endif
    
47. 
    
48. /* PPP interface resources */
    
49. #if (PPP_ENABLE)
    
50. STATIC osSemaphoreDef(ppp_lock);
    
51.        osThreadDef(netPPP_Thread, PPP_THREAD_PRIORITY, 1, PPP_THREAD_STACK_SIZE);
    
52. #endif
    
53. 
    
54. /* SLIP interface resources */
    
55. #if (SLIP_ENABLE)
    
56. STATIC osSemaphoreDef(slip_lock);
    
57.        osThreadDef(netSLIP_Thread, SLIP_THREAD_PRIORITY, 1, SLIP_THREAD_STACK_SIZE);
    
58. #endif
    
59. 
    
60. 
    
61. /* Create network core thread */
    
62. NETOS_ID netos_thread_create (void) {
    
63.   return (osThreadCreate (osThread(netCore_Thread), NULL));
    
64. }
    
65. 
    
66. /* Delete network thread */
    
67. void netos_thread_delete (NETOS_ID thread) {
    
68.   osThreadTerminate (thread);
    
69. }
    
70. 
    
71. /* Get running thread identifier */
    
72. NETOS_ID netos_thread_id (void) {
    
73.   return (osThreadGetId ());
    
74. }
    
75. 
    
76. /* Pass control to next ready thread */
    
77. void netos_thread_pass (void) {
    
78.   osThreadYield ();
    
79. }
    
80. 
    
81. /* Create periodic tick timer */
    
82. NETOS_ID netos_timer_create (void) {
    
83.   return (osTimerCreate (osTimer(net_tick), osTimerPeriodic, NULL));
    
84. }
    
85. 
    
86. /* Delete periodic tick timer */
    
87. void netos_timer_delete (NETOS_ID timer) {
    
88.   osTimerDelete (timer);
    
89. }
    
90. 
    
91. /* Start periodic tick timer */
    
92. void netos_timer_start (NETOS_ID timer, uint32_t interval_ms) {
    
93.   osTimerStart (timer, interval_ms);
    
94. }
    
95. 
    
96. /* Create network protection mutex */
    
97. NETOS_ID netos_mutex_create (uint8_t sys_id) {
    
98.   switch (sys_id) {
    
99.     case 0:  return (osMutexCreate (osMutex(net_lock)));
    
100.     default: return (osMutexCreate (osMutex(mem_lock)));
     
101.   }
     
102. }
     
103. 
     
104. /* Delete network protection mutex */
     
105. void netos_mutex_delete (NETOS_ID mutex) {
     
106.   osMutexDelete (mutex);
     
107. }
     
108. 
     
109. /* Lock network protection mutex */
     
110. void netos_lock (NETOS_ID mutex) {
     
111.   osMutexWait (mutex, osWaitForever);
     
112. }
     
113. 
     
114. /* Unlock network protection mutex */
     
115. void netos_unlock (NETOS_ID mutex) {
     
116.   osMutexRelease (mutex);
     
117. }
     
118. 
     
119. /* Wait for thread signal/event flag */
     
120. void netos_flag_wait (uint32_t flag, uint32_t ms) {
     
121.   osSignalWait ((int32_t)flag, ms);
     
122. }
     
123. 
     
124. /* Set thread signal/event flag */
     
125. void netos_flag_set (NETOS_ID thread, uint32_t flag) {
     
126.   osSignalSet (thread, (int32_t)flag);
     
127. }
     
128. 
     
129. /* Clear thread signal/event flag */
     
130. void netos_flag_clear (NETOS_ID thread, uint32_t flag) {
     
131.   osSignalClear (thread, (int32_t)flag);
     
132. }
     
133. 
     
134. /* Delay thread execution */
     
135. void netos_delay (uint32_t ms) {
     
136.   osDelay (ms);
     
137. }
     
138. 
     
139. /* Create network interface thread and semaphore */
     
140. NETOS_ID netif_create (uint8_t netif, NETOS_ID *semaphore) {
     
141.   switch (netif) {
     
142. #if (ETH0_ENABLE)
     
143.     case  NETIF_ETH:
     
144.       *semaphore = osSemaphoreCreate (osSemaphore(eth0_lock), 1);
     
145.       return (osThreadCreate (osThread(netETH_Thread), NULL));
     
146. #endif
     
147. #if (PPP_ENABLE)
     
148.     case NETIF_PPP:
     
149.       *semaphore = osSemaphoreCreate (osSemaphore(ppp_lock), 1);
     
150.       return (osThreadCreate (osThread(netPPP_Thread), NULL));
     
151. #endif
     
152. #if (SLIP_ENABLE)
     
153.     case NETIF_SLIP:
     
154.       *semaphore = osSemaphoreCreate (osSemaphore(slip_lock), 1);
     
155.       return (osThreadCreate (osThread(netSLIP_Thread), NULL));
     
156. #endif
     
157.   }
     
158.   return (NULL);
     
159. }
     
160. 
     
161. /* Delete network interface thread and semaphore */
     
162. void netif_delete (NETOS_ID thread, NETOS_ID semaphore) {
     
163.   osSemaphoreDelete (semaphore);
     
164.   osThreadTerminate (thread);
     
165. }
     
166. 
     
167. /* Lock interface protection semaphore */
     
168. void netif_lock (NETOS_ID semaphore) {
     
169.   osSemaphoreWait (semaphore, osWaitForever);
     
170. }
     
171. 
     
172. /* Unlock interface protection semaphore */
     
173. void netif_unlock (NETOS_ID semaphore) {
     
174.   osSemaphoreRelease (semaphore);
     
175. }
     

复制代码