uart.c 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583
  1. #include "uart.h"
  2. #include "bsp/shark_bsp.h"
  3. #include "bsp/gpio.h"
  4. #include "libs/shark_libs.h"
  5. #include "libs/shark_task.h"
  6. #include "libs/logger.h"
  7. #define SHARK_UART_BAUDRATE 38400
  8. #define SHARK_UART0_com USART0
  9. #define SHARK_UART0_tx_port GPIOB
  10. #define SHARK_UART0_tx_pin GPIO_PIN_6
  11. #define SHARK_UART0_rx_port GPIOB
  12. #define SHARK_UART0_rx_pin GPIO_PIN_7
  13. #define SHARK_UART0_irq USART0_IRQn
  14. #define SHARK_UART0_clk RCU_USART0
  15. #define SHARK_UART0_tx_gpio_clk RCU_GPIOB
  16. #define SHARK_UART0_rx_gpio_clk RCU_GPIOB
  17. #define SHARK_UART0_tx_dma DMA
  18. #define SHARK_UART0_tx_dma_ch DMA_CH1
  19. #define SHARK_UART0_tx_dma_clk RCU_DMA
  20. #define SHARK_UART0_rx_dma DMA
  21. #define SHARK_UART0_rx_dma_ch DMA_CH2
  22. #define SHARK_UART0_rx_dma_clk RCU_DMA
  23. #define SHARK_UART1_com USART1
  24. #define SHARK_UART1_tx_port GPIOA
  25. #define SHARK_UART1_tx_pin GPIO_PIN_2
  26. #define SHARK_UART1_rx_port GPIOA
  27. #define SHARK_UART1_rx_pin GPIO_PIN_3
  28. #define SHARK_UART1_irq USART1_IRQn
  29. #define SHARK_UART1_clk RCU_USART1
  30. #define SHARK_UART1_tx_gpio_clk RCU_GPIOA
  31. #define SHARK_UART1_rx_gpio_clk RCU_GPIOA
  32. #define SHARK_UART1_tx_dma DMA
  33. #define SHARK_UART1_tx_dma_ch DMA_CH3
  34. #define SHARK_UART1_tx_dma_clk RCU_DMA
  35. #define SHARK_UART1_rx_dma DMA
  36. #define SHARK_UART1_rx_dma_ch DMA_CH4
  37. #define SHARK_UART1_rx_dma_clk RCU_DMA
  38. // ================================================================================
  39. #define ENABLE_RX_DMA 1
  40. static u8 shark_uart0_tx_cache[SHARK_UART_TX_MEM_SIZE];
  41. #if UART_NUM==2
  42. static u8 shark_uart1_tx_cache[SHARK_UART_TX_MEM_SIZE];
  43. #endif
  44. static u8 shark_uart0_rx_cache[SHARK_UART_RX_MEM_SIZE];
  45. #if UART_NUM==2
  46. static u8 shark_uart1_rx_cache[SHARK_UART_RX_MEM_SIZE];
  47. #endif
  48. static shark_uart_t _shark_uart[UART_NUM];
  49. static shark_task_t _uart_task;
  50. static u64 _rx_time;
  51. u32 uart_rx_bytes = 0;
  52. u32 uart_old_prot = 0;
  53. u32 uart_new_prot = 0;
  54. u32 uart_tx_bytes = 0;
  55. static u32 uart_run_times[2];
  56. static u32 uart_irq_times[2];
  57. ///static bool uart_no_data = false;
  58. #if ENABLE_RX_DMA==1
  59. #define update_dma_w_pos(uart) circle_update_write_position(&uart->rx_queue, SHARK_UART_RX_MEM_SIZE - DMA_CHCNT(uart->rx_dma_ch))
  60. #else
  61. #define update_dma_w_pos(uart){}
  62. #endif
  63. extern void protocol_recv_frame(uart_enum_t uart_no, char *data, int len);
  64. extern void protocol_old_recv_frame(uart_enum_t uart_no, uint8_t *data, int len);
  65. extern void health_add_uart_error(uint32_t c, uint32_t l, uint32_t d);
  66. // ================================================================================
  67. static uart_enum_t _uart_index(uint32_t com){
  68. return com == SHARK_UART0_com?SHARK_UART0:SHARK_UART1;
  69. }
  70. static bool shark_uart_on_rx_frame(shark_uart_t *uart)
  71. {
  72. u16 crc0 = shark_decode_u16(uart->rx_frame + uart->rx_length);
  73. u16 crc1 = shark_crc16_check(uart->rx_frame, uart->rx_length);
  74. if (crc0 != crc1) {
  75. health_add_uart_error(1, 0, 0);
  76. return false;
  77. }
  78. #if (CONFIG_BOARD_TYPE==SHARK_BOARD_SP600)
  79. //wait 250us to give the time for PS200 485 switch to rx mode
  80. task_udelay(250);
  81. #endif
  82. protocol_recv_frame(_uart_index(uart->uart_com), (char *)uart->rx_frame, uart->rx_length);
  83. return true;
  84. }
  85. static void shark_uart_rx(shark_uart_t *uart){
  86. while(1) {
  87. u8 data;
  88. uart_run_times[_uart_index(uart->uart_com)] ++;
  89. update_dma_w_pos(uart);
  90. if (circle_get_one_data(&uart->rx_queue, &data) != 1) {
  91. if (shark_get_mseconds() >= (5 + _rx_time)) {
  92. //_rx_time = 0xFFFFFFFFFFFFL;
  93. if (uart->rx_length_old_prot > 0){
  94. protocol_old_recv_frame(_uart_index(uart->uart_com), uart->rx_frame_old_prot, uart->rx_length_old_prot);
  95. uart->rx_length_old_prot = 0;
  96. }
  97. }
  98. if (shark_get_mseconds() >= (UART_TIMEOUT + _rx_time)){
  99. uart->uart_no_data = true;
  100. }else {
  101. uart->uart_no_data = false;
  102. }
  103. break;
  104. }
  105. uart_rx_bytes ++;
  106. _rx_time = shark_get_mseconds();
  107. uart->rx_frame_old_prot[uart->rx_length_old_prot ++] = data;
  108. if (uart->rx_length_old_prot == sizeof(uart->rx_frame_old_prot)){
  109. uart->rx_length_old_prot = 0;
  110. }
  111. switch(data){
  112. case CH_START:
  113. uart->rx_length = 0;
  114. uart->escape = false;
  115. uart->start = true;
  116. break;
  117. case CH_END:
  118. if (uart->rx_length > 2 && uart->rx_length != 0xFFFF){
  119. uart->rx_length -= 2; //skip crc
  120. shark_uart_on_rx_frame(uart);
  121. }else if (uart->start == true){
  122. health_add_uart_error(0, 1, 0);
  123. }
  124. uart->rx_length = 0xFFFF;
  125. uart->start = false;
  126. break;
  127. case CH_ESC:
  128. uart->escape = true;
  129. break;
  130. default:
  131. if (uart->escape) {
  132. uart->escape = false;
  133. switch (data) {
  134. case CH_ESC_START:
  135. data = CH_START;
  136. break;
  137. case CH_ESC_END:
  138. data = CH_END;
  139. break;
  140. case CH_ESC_ESC:
  141. data = CH_ESC;
  142. break;
  143. default:
  144. data = 0xFF;
  145. }
  146. }
  147. if (uart->rx_length < sizeof(uart->rx_frame)) {
  148. uart->rx_frame[uart->rx_length] = data;
  149. uart->rx_length++;
  150. } else {
  151. uart->rx_length = 0xFFFF;
  152. if (uart->start == true) {
  153. health_add_uart_error(0, 1, 0);
  154. }
  155. }
  156. }
  157. }
  158. }
  159. static void shark_uart_dma_tx(shark_uart_t *uart)
  160. {
  161. u32 value = DMA_CHCTL(uart->tx_dma_ch);
  162. if (value & DMA_CHXCTL_CHEN) {
  163. if (SET != dma_flag_get(uart->tx_dma_ch, DMA_FLAG_FTF)) {
  164. return;
  165. }
  166. byte_queue_skip(&uart->tx_queue, uart->tx_length);
  167. DMA_CHCTL(uart->tx_dma_ch) = value & (~DMA_CHXCTL_CHEN);
  168. }
  169. uart->tx_length = byte_queue_peek(&uart->tx_queue);
  170. if (uart->tx_length > 0) {
  171. DMA_CHCNT(uart->tx_dma_ch) = uart->tx_length;
  172. DMA_CHMADDR(uart->tx_dma_ch) = (u32) byte_queue_head(&uart->tx_queue);
  173. dma_flag_clear(uart->tx_dma_ch, DMA_FLAG_FTF);
  174. DMA_CHCTL(uart->tx_dma_ch) = value | DMA_CHXCTL_CHEN;
  175. }
  176. }
  177. static void shark_uart_write(shark_uart_t *uart, const u8 *buff, u16 size)
  178. {
  179. uart_tx_bytes += size;
  180. while (size > 0) {
  181. u16 length = byte_queue_write(&uart->tx_queue, buff, size);
  182. if (length == size) {
  183. shark_uart_dma_tx(uart);
  184. break;
  185. }
  186. shark_uart_dma_tx(uart);
  187. buff += length;
  188. size -= length;
  189. }
  190. }
  191. static void shark_uart_write_byte(shark_uart_t *uart, u8 value)
  192. {
  193. shark_uart_write(uart, &value, 1);
  194. }
  195. static void shark_uart_tx_dma_init(shark_uart_t *uart){
  196. dma_parameter_struct dma_init_struct;
  197. rcu_periph_clock_enable(_uart_index(uart->uart_com)== SHARK_UART0?SHARK_UART0_tx_dma_clk:SHARK_UART1_tx_dma_clk);
  198. dma_deinit(uart->tx_dma_ch);
  199. dma_init_struct.direction = DMA_MEMORY_TO_PERIPHERAL;
  200. dma_init_struct.memory_inc = DMA_MEMORY_INCREASE_ENABLE;
  201. dma_init_struct.memory_width = DMA_MEMORY_WIDTH_8BIT;
  202. dma_init_struct.periph_addr = (u32) &USART_TDATA(uart->uart_com);
  203. dma_init_struct.periph_inc = DMA_PERIPH_INCREASE_DISABLE;
  204. dma_init_struct.periph_width = DMA_PERIPHERAL_WIDTH_8BIT;
  205. dma_init_struct.priority = DMA_PRIORITY_ULTRA_HIGH;
  206. dma_init(uart->tx_dma_ch, &dma_init_struct);
  207. dma_circulation_disable(uart->tx_dma_ch);
  208. dma_memory_to_memory_disable(uart->tx_dma_ch);
  209. usart_dma_transmit_config(uart->uart_com, USART_DENT_ENABLE);
  210. #if 0
  211. if (uart->tx_dma_ch == DMA_CH1) {
  212. nvic_irq_enable(DMA_Channel1_2_IRQn ,4, 0);
  213. }else {
  214. nvic_irq_enable(DMA_Channel3_4_IRQn ,4, 0);
  215. }
  216. dma_interrupt_enable(uart->tx_dma_ch, DMA_INT_FTF);
  217. #endif
  218. }
  219. #if ENABLE_RX_DMA==1
  220. static void shark_uart_rx_dma_init(shark_uart_t *uart){
  221. dma_parameter_struct dma_init_struct;
  222. rcu_periph_clock_enable(_uart_index(uart->uart_com)== SHARK_UART0?SHARK_UART0_rx_dma_clk:SHARK_UART1_rx_dma_clk);
  223. dma_deinit(uart->rx_dma_ch);
  224. dma_init_struct.direction = DMA_PERIPHERAL_TO_MEMORY;
  225. dma_init_struct.memory_inc = DMA_MEMORY_INCREASE_ENABLE;
  226. dma_init_struct.memory_width = DMA_MEMORY_WIDTH_8BIT;
  227. dma_init_struct.memory_addr = (u32)uart->rx_queue.buffer;
  228. dma_init_struct.number = uart->rx_queue.buffer_len;
  229. dma_init_struct.periph_addr = (u32) &USART_RDATA(uart->uart_com);
  230. dma_init_struct.periph_inc = DMA_PERIPH_INCREASE_DISABLE;
  231. dma_init_struct.periph_width = DMA_PERIPHERAL_WIDTH_8BIT;
  232. dma_init_struct.priority = DMA_PRIORITY_ULTRA_HIGH;
  233. dma_init(uart->rx_dma_ch, &dma_init_struct);
  234. dma_circulation_enable(uart->rx_dma_ch);
  235. dma_memory_to_memory_disable(uart->rx_dma_ch);
  236. dma_channel_enable(uart->rx_dma_ch);
  237. usart_dma_receive_config(uart->uart_com, USART_DENR_ENABLE);
  238. }
  239. #endif
  240. static void shark_uart_pin_init(shark_uart_t *uart){
  241. if (_uart_index(uart->uart_com) == SHARK_UART0) {
  242. rcu_periph_clock_enable(SHARK_UART0_clk);
  243. rcu_periph_clock_enable(SHARK_UART0_rx_gpio_clk);
  244. rcu_periph_clock_enable(SHARK_UART0_tx_gpio_clk);
  245. gpio_af_set(SHARK_UART0_tx_port, GPIO_AF_0,SHARK_UART0_tx_pin);
  246. gpio_mode_set(SHARK_UART0_tx_port, GPIO_MODE_AF, GPIO_PUPD_PULLUP, SHARK_UART0_tx_pin);
  247. gpio_output_options_set(SHARK_UART0_tx_port, GPIO_OTYPE_PP, GPIO_OSPEED_50MHZ, SHARK_UART0_tx_pin);
  248. gpio_af_set(SHARK_UART0_rx_port, GPIO_AF_0,SHARK_UART0_rx_pin);
  249. gpio_mode_set(SHARK_UART0_rx_port, GPIO_MODE_AF, GPIO_PUPD_PULLUP, SHARK_UART0_rx_pin);
  250. gpio_output_options_set(SHARK_UART0_rx_port, GPIO_OTYPE_PP, GPIO_OSPEED_50MHZ,SHARK_UART0_rx_pin);
  251. }else {
  252. rcu_periph_clock_enable(SHARK_UART1_clk);
  253. rcu_periph_clock_enable(SHARK_UART1_rx_gpio_clk);
  254. rcu_periph_clock_enable(SHARK_UART1_tx_gpio_clk);
  255. gpio_af_set(SHARK_UART1_tx_port, GPIO_AF_1,SHARK_UART1_tx_pin);
  256. gpio_mode_set(SHARK_UART1_tx_port, GPIO_MODE_AF, GPIO_PUPD_PULLUP, SHARK_UART1_tx_pin);
  257. gpio_output_options_set(SHARK_UART1_tx_port, GPIO_OTYPE_PP, GPIO_OSPEED_50MHZ, SHARK_UART1_tx_pin);
  258. gpio_af_set(SHARK_UART1_rx_port, GPIO_AF_1,SHARK_UART1_rx_pin);
  259. gpio_mode_set(SHARK_UART1_rx_port, GPIO_MODE_AF, GPIO_PUPD_PULLUP, SHARK_UART1_rx_pin);
  260. gpio_output_options_set(SHARK_UART1_rx_port, GPIO_OTYPE_PP, GPIO_OSPEED_50MHZ,SHARK_UART1_rx_pin);
  261. }
  262. }
  263. static void shark_uart_pin_deinit(shark_uart_t *uart){
  264. if (_uart_index(uart->uart_com) == SHARK_UART0) {
  265. gpio_mode_set(SHARK_UART0_tx_port, GPIO_MODE_INPUT, GPIO_PUPD_PULLUP, SHARK_UART0_tx_pin);
  266. //gpio_bit_set(SHARK_UART0_tx_port ,SHARK_UART0_tx_pin);
  267. gpio_mode_set(SHARK_UART0_rx_port, GPIO_MODE_INPUT, GPIO_PUPD_NONE, SHARK_UART0_rx_pin);
  268. }else {
  269. gpio_mode_set(SHARK_UART1_tx_port, GPIO_MODE_INPUT, GPIO_PUPD_PULLUP, SHARK_UART1_tx_pin);
  270. //gpio_bit_set(SHARK_UART1_tx_port ,SHARK_UART1_tx_pin);
  271. gpio_mode_set(SHARK_UART1_rx_port, GPIO_MODE_INPUT, GPIO_PUPD_NONE, SHARK_UART1_rx_pin);
  272. }
  273. }
  274. static void shark_uart_device_init(shark_uart_t *uart){
  275. usart_deinit(uart->uart_com);
  276. usart_baudrate_set(uart->uart_com, SHARK_UART_BAUDRATE);
  277. usart_word_length_set(uart->uart_com, USART_WL_8BIT);
  278. usart_stop_bit_set(uart->uart_com, USART_STB_1BIT);
  279. usart_parity_config(uart->uart_com, USART_PM_NONE);
  280. usart_hardware_flow_rts_config(uart->uart_com, USART_RTS_DISABLE);
  281. usart_hardware_flow_cts_config(uart->uart_com, USART_CTS_DISABLE);
  282. usart_receive_config(uart->uart_com, USART_RECEIVE_ENABLE);
  283. usart_transmit_config(uart->uart_com, USART_TRANSMIT_ENABLE);
  284. #if ENABLE_RX_DMA==0
  285. usart_overrun_disable(uart->uart_com);//must add
  286. usart_lin_mode_disable(uart->uart_com);
  287. usart_receiver_timeout_disable(uart->uart_com);
  288. usart_reception_error_dma_disable(uart->uart_com);
  289. usart_interrupt_enable(uart->uart_com,USART_INT_RBNE);
  290. #endif
  291. }
  292. static u32 shark_uart_handler(void)
  293. {
  294. shark_uart_t *uart = _shark_uart + SHARK_UART0;
  295. if (uart->uart_com != 0) {
  296. shark_uart_rx(uart);
  297. shark_uart_dma_tx(uart);
  298. }
  299. #if UART_NUM==2
  300. uart = _shark_uart + SHARK_UART1;
  301. if (uart->uart_com != 0) {
  302. shark_uart_rx(uart);
  303. shark_uart_dma_tx(uart);
  304. }
  305. #endif
  306. return 0;
  307. }
  308. void shark_uart_log(void){
  309. shark_uart_t *uart = _shark_uart + SHARK_UART0;
  310. sys_debug("Debug: %d, %d, %d, %d\n", uart_tx_bytes, uart_rx_bytes, uart_new_prot, uart_old_prot);
  311. sys_debug("uart0: %d, %d, %d, %d, %d\n", uart_run_times[0], uart->rx_queue.r_pos, uart->rx_queue.w_pos, uart->rx_queue.buffer_len, uart_irq_times[0]);
  312. #if ENABLE_RX_DMA==1
  313. sys_debug("dma0: %d\n", DMA_CHCNT(uart->rx_dma_ch));
  314. #endif
  315. #if UART_NUM==2
  316. uart = _shark_uart + SHARK_UART1;
  317. sys_debug("uart1: %d, %d, %d, %d, %d\n", uart_run_times[1], uart->rx_queue.r_pos, uart->rx_queue.w_pos, uart->rx_queue.buffer_len, uart_irq_times[1]);
  318. #if ENABLE_RX_DMA==1
  319. sys_debug("dma1: %d\n", DMA_CHCNT(uart->rx_dma_ch));
  320. #endif
  321. #endif
  322. }
  323. void shark_uart_flush(void){
  324. shark_uart_t *uart = _shark_uart + SHARK_UART0;
  325. if (uart->uart_com != 0) {
  326. while(!byte_queue_empty(&uart->tx_queue)) {
  327. shark_uart_dma_tx(uart);
  328. }
  329. }
  330. #if UART_NUM==2
  331. uart = _shark_uart + SHARK_UART1;
  332. if (uart->uart_com != 0) {
  333. while(!byte_queue_empty(&uart->tx_queue)) {
  334. shark_uart_dma_tx(uart);
  335. }
  336. }
  337. #endif
  338. }
  339. #if 0
  340. void DMA_Channel1_2_IRQHandler(void){
  341. shark_uart_t *uart = _shark_uart + SHARK_UART0;
  342. if (dma_interrupt_flag_get(uart->tx_dma_ch, DMA_INT_FLAG_FTF) != RESET){
  343. shark_uart_dma_tx(uart);
  344. dma_interrupt_flag_clear(uart->tx_dma_ch, DMA_INT_FLAG_FTF);
  345. }
  346. }
  347. void DMA_Channel3_4_IRQHandler(void){
  348. shark_uart_t *uart = _shark_uart + SHARK_UART1;
  349. if (dma_interrupt_flag_get(uart->tx_dma_ch, DMA_INT_FLAG_FTF) != RESET){
  350. shark_uart_dma_tx(uart);
  351. dma_interrupt_flag_clear(uart->tx_dma_ch, DMA_INT_FLAG_FTF);
  352. }
  353. }
  354. #endif
  355. static u8 *tx_cache_addr(uart_enum_t uart_no){
  356. #if UART_NUM==2
  357. return (uart_no == SHARK_UART0)?shark_uart0_tx_cache:shark_uart1_tx_cache;
  358. #else
  359. return shark_uart0_tx_cache;
  360. #endif
  361. }
  362. static u8 *rx_cache_addr(uart_enum_t uart_no){
  363. #if UART_NUM==2
  364. return (uart_no == SHARK_UART0)?shark_uart0_rx_cache:shark_uart1_rx_cache;
  365. #else
  366. return shark_uart0_rx_cache;
  367. #endif
  368. }
  369. void shark_uart_deinit(uart_enum_t uart_no){
  370. shark_uart_t *uart = _shark_uart + uart_no;
  371. if (uart->uart_com != 0) {
  372. usart_disable(uart->uart_com);
  373. usart_deinit(uart->uart_com);
  374. rcu_periph_clock_disable(uart_no == SHARK_UART0?SHARK_UART0_clk:SHARK_UART1_clk);
  375. dma_channel_disable(uart->rx_dma_ch);
  376. dma_channel_disable(uart->tx_dma_ch);
  377. rcu_periph_clock_disable(uart_no == SHARK_UART0?SHARK_UART0_tx_dma_clk:SHARK_UART1_tx_dma_clk);
  378. rcu_periph_clock_disable(uart_no == SHARK_UART0?SHARK_UART0_rx_dma_clk:SHARK_UART1_rx_dma_clk);
  379. shark_uart_pin_deinit(uart);
  380. }
  381. if (uart_no == SHARK_UART0) {
  382. UART0_IR_EN(0);
  383. #if ENABLE_RX_DMA==0
  384. nvic_irq_disable(USART0_IRQn);
  385. #endif
  386. }else {
  387. UART1_IR_EN(0);
  388. #if ENABLE_RX_DMA==0
  389. nvic_irq_disable(USART1_IRQn);
  390. #endif
  391. }
  392. }
  393. bool shark_uart_timeout(void){
  394. #if UART_NUM==2
  395. return (_shark_uart[0].uart_no_data && _shark_uart[1].uart_no_data)?TRUE:FALSE;
  396. #else
  397. return (_shark_uart[0].uart_no_data)?TRUE:FALSE;
  398. #endif
  399. }
  400. void shark_uart_init(uart_enum_t uart_no)
  401. {
  402. shark_uart_t *uart = _shark_uart + uart_no;
  403. uart->escape = false;
  404. uart->rx_length = 0;
  405. uart->tx_length = 0;
  406. uart->uart_com = (uart_no == SHARK_UART0)?SHARK_UART0_com:SHARK_UART1_com;
  407. circle_buffer_init(&uart->rx_queue, rx_cache_addr(uart_no), SHARK_UART_RX_MEM_SIZE);
  408. byte_queue_init(&uart->tx_queue,tx_cache_addr(uart_no), SHARK_UART_TX_MEM_SIZE);
  409. uart->rx_dma_ch = (uart_no == SHARK_UART0)?SHARK_UART0_rx_dma_ch:SHARK_UART1_rx_dma_ch;
  410. uart->tx_dma_ch = (uart_no == SHARK_UART0)?SHARK_UART0_tx_dma_ch:SHARK_UART1_tx_dma_ch;
  411. shark_uart_pin_init(uart);
  412. shark_uart_device_init(uart);
  413. #if ENABLE_RX_DMA==1
  414. shark_uart_rx_dma_init(uart);
  415. #endif
  416. shark_uart_tx_dma_init(uart);
  417. usart_enable(uart->uart_com);
  418. if (_uart_task.handler == NULL) {
  419. _uart_task.handler = shark_uart_handler;
  420. shark_task_add(&_uart_task);
  421. }
  422. if (uart_no == SHARK_UART0) {
  423. UART0_IR_EN(1);
  424. #if ENABLE_RX_DMA==0
  425. nvic_irq_enable(USART0_IRQn, 3, 0);
  426. #endif
  427. }else {
  428. UART1_IR_EN(1);
  429. #if ENABLE_RX_DMA==0
  430. nvic_irq_enable(USART1_IRQn, 3, 0);
  431. #endif
  432. }
  433. _rx_time = shark_get_mseconds();
  434. uart->uart_no_data = false;
  435. }
  436. #if ENABLE_RX_DMA==0
  437. void USART0_IRQHandler(void){
  438. if(usart_flag_get(USART0, USART_FLAG_RBNE) == SET){
  439. shark_uart_t *uart = _shark_uart + SHARK_UART0;
  440. uart_irq_times[0] ++;
  441. u8 c = usart_data_receive(USART0);
  442. circle_put_one_data(&uart->rx_queue, c);
  443. }
  444. }
  445. void USART1_IRQHandler(void){
  446. if(usart_flag_get(USART1, USART_FLAG_RBNE) == SET){
  447. shark_uart_t *uart = _shark_uart + SHARK_UART1;
  448. uart_irq_times[1] ++;
  449. u8 c = usart_data_receive(USART1);
  450. circle_put_one_data(&uart->rx_queue, c);
  451. }
  452. }
  453. #endif
  454. static void shark_uart_write_byte_esc(shark_uart_t *uart, u8 value)
  455. {
  456. switch (value) {
  457. case CH_START:
  458. shark_uart_write_byte(uart, CH_ESC);
  459. value = CH_ESC_START;
  460. break;
  461. case CH_END:
  462. shark_uart_write_byte(uart, CH_ESC);
  463. value = CH_ESC_END;
  464. break;
  465. case CH_ESC:
  466. shark_uart_write_byte(uart, CH_ESC);
  467. value = CH_ESC_ESC;
  468. break;
  469. }
  470. shark_uart_write_byte(uart, value);
  471. }
  472. static void shark_uart_write_esc(shark_uart_t *uart, const u8 *buff, u16 length)
  473. {
  474. const u8 *buff_end;
  475. for (buff_end = buff + length; buff < buff_end; buff++) {
  476. shark_uart_write_byte_esc(uart, *buff);
  477. }
  478. }
  479. static void shark_uart_tx_start(shark_uart_t *uart)
  480. {
  481. shark_uart_write_byte(uart, CH_START);
  482. uart->tx_crc16 = 0;
  483. }
  484. static void shark_uart_tx_continue(shark_uart_t *uart, const void *buff, u16 length)
  485. {
  486. shark_uart_write_esc(uart, (const u8 *) buff, length);
  487. uart->tx_crc16 = shark_crc16_update(uart->tx_crc16, (const u8 *) buff, length);
  488. }
  489. static void shark_uart_tx_end(shark_uart_t *uart)
  490. {
  491. shark_uart_write_esc(uart, (u8 *)&uart->tx_crc16, sizeof(uart->tx_crc16));
  492. shark_uart_write_byte(uart, CH_END);
  493. }
  494. void shark_uart_write_frame(uart_enum_t uart_no, uint8_t *bytes, int len){
  495. shark_uart_t *uart = _shark_uart + uart_no;
  496. shark_uart_tx_start(uart);
  497. shark_uart_tx_continue(uart, bytes, len);
  498. shark_uart_tx_end(uart);
  499. }
  500. void shark_uart_frame_start(uart_enum_t uart_no, uint8_t *bytes, int len){
  501. shark_uart_t *uart = _shark_uart + uart_no;
  502. shark_uart_tx_start(uart);
  503. shark_uart_tx_continue(uart, bytes, len);
  504. }
  505. void shark_uart_frame_continue(uart_enum_t uart_no, uint8_t *bytes, int len){
  506. shark_uart_t *uart = _shark_uart + uart_no;
  507. shark_uart_tx_continue(uart, bytes, len);
  508. }
  509. void shark_uart_frame_end(uart_enum_t uart_no){
  510. shark_uart_tx_end(_shark_uart + uart_no);
  511. }
  512. void shark_uart_write_bytes(uart_enum_t uart_no, u8 *buff, u16 size){
  513. shark_uart_write(_shark_uart + uart_no, buff, size);
  514. }