drv_bluetooth.c 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885
  1. /*
  2. * Copyright (c) 2006-2021, RT-Thread Development Team
  3. *
  4. * SPDX-License-Identifier: Apache-2.0
  5. *
  6. * Change Logs:
  7. * Date Author Notes
  8. * 2020-11-29 bigmagic first version
  9. */
  10. #include <rthw.h>
  11. #include <rtthread.h>
  12. #include "drv_bluetooth.h"
  13. #include "drv_uart.h"
  14. #include "raspi4.h"
  15. //https://github.com/RPi-Distro/bluez-firmware/tree/master/broadcom
  16. //arm-none-eabi-objcopy.exe -I binary -O elf32-littlearm -B arm driver\BCM4345C0.hcd driver\BCM4345C0.a
  17. #define BT_UART_NAME "uart0"
  18. #define BT_TX_MAX (256)
  19. #define BT_RX_MAX (256)
  20. #define BT_HEAD_NUM (4)
  21. #define BT_TRY_NUM_MAX (3)
  22. #define BT_SEND_MIN_PACK (8)
  23. unsigned char lo(unsigned int val) { return (unsigned char)(val & 0xff); }
  24. unsigned char hi(unsigned int val) { return (unsigned char)((val & 0xff00) >> 8); }
  25. #define BT_THREAD_STACK_SIZE (2048)
  26. #define BT_THREAD_PRIORITY (15)
  27. #define BT_THREAD_TICK (10)
  28. enum
  29. {
  30. LE_EVENT_CODE = 0x3e,
  31. LE_CONNECT_CODE = 0x01,
  32. LE_ADREPORT_CODE = 0x02,
  33. HCI_ACL_PKT = 0x02,
  34. HCI_EVENT_PKT = 0x04
  35. };
  36. static char ch;
  37. static rt_sem_t bt_rx_sem = RT_NULL;
  38. static rt_device_t bt_device;
  39. static rt_uint8_t tx_buff[BT_TX_MAX];
  40. static rt_uint8_t rx_buff[BT_RX_MAX];
  41. static rt_err_t bt_rx_ind(rt_device_t dev, rt_size_t size)
  42. {
  43. rt_sem_release(bt_rx_sem);
  44. return RT_EOK;
  45. }
  46. int bt_uart_send_data(rt_device_t dev, rt_uint32_t *buf, int len)
  47. {
  48. return rt_device_write(dev, 0, buf, len);
  49. }
  50. void bt_uart_receive_flush(rt_device_t dev)
  51. {
  52. rt_device_read(dev, RT_NULL, rx_buff, BT_RX_MAX);
  53. }
  54. int bt_uart_receive_data(rt_device_t dev, rt_uint8_t *buf, rt_uint32_t *len, rt_int32_t time)
  55. {
  56. rt_uint16_t ii = 0;
  57. ii = rt_device_read(dev, 0, buf, BT_RX_MAX);
  58. *len = ii;
  59. return ii;
  60. }
  61. void bt_data_pack(rt_uint8_t *tx_buff, rt_uint8_t ogf, rt_uint8_t ocf, rt_uint32_t data_len)
  62. {
  63. tx_buff[0] = BT_HCI_COMMAND_PKT;
  64. tx_buff[1] = ogf; //hi(ogf << 10 | ocf);//opcode hi
  65. tx_buff[2] = ocf; //lo(ogf << 10 | ocf);//opcode lo
  66. tx_buff[3] = data_len;
  67. }
  68. rt_uint32_t bt_reply_check(const rt_uint8_t *buff, rt_uint16_t ogf, rt_uint16_t ocf, int pack_len)
  69. {
  70. //step 1
  71. if (buff[0] != BT_HCI_EVENT_PKT)
  72. {
  73. return 1;
  74. }
  75. //step2
  76. if (buff[1] == BT_CONNECT_COMPLETE_CODE)
  77. {
  78. if (buff[2] != 4)
  79. {
  80. return 2;
  81. }
  82. //err code
  83. if (buff[3] != 0)
  84. {
  85. rt_kprintf("Saw HCI COMMAND STATUS error:%d", buff[3]);
  86. return 12;
  87. }
  88. if (buff[4] == 0)
  89. {
  90. return 3;
  91. }
  92. if (buff[5] != ogf)
  93. {
  94. return 4;
  95. }
  96. if (buff[6] != ocf)
  97. {
  98. return 5;
  99. }
  100. }
  101. else if (buff[1] == BT_COMMAND_COMPLETE_CODE)
  102. {
  103. if (buff[2] != 4)
  104. {
  105. return 6;
  106. }
  107. if (buff[3] == 0)
  108. {
  109. return 7;
  110. }
  111. if (buff[4] != ogf)
  112. {
  113. return 8;
  114. }
  115. if (buff[5] != ocf)
  116. {
  117. return 9;
  118. }
  119. if (buff[6] == 0)
  120. {
  121. return 10;
  122. }
  123. }
  124. else
  125. {
  126. return 11;
  127. }
  128. return 0;
  129. }
  130. rt_err_t bt_loadfirmware(void)
  131. {
  132. int ii = 0;
  133. int ret = 0;
  134. int recv_len = BT_RX_MAX;
  135. int step = 0;
  136. rt_uint8_t ogf, ocf;
  137. rt_memset(tx_buff, 0, BT_TX_MAX);
  138. ogf = hi(BT_OGF_VENDOR << 10 | BT_COMMAND_LOAD_FIRMWARE);
  139. ocf = lo(BT_OGF_VENDOR << 10 | BT_COMMAND_LOAD_FIRMWARE);
  140. bt_data_pack(tx_buff, ogf, ocf, 0);
  141. int kk = 0;
  142. for (ii = 0; ii < BT_TRY_NUM_MAX; ii++)
  143. {
  144. recv_len = BT_RX_MAX;
  145. bt_uart_receive_flush(bt_device);
  146. bt_uart_send_data(bt_device, tx_buff, BT_SEND_MIN_PACK);
  147. rt_thread_mdelay(5);
  148. ret = bt_uart_receive_data(bt_device, rx_buff, &recv_len, 2000);
  149. if (ret > 0)
  150. {
  151. ret = bt_reply_check(rx_buff, ogf, ocf, RT_NULL);
  152. if (ret == 0)
  153. {
  154. step = 1;
  155. break;
  156. }
  157. else
  158. {
  159. rt_kprintf("err code is %d\n", ret);
  160. }
  161. }
  162. }
  163. if (step == 1)
  164. {
  165. extern unsigned char _binary_driver_BCM4345C0_hcd_size[];
  166. extern unsigned char _binary_driver_BCM4345C0_hcd_start[];
  167. unsigned int c = 0;
  168. unsigned int size = (long)&_binary_driver_BCM4345C0_hcd_size;
  169. while (c < size)
  170. {
  171. //unsigned char opcodebytes[] = {_binary_BCM4345C0_hcd_start[c], _binary_BCM4345C0_hcd_start[c + 1]};
  172. unsigned char length = _binary_driver_BCM4345C0_hcd_start[c + 2];
  173. unsigned char *data = &(_binary_driver_BCM4345C0_hcd_start[c + 3]);
  174. rt_memset(tx_buff, 0, BT_TX_MAX);
  175. ogf = _binary_driver_BCM4345C0_hcd_start[c + 1];
  176. ocf = _binary_driver_BCM4345C0_hcd_start[c];
  177. bt_data_pack(tx_buff, ogf, ocf, length);
  178. rt_memcpy(&tx_buff[BT_HEAD_NUM], data, length);
  179. int kk = 0;
  180. for (ii = 0; ii < BT_TRY_NUM_MAX; ii++)
  181. {
  182. recv_len = BT_RX_MAX;
  183. rt_memset(rx_buff, 0, BT_TX_MAX);
  184. bt_uart_receive_flush(bt_device);
  185. bt_uart_send_data(bt_device, tx_buff, length + BT_HEAD_NUM);
  186. bt_uart_receive_flush(bt_device);
  187. rt_thread_mdelay(5);
  188. ret = bt_uart_receive_data(bt_device, rx_buff, &recv_len, 1000);
  189. if (ret > 0)
  190. {
  191. ret = bt_reply_check(rx_buff, ogf, ocf, RT_NULL);
  192. if (ret == 0)
  193. {
  194. step = 2;
  195. break;
  196. }
  197. else
  198. {
  199. rt_kprintf("err code is %d\n", ret);
  200. }
  201. }
  202. }
  203. if (ii >= 3)
  204. {
  205. step = 3;
  206. break;
  207. }
  208. c += 3 + length;
  209. }
  210. if (step != 3)
  211. {
  212. return RT_EOK;
  213. }
  214. }
  215. else
  216. {
  217. return -RT_ERROR;
  218. }
  219. return -RT_ERROR;
  220. }
  221. rt_err_t bt_setbaud(void)
  222. {
  223. static unsigned char params[] = {0, 0, 0x00, 0xc2, 0x01, 0x00}; // little endian, 115200
  224. int params_len = 6;
  225. int ii = 0;
  226. int ret = 0;
  227. int recv_len = BT_RX_MAX;
  228. rt_uint16_t ogf, ocf;
  229. rt_memset(tx_buff, 0, BT_TX_MAX);
  230. ogf = hi(BT_OGF_VENDOR << 10 | BT_COMMAND_SET_BAUD);
  231. ocf = lo(BT_OGF_VENDOR << 10 | BT_COMMAND_SET_BAUD);
  232. bt_data_pack(tx_buff, ogf, ocf, params_len);
  233. //rt_memcpy(&tx_buff[BT_HEAD_NUM], params, params_len);
  234. tx_buff[4] = 0x00;
  235. tx_buff[5] = 0x01;
  236. tx_buff[6] = 0xc2;
  237. tx_buff[7] = 0x00;
  238. tx_buff[8] = 0x00;
  239. tx_buff[9] = 0x00;
  240. for (ii = 0; ii < BT_TRY_NUM_MAX; ii++)
  241. {
  242. recv_len = BT_RX_MAX;
  243. bt_uart_receive_flush(bt_device);
  244. bt_uart_send_data(bt_device, tx_buff, params_len + BT_HEAD_NUM);
  245. rt_thread_mdelay(5);
  246. ret = bt_uart_receive_data(bt_device, rx_buff, &recv_len, 1000);
  247. if (ret > 0)
  248. {
  249. ret = bt_reply_check(rx_buff, ogf, ocf, RT_NULL);
  250. if (ret == 0)
  251. {
  252. return RT_EOK;
  253. }
  254. else
  255. {
  256. rt_kprintf("err code is %d\n", ret);
  257. }
  258. }
  259. }
  260. return -RT_ERROR;
  261. }
  262. rt_err_t setLEeventmask(unsigned char mask)
  263. {
  264. unsigned char params[] = {mask, 0, 0, 0, 0, 0, 0, 0};
  265. //static unsigned char params[] = { 0xee, 0xff, 0xc0, 0xee, 0xff, 0xc0 }; // reversed
  266. int params_len = 8;
  267. int ii = 0;
  268. int ret = 0;
  269. int recv_len = BT_RX_MAX;
  270. rt_uint16_t ogf, ocf;
  271. rt_memset(tx_buff, 0, BT_TX_MAX);
  272. ogf = hi(BT_OGF_LE_CONTROL << 10 | 0x01);
  273. ocf = lo(BT_OGF_LE_CONTROL << 10 | 0x01);
  274. bt_data_pack(tx_buff, ogf, ocf, params_len);
  275. //rt_memcpy(&tx_buff[BT_HEAD_NUM], params, params_len);
  276. tx_buff[4] = params[0];
  277. tx_buff[5] = params[1];
  278. tx_buff[6] = params[2];
  279. tx_buff[7] = params[3];
  280. tx_buff[8] = params[4];
  281. tx_buff[9] = params[5];
  282. tx_buff[10] = params[6];
  283. tx_buff[11] = params[7];
  284. for (ii = 0; ii < BT_TRY_NUM_MAX; ii++)
  285. {
  286. recv_len = BT_RX_MAX;
  287. bt_uart_receive_flush(bt_device);
  288. bt_uart_send_data(bt_device, tx_buff, params_len + BT_HEAD_NUM);
  289. rt_thread_mdelay(5);
  290. ret = bt_uart_receive_data(bt_device, rx_buff, &recv_len, 1000);
  291. if (ret > 0)
  292. {
  293. ret = bt_reply_check(rx_buff, ogf, ocf, RT_NULL);
  294. if (ret == 0)
  295. {
  296. return RT_EOK;
  297. }
  298. else
  299. {
  300. rt_kprintf("err code is %d\n", ret);
  301. }
  302. }
  303. }
  304. return -RT_ERROR;
  305. //if (hciCommand(OGF_LE_CONTROL, 0x01, params, 8)) uart_writeText("setLEeventmask failed\n");
  306. }
  307. rt_err_t bt_getbdaddr(unsigned char *bdaddr)
  308. {
  309. static unsigned char params[] = {0x00, 0x10, 0x09, BT_HCI_COMMAND_PKT}; //get bdaddr
  310. int params_len = 4;
  311. int recv_len = BT_RX_MAX;
  312. // rt_memcpy(tx_buff, params, 4);
  313. tx_buff[0] = BT_HCI_COMMAND_PKT;
  314. tx_buff[1] = 0x09;
  315. tx_buff[2] = 0x10;
  316. tx_buff[3] = 0x00;
  317. bt_uart_receive_flush(bt_device);
  318. bt_uart_send_data(bt_device, tx_buff, 4);
  319. rt_thread_mdelay(100);
  320. bt_uart_receive_data(bt_device, rx_buff, &recv_len, 1000);
  321. if (recv_len > 0)
  322. {
  323. if ((rx_buff[0] != BT_HCI_EVENT_PKT) || (rx_buff[1] != BT_COMMAND_COMPLETE_CODE))
  324. {
  325. return -RT_ERROR;
  326. }
  327. if ((rx_buff[2] != 0x0a) || (rx_buff[3] != 0x01))
  328. {
  329. return -RT_ERROR;
  330. }
  331. if ((rx_buff[4] != 0x09) || (rx_buff[5] != 0x10))
  332. {
  333. return -RT_ERROR;
  334. }
  335. bdaddr[0] = rx_buff[7];
  336. bdaddr[1] = rx_buff[8];
  337. bdaddr[2] = rx_buff[9];
  338. bdaddr[3] = rx_buff[10];
  339. bdaddr[4] = rx_buff[11];
  340. bdaddr[5] = rx_buff[12];
  341. }
  342. else
  343. {
  344. return -RT_ERROR;
  345. }
  346. return RT_EOK;
  347. }
  348. rt_err_t setLEscanenable(unsigned char state, unsigned char duplicates)
  349. {
  350. unsigned char params[] = {state, duplicates};
  351. //static unsigned char params[] = { 0xee, 0xff, 0xc0, 0xee, 0xff, 0xc0 }; // reversed
  352. int params_len = 2;
  353. int ii = 0;
  354. int ret = 0;
  355. int recv_len = BT_RX_MAX;
  356. rt_uint16_t ogf, ocf;
  357. rt_memset(tx_buff, 0, BT_TX_MAX);
  358. ogf = hi(BT_OGF_LE_CONTROL << 10 | 0x0c);
  359. ocf = lo(BT_OGF_LE_CONTROL << 10 | 0x0c);
  360. bt_data_pack(tx_buff, ogf, ocf, params_len);
  361. tx_buff[4] = params[0];
  362. tx_buff[5] = params[1];
  363. //rt_memcpy(&tx_buff[BT_HEAD_NUM], params, params_len);
  364. for (ii = 0; ii < BT_TRY_NUM_MAX; ii++)
  365. {
  366. recv_len = BT_RX_MAX;
  367. bt_uart_receive_flush(bt_device);
  368. bt_uart_send_data(bt_device, tx_buff, params_len + BT_HEAD_NUM);
  369. rt_thread_mdelay(5);
  370. ret = bt_uart_receive_data(bt_device, rx_buff, &recv_len, 1000);
  371. if (ret > 0)
  372. {
  373. ret = bt_reply_check(rx_buff, ogf, ocf, RT_NULL);
  374. if (ret == 0)
  375. {
  376. return RT_EOK;
  377. }
  378. else
  379. {
  380. rt_kprintf("err code is %d\n", ret);
  381. }
  382. }
  383. }
  384. return -RT_ERROR;
  385. }
  386. rt_err_t setLEscanparameters(unsigned char type, unsigned char linterval, unsigned char hinterval, unsigned char lwindow, unsigned char hwindow, unsigned char own_address_type, unsigned char filter_policy)
  387. {
  388. unsigned char params[] = {type, linterval, hinterval, lwindow, hwindow, own_address_type, filter_policy};
  389. int params_len = 7;
  390. int ii = 0;
  391. int ret = 0;
  392. int recv_len = BT_RX_MAX;
  393. rt_uint16_t ogf, ocf;
  394. rt_memset(tx_buff, 0, BT_TX_MAX);
  395. ogf = hi(BT_OGF_LE_CONTROL << 10 | 0x0b);
  396. ocf = lo(BT_OGF_LE_CONTROL << 10 | 0x0b);
  397. bt_data_pack(tx_buff, ogf, ocf, params_len);
  398. tx_buff[4] = params[0];
  399. tx_buff[5] = params[1];
  400. tx_buff[6] = params[2];
  401. tx_buff[7] = params[3];
  402. tx_buff[8] = params[4];
  403. tx_buff[9] = params[5];
  404. tx_buff[10] = params[6];
  405. //rt_memcpy(&tx_buff[BT_HEAD_NUM], params, params_len);
  406. for (ii = 0; ii < BT_TRY_NUM_MAX; ii++)
  407. {
  408. recv_len = BT_RX_MAX;
  409. bt_uart_receive_flush(bt_device);
  410. bt_uart_send_data(bt_device, tx_buff, params_len + BT_HEAD_NUM);
  411. rt_thread_mdelay(5);
  412. ret = bt_uart_receive_data(bt_device, rx_buff, &recv_len, 1000);
  413. if (ret > 0)
  414. {
  415. ret = bt_reply_check(rx_buff, ogf, ocf, RT_NULL);
  416. if (ret == 0)
  417. {
  418. return RT_EOK;
  419. }
  420. else
  421. {
  422. rt_kprintf("err code is %d\n", ret);
  423. }
  424. }
  425. }
  426. return -RT_ERROR;
  427. }
  428. rt_err_t startActiveScanning()
  429. {
  430. float BleScanInterval = 60; // every 60ms
  431. float BleScanWindow = 60;
  432. float BleScanDivisor = 0.625;
  433. unsigned int p = BleScanInterval / BleScanDivisor;
  434. unsigned int q = BleScanWindow / BleScanDivisor;
  435. if (setLEscanparameters(BT_LL_SCAN_ACTIVE, lo(p), hi(p), lo(q), hi(q), 0, 0) == RT_EOK)
  436. {
  437. rt_kprintf("setLEscanparameters ok!\n");
  438. }
  439. if (setLEscanenable(1, 0) == RT_EOK)
  440. {
  441. rt_kprintf("setLEscanenable ok!\n");
  442. }
  443. }
  444. rt_err_t bt_setbdaddr(void)
  445. {
  446. static unsigned char params[] = {0xee, 0xff, 0xc0, 0xee, 0xff, 0xc0}; // reversed
  447. int params_len = 6;
  448. int ii = 0;
  449. int ret = 0;
  450. int recv_len = BT_RX_MAX;
  451. rt_uint16_t ogf, ocf;
  452. rt_memset(tx_buff, 0, BT_TX_MAX);
  453. ogf = hi(BT_OGF_VENDOR << 10 | BT_COMMAND_SET_BDADDR);
  454. ocf = lo(BT_OGF_VENDOR << 10 | BT_COMMAND_SET_BDADDR);
  455. bt_data_pack(tx_buff, ogf, ocf, params_len);
  456. tx_buff[4] = 0xc0;
  457. tx_buff[5] = 0xff;
  458. tx_buff[6] = 0xee;
  459. tx_buff[7] = 0xc0;
  460. tx_buff[8] = 0xff;
  461. tx_buff[9] = 0xee;
  462. //rt_memcpy(&tx_buff[BT_HEAD_NUM], params, params_len);
  463. for (ii = 0; ii < BT_TRY_NUM_MAX; ii++)
  464. {
  465. recv_len = BT_RX_MAX;
  466. bt_uart_receive_flush(bt_device);
  467. bt_uart_send_data(bt_device, tx_buff, params_len + BT_HEAD_NUM);
  468. rt_thread_mdelay(5);
  469. ret = bt_uart_receive_data(bt_device, rx_buff, &recv_len, 1000);
  470. if (ret > 0)
  471. {
  472. ret = bt_reply_check(rx_buff, ogf, ocf, RT_NULL);
  473. if (ret == 0)
  474. {
  475. return RT_EOK;
  476. }
  477. else
  478. {
  479. rt_kprintf("err code is %d\n", ret);
  480. }
  481. }
  482. }
  483. return -RT_ERROR;
  484. }
  485. rt_err_t bt_reset(void)
  486. {
  487. int ii = 0;
  488. int ret = 0;
  489. int recv_len = BT_RX_MAX;
  490. rt_uint16_t ogf, ocf;
  491. rt_memset(tx_buff, 0, BT_TX_MAX);
  492. ogf = hi(BT_OGF_HOST_CONTROL << 10 | BT_COMMAND_RESET_CHIP);
  493. ocf = lo(BT_OGF_HOST_CONTROL << 10 | BT_COMMAND_RESET_CHIP);
  494. bt_data_pack(tx_buff, ogf, ocf, 0);
  495. for (ii = 0; ii < BT_TRY_NUM_MAX; ii++)
  496. {
  497. recv_len = BT_RX_MAX;
  498. bt_uart_receive_flush(bt_device);
  499. bt_uart_send_data(bt_device, tx_buff, 8);
  500. rt_thread_mdelay(5);
  501. ret = bt_uart_receive_data(bt_device, rx_buff, &recv_len, 1000);
  502. //rt_kprintf("recv_len is %d\n", recv_len);
  503. if (ret > 0)
  504. {
  505. ret = bt_reply_check(rx_buff, ogf, ocf, RT_NULL);
  506. if (ret == 0)
  507. {
  508. return RT_EOK;
  509. }
  510. else
  511. {
  512. rt_kprintf("err code is %d\n", ret);
  513. }
  514. }
  515. }
  516. return -RT_ERROR;
  517. }
  518. rt_device_t bt_uart_init(const char *uartname)
  519. {
  520. rt_device_t dev = RT_NULL;
  521. if (strcmp(uartname, BT_UART_NAME) == 0)
  522. {
  523. bt_rx_sem = rt_sem_create("btbuf", 0, RT_IPC_FLAG_FIFO);
  524. dev = rt_device_find(uartname);
  525. if (dev == RT_NULL)
  526. {
  527. rt_kprintf("can no find dev %s\n", uartname);
  528. return dev;
  529. }
  530. if (rt_device_open(dev, RT_DEVICE_OFLAG_RDWR) == RT_EOK)
  531. {
  532. rt_device_set_rx_indicate(dev, bt_rx_ind);
  533. }
  534. return dev;
  535. }
  536. return dev;
  537. }
  538. static void bt_task_entry(void *param)
  539. {
  540. while (1)
  541. {
  542. rt_thread_delay(1000);
  543. }
  544. }
  545. #define MAX_MSG_LEN 50
  546. #define MAX_READ_RUN 100
  547. unsigned char data_buf[MAX_MSG_LEN];
  548. unsigned int data_len;
  549. unsigned int messages_received = 0;
  550. unsigned int poll_state = 0;
  551. unsigned int got_echo_sid = 0;
  552. unsigned int got_echo_name = 0;
  553. unsigned char echo_addr[6];
  554. void hci_poll2(unsigned char byte)
  555. {
  556. switch (poll_state)
  557. {
  558. case 0:
  559. if (byte != HCI_EVENT_PKT)
  560. poll_state = 0;
  561. else
  562. poll_state = 1;
  563. break;
  564. case 1:
  565. if (byte != LE_EVENT_CODE)
  566. poll_state = 0;
  567. else
  568. poll_state = 2;
  569. break;
  570. case 2:
  571. if (byte > MAX_MSG_LEN)
  572. poll_state = 0;
  573. else
  574. {
  575. poll_state = 3;
  576. data_len = byte;
  577. }
  578. break;
  579. default:
  580. data_buf[poll_state - 3] = byte;
  581. if (poll_state == data_len + 3 - 1)
  582. {
  583. messages_received++;
  584. poll_state = 0;
  585. }
  586. else
  587. poll_state++;
  588. }
  589. }
  590. unsigned char *hci_poll()
  591. {
  592. int recv_len = 256;
  593. unsigned int goal = messages_received + 1;
  594. bt_uart_receive_data(bt_device, rx_buff, &recv_len, 1000);
  595. rt_thread_mdelay(10);
  596. if (recv_len > 0)
  597. {
  598. unsigned int run = 0;
  599. while (run < MAX_READ_RUN && messages_received < goal)
  600. {
  601. recv_len = recv_len - 1;
  602. hci_poll2(rx_buff[recv_len]);
  603. run++;
  604. if (recv_len == 0)
  605. {
  606. break;
  607. }
  608. }
  609. if (run == MAX_READ_RUN)
  610. return 0;
  611. else
  612. return data_buf;
  613. }
  614. return 0;
  615. }
  616. void bt_search()
  617. {
  618. unsigned char *buf;
  619. while ((buf = hci_poll()))
  620. {
  621. if (data_len >= 2)
  622. {
  623. if (buf[0] == LE_ADREPORT_CODE)
  624. {
  625. unsigned char numreports = buf[1];
  626. if (numreports == 1)
  627. {
  628. unsigned char event_type = buf[2];
  629. if (event_type == 0x00)
  630. {
  631. unsigned char buf_len = buf[10];
  632. unsigned char ad_len = buf[11];
  633. if (ad_len < data_len && buf_len + 11 == data_len - 1)
  634. {
  635. for (int c = 9; c >= 4; c--)
  636. echo_addr[9 - c] = buf[c];
  637. buf += 11;
  638. got_echo_sid = 0;
  639. got_echo_name = 0; // Reset the search state machine
  640. do
  641. {
  642. ad_len = buf[0];
  643. unsigned char ad_type = buf[1];
  644. buf += 2;
  645. if (ad_len >= 2)
  646. {
  647. if (ad_type == 0x03)
  648. {
  649. unsigned int sid = 0;
  650. for (int d = 0; d < ad_len - 1; d += 2)
  651. {
  652. sid = buf[d] | (buf[d + 1] << 8);
  653. if (sid == 0xEC00)
  654. {
  655. rt_kprintf("sid is %d\n", sid);
  656. //uart_hex(sid); uart_writeText(" ");
  657. got_echo_sid = 1;
  658. }
  659. }
  660. }
  661. else if (ad_type == 0x09)
  662. {
  663. char remote_name[ad_len - 1];
  664. unsigned int d = 0;
  665. while (d < ad_len - 1)
  666. {
  667. remote_name[d] = buf[d];
  668. d++;
  669. }
  670. if (!memcmp(remote_name, "echo", 4))
  671. {
  672. rt_kprintf("remote_name is %s\n", remote_name);
  673. got_echo_name = 1;
  674. }
  675. }
  676. }
  677. buf += ad_len - 1;
  678. } while (buf[1]);
  679. }
  680. }
  681. }
  682. }
  683. }
  684. }
  685. }
  686. void bt_uart_protocol_init()
  687. {
  688. rt_thread_t bt_tid = RT_NULL;
  689. bt_device = bt_uart_init(BT_UART_NAME);
  690. bt_tid = rt_thread_create("bt_task", bt_task_entry, RT_NULL, BT_THREAD_STACK_SIZE, BT_THREAD_PRIORITY, BT_THREAD_TICK);
  691. if (bt_tid == RT_NULL)
  692. {
  693. rt_kprintf("bt_task create err!\n");
  694. return 0;
  695. }
  696. rt_thread_startup(bt_tid);
  697. }
  698. int rt_hw_bluetooth_init(void)
  699. {
  700. bt_uart_protocol_init();
  701. if (bt_reset() == RT_EOK)
  702. {
  703. rt_kprintf("bluetooth reset ok!\n");
  704. }
  705. else
  706. {
  707. rt_kprintf("bluetooth reset err!\n");
  708. }
  709. rt_thread_delay(10);
  710. if (bt_loadfirmware() == RT_EOK)
  711. {
  712. rt_kprintf("loadfirmware ok!\n");
  713. }
  714. else
  715. {
  716. rt_kprintf("loadfirmware err!\n");
  717. }
  718. rt_thread_delay(10);
  719. if (bt_setbaud() == RT_EOK)
  720. {
  721. rt_kprintf("setbaud ok!\n");
  722. }
  723. else
  724. {
  725. rt_kprintf("setbaud err!\n");
  726. }
  727. rt_thread_delay(10);
  728. if (bt_setbdaddr() == RT_EOK)
  729. {
  730. rt_kprintf("setbdaddr ok!\n");
  731. }
  732. else
  733. {
  734. rt_kprintf("setbdaddr err!\n");
  735. }
  736. rt_thread_delay(100);
  737. rt_uint8_t bdaddr[6];
  738. if (bt_getbdaddr(bdaddr) == RT_EOK)
  739. {
  740. rt_kprintf("bdaddr :%02x:%02x:%02x:%02x:%02x:%02x\n", bdaddr[0], bdaddr[1], bdaddr[2], bdaddr[3], bdaddr[4], bdaddr[5]);
  741. }
  742. else
  743. {
  744. rt_kprintf("getbdaddr err!\n");
  745. }
  746. rt_thread_delay(100);
  747. if (setLEeventmask(0xff) == RT_EOK)
  748. {
  749. rt_kprintf("setLEeventmask ok!\n");
  750. }
  751. rt_thread_delay(100);
  752. startActiveScanning();
  753. rt_thread_delay(500);
  754. rt_kprintf("start!\n");
  755. while (1)
  756. {
  757. bt_search();
  758. if (got_echo_sid && got_echo_name)
  759. {
  760. break;
  761. }
  762. rt_thread_mdelay(10);
  763. }
  764. rt_kprintf("stop scan!\n");
  765. }