core_debug.c 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766
  1. /*
  2. * Copyright (c) 2022 OpenLuat & AirM2M
  3. *
  4. * Permission is hereby granted, free of charge, to any person obtaining a copy of
  5. * this software and associated documentation files (the "Software"), to deal in
  6. * the Software without restriction, including without limitation the rights to
  7. * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
  8. * the Software, and to permit persons to whom the Software is furnished to do so,
  9. * subject to the following conditions:
  10. *
  11. * The above copyright notice and this permission notice shall be included in all
  12. * copies or substantial portions of the Software.
  13. *
  14. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  15. * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
  16. * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
  17. * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
  18. * IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  19. * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  20. */
  21. #include "user.h"
  22. #define JTT_PACK_FLAG (0x7e)
  23. #define JTT_PACK_CODE (0x7d)
  24. #define JTT_PACK_CODE_F1 (0x02)
  25. #define JTT_PACK_CODE_F2 (0x01)
  26. #ifdef __BUILD_APP__
  27. #define DBG_BUF_SIZE (2048)
  28. #define DBG_TXBUF_SIZE DBG_BUF_SIZE
  29. #define DBG_RXBUF_SIZE (0)
  30. #define DBG_RXBUF_BAND (1)
  31. #else
  32. #define DBG_BUF_SIZE (4090)
  33. #define DBG_TXBUF_SIZE DBG_BUF_SIZE
  34. #define DBG_RXBUF_SIZE DBG_BUF_SIZE
  35. #define DBG_RXBUF_BAND (3)
  36. #endif
  37. typedef struct
  38. {
  39. Buffer_Struct LogBuffer;
  40. Buffer_Struct RxBuffer;
  41. CBFuncEx_t Fun;
  42. CBDataFun_t TxFun;
  43. //Loop_Buffer IrqBuffer;
  44. uint8_t Data[DBG_BUF_SIZE];
  45. #ifdef __RUN_IN_RAM__
  46. uint8_t CacheData[__FLASH_BLOCK_SIZE__];
  47. #else
  48. uint8_t CacheData[DBG_BUF_SIZE * 2];
  49. #endif
  50. #ifdef __RUN_IN_RAM__
  51. uint8_t RxData[__FLASH_BLOCK_SIZE__];
  52. #else
  53. uint8_t RxData[DBG_BUF_SIZE * 2];
  54. #endif
  55. uint8_t TxBuf[DBG_TXBUF_SIZE];
  56. uint8_t RxDMABuf[DBG_RXBUF_BAND][DBG_RXBUF_SIZE + 16];
  57. uint8_t AppMode;
  58. uint8_t InitDone;
  59. uint8_t InsertBusy;
  60. uint8_t TxBusy;
  61. uint8_t RxDMASn;
  62. }DBG_CtrlStruct;
  63. static DBG_CtrlStruct prvDBGCtrl;
  64. static void prvDBG_Out(void)
  65. {
  66. uint32_t TxLen;
  67. SEND_AGAIN:
  68. if (prvDBGCtrl.LogBuffer.Pos)
  69. {
  70. prvDBGCtrl.TxBusy = 1;
  71. TxLen = (prvDBGCtrl.LogBuffer.Pos > sizeof(prvDBGCtrl.TxBuf))?sizeof(prvDBGCtrl.TxBuf):prvDBGCtrl.LogBuffer.Pos;
  72. memcpy(prvDBGCtrl.TxBuf, prvDBGCtrl.LogBuffer.Data, TxLen);
  73. OS_BufferRemove(&prvDBGCtrl.LogBuffer, TxLen);
  74. Uart_DMATx(DBG_UART_ID, DBG_UART_TX_DMA_STREAM, prvDBGCtrl.TxBuf, TxLen);
  75. // if (!Uart_BufferTx(DBG_UART_ID, prvDBGCtrl.TxBuf, TxLen))
  76. // {
  77. // prvDBGCtrl.TxBusy = 0;
  78. // goto SEND_AGAIN;
  79. // }
  80. }
  81. else
  82. {
  83. if (prvDBGCtrl.LogBuffer.MaxLen > (DBG_BUF_SIZE * 8))
  84. {
  85. OS_ReInitBuffer(&prvDBGCtrl.LogBuffer, (DBG_BUF_SIZE * 4));
  86. }
  87. }
  88. }
  89. static void add_trace_data(uint8_t *data, uint32_t len)
  90. {
  91. Buffer_StaticWrite(&prvDBGCtrl.LogBuffer, data, len);
  92. }
  93. void add_printf_data(uint8_t *data, uint32_t len)
  94. {
  95. #ifdef __BUILD_APP__
  96. uint32_t Critical = OS_EnterCritical();
  97. ASSERT(prvDBGCtrl.InsertBusy == 0);
  98. prvDBGCtrl.InsertBusy = 1;
  99. if ((prvDBGCtrl.LogBuffer.Pos + len) > prvDBGCtrl.LogBuffer.MaxLen)
  100. {
  101. OS_ReSizeBuffer(&prvDBGCtrl.LogBuffer, prvDBGCtrl.LogBuffer.MaxLen * 2);
  102. }
  103. OS_BufferWrite(&prvDBGCtrl.LogBuffer, data, len);
  104. prvDBGCtrl.InsertBusy = 0;
  105. if (prvDBGCtrl.TxBusy || !prvDBGCtrl.InitDone || !prvDBGCtrl.AppMode)
  106. {
  107. OS_ExitCritical(Critical);
  108. return;
  109. }
  110. prvDBG_Out();
  111. OS_ExitCritical(Critical);
  112. #endif
  113. }
  114. extern const uint8_t ByteToAsciiTable[16];
  115. void DBG_Trace(const char* format, ...)
  116. {
  117. #ifndef __RAMRUN__
  118. char c;
  119. char *s = 0;
  120. int d = 0, i = 0, p = 0;
  121. uint32_t slen;
  122. unsigned int ud = 0;
  123. unsigned char ch[36] = {0};
  124. unsigned char int_max;
  125. unsigned char flag;
  126. va_list ap;
  127. #ifdef __BUILD_APP__
  128. __disable_irq();
  129. if (prvDBGCtrl.AppMode)
  130. {
  131. prvDBGCtrl.AppMode = 0;
  132. //关闭掉APP的DMA UART输出
  133. //
  134. DMA_StopStream(DBG_UART_TX_DMA_STREAM);
  135. Buffer_StaticInit(&prvDBGCtrl.LogBuffer, prvDBGCtrl.Data, sizeof(prvDBGCtrl.Data));
  136. }
  137. #endif
  138. va_start(ap, format);
  139. while (* format)
  140. {
  141. if (* format != '%')
  142. {
  143. add_trace_data((uint8_t *)format, 1);
  144. format += 1;
  145. continue;
  146. }
  147. slen = 0;
  148. repeat:
  149. switch (*(++format))
  150. {
  151. case '*':
  152. slen = va_arg(ap, int);
  153. goto repeat;
  154. break;
  155. case 's':
  156. case 'S':
  157. s = va_arg(ap, char *);
  158. if (!slen)
  159. {
  160. for ( ; *s; s++)
  161. {
  162. add_trace_data((uint8_t *) s, 1);
  163. }
  164. }
  165. else
  166. {
  167. add_trace_data((uint8_t *) s, slen);
  168. }
  169. break;
  170. case 'c':
  171. case 'C':
  172. c = va_arg(ap, int);
  173. add_trace_data((uint8_t *)&c, 1);
  174. break;
  175. case 'x':
  176. case 'X':
  177. ud = va_arg(ap, int);
  178. p = 8;
  179. for(i = 0; i < p; i++)
  180. {
  181. ch[i] = ByteToAsciiTable[(unsigned char)(ud&0x0f)];
  182. ud >>= 4;
  183. }
  184. for(i = p; i > 0; i--)
  185. {
  186. add_trace_data(&ch[i -1], 1);
  187. }
  188. break;
  189. case 'u':
  190. case 'U':
  191. ud = va_arg(ap, unsigned int);
  192. int_max = 0;
  193. for(i = 0; i < 16; i++)
  194. {
  195. ch[i] = ud%10 + '0';
  196. ud = ud/10;
  197. int_max++;
  198. if (!ud)
  199. break;
  200. }
  201. for(i = int_max; i > 0; i--)
  202. {
  203. add_trace_data(&ch[i -1], 1);
  204. }
  205. break;
  206. case 'd':
  207. case 'D':
  208. d = va_arg(ap, int);
  209. if (d < 0) {
  210. flag = 1;
  211. } else {
  212. flag = 0;
  213. }
  214. d = abs(d);
  215. int_max = 0;
  216. for(i = 0; i < 16; i++)
  217. {
  218. ch[i] = d%10 + '0';
  219. d = d/10;
  220. int_max++;
  221. if (!d)
  222. break;
  223. }
  224. if (flag)
  225. {
  226. flag = '-';
  227. add_trace_data(&flag, 1);
  228. }
  229. for(i = int_max; i > 0; i--)
  230. {
  231. add_trace_data(&ch[i -1], 1);
  232. }
  233. break;
  234. case 'b':
  235. case 'B':
  236. ud = va_arg(ap, int);
  237. if (ud > 0xffff)
  238. {
  239. p = 32;
  240. }
  241. else if (ud > 0xff)
  242. {
  243. p = 16;
  244. }
  245. else
  246. {
  247. p = 8;
  248. }
  249. for(i = 0; i < p; i++)
  250. {
  251. ch[i] = ByteToAsciiTable[(unsigned char)(ud&0x01)];
  252. ud >>= 1;
  253. }
  254. for(i = p; i > 0; i--)
  255. {
  256. add_trace_data(&ch[i -1], 1);
  257. }
  258. break;
  259. default:
  260. //add_trace_data((uint8_t *)format, 1);
  261. goto repeat;
  262. break;
  263. }
  264. format++;
  265. }
  266. va_end(ap);
  267. add_trace_data("\r\n", 2);
  268. // va_list ap;
  269. // va_start(ap, format);
  270. // prvDBGCtrl.TxPos = vsnprintf(prvDBGCtrl.TxBuf, sizeof(prvDBGCtrl.TxBuf) - 2, format, ap);
  271. // va_end(ap);
  272. // prvDBGCtrl.TxBuf[prvDBGCtrl.TxPos] = '\r';
  273. // prvDBGCtrl.TxBuf[prvDBGCtrl.TxPos + 1] = '\n';
  274. Uart_BlockTx(DBG_UART_ID, prvDBGCtrl.LogBuffer.Data, prvDBGCtrl.LogBuffer.Pos);
  275. prvDBGCtrl.LogBuffer.Pos = 0;
  276. #ifdef __BUILD_APP__
  277. __enable_irq();
  278. #endif
  279. #endif
  280. }
  281. void DBG_BlHexPrintf(void *Data, unsigned int len)
  282. {
  283. uint8_t *data = (uint8_t *)Data;
  284. int8_t uart_buf[128];
  285. uint32_t i,j;
  286. j = 0;
  287. if (!len)
  288. {
  289. return ;
  290. }
  291. for (i = 0; i < len; i++)
  292. {
  293. uart_buf[j++] = ByteToAsciiTable[(data[i] & 0xf0) >> 4];
  294. uart_buf[j++] = ByteToAsciiTable[data[i] & 0x0f];
  295. uart_buf[j++] = ' ';
  296. }
  297. uart_buf[j++] = '\r';
  298. uart_buf[j++] = '\n';
  299. add_trace_data(uart_buf, j);
  300. Uart_BlockTx(DBG_UART_ID, prvDBGCtrl.LogBuffer.Data, prvDBGCtrl.LogBuffer.Pos);
  301. prvDBGCtrl.LogBuffer.Pos = 0;
  302. }
  303. #ifdef __BUILD_OS__
  304. void DBG_HexPrintf(void *Data, unsigned int len)
  305. {
  306. uint8_t *data = (uint8_t *)Data;
  307. int8_t *uart_buf;
  308. uint32_t i,j;
  309. j = 0;
  310. if (!prvDBGCtrl.AppMode) return;
  311. if (!len)
  312. {
  313. return ;
  314. }
  315. uart_buf = OS_Zalloc(len * 3 + 2);
  316. if (!uart_buf)
  317. {
  318. return;
  319. }
  320. for (i = 0; i < len; i++)
  321. {
  322. uart_buf[j++] = ByteToAsciiTable[(data[i] & 0xf0) >> 4];
  323. uart_buf[j++] = ByteToAsciiTable[data[i] & 0x0f];
  324. uart_buf[j++] = ' ';
  325. }
  326. uart_buf[j++] = '\r';
  327. uart_buf[j++] = '\n';
  328. prvDBGCtrl.TxFun(uart_buf, len * 3 + 2);
  329. OS_Free(uart_buf);
  330. }
  331. void DBG_Printf(const char* format, ...)
  332. {
  333. char *buf = NULL;
  334. char isr_buf[256];
  335. int len;
  336. va_list ap;
  337. if (!prvDBGCtrl.AppMode) return;
  338. va_start(ap, format);
  339. if (OS_CheckInIrq())
  340. {
  341. buf = isr_buf;
  342. len = vsnprintf_(buf, 255, format, ap);
  343. }
  344. else
  345. {
  346. buf = OS_Zalloc(1024);
  347. len = vsnprintf_(buf, 1023, format, ap);
  348. }
  349. va_end(ap);
  350. #ifndef __DEBUG__
  351. prvDBGCtrl.TxFun( buf, len);
  352. #else
  353. add_printf_data(buf, len);
  354. #endif
  355. if (!OS_CheckInIrq())
  356. {
  357. OS_Free(buf);
  358. }
  359. }
  360. void DBG_DirectOut(void *Data, uint32_t Len)
  361. {
  362. add_printf_data(Data, Len);
  363. }
  364. void DBG_Send(void)
  365. {
  366. uint32_t Critical;
  367. uint32_t TxLen;
  368. if (prvDBGCtrl.TxBusy || !prvDBGCtrl.InitDone || !prvDBGCtrl.AppMode)
  369. {
  370. return;
  371. }
  372. Critical = OS_EnterCritical();
  373. prvDBG_Out();
  374. OS_ExitCritical(Critical);
  375. }
  376. int _write(int file, char *ptr, int len)
  377. {
  378. add_printf_data(ptr, len);
  379. return len;
  380. }
  381. #endif
  382. int32_t DBG_UartIrqCB(void *pData, void *pParam)
  383. {
  384. uint32_t Length;
  385. uint32_t State = (uint32_t)pParam;
  386. uint8_t LastRxSn;
  387. switch (State)
  388. {
  389. case UART_CB_TX_BUFFER_DONE:
  390. case UART_CB_TX_ALL_DONE:
  391. #ifdef __BUILD_APP__
  392. case DMA_CB_DONE:
  393. {
  394. DMA_ClearStreamFlag(DBG_UART_TX_DMA_STREAM);
  395. prvDBGCtrl.TxBusy = 0;
  396. if (!prvDBGCtrl.InsertBusy)
  397. {
  398. DBG_Send();
  399. }
  400. }
  401. #endif
  402. break;
  403. case UART_CB_RX_BUFFER_FULL:
  404. case UART_CB_RX_TIMEOUT:
  405. #ifdef __BUILD_APP__
  406. Uart_RxBufferCB(DBG_UART_ID, prvDBGCtrl.Fun);
  407. break;
  408. #endif
  409. case UART_CB_RX_NEW:
  410. #ifndef __BUILD_APP__
  411. case DMA_CB_DONE:
  412. DMA_StopStream(DBG_UART_RX_DMA_STREAM);
  413. Length = DMA_GetDataLength(DBG_UART_RX_DMA_STREAM, &prvDBGCtrl.RxDMABuf[prvDBGCtrl.RxDMASn][0]);
  414. Length += Uart_FifoRead(DBG_UART_ID, &prvDBGCtrl.RxDMABuf[prvDBGCtrl.RxDMASn][Length]);
  415. LastRxSn = prvDBGCtrl.RxDMASn;
  416. prvDBGCtrl.RxDMASn = (prvDBGCtrl.RxDMASn + 1)%DBG_RXBUF_BAND;
  417. Uart_DMARx(DBG_UART_ID, DBG_UART_RX_DMA_STREAM, &prvDBGCtrl.RxDMABuf[prvDBGCtrl.RxDMASn][0], DBG_RXBUF_SIZE);
  418. if (Length)
  419. {
  420. prvDBGCtrl.Fun(&prvDBGCtrl.RxDMABuf[LastRxSn][0], Length);
  421. }
  422. #else
  423. // Length = Uart_FifoRead(DBG_UART_ID, &prvDBGCtrl.RxDMABuf[prvDBGCtrl.RxDMASn][0]);
  424. // LastRxSn = prvDBGCtrl.RxDMASn;
  425. // prvDBGCtrl.RxDMASn = (prvDBGCtrl.RxDMASn + 1)%DBG_RXBUF_BAND;
  426. #endif
  427. break;
  428. case UART_CB_ERROR:
  429. // DBG("%x", pParam);
  430. break;
  431. }
  432. }
  433. void DBG_Response(uint8_t Cmd, uint8_t Result, uint8_t *Data, uint8_t Len)
  434. {
  435. uint8_t Temp[260];
  436. uint16_t TxLen, Check;
  437. Temp[0] = Cmd;
  438. Temp[1] = Result;
  439. Temp[2] = Len;
  440. memcpy(Temp + 3, Data, Len);
  441. Check = CRC16Cal(Temp, Len + 3, CRC16_CCITT_SEED, CRC16_CCITT_GEN, 0);
  442. BytesPutLe16(&Temp[Len + 3], Check);
  443. TxLen = TransferPack(JTT_PACK_FLAG, JTT_PACK_CODE, JTT_PACK_CODE_F1, JTT_PACK_CODE_F2, Temp, Len + 5, prvDBGCtrl.TxBuf);
  444. Uart_BufferTx(DBG_UART_ID, prvDBGCtrl.TxBuf, TxLen);
  445. }
  446. static int32_t DBG_RebootTimeoutCB(void *pData, void *pParam)
  447. {
  448. NVIC_SystemReset();
  449. }
  450. static void DBG_Reboot(uint8_t *Data, uint32_t Len)
  451. {
  452. #ifdef __BUILD_APP__
  453. timer_t *Timer = Timer_Create(DBG_RebootTimeoutCB, NULL, NULL);
  454. Timer_StartMS(Timer, 100, 1);
  455. Uart_DeInit(DBG_UART_ID);
  456. prvDBGCtrl.AppMode = 0;
  457. #else
  458. NVIC_SystemReset();
  459. #endif
  460. }
  461. static void DBG_FlashDownloadStart(uint8_t *Data, uint32_t Len)
  462. {
  463. #ifdef __BUILD_APP__
  464. #else
  465. if (Len < 12)
  466. {
  467. DBG_Response(DBG_CMD_FLASHDOWNLOADSTART, ERROR_PARAM_INVALID, &Len, 4);
  468. return;
  469. }
  470. uint32_t StartAddress = BytesGetLe32(Data);
  471. uint32_t TotalLen = BytesGetLe32(Data + 4);
  472. uint32_t CRC32 = BytesGetLe32(Data + 8);
  473. if (BL_StartNewDownload(StartAddress, TotalLen, CRC32))
  474. {
  475. DBG_Response(DBG_CMD_FLASHDOWNLOADSTART, ERROR_PERMISSION_DENIED, &Len, 4);
  476. return;
  477. }
  478. else
  479. {
  480. DBG_Response(DBG_CMD_FLASHDOWNLOADSTART, ERROR_NONE, &Len, 4);
  481. return;
  482. }
  483. #endif
  484. }
  485. static void DBG_FlashDownload(uint8_t *Data, uint32_t Len)
  486. {
  487. #ifdef __BUILD_APP__
  488. #else
  489. if (Len < 7)
  490. {
  491. DBG_Response(DBG_CMD_FLASHDOWNLOAD, ERROR_PARAM_INVALID, &Len, 4);
  492. return;
  493. }
  494. uint32_t PacketSn = BytesGetLe32(Data);
  495. uint32_t NextPacketSn;
  496. int Result;
  497. uint16_t PacketLen = BytesGetLe32(Data + 4);
  498. if ( (PacketLen + 6) != Len )
  499. {
  500. DBG_Response(DBG_CMD_FLASHDOWNLOAD, ERROR_PARAM_INVALID, &Len, 4);
  501. return;
  502. }
  503. else
  504. {
  505. Result = BL_DownloadAddData(PacketSn, Data + 6, PacketLen, &NextPacketSn);
  506. if (Result >= 0)
  507. {
  508. DBG_Response(DBG_CMD_FLASHDOWNLOAD, ERROR_NONE, &Result, 4);
  509. }
  510. else
  511. {
  512. DBG_Response(DBG_CMD_FLASHDOWNLOAD, ERROR_PARAM_OVERFLOW, &NextPacketSn, 4);
  513. }
  514. return;
  515. }
  516. #endif
  517. }
  518. static void DBG_FlashDownloadEnd(uint8_t *Data, uint32_t Len)
  519. {
  520. #ifdef __BUILD_APP__
  521. #else
  522. uint8_t Result = BL_DownloadEnd();
  523. DBG_Response(DBG_CMD_FLASHDOWNLOADEND, Result, &Result, 1);
  524. #endif
  525. }
  526. static void DBG_RunApp(uint8_t *Data, uint32_t Len)
  527. {
  528. #ifdef __BUILD_APP__
  529. #else
  530. uint32_t Result = BL_RunAPP();
  531. DBG_Response(DBG_CMD_RUNAPP, Result, &Result, 4);
  532. #endif
  533. }
  534. static void DBG_FlashZipBlockEnd(uint8_t *Data, uint32_t Len)
  535. {
  536. #ifdef __BUILD_APP__
  537. #else
  538. uint8_t Result = BL_RunLzmaBlock(Data + 1, Data[0]);
  539. DBG_Response(DBG_CMD_FLASHLZMABLOCKEND, Result, &Result, 1);
  540. #endif
  541. }
  542. static const CBDataFun_t DBG_ProtoclFunlist[] =
  543. {
  544. DBG_Reboot,
  545. DBG_FlashDownloadStart,
  546. DBG_FlashDownload,
  547. DBG_FlashDownloadEnd,
  548. DBG_RunApp,
  549. DBG_FlashZipBlockEnd,
  550. };
  551. static int32_t DBG_DummyRx(void *pData, void *pParam)
  552. {
  553. uint32_t DelLen;
  554. uint32_t i, DealLen;
  555. uint16_t Check, Check2;
  556. //Buffer_Struct Buffer;
  557. uint8_t FindHead = 0;
  558. uint8_t FindEnd = 0;
  559. uint8_t NoMoreData = 0;
  560. int32_t Result;
  561. Buffer_Struct *RxBuf = &prvDBGCtrl.RxBuffer;
  562. DBG("%u", pParam);
  563. if (pParam)
  564. {
  565. #ifdef __BUILD_APP__
  566. OS_BufferWrite(&prvDBGCtrl.RxBuffer, (uint8_t *)pData, (uint32_t)pParam);
  567. #else
  568. Buffer_StaticWrite(&prvDBGCtrl.RxBuffer, (uint8_t *)pData, (uint32_t)pParam);
  569. #endif
  570. while(!NoMoreData)
  571. {
  572. if (!RxBuf->Pos)
  573. {
  574. // DBG("no more net rx data");
  575. break;
  576. }
  577. if (!FindHead)
  578. {
  579. for(i = 0; i < RxBuf->Pos; i++)
  580. {
  581. if (JTT_PACK_FLAG == RxBuf->Data[i])
  582. {
  583. OS_BufferRemove(RxBuf, i);
  584. FindHead = 1;
  585. break;
  586. }
  587. }
  588. if (!FindHead)
  589. {
  590. NoMoreData = 1;
  591. RxBuf->Pos = 0;
  592. continue;
  593. }
  594. }
  595. FindEnd = 0;
  596. DealLen = 0;
  597. DelLen = 0;
  598. for(i = 1; i < RxBuf->Pos; i++)
  599. {
  600. if (JTT_PACK_FLAG == RxBuf->Data[i])
  601. {
  602. DelLen = i + 1;
  603. // DBG("msg rec len %dbyte", DelLen);
  604. DealLen = i + 1;
  605. FindEnd = 1;
  606. break;
  607. }
  608. }
  609. if (!FindEnd)
  610. {
  611. // DBG("rest %dbyte", RxBuf->Pos);
  612. NoMoreData = 1;
  613. continue;
  614. }
  615. if (2 == DealLen) //连续2个0x7E,去除第一个,第二个作为头开始重新搜索
  616. {
  617. // DBG("!");
  618. OS_BufferRemove(RxBuf, 1);
  619. FindHead = 1;
  620. continue;
  621. }
  622. if (FindEnd)
  623. {
  624. FindHead = 0;
  625. #ifdef __RUN_IN_RAM__
  626. if (DelLen >= sizeof(prvDBGCtrl.CacheData))
  627. #else
  628. if (DelLen > DBG_BUF_SIZE)
  629. #endif
  630. {
  631. DBG("msg too long, %u", DelLen);
  632. OS_BufferRemove(RxBuf, DelLen);
  633. continue;
  634. }
  635. DealLen = TransferUnpack(JTT_PACK_FLAG, JTT_PACK_CODE, JTT_PACK_CODE_F1, JTT_PACK_CODE_F2,
  636. &RxBuf->Data[1], DealLen - 2, prvDBGCtrl.RxData);
  637. OS_BufferRemove(RxBuf, DelLen);
  638. if (DealLen >= 5)
  639. {
  640. Check = CRC16Cal(prvDBGCtrl.RxData, DealLen - 2, CRC16_CCITT_SEED, CRC16_CCITT_GEN, 0);
  641. Check2 = BytesGetLe16(&prvDBGCtrl.RxData[DealLen - 2]);
  642. if (Check != Check2)
  643. {
  644. // DBG_BlHexPrintf(Data, Len);
  645. DBG("check error %04x %04x", Check, Check2);
  646. DBG_Response(prvDBGCtrl.RxData[0], ERROR_PROTOCL, &Result, 4);
  647. RxBuf->Pos = 0;
  648. return 0;
  649. }
  650. else
  651. {
  652. DealLen -= 2;
  653. if (prvDBGCtrl.RxData[0] < sizeof(DBG_ProtoclFunlist)/sizeof(CBDataFun_t))
  654. {
  655. DBG_ProtoclFunlist[prvDBGCtrl.RxData[0]](prvDBGCtrl.RxData + 1, DealLen - 1);
  656. }
  657. }
  658. }
  659. else
  660. {
  661. DBG("%d", DealLen);
  662. }
  663. }
  664. }
  665. }
  666. return 0;
  667. }
  668. void DBG_Init(uint8_t AppMode)
  669. {
  670. prvDBGCtrl.AppMode = AppMode;
  671. GPIO_Iomux(DBG_UART_TX_PIN, DBG_UART_TX_AF);
  672. GPIO_Iomux(DBG_UART_RX_PIN, DBG_UART_RX_AF);
  673. #ifdef __BUILD_APP__
  674. if (AppMode)
  675. {
  676. OS_InitBuffer(&prvDBGCtrl.LogBuffer, DBG_BUF_SIZE * 4);
  677. OS_InitBuffer(&prvDBGCtrl.RxBuffer, DBG_BUF_SIZE);
  678. //Buffer_StaticInit(&prvDBGCtrl.LogBuffer, prvDBGCtrl.Data, sizeof(prvDBGCtrl.Data));
  679. Uart_BaseInit(DBG_UART_ID, DBG_UART_BR, 1, UART_DATA_BIT8, UART_PARITY_NONE, UART_STOP_BIT1, DBG_UartIrqCB);
  680. Uart_EnableRxIrq(DBG_UART_ID);
  681. DMA_TakeStream(DBG_UART_TX_DMA_STREAM);
  682. Uart_DMATxInit(DBG_UART_ID, DBG_UART_TX_DMA_STREAM, DBG_UART_TX_DMA_CHANNEL);
  683. prvDBGCtrl.TxFun = add_printf_data;
  684. }
  685. else
  686. #endif
  687. {
  688. Buffer_StaticInit(&prvDBGCtrl.LogBuffer, prvDBGCtrl.Data, sizeof(prvDBGCtrl.Data));
  689. Buffer_StaticInit(&prvDBGCtrl.RxBuffer, prvDBGCtrl.CacheData, sizeof(prvDBGCtrl.CacheData));
  690. Uart_BaseInit(DBG_UART_ID, BL_UART_BR, 0, UART_DATA_BIT8, UART_PARITY_NONE, UART_STOP_BIT1, DBG_UartIrqCB);
  691. DMA_TakeStream(DBG_UART_RX_DMA_STREAM);
  692. Uart_DMARxInit(DBG_UART_ID, DBG_UART_RX_DMA_STREAM, DBG_UART_RX_DMA_CHANNEL);
  693. Uart_DMARx(DBG_UART_ID, DBG_UART_RX_DMA_STREAM, &prvDBGCtrl.RxDMABuf[prvDBGCtrl.RxDMASn][0], DBG_RXBUF_SIZE);
  694. }
  695. prvDBGCtrl.InitDone = 1;
  696. prvDBGCtrl.Fun = DBG_DummyRx;
  697. PM_SetDriverRunFlag(PM_DRV_DBG, 1);
  698. }
  699. void DBG_SetRxCB(CBFuncEx_t cb)
  700. {
  701. prvDBGCtrl.Fun = cb;
  702. }
  703. void DBG_SetTxCB(CBDataFun_t cb)
  704. {
  705. prvDBGCtrl.TxFun = cb;
  706. }