USB Host Shield 2.0
 All Classes Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
SPP.cpp
Go to the documentation of this file.
1 /* Copyright (C) 2012 Kristian Lauszus, TKJ Electronics. All rights reserved.
2 
3  This software may be distributed and modified under the terms of the GNU
4  General Public License version 2 (GPL2) as published by the Free Software
5  Foundation and appearing in the file GPL2.TXT included in the packaging of
6  this file. Please note that GPL2 Section 2[b] requires that all works based
7  on this software must also be made publicly available under the terms of
8  the GPL2 ("Copyleft").
9 
10  Contact information
11  -------------------
12 
13  Kristian Lauszus, TKJ Electronics
14  Web : http://www.tkjelectronics.com
15  e-mail : kristianl@tkjelectronics.com
16  */
17 
18 #include "SPP.h"
19 // To enable serial debugging uncomment "#define DEBUG_USB_HOST" in message.h
20 //#define EXTRADEBUG // Uncomment to get even more debugging data
21 //#define PRINTREPORT // Uncomment to print the report sent to the Arduino
22 
23 /*
24  * CRC (reversed crc) lookup table as calculated by the table generator in ETSI TS 101 369 V6.3.0.
25  */
26 const uint8_t rfcomm_crc_table[256] PROGMEM = {/* reversed, 8-bit, poly=0x07 */
27  0x00, 0x91, 0xE3, 0x72, 0x07, 0x96, 0xE4, 0x75, 0x0E, 0x9F, 0xED, 0x7C, 0x09, 0x98, 0xEA, 0x7B,
28  0x1C, 0x8D, 0xFF, 0x6E, 0x1B, 0x8A, 0xF8, 0x69, 0x12, 0x83, 0xF1, 0x60, 0x15, 0x84, 0xF6, 0x67,
29  0x38, 0xA9, 0xDB, 0x4A, 0x3F, 0xAE, 0xDC, 0x4D, 0x36, 0xA7, 0xD5, 0x44, 0x31, 0xA0, 0xD2, 0x43,
30  0x24, 0xB5, 0xC7, 0x56, 0x23, 0xB2, 0xC0, 0x51, 0x2A, 0xBB, 0xC9, 0x58, 0x2D, 0xBC, 0xCE, 0x5F,
31  0x70, 0xE1, 0x93, 0x02, 0x77, 0xE6, 0x94, 0x05, 0x7E, 0xEF, 0x9D, 0x0C, 0x79, 0xE8, 0x9A, 0x0B,
32  0x6C, 0xFD, 0x8F, 0x1E, 0x6B, 0xFA, 0x88, 0x19, 0x62, 0xF3, 0x81, 0x10, 0x65, 0xF4, 0x86, 0x17,
33  0x48, 0xD9, 0xAB, 0x3A, 0x4F, 0xDE, 0xAC, 0x3D, 0x46, 0xD7, 0xA5, 0x34, 0x41, 0xD0, 0xA2, 0x33,
34  0x54, 0xC5, 0xB7, 0x26, 0x53, 0xC2, 0xB0, 0x21, 0x5A, 0xCB, 0xB9, 0x28, 0x5D, 0xCC, 0xBE, 0x2F,
35  0xE0, 0x71, 0x03, 0x92, 0xE7, 0x76, 0x04, 0x95, 0xEE, 0x7F, 0x0D, 0x9C, 0xE9, 0x78, 0x0A, 0x9B,
36  0xFC, 0x6D, 0x1F, 0x8E, 0xFB, 0x6A, 0x18, 0x89, 0xF2, 0x63, 0x11, 0x80, 0xF5, 0x64, 0x16, 0x87,
37  0xD8, 0x49, 0x3B, 0xAA, 0xDF, 0x4E, 0x3C, 0xAD, 0xD6, 0x47, 0x35, 0xA4, 0xD1, 0x40, 0x32, 0xA3,
38  0xC4, 0x55, 0x27, 0xB6, 0xC3, 0x52, 0x20, 0xB1, 0xCA, 0x5B, 0x29, 0xB8, 0xCD, 0x5C, 0x2E, 0xBF,
39  0x90, 0x01, 0x73, 0xE2, 0x97, 0x06, 0x74, 0xE5, 0x9E, 0x0F, 0x7D, 0xEC, 0x99, 0x08, 0x7A, 0xEB,
40  0x8C, 0x1D, 0x6F, 0xFE, 0x8B, 0x1A, 0x68, 0xF9, 0x82, 0x13, 0x61, 0xF0, 0x85, 0x14, 0x66, 0xF7,
41  0xA8, 0x39, 0x4B, 0xDA, 0xAF, 0x3E, 0x4C, 0xDD, 0xA6, 0x37, 0x45, 0xD4, 0xA1, 0x30, 0x42, 0xD3,
42  0xB4, 0x25, 0x57, 0xC6, 0xB3, 0x22, 0x50, 0xC1, 0xBA, 0x2B, 0x59, 0xC8, 0xBD, 0x2C, 0x5E, 0xCF
43 };
44 
45 SPP::SPP(BTD *p, const char* name, const char* pin) :
46 pBtd(p) // Pointer to BTD class instance - mandatory
47 {
48  if (pBtd)
49  pBtd->registerServiceClass(this); // Register it as a Bluetooth service
50 
51  pBtd->btdName = name;
52  pBtd->btdPin = pin;
53 
54  /* Set device cid for the SDP and RFCOMM channelse */
55  sdp_dcid[0] = 0x50; // 0x0050
56  sdp_dcid[1] = 0x00;
57  rfcomm_dcid[0] = 0x51; // 0x0051
58  rfcomm_dcid[1] = 0x00;
59 
60  Reset();
61 }
62 
63 void SPP::Reset() {
64  connected = false;
65  RFCOMMConnected = false;
66  SDPConnected = false;
67  l2cap_sdp_state = L2CAP_SDP_WAIT;
68  l2cap_rfcomm_state = L2CAP_RFCOMM_WAIT;
69  l2cap_event_flag = 0;
70  sppIndex = 0;
71 }
72 
74  connected = false;
75  // First the two L2CAP channels has to be disconencted and then the HCI connection
76  if (RFCOMMConnected)
77  pBtd->l2cap_disconnection_request(hci_handle, 0x0A, rfcomm_scid, rfcomm_dcid);
78  if (RFCOMMConnected && SDPConnected)
79  delay(1); // Add delay between commands
80  if (SDPConnected)
81  pBtd->l2cap_disconnection_request(hci_handle, 0x0B, sdp_scid, sdp_dcid);
82  l2cap_sdp_state = L2CAP_DISCONNECT_RESPONSE;
83 }
84 
85 void SPP::ACLData(uint8_t* l2capinbuf) {
86  if (!connected) {
87  if (l2capinbuf[8] == L2CAP_CMD_CONNECTION_REQUEST) {
88  if ((l2capinbuf[12] | (l2capinbuf[13] << 8)) == SDP_PSM && !pBtd->sdpConnectionClaimed) {
89  pBtd->sdpConnectionClaimed = true;
90  hci_handle = pBtd->hci_handle; // Store the HCI Handle for the connection
91  l2cap_sdp_state = L2CAP_SDP_WAIT; // Reset state
92  } else if ((l2capinbuf[12] | (l2capinbuf[13] << 8)) == RFCOMM_PSM && !pBtd->rfcommConnectionClaimed) {
93  pBtd->rfcommConnectionClaimed = true;
94  hci_handle = pBtd->hci_handle; // Store the HCI Handle for the connection
95  l2cap_rfcomm_state = L2CAP_RFCOMM_WAIT; // Reset state
96  }
97  }
98  }
99  if (((l2capinbuf[0] | (l2capinbuf[1] << 8)) == (hci_handle | 0x2000))) { // acl_handle_ok
100  if ((l2capinbuf[6] | (l2capinbuf[7] << 8)) == 0x0001) { //l2cap_control - Channel ID for ACL-U
101  if (l2capinbuf[8] == L2CAP_CMD_COMMAND_REJECT) {
102 #ifdef DEBUG_USB_HOST
103  Notify(PSTR("\r\nL2CAP Command Rejected - Reason: "), 0x80);
104  D_PrintHex<uint8_t > (l2capinbuf[13], 0x80);
105  Notify(PSTR(" "), 0x80);
106  D_PrintHex<uint8_t > (l2capinbuf[12], 0x80);
107  Notify(PSTR(" Data: "), 0x80);
108  D_PrintHex<uint8_t > (l2capinbuf[17], 0x80);
109  Notify(PSTR(" "), 0x80);
110  D_PrintHex<uint8_t > (l2capinbuf[16], 0x80);
111  Notify(PSTR(" "), 0x80);
112  D_PrintHex<uint8_t > (l2capinbuf[15], 0x80);
113  Notify(PSTR(" "), 0x80);
114  D_PrintHex<uint8_t > (l2capinbuf[14], 0x80);
115 #endif
116  } else if (l2capinbuf[8] == L2CAP_CMD_CONNECTION_REQUEST) {
117 #ifdef EXTRADEBUG
118  Notify(PSTR("\r\nL2CAP Connection Request - PSM: "), 0x80);
119  D_PrintHex<uint8_t > (l2capinbuf[13], 0x80);
120  Notify(PSTR(" "), 0x80);
121  D_PrintHex<uint8_t > (l2capinbuf[12], 0x80);
122  Notify(PSTR(" SCID: "), 0x80);
123  D_PrintHex<uint8_t > (l2capinbuf[15], 0x80);
124  Notify(PSTR(" "), 0x80);
125  D_PrintHex<uint8_t > (l2capinbuf[14], 0x80);
126  Notify(PSTR(" Identifier: "), 0x80);
127  D_PrintHex<uint8_t > (l2capinbuf[9], 0x80);
128 #endif
129  if ((l2capinbuf[12] | (l2capinbuf[13] << 8)) == SDP_PSM) { // It doesn't matter if it receives another reqeust, since it waits for the channel to disconnect in the L2CAP_SDP_DONE state, and the l2cap_event_flag will be cleared if so
130  identifier = l2capinbuf[9];
131  sdp_scid[0] = l2capinbuf[14];
132  sdp_scid[1] = l2capinbuf[15];
133  l2cap_event_flag |= L2CAP_FLAG_CONNECTION_SDP_REQUEST;
134  } else if ((l2capinbuf[12] | (l2capinbuf[13] << 8)) == RFCOMM_PSM) { // ----- || -----
135  identifier = l2capinbuf[9];
136  rfcomm_scid[0] = l2capinbuf[14];
137  rfcomm_scid[1] = l2capinbuf[15];
138  l2cap_event_flag |= L2CAP_FLAG_CONNECTION_RFCOMM_REQUEST;
139  }
140  } else if (l2capinbuf[8] == L2CAP_CMD_CONFIG_RESPONSE) {
141  if ((l2capinbuf[16] | (l2capinbuf[17] << 8)) == 0x0000) { // Success
142  if (l2capinbuf[12] == sdp_dcid[0] && l2capinbuf[13] == sdp_dcid[1]) {
143  //Notify(PSTR("\r\nSDP Configuration Complete"), 0x80);
144  l2cap_event_flag |= L2CAP_FLAG_CONFIG_SDP_SUCCESS;
145  } else if (l2capinbuf[12] == rfcomm_dcid[0] && l2capinbuf[13] == rfcomm_dcid[1]) {
146  //Notify(PSTR("\r\nRFCOMM Configuration Complete"), 0x80);
147  l2cap_event_flag |= L2CAP_FLAG_CONFIG_RFCOMM_SUCCESS;
148  }
149  }
150  } else if (l2capinbuf[8] == L2CAP_CMD_CONFIG_REQUEST) {
151  if (l2capinbuf[12] == sdp_dcid[0] && l2capinbuf[13] == sdp_dcid[1]) {
152  //Notify(PSTR("\r\nSDP Configuration Request"), 0x80);
153  identifier = l2capinbuf[9];
154  l2cap_event_flag |= L2CAP_FLAG_CONFIG_SDP_REQUEST;
155  } else if (l2capinbuf[12] == rfcomm_dcid[0] && l2capinbuf[13] == rfcomm_dcid[1]) {
156  //Notify(PSTR("\r\nRFCOMM Configuration Request"), 0x80);
157  identifier = l2capinbuf[9];
158  l2cap_event_flag |= L2CAP_FLAG_CONFIG_RFCOMM_REQUEST;
159  }
160  } else if (l2capinbuf[8] == L2CAP_CMD_DISCONNECT_REQUEST) {
161  if (l2capinbuf[12] == sdp_dcid[0] && l2capinbuf[13] == sdp_dcid[1]) {
162  //Notify(PSTR("\r\nDisconnect Request: SDP Channel"), 0x80);
163  identifier = l2capinbuf[9];
164  l2cap_event_flag |= L2CAP_FLAG_DISCONNECT_SDP_REQUEST;
165  } else if (l2capinbuf[12] == rfcomm_dcid[0] && l2capinbuf[13] == rfcomm_dcid[1]) {
166  //Notify(PSTR("\r\nDisconnect Request: RFCOMM Channel"), 0x80);
167  identifier = l2capinbuf[9];
168  l2cap_event_flag |= L2CAP_FLAG_DISCONNECT_RFCOMM_REQUEST;
169  }
170  } else if (l2capinbuf[8] == L2CAP_CMD_DISCONNECT_RESPONSE) {
171  if (l2capinbuf[12] == sdp_scid[0] && l2capinbuf[13] == sdp_scid[1]) {
172  //Notify(PSTR("\r\nDisconnect Response: SDP Channel"), 0x80);
173  identifier = l2capinbuf[9];
174  l2cap_event_flag |= L2CAP_FLAG_DISCONNECT_RESPONSE;
175  } else if (l2capinbuf[12] == rfcomm_scid[0] && l2capinbuf[13] == rfcomm_scid[1]) {
176  //Notify(PSTR("\r\nDisconnect Response: RFCOMM Channel"), 0x80);
177  identifier = l2capinbuf[9];
178  l2cap_event_flag |= L2CAP_FLAG_DISCONNECT_RESPONSE;
179  }
180  } else if (l2capinbuf[8] == L2CAP_CMD_INFORMATION_REQUEST) {
181 #ifdef DEBUG_USB_HOST
182  Notify(PSTR("\r\nInformation request"), 0x80);
183 #endif
184  identifier = l2capinbuf[9];
185  pBtd->l2cap_information_response(hci_handle, identifier, l2capinbuf[12], l2capinbuf[13]);
186  }
187 #ifdef EXTRADEBUG
188  else {
189  Notify(PSTR("\r\nL2CAP Unknown Signaling Command: "), 0x80);
190  D_PrintHex<uint8_t > (l2capinbuf[8], 0x80);
191  }
192 #endif
193  } else if (l2capinbuf[6] == sdp_dcid[0] && l2capinbuf[7] == sdp_dcid[1]) { // SDP
194  if (l2capinbuf[8] == SDP_SERVICE_SEARCH_ATTRIBUTE_REQUEST_PDU) {
195  if (((l2capinbuf[16] << 8 | l2capinbuf[17]) == SERIALPORT_UUID) || ((l2capinbuf[16] << 8 | l2capinbuf[17]) == 0x0000 && (l2capinbuf[18] << 8 | l2capinbuf[19]) == SERIALPORT_UUID)) { // Check if it's sending the full UUID, see: https://www.bluetooth.org/Technical/AssignedNumbers/service_discovery.htm, we will just check the first four bytes
196  if (firstMessage) {
197  serialPortResponse1(l2capinbuf[9], l2capinbuf[10]);
198  firstMessage = false;
199  } else {
200  serialPortResponse2(l2capinbuf[9], l2capinbuf[10]); // Serialport continuation state
201  firstMessage = true;
202  }
203  } else if (((l2capinbuf[16] << 8 | l2capinbuf[17]) == L2CAP_UUID) || ((l2capinbuf[16] << 8 | l2capinbuf[17]) == 0x0000 && (l2capinbuf[18] << 8 | l2capinbuf[19]) == L2CAP_UUID)) {
204  if (firstMessage) {
205  l2capResponse1(l2capinbuf[9], l2capinbuf[10]);
206  firstMessage = false;
207  } else {
208  l2capResponse2(l2capinbuf[9], l2capinbuf[10]); // L2CAP continuation state
209  firstMessage = true;
210  }
211  } else
212  serviceNotSupported(l2capinbuf[9], l2capinbuf[10]); // The service is not supported
213 #ifdef EXTRADEBUG
214  Notify(PSTR("\r\nUUID: "), 0x80);
215  uint16_t uuid;
216  if((l2capinbuf[16] << 8 | l2capinbuf[17]) == 0x0000) // Check if it's sending the UUID as a 128-bit UUID
217  uuid = (l2capinbuf[18] << 8 | l2capinbuf[19]);
218  else // Short UUID
219  uuid = (l2capinbuf[16] << 8 | l2capinbuf[17]);
220  D_PrintHex<uint16_t> (uuid, 0x80);
221 
222  Notify(PSTR("\r\nLength: "), 0x80);
223  uint16_t length = l2capinbuf[11] << 8 | l2capinbuf[12];
224  D_PrintHex<uint16_t> (length, 0x80);
225  Notify(PSTR("\r\nData: "), 0x80);
226  for (uint8_t i = 0; i < length; i++) {
227  D_PrintHex<uint8_t> (l2capinbuf[13+i], 0x80);
228  Notify(PSTR(" "), 0x80);
229  }
230 #endif
231  }
232 #ifdef EXTRADEBUG
233  else {
234  Notify(PSTR("\r\nUnknown PDU: "), 0x80);
235  D_PrintHex<uint8_t > (l2capinbuf[8], 0x80);
236  }
237 #endif
238  } else if (l2capinbuf[6] == rfcomm_dcid[0] && l2capinbuf[7] == rfcomm_dcid[1]) { // RFCOMM
239  rfcommChannel = l2capinbuf[8] & 0xF8;
240  rfcommDirection = l2capinbuf[8] & 0x04;
241  rfcommCommandResponse = l2capinbuf[8] & 0x02;
242  rfcommChannelType = l2capinbuf[9] & 0xEF;
243  rfcommPfBit = l2capinbuf[9] & 0x10;
244 
245  if (rfcommChannel >> 3 != 0x00)
246  rfcommChannelConnection = rfcommChannel;
247 
248 #ifdef EXTRADEBUG
249  Notify(PSTR("\r\nRFCOMM Channel: "), 0x80);
250  D_PrintHex<uint8_t > (rfcommChannel >> 3, 0x80);
251  Notify(PSTR(" Direction: "), 0x80);
252  D_PrintHex<uint8_t > (rfcommDirection >> 2, 0x80);
253  Notify(PSTR(" CommandResponse: "), 0x80);
254  D_PrintHex<uint8_t > (rfcommCommandResponse >> 1, 0x80);
255  Notify(PSTR(" ChannelType: "), 0x80);
256  D_PrintHex<uint8_t > (rfcommChannelType, 0x80);
257  Notify(PSTR(" PF_BIT: "), 0x80);
258  D_PrintHex<uint8_t > (rfcommPfBit, 0x80);
259 #endif
260  if (rfcommChannelType == RFCOMM_DISC) {
261 #ifdef DEBUG_USB_HOST
262  Notify(PSTR("\r\nReceived Disconnect RFCOMM Command on channel: "), 0x80);
263  D_PrintHex<uint8_t > (rfcommChannel >> 3, 0x80);
264 #endif
265  connected = false;
266  sendRfcomm(rfcommChannel, rfcommDirection, rfcommCommandResponse, RFCOMM_UA, rfcommPfBit, rfcommbuf, 0x00); // UA Command
267  }
268  if (connected) {
269  /* Read the incoming message */
270  if (rfcommChannelType == RFCOMM_UIH && rfcommChannel == rfcommChannelConnection) {
271  uint8_t length = l2capinbuf[10] >> 1; // Get length
272  uint8_t offset = l2capinbuf[4] - length - 4; // See if there is credit
273  if (rfcommAvailable + length <= sizeof (rfcommDataBuffer)) { // Don't add data to buffer if it would be full
274  for (uint8_t i = 0; i < length; i++)
275  rfcommDataBuffer[rfcommAvailable + i] = l2capinbuf[11 + i + offset];
276  rfcommAvailable += length;
277  }
278 #ifdef EXTRADEBUG
279  Notify(PSTR("\r\nRFCOMM Data Available: "), 0x80);
280  Notify(rfcommAvailable, 0x80);
281  if (offset) {
282  Notify(PSTR(" - Credit: 0x"), 0x80);
283  D_PrintHex<uint8_t > (l2capinbuf[11], 0x80);
284  }
285 #endif
286 #ifdef PRINTREPORT // Uncomment "#define PRINTREPORT" to print the report send to the Arduino via Bluetooth
287  for (uint8_t i = 0; i < length; i++)
288  Notifyc(l2capinbuf[i + 11 + offset], 0x80);
289 #endif
290  } else if (rfcommChannelType == RFCOMM_UIH && l2capinbuf[11] == BT_RFCOMM_RPN_CMD) { // UIH Remote Port Negotiation Command
291 #ifdef DEBUG_USB_HOST
292  Notify(PSTR("\r\nReceived UIH Remote Port Negotiation Command"), 0x80);
293 #endif
294  rfcommbuf[0] = BT_RFCOMM_RPN_RSP; // Command
295  rfcommbuf[1] = l2capinbuf[12]; // Length and shiftet like so: length << 1 | 1
296  rfcommbuf[2] = l2capinbuf[13]; // Channel: channel << 1 | 1
297  rfcommbuf[3] = l2capinbuf[14]; // Pre difined for Bluetooth, see 5.5.3 of TS 07.10 Adaption for RFCOMM
298  rfcommbuf[4] = l2capinbuf[15]; // Priority
299  rfcommbuf[5] = l2capinbuf[16]; // Timer
300  rfcommbuf[6] = l2capinbuf[17]; // Max Fram Size LSB
301  rfcommbuf[7] = l2capinbuf[18]; // Max Fram Size MSB
302  rfcommbuf[8] = l2capinbuf[19]; // MaxRatransm.
303  rfcommbuf[9] = l2capinbuf[20]; // Number of Frames
304  sendRfcomm(rfcommChannel, rfcommDirection, 0, RFCOMM_UIH, rfcommPfBit, rfcommbuf, 0x0A); // UIH Remote Port Negotiation Response
305  } else if (rfcommChannelType == RFCOMM_UIH && l2capinbuf[11] == BT_RFCOMM_MSC_CMD) { // UIH Modem Status Command
306 #ifdef DEBUG_USB_HOST
307  Notify(PSTR("\r\nSend UIH Modem Status Response"), 0x80);
308 #endif
309  rfcommbuf[0] = BT_RFCOMM_MSC_RSP; // UIH Modem Status Response
310  rfcommbuf[1] = 2 << 1 | 1; // Length and shiftet like so: length << 1 | 1
311  rfcommbuf[2] = l2capinbuf[13]; // Channel: (1 << 0) | (1 << 1) | (0 << 2) | (channel << 3)
312  rfcommbuf[3] = l2capinbuf[14];
313  sendRfcomm(rfcommChannel, rfcommDirection, 0, RFCOMM_UIH, rfcommPfBit, rfcommbuf, 0x04);
314  }
315  } else {
316  if (rfcommChannelType == RFCOMM_SABM) { // SABM Command - this is sent twice: once for channel 0 and then for the channel to establish
317 #ifdef DEBUG_USB_HOST
318  Notify(PSTR("\r\nReceived SABM Command"), 0x80);
319 #endif
320  sendRfcomm(rfcommChannel, rfcommDirection, rfcommCommandResponse, RFCOMM_UA, rfcommPfBit, rfcommbuf, 0x00); // UA Command
321  } else if (rfcommChannelType == RFCOMM_UIH && l2capinbuf[11] == BT_RFCOMM_PN_CMD) { // UIH Parameter Negotiation Command
322 #ifdef DEBUG_USB_HOST
323  Notify(PSTR("\r\nReceived UIH Parameter Negotiation Command"), 0x80);
324 #endif
325  rfcommbuf[0] = BT_RFCOMM_PN_RSP; // UIH Parameter Negotiation Response
326  rfcommbuf[1] = l2capinbuf[12]; // Length and shiftet like so: length << 1 | 1
327  rfcommbuf[2] = l2capinbuf[13]; // Channel: channel << 1 | 1
328  rfcommbuf[3] = 0xE0; // Pre difined for Bluetooth, see 5.5.3 of TS 07.10 Adaption for RFCOMM
329  rfcommbuf[4] = 0x00; // Priority
330  rfcommbuf[5] = 0x00; // Timer
331  rfcommbuf[6] = BULK_MAXPKTSIZE - 14; // Max Fram Size LSB - set to the size of received data (50)
332  rfcommbuf[7] = 0x00; // Max Fram Size MSB
333  rfcommbuf[8] = 0x00; // MaxRatransm.
334  rfcommbuf[9] = 0x00; // Number of Frames
335  sendRfcomm(rfcommChannel, rfcommDirection, 0, RFCOMM_UIH, rfcommPfBit, rfcommbuf, 0x0A);
336  } else if (rfcommChannelType == RFCOMM_UIH && l2capinbuf[11] == BT_RFCOMM_MSC_CMD) { // UIH Modem Status Command
337 #ifdef DEBUG_USB_HOST
338  Notify(PSTR("\r\nSend UIH Modem Status Response"), 0x80);
339 #endif
340  rfcommbuf[0] = BT_RFCOMM_MSC_RSP; // UIH Modem Status Response
341  rfcommbuf[1] = 2 << 1 | 1; // Length and shiftet like so: length << 1 | 1
342  rfcommbuf[2] = l2capinbuf[13]; // Channel: (1 << 0) | (1 << 1) | (0 << 2) | (channel << 3)
343  rfcommbuf[3] = l2capinbuf[14];
344  sendRfcomm(rfcommChannel, rfcommDirection, 0, RFCOMM_UIH, rfcommPfBit, rfcommbuf, 0x04);
345 
346  delay(1);
347 #ifdef DEBUG_USB_HOST
348  Notify(PSTR("\r\nSend UIH Modem Status Command"), 0x80);
349 #endif
350  rfcommbuf[0] = BT_RFCOMM_MSC_CMD; // UIH Modem Status Command
351  rfcommbuf[1] = 2 << 1 | 1; // Length and shiftet like so: length << 1 | 1
352  rfcommbuf[2] = l2capinbuf[13]; // Channel: (1 << 0) | (1 << 1) | (0 << 2) | (channel << 3)
353  rfcommbuf[3] = 0x8D; // Can receive frames (YES), Ready to Communicate (YES), Ready to Receive (YES), Incomig Call (NO), Data is Value (YES)
354 
355  sendRfcomm(rfcommChannel, rfcommDirection, 0, RFCOMM_UIH, rfcommPfBit, rfcommbuf, 0x04);
356  } else if (rfcommChannelType == RFCOMM_UIH && l2capinbuf[11] == BT_RFCOMM_MSC_RSP) { // UIH Modem Status Response
357  if (!creditSent) {
358 #ifdef DEBUG_USB_HOST
359  Notify(PSTR("\r\nSend UIH Command with credit"), 0x80);
360 #endif
361  sendRfcommCredit(rfcommChannelConnection, rfcommDirection, 0, RFCOMM_UIH, 0x10, sizeof (rfcommDataBuffer)); // Send credit
362  creditSent = true;
363  timer = millis();
364  waitForLastCommand = true;
365  }
366  } else if (rfcommChannelType == RFCOMM_UIH && l2capinbuf[10] == 0x01) { // UIH Command with credit
367 #ifdef DEBUG_USB_HOST
368  Notify(PSTR("\r\nReceived UIH Command with credit"), 0x80);
369 #endif
370  } else if (rfcommChannelType == RFCOMM_UIH && l2capinbuf[11] == BT_RFCOMM_RPN_CMD) { // UIH Remote Port Negotiation Command
371 #ifdef DEBUG_USB_HOST
372  Notify(PSTR("\r\nReceived UIH Remote Port Negotiation Command"), 0x80);
373 #endif
374  rfcommbuf[0] = BT_RFCOMM_RPN_RSP; // Command
375  rfcommbuf[1] = l2capinbuf[12]; // Length and shiftet like so: length << 1 | 1
376  rfcommbuf[2] = l2capinbuf[13]; // Channel: channel << 1 | 1
377  rfcommbuf[3] = l2capinbuf[14]; // Pre difined for Bluetooth, see 5.5.3 of TS 07.10 Adaption for RFCOMM
378  rfcommbuf[4] = l2capinbuf[15]; // Priority
379  rfcommbuf[5] = l2capinbuf[16]; // Timer
380  rfcommbuf[6] = l2capinbuf[17]; // Max Fram Size LSB
381  rfcommbuf[7] = l2capinbuf[18]; // Max Fram Size MSB
382  rfcommbuf[8] = l2capinbuf[19]; // MaxRatransm.
383  rfcommbuf[9] = l2capinbuf[20]; // Number of Frames
384  sendRfcomm(rfcommChannel, rfcommDirection, 0, RFCOMM_UIH, rfcommPfBit, rfcommbuf, 0x0A); // UIH Remote Port Negotiation Response
385 #ifdef DEBUG_USB_HOST
386  Notify(PSTR("\r\nRFCOMM Connection is now established\r\n"), 0x80);
387 #endif
388  waitForLastCommand = false;
389  creditSent = false;
390  connected = true; // The RFCOMM channel is now established
391  sppIndex = 0;
392  }
393 #ifdef DEBUG_USB_HOST
394  else if (rfcommChannelType != RFCOMM_DISC) {
395  Notify(PSTR("\r\nUnsupported RFCOMM Data - ChannelType: "), 0x80);
396  D_PrintHex<uint8_t > (rfcommChannelType, 0x80);
397  Notify(PSTR(" Command: "), 0x80);
398  D_PrintHex<uint8_t > (l2capinbuf[11], 0x80);
399  }
400 #endif
401  }
402  }
403 #ifdef EXTRADEBUG
404  else {
405  Notify(PSTR("\r\nUnsupported L2CAP Data - Channel ID: "), 0x80);
406  D_PrintHex<uint8_t > (l2capinbuf[7], 0x80);
407  Notify(PSTR(" "), 0x80);
408  D_PrintHex<uint8_t > (l2capinbuf[6], 0x80);
409  }
410 #endif
411  SDP_task();
412  RFCOMM_task();
413  }
414 }
415 
416 void SPP::Run() {
417  if (waitForLastCommand && (millis() - timer) > 100) { // We will only wait 100ms and see if the UIH Remote Port Negotiation Command is send, as some deviced don't send it
418 #ifdef DEBUG_USB_HOST
419  Notify(PSTR("\r\nRFCOMM Connection is now established - Automatic\r\n"), 0x80);
420 #endif
421  creditSent = false;
422  waitForLastCommand = false;
423  connected = true; // The RFCOMM channel is now established
424  sppIndex = 0;
425  }
426  send(); // Send all bytes currently in the buffer
427 }
428 
429 void SPP::SDP_task() {
430  switch (l2cap_sdp_state) {
431  case L2CAP_SDP_WAIT:
433  l2cap_event_flag &= ~L2CAP_FLAG_CONNECTION_SDP_REQUEST; // Clear flag
434 #ifdef DEBUG_USB_HOST
435  Notify(PSTR("\r\nSDP Incoming Connection Request"), 0x80);
436 #endif
437  pBtd->l2cap_connection_response(hci_handle, identifier, sdp_dcid, sdp_scid, PENDING);
438  delay(1);
439  pBtd->l2cap_connection_response(hci_handle, identifier, sdp_dcid, sdp_scid, SUCCESSFUL);
440  identifier++;
441  delay(1);
442  pBtd->l2cap_config_request(hci_handle, identifier, sdp_scid);
443  l2cap_sdp_state = L2CAP_SDP_REQUEST;
444  }
445  break;
446  case L2CAP_SDP_REQUEST:
448  l2cap_event_flag &= ~L2CAP_FLAG_CONFIG_SDP_REQUEST; // Clear flag
449 #ifdef DEBUG_USB_HOST
450  Notify(PSTR("\r\nSDP Configuration Request"), 0x80);
451 #endif
452  pBtd->l2cap_config_response(hci_handle, identifier, sdp_scid);
453  l2cap_sdp_state = L2CAP_SDP_SUCCESS;
454  }
455  break;
456  case L2CAP_SDP_SUCCESS:
458  l2cap_event_flag &= ~L2CAP_FLAG_CONFIG_SDP_SUCCESS; // Clear flag
459 #ifdef DEBUG_USB_HOST
460  Notify(PSTR("\r\nSDP Successfully Configured"), 0x80);
461 #endif
462  firstMessage = true; // Reset bool
463  SDPConnected = true;
464  l2cap_sdp_state = L2CAP_SDP_DONE;
465  }
466  break;
467  case L2CAP_SDP_DONE:
469  l2cap_event_flag &= ~L2CAP_FLAG_DISCONNECT_SDP_REQUEST; // Clear flag
470  SDPConnected = false;
471 #ifdef DEBUG_USB_HOST
472  Notify(PSTR("\r\nDisconnected SDP Channel"), 0x80);
473 #endif
474  pBtd->l2cap_disconnection_response(hci_handle, identifier, sdp_dcid, sdp_scid);
475  l2cap_sdp_state = L2CAP_SDP_WAIT;
477  l2cap_rfcomm_state = L2CAP_SDP_WAIT;
478  break;
479  case L2CAP_DISCONNECT_RESPONSE: // This is for both disconnection response from the RFCOMM and SDP channel if they were connected
481 #ifdef DEBUG_USB_HOST
482  Notify(PSTR("\r\nDisconnected L2CAP Connection"), 0x80);
483 #endif
484  RFCOMMConnected = false;
485  SDPConnected = false;
486  pBtd->hci_disconnect(hci_handle);
487  hci_handle = -1; // Reset handle
488  l2cap_event_flag = 0; // Reset flags
489  l2cap_sdp_state = L2CAP_SDP_WAIT;
490  l2cap_rfcomm_state = L2CAP_RFCOMM_WAIT;
491  }
492  break;
493  }
494 }
495 
496 void SPP::RFCOMM_task() {
497  switch (l2cap_rfcomm_state) {
498  case L2CAP_RFCOMM_WAIT:
500  l2cap_event_flag &= ~L2CAP_FLAG_CONNECTION_RFCOMM_REQUEST; // Clear flag
501 #ifdef DEBUG_USB_HOST
502  Notify(PSTR("\r\nRFCOMM Incoming Connection Request"), 0x80);
503 #endif
504  pBtd->l2cap_connection_response(hci_handle, identifier, rfcomm_dcid, rfcomm_scid, PENDING);
505  delay(1);
506  pBtd->l2cap_connection_response(hci_handle, identifier, rfcomm_dcid, rfcomm_scid, SUCCESSFUL);
507  identifier++;
508  delay(1);
509  pBtd->l2cap_config_request(hci_handle, identifier, rfcomm_scid);
510  l2cap_rfcomm_state = L2CAP_RFCOMM_REQUEST;
511  }
512  break;
515  l2cap_event_flag &= ~L2CAP_FLAG_CONFIG_RFCOMM_REQUEST; // Clear flag
516 #ifdef DEBUG_USB_HOST
517  Notify(PSTR("\r\nRFCOMM Configuration Request"), 0x80);
518 #endif
519  pBtd->l2cap_config_response(hci_handle, identifier, rfcomm_scid);
520  l2cap_rfcomm_state = L2CAP_RFCOMM_SUCCESS;
521  }
522  break;
525  l2cap_event_flag &= ~L2CAP_FLAG_CONFIG_RFCOMM_SUCCESS; // Clear flag
526 #ifdef DEBUG_USB_HOST
527  Notify(PSTR("\r\nRFCOMM Successfully Configured"), 0x80);
528 #endif
529  rfcommAvailable = 0; // Reset number of bytes available
530  bytesRead = 0; // Reset number of bytes received
531  RFCOMMConnected = true;
532  l2cap_rfcomm_state = L2CAP_RFCOMM_DONE;
533  }
534  break;
535  case L2CAP_RFCOMM_DONE:
537  l2cap_event_flag &= ~L2CAP_FLAG_DISCONNECT_RFCOMM_REQUEST; // Clear flag
538  RFCOMMConnected = false;
539  connected = false;
540 #ifdef DEBUG_USB_HOST
541  Notify(PSTR("\r\nDisconnected RFCOMM Channel"), 0x80);
542 #endif
543  pBtd->l2cap_disconnection_response(hci_handle, identifier, rfcomm_dcid, rfcomm_scid);
544  l2cap_rfcomm_state = L2CAP_RFCOMM_WAIT;
546  l2cap_rfcomm_state = L2CAP_RFCOMM_WAIT;
547  break;
548  }
549 }
550 /************************************************************/
551 /* SDP Commands */
552 
553 /************************************************************/
554 void SPP::SDP_Command(uint8_t* data, uint8_t nbytes) { // See page 223 in the Bluetooth specs
555  pBtd->L2CAP_Command(hci_handle, data, nbytes, sdp_scid[0], sdp_scid[1]);
556 }
557 
558 void SPP::serviceNotSupported(uint8_t transactionIDHigh, uint8_t transactionIDLow) { // See page 235 in the Bluetooth specs
560  l2capoutbuf[1] = transactionIDHigh;
561  l2capoutbuf[2] = transactionIDLow;
562  l2capoutbuf[3] = 0x00; // Parameter Length
563  l2capoutbuf[4] = 0x05; // Parameter Length
564  l2capoutbuf[5] = 0x00; // AttributeListsByteCount
565  l2capoutbuf[6] = 0x02; // AttributeListsByteCount
566 
567  /* Attribute ID/Value Sequence: */
568  l2capoutbuf[7] = 0x35;
569  l2capoutbuf[8] = 0x00;
570  l2capoutbuf[9] = 0x00;
571 
572  SDP_Command(l2capoutbuf, 10);
573 }
574 
575 void SPP::serialPortResponse1(uint8_t transactionIDHigh, uint8_t transactionIDLow) {
577  l2capoutbuf[1] = transactionIDHigh;
578  l2capoutbuf[2] = transactionIDLow;
579  l2capoutbuf[3] = 0x00; // Parameter Length
580  l2capoutbuf[4] = 0x2B; // Parameter Length
581  l2capoutbuf[5] = 0x00; // AttributeListsByteCount
582  l2capoutbuf[6] = 0x26; // AttributeListsByteCount
583 
584  /* Attribute ID/Value Sequence: */
585  l2capoutbuf[7] = 0x36;
586  l2capoutbuf[8] = 0x00;
587  l2capoutbuf[9] = 0x3C;
588  l2capoutbuf[10] = 0x36;
589  l2capoutbuf[11] = 0x00;
590 
591  l2capoutbuf[12] = 0x39;
592  l2capoutbuf[13] = 0x09;
593  l2capoutbuf[14] = 0x00;
594  l2capoutbuf[15] = 0x00;
595  l2capoutbuf[16] = 0x0A;
596  l2capoutbuf[17] = 0x00;
597  l2capoutbuf[18] = 0x01;
598  l2capoutbuf[19] = 0x00;
599  l2capoutbuf[20] = 0x06;
600  l2capoutbuf[21] = 0x09;
601  l2capoutbuf[22] = 0x00;
602  l2capoutbuf[23] = 0x01;
603  l2capoutbuf[24] = 0x35;
604  l2capoutbuf[25] = 0x03;
605  l2capoutbuf[26] = 0x19;
606  l2capoutbuf[27] = 0x11;
607 
608  l2capoutbuf[28] = 0x01;
609  l2capoutbuf[29] = 0x09;
610  l2capoutbuf[30] = 0x00;
611  l2capoutbuf[31] = 0x04;
612  l2capoutbuf[32] = 0x35;
613  l2capoutbuf[33] = 0x0C;
614  l2capoutbuf[34] = 0x35;
615  l2capoutbuf[35] = 0x03;
616  l2capoutbuf[36] = 0x19;
617  l2capoutbuf[37] = 0x01;
618  l2capoutbuf[38] = 0x00;
619  l2capoutbuf[39] = 0x35;
620  l2capoutbuf[40] = 0x05;
621  l2capoutbuf[41] = 0x19;
622  l2capoutbuf[42] = 0x00;
623  l2capoutbuf[43] = 0x03;
624 
625  l2capoutbuf[44] = 0x08;
626  l2capoutbuf[45] = 0x02; // Two extra bytes
627  l2capoutbuf[46] = 0x00; // 25 (0x19) more bytes to come
628  l2capoutbuf[47] = 0x19;
629 
630  SDP_Command(l2capoutbuf, 48);
631 }
632 
633 void SPP::serialPortResponse2(uint8_t transactionIDHigh, uint8_t transactionIDLow) {
635  l2capoutbuf[1] = transactionIDHigh;
636  l2capoutbuf[2] = transactionIDLow;
637  l2capoutbuf[3] = 0x00; // Parameter Length
638  l2capoutbuf[4] = 0x1C; // Parameter Length
639  l2capoutbuf[5] = 0x00; // AttributeListsByteCount
640  l2capoutbuf[6] = 0x19; // AttributeListsByteCount
641 
642  /* Attribute ID/Value Sequence: */
643  l2capoutbuf[7] = 0x01;
644  l2capoutbuf[8] = 0x09;
645  l2capoutbuf[9] = 0x00;
646  l2capoutbuf[10] = 0x06;
647  l2capoutbuf[11] = 0x35;
648 
649  l2capoutbuf[12] = 0x09;
650  l2capoutbuf[13] = 0x09;
651  l2capoutbuf[14] = 0x65;
652  l2capoutbuf[15] = 0x6E;
653  l2capoutbuf[16] = 0x09;
654  l2capoutbuf[17] = 0x00;
655  l2capoutbuf[18] = 0x6A;
656  l2capoutbuf[19] = 0x09;
657  l2capoutbuf[20] = 0x01;
658  l2capoutbuf[21] = 0x00;
659  l2capoutbuf[22] = 0x09;
660  l2capoutbuf[23] = 0x01;
661  l2capoutbuf[24] = 0x00;
662  l2capoutbuf[25] = 0x25;
663 
664  l2capoutbuf[26] = 0x05; // Name length
665  l2capoutbuf[27] = 'T';
666  l2capoutbuf[28] = 'K';
667  l2capoutbuf[29] = 'J';
668  l2capoutbuf[30] = 'S';
669  l2capoutbuf[31] = 'P';
670  l2capoutbuf[32] = 0x00; // No more data
671 
672  SDP_Command(l2capoutbuf, 33);
673 }
674 
675 void SPP::l2capResponse1(uint8_t transactionIDHigh, uint8_t transactionIDLow) {
676  serialPortResponse1(transactionIDHigh, transactionIDLow); // These has to send all the supported functions, since it only supports virtual serialport it just sends the message again
677 }
678 
679 void SPP::l2capResponse2(uint8_t transactionIDHigh, uint8_t transactionIDLow) {
680  serialPortResponse2(transactionIDHigh, transactionIDLow); // Same data as serialPortResponse2
681 }
682 /************************************************************/
683 /* RFCOMM Commands */
684 
685 /************************************************************/
686 void SPP::RFCOMM_Command(uint8_t* data, uint8_t nbytes) {
687  pBtd->L2CAP_Command(hci_handle, data, nbytes, rfcomm_scid[0], rfcomm_scid[1]);
688 }
689 
690 void SPP::sendRfcomm(uint8_t channel, uint8_t direction, uint8_t CR, uint8_t channelType, uint8_t pfBit, uint8_t* data, uint8_t length) {
691  l2capoutbuf[0] = channel | direction | CR | extendAddress; // RFCOMM Address
692  l2capoutbuf[1] = channelType | pfBit; // RFCOMM Control
693  l2capoutbuf[2] = length << 1 | 0x01; // Length and format (always 0x01 bytes format)
694  uint8_t i = 0;
695  for (; i < length; i++)
696  l2capoutbuf[i + 3] = data[i];
697  l2capoutbuf[i + 3] = calcFcs(l2capoutbuf);
698 #ifdef EXTRADEBUG
699  Notify(PSTR(" - RFCOMM Data: "), 0x80);
700  for (i = 0; i < length + 4; i++) {
701  D_PrintHex<uint8_t > (l2capoutbuf[i], 0x80);
702  Notify(PSTR(" "), 0x80);
703  }
704 #endif
705  RFCOMM_Command(l2capoutbuf, length + 4);
706 }
707 
708 void SPP::sendRfcommCredit(uint8_t channel, uint8_t direction, uint8_t CR, uint8_t channelType, uint8_t pfBit, uint8_t credit) {
709  l2capoutbuf[0] = channel | direction | CR | extendAddress; // RFCOMM Address
710  l2capoutbuf[1] = channelType | pfBit; // RFCOMM Control
711  l2capoutbuf[2] = 0x01; // Length = 0
712  l2capoutbuf[3] = credit; // Credit
713  l2capoutbuf[4] = calcFcs(l2capoutbuf);
714 #ifdef EXTRADEBUG
715  Notify(PSTR(" - RFCOMM Credit Data: "), 0x80);
716  for (uint8_t i = 0; i < 5; i++) {
717  D_PrintHex<uint8_t > (l2capoutbuf[i], 0x80);
718  Notify(PSTR(" "), 0x80);
719  }
720 #endif
721  RFCOMM_Command(l2capoutbuf, 5);
722 }
723 
724 /* CRC on 2 bytes */
725 uint8_t SPP::__crc(uint8_t* data) {
726  return (pgm_read_byte(&rfcomm_crc_table[pgm_read_byte(&rfcomm_crc_table[0xff ^ data[0]]) ^ data[1]]));
727 }
728 
729 /* Calculate FCS - we never actually check if the host sends correct FCS to the Arduino */
730 uint8_t SPP::calcFcs(uint8_t *data) {
731  if ((data[1] & 0xEF) == RFCOMM_UIH)
732  return (0xff - __crc(data)); // FCS on 2 bytes
733  else
734  return (0xff - pgm_read_byte(&rfcomm_crc_table[__crc(data) ^ data[2]])); // FCS on 3 bytes
735 }
736 
737 /* Serial commands */
738 size_t SPP::write(uint8_t data) {
739  return write(&data,1);
740 }
741 
742 size_t SPP::write(const uint8_t* data, size_t size) {
743  for(uint8_t i = 0; i < size; i++) {
744  if(sppIndex >= sizeof(sppOutputBuffer)/sizeof(sppOutputBuffer[0]))
745  send(); // Send the current data in the buffer
746  sppOutputBuffer[sppIndex++] = data[i]; // All the bytes are put into a buffer and then send using the send() function
747  }
748  return size;
749 }
750 
751 void SPP::send() {
752  if (!connected || !sppIndex)
753  return;
754  uint8_t length; // This is the length of the string we are sending
755  uint8_t offset = 0; // This is used to keep track of where we are in the string
756 
757  l2capoutbuf[0] = rfcommChannelConnection | 0 | 0 | extendAddress; // RFCOMM Address
758  l2capoutbuf[1] = RFCOMM_UIH; // RFCOMM Control
759 
760  while (sppIndex) { // We will run this while loop until this variable is 0
761  if (sppIndex > (sizeof (l2capoutbuf) - 4)) // Check if the string is larger than the outgoing buffer
762  length = sizeof (l2capoutbuf) - 4;
763  else
764  length = sppIndex;
765 
766  l2capoutbuf[2] = length << 1 | 1; // Length
767  uint8_t i = 0;
768  for (; i < length; i++)
769  l2capoutbuf[i + 3] = sppOutputBuffer[i + offset];
770  l2capoutbuf[i + 3] = calcFcs(l2capoutbuf); // Calculate checksum
771 
772  RFCOMM_Command(l2capoutbuf, length + 4);
773 
774  sppIndex -= length;
775  offset += length; // Increment the offset
776  }
777 }
778 
779 int SPP::available(void) {
780  return rfcommAvailable;
781 };
782 
783 void SPP::flush(void) {
784  rfcommAvailable = 0;
785 }
786 
787 int SPP::peek(void) {
788  if (rfcommAvailable == 0) // Don't read if there is nothing in the buffer
789  return -1;
790  return rfcommDataBuffer[0];
791 }
792 
793 int SPP::read(void) {
794  if (rfcommAvailable == 0) // Don't read if there is nothing in the buffer
795  return -1;
796  uint8_t output = rfcommDataBuffer[0];
797  for (uint8_t i = 1; i < rfcommAvailable; i++)
798  rfcommDataBuffer[i - 1] = rfcommDataBuffer[i]; // Shift the buffer one left
799  rfcommAvailable--;
800  bytesRead++;
801  if (bytesRead > (sizeof (rfcommDataBuffer) - 5)) { // We will send the command just before it runs out of credit
802  bytesRead = 0;
803  sendRfcommCredit(rfcommChannelConnection, rfcommDirection, 0, RFCOMM_UIH, 0x10, sizeof (rfcommDataBuffer)); // Send more credit
804 #ifdef EXTRADEBUG
805  Notify(PSTR("\r\nSent "), 0x80);
806  Notify((uint8_t)sizeof (rfcommDataBuffer), 0x80);
807  Notify(PSTR(" more credit"), 0x80);
808 #endif
809  }
810  return output;
811 }