1 /* 2 * Copyright (C) 2014 BlueKitchen GmbH 3 * 4 * Redistribution and use in source and binary forms, with or without 5 * modification, are permitted provided that the following conditions 6 * are met: 7 * 8 * 1. Redistributions of source code must retain the above copyright 9 * notice, this list of conditions and the following disclaimer. 10 * 2. Redistributions in binary form must reproduce the above copyright 11 * notice, this list of conditions and the following disclaimer in the 12 * documentation and/or other materials provided with the distribution. 13 * 3. Neither the name of the copyright holders nor the names of 14 * contributors may be used to endorse or promote products derived 15 * from this software without specific prior written permission. 16 * 4. Any redistribution, use, or modification is done solely for 17 * personal benefit and not for any commercial purpose or for 18 * monetary gain. 19 * 20 * THIS SOFTWARE IS PROVIDED BY BLUEKITCHEN GMBH AND CONTRIBUTORS 21 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 22 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS 23 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MATTHIAS 24 * RINGWALD OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 25 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, 26 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS 27 * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED 28 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, 29 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF 30 * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 31 * SUCH DAMAGE. 32 * 33 * Please inquire about commercial licensing options at 34 * [email protected] 35 * 36 */ 37 38 // ***************************************************************************** 39 // 40 // minimal setup for SDP client over USB or UART 41 // 42 // ***************************************************************************** 43 44 #include "btstack_config.h" 45 46 #include <stdint.h> 47 #include <stdio.h> 48 #include <stdlib.h> 49 #include <string.h> 50 51 52 #include "hci_cmd.h" 53 #include "btstack_run_loop.h" 54 55 #include "hci.h" 56 #include "btstack_memory.h" 57 #include "hci_dump.h" 58 #include "l2cap.h" 59 #include "classic/sdp_query_rfcomm.h" 60 #include "classic/rfcomm.h" 61 #include "btstack_event.h" 62 63 #define NUM_ROWS 25 64 #define NUM_COLS 40 65 66 typedef enum { 67 W4_SDP_RESULT, 68 W4_SDP_COMPLETE, 69 W4_RFCOMM_CHANNEL, 70 DONE 71 } state_t; 72 73 static void handle_query_rfcomm_event(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size); 74 75 #define DATA_VOLUME (1000 * 1000) 76 77 // configuration area { 78 static bd_addr_t remote = {0x84, 0x38, 0x35, 0x65, 0xD1, 0x15}; // address of remote device 79 static const char * spp_service_name_prefix = "Bluetooth-Incoming"; // default on OS X 80 // configuration area } 81 82 static uint8_t test_data[NUM_ROWS * NUM_COLS]; 83 static uint16_t test_data_len = sizeof(test_data); 84 static uint8_t channel_nr = 0; 85 static uint16_t mtu; 86 static uint16_t rfcomm_cid = 0; 87 static uint32_t data_to_send = DATA_VOLUME; 88 static state_t state = W4_SDP_RESULT; 89 static btstack_packet_callback_registration_t hci_event_callback_registration; 90 91 static void create_test_data(void){ 92 int x,y; 93 for (y=0;y<NUM_ROWS;y++){ 94 for (x=0;x<NUM_COLS-2;x++){ 95 test_data[y*NUM_COLS+x] = '0' + (x % 10); 96 } 97 test_data[y*NUM_COLS+NUM_COLS-2] = '\n'; 98 test_data[y*NUM_COLS+NUM_COLS-1] = '\r'; 99 } 100 } 101 102 static void send_packet(void){ 103 int err = rfcomm_send(rfcomm_cid, (uint8_t*) test_data, test_data_len); 104 if (err){ 105 printf("rfcomm_send -> error 0X%02x", err); 106 return; 107 } 108 109 if (data_to_send < test_data_len){ 110 rfcomm_disconnect(rfcomm_cid); 111 rfcomm_cid = 0; 112 state = DONE; 113 printf("SPP Streamer: enough data send, closing DLC\n"); 114 return; 115 } 116 data_to_send -= test_data_len; 117 } 118 119 static void packet_handler (uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 120 // printf("packet_handler type %u, packet[0] %x\n", packet_type, packet[0]); 121 122 if (packet_type != HCI_EVENT_PACKET) return; 123 uint8_t event = packet[0]; 124 125 switch (event) { 126 case BTSTACK_EVENT_STATE: 127 // bt stack activated, get started 128 if (packet[2] == HCI_STATE_WORKING){ 129 sdp_query_rfcomm_channel_and_name_for_uuid(&handle_query_rfcomm_event, remote, SDP_PublicBrowseGroup); 130 } 131 break; 132 case RFCOMM_EVENT_OPEN_CHANNEL_COMPLETE: 133 // data: event(8), len(8), status (8), address (48), handle(16), server channel(8), rfcomm_cid(16), max frame size(16) 134 if (packet[2]) { 135 printf("RFCOMM channel open failed, status %u\n", packet[2]); 136 } else { 137 // data: event(8), len(8), status (8), address (48), handle (16), server channel(8), rfcomm_cid(16), max frame size(16) 138 rfcomm_cid = little_endian_read_16(packet, 12); 139 mtu = little_endian_read_16(packet, 14); 140 printf("RFCOMM channel open succeeded. New RFCOMM Channel ID %u, max frame size %u\n", rfcomm_cid, mtu); 141 if ((test_data_len > mtu)) { 142 test_data_len = mtu; 143 } 144 if (rfcomm_can_send_packet_now(rfcomm_cid)) send_packet(); 145 break; 146 } 147 break; 148 case RFCOMM_EVENT_CAN_SEND_NOW: 149 if (rfcomm_can_send_packet_now(rfcomm_cid)) send_packet(); 150 break; 151 default: 152 break; 153 } 154 } 155 156 static void handle_found_service(const char * name, uint8_t port){ 157 printf("APP: Service name: '%s', RFCOMM port %u\n", name, port); 158 159 if (strncmp(name, spp_service_name_prefix, strlen(spp_service_name_prefix)) != 0) return; 160 161 printf("APP: matches requested SPP Service Name\n"); 162 channel_nr = port; 163 state = W4_SDP_COMPLETE; 164 } 165 166 static void handle_query_rfcomm_event(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 167 switch (packet[0]){ 168 case SDP_EVENT_QUERY_RFCOMM_SERVICE: 169 handle_found_service(sdp_event_query_rfcomm_service_get_name(packet), 170 sdp_event_query_rfcomm_service_get_rfcomm_channel(packet)); 171 break; 172 case SDP_EVENT_QUERY_COMPLETE: 173 if (state != W4_SDP_COMPLETE){ 174 printf("Requested SPP Service %s not found \n", spp_service_name_prefix); 175 break; 176 } 177 // connect 178 printf("Requested SPP Service found, creating RFCOMM channel\n"); 179 state = W4_RFCOMM_CHANNEL; 180 rfcomm_create_channel(packet_handler, remote, channel_nr, NULL); 181 break; 182 default: 183 break; 184 } 185 } 186 187 int btstack_main(int argc, const char * argv[]); 188 int btstack_main(int argc, const char * argv[]){ 189 190 create_test_data(); 191 192 printf("Client HCI init done\r\n"); 193 194 // register for HCI events 195 hci_event_callback_registration.callback = &packet_handler; 196 hci_add_event_handler(&hci_event_callback_registration); 197 198 // init L2CAP 199 l2cap_init(); 200 201 // turn on! 202 hci_power_control(HCI_POWER_ON); 203 204 return 0; 205 } 206