core_debug.c 16 KB

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