13deb3ec6SMatthias Ringwald /* 23deb3ec6SMatthias Ringwald * Copyright (C) 2014 BlueKitchen GmbH 33deb3ec6SMatthias Ringwald * 43deb3ec6SMatthias Ringwald * Redistribution and use in source and binary forms, with or without 53deb3ec6SMatthias Ringwald * modification, are permitted provided that the following conditions 63deb3ec6SMatthias Ringwald * are met: 73deb3ec6SMatthias Ringwald * 83deb3ec6SMatthias Ringwald * 1. Redistributions of source code must retain the above copyright 93deb3ec6SMatthias Ringwald * notice, this list of conditions and the following disclaimer. 103deb3ec6SMatthias Ringwald * 2. Redistributions in binary form must reproduce the above copyright 113deb3ec6SMatthias Ringwald * notice, this list of conditions and the following disclaimer in the 123deb3ec6SMatthias Ringwald * documentation and/or other materials provided with the distribution. 133deb3ec6SMatthias Ringwald * 3. Neither the name of the copyright holders nor the names of 143deb3ec6SMatthias Ringwald * contributors may be used to endorse or promote products derived 153deb3ec6SMatthias Ringwald * from this software without specific prior written permission. 163deb3ec6SMatthias Ringwald * 4. Any redistribution, use, or modification is done solely for 173deb3ec6SMatthias Ringwald * personal benefit and not for any commercial purpose or for 183deb3ec6SMatthias Ringwald * monetary gain. 193deb3ec6SMatthias Ringwald * 203deb3ec6SMatthias Ringwald * THIS SOFTWARE IS PROVIDED BY BLUEKITCHEN GMBH AND CONTRIBUTORS 213deb3ec6SMatthias Ringwald * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 223deb3ec6SMatthias Ringwald * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS 233deb3ec6SMatthias Ringwald * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MATTHIAS 243deb3ec6SMatthias Ringwald * RINGWALD OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 253deb3ec6SMatthias Ringwald * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, 263deb3ec6SMatthias Ringwald * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS 273deb3ec6SMatthias Ringwald * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED 283deb3ec6SMatthias Ringwald * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, 293deb3ec6SMatthias Ringwald * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF 303deb3ec6SMatthias Ringwald * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 313deb3ec6SMatthias Ringwald * SUCH DAMAGE. 323deb3ec6SMatthias Ringwald * 333deb3ec6SMatthias Ringwald * Please inquire about commercial licensing options at 343deb3ec6SMatthias Ringwald * [email protected] 353deb3ec6SMatthias Ringwald * 363deb3ec6SMatthias Ringwald */ 373deb3ec6SMatthias Ringwald 383deb3ec6SMatthias Ringwald // ***************************************************************************** 393deb3ec6SMatthias Ringwald // 4066a048abSMatthias Ringwald // HSP Headset 413deb3ec6SMatthias Ringwald // 423deb3ec6SMatthias Ringwald // ***************************************************************************** 433deb3ec6SMatthias Ringwald 447907f069SMatthias Ringwald #include "btstack_config.h" 453deb3ec6SMatthias Ringwald 463deb3ec6SMatthias Ringwald #include <stdint.h> 473deb3ec6SMatthias Ringwald #include <stdio.h> 483deb3ec6SMatthias Ringwald #include <stdlib.h> 493deb3ec6SMatthias Ringwald #include <string.h> 503deb3ec6SMatthias Ringwald 5116ece135SMatthias Ringwald #include "btstack_debug.h" 527bd8e93bSMatthias Ringwald #include "btstack_event.h" 537bd8e93bSMatthias Ringwald #include "btstack_memory.h" 547bd8e93bSMatthias Ringwald #include "btstack_run_loop.h" 55746ccb7eSMatthias Ringwald #include "classic/sdp_server.h" 56efda0b48SMatthias Ringwald #include "classic/sdp_client_rfcomm.h" 57023f2764SMatthias Ringwald #include "classic/sdp_util.h" 587bd8e93bSMatthias Ringwald #include "hci.h" 597bd8e93bSMatthias Ringwald #include "hci_cmd.h" 607bd8e93bSMatthias Ringwald #include "hci_dump.h" 613deb3ec6SMatthias Ringwald #include "hsp_hs.h" 627bd8e93bSMatthias Ringwald #include "l2cap.h" 633deb3ec6SMatthias Ringwald 643deb3ec6SMatthias Ringwald #define HSP_AG_OK "OK" 653deb3ec6SMatthias Ringwald #define HSP_AG_ERROR "ERROR" 663deb3ec6SMatthias Ringwald #define HSP_AG_RING "RING" 673deb3ec6SMatthias Ringwald #define HSP_MICROPHONE_GAIN "+VGM=" 683deb3ec6SMatthias Ringwald #define HSP_SPEAKER_GAIN "+VGS=" 693deb3ec6SMatthias Ringwald 703deb3ec6SMatthias Ringwald #define HSP_HS_AT_CKPD "AT+CKPD=200\r\n" 713deb3ec6SMatthias Ringwald #define HSP_HS_MICROPHONE_GAIN "AT+VGM" 723deb3ec6SMatthias Ringwald #define HSP_HS_SPEAKER_GAIN "AT+VGS" 733deb3ec6SMatthias Ringwald 743deb3ec6SMatthias Ringwald static const char default_hsp_hs_service_name[] = "Headset"; 753deb3ec6SMatthias Ringwald 763deb3ec6SMatthias Ringwald static bd_addr_t remote = {0x04, 0x0C, 0xCE, 0xE4, 0x85, 0xD3}; 773deb3ec6SMatthias Ringwald static uint8_t channel_nr = 0; 783deb3ec6SMatthias Ringwald 793deb3ec6SMatthias Ringwald static uint16_t mtu; 803deb3ec6SMatthias Ringwald static uint16_t rfcomm_cid = 0; 813deb3ec6SMatthias Ringwald static uint16_t sco_handle = 0; 823deb3ec6SMatthias Ringwald static uint16_t rfcomm_handle = 0; 833deb3ec6SMatthias Ringwald 843deb3ec6SMatthias Ringwald // static uint8_t connection_state = 0; 853deb3ec6SMatthias Ringwald 863deb3ec6SMatthias Ringwald static int hs_microphone_gain = -1; 873deb3ec6SMatthias Ringwald static int hs_speaker_gain = -1; 883deb3ec6SMatthias Ringwald 893deb3ec6SMatthias Ringwald static uint8_t hs_send_button_press = 0; 9099a10067SMatthias Ringwald static uint8_t wait_ok = 0; 913deb3ec6SMatthias Ringwald 9299a10067SMatthias Ringwald static uint8_t hs_support_custom_indications = 0; 93c5b64319SMatthias Ringwald static btstack_packet_callback_registration_t hci_event_callback_registration; 9499a10067SMatthias Ringwald static uint8_t hsp_disconnect_rfcomm = 0; 9599a10067SMatthias Ringwald static uint8_t hsp_establish_audio_connection = 0; 9699a10067SMatthias Ringwald static uint8_t hsp_release_audio_connection = 0; 97c5b64319SMatthias Ringwald 983deb3ec6SMatthias Ringwald typedef enum { 993deb3ec6SMatthias Ringwald HSP_IDLE, 1003deb3ec6SMatthias Ringwald HSP_SDP_QUERY_RFCOMM_CHANNEL, 10199a10067SMatthias Ringwald HSP_W4_SDP_QUERY_COMPLETE, 1023deb3ec6SMatthias Ringwald HSP_W4_RFCOMM_CONNECTED, 10399a10067SMatthias Ringwald 10499a10067SMatthias Ringwald HSP_RFCOMM_CONNECTION_ESTABLISHED, 10599a10067SMatthias Ringwald 1063deb3ec6SMatthias Ringwald HSP_W2_CONNECT_SCO, 1073deb3ec6SMatthias Ringwald HSP_W4_SCO_CONNECTED, 10899a10067SMatthias Ringwald 10999a10067SMatthias Ringwald HSP_AUDIO_CONNECTION_ESTABLISHED, 11099a10067SMatthias Ringwald 1113deb3ec6SMatthias Ringwald HSP_W2_DISCONNECT_SCO, 1123deb3ec6SMatthias Ringwald HSP_W4_SCO_DISCONNECTED, 11399a10067SMatthias Ringwald 1143deb3ec6SMatthias Ringwald HSP_W2_DISCONNECT_RFCOMM, 1153deb3ec6SMatthias Ringwald HSP_W4_RFCOMM_DISCONNECTED, 1163deb3ec6SMatthias Ringwald HSP_W4_CONNECTION_ESTABLISHED_TO_SHUTDOWN 1173deb3ec6SMatthias Ringwald } hsp_state_t; 1183deb3ec6SMatthias Ringwald 1193deb3ec6SMatthias Ringwald static hsp_state_t hsp_state = HSP_IDLE; 1203deb3ec6SMatthias Ringwald 1213deb3ec6SMatthias Ringwald static void hsp_run(void); 122e53943d7SMatthias Ringwald static void packet_handler (uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size); 1236c927b22SMatthias Ringwald static void handle_query_rfcomm_event(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size); 1243deb3ec6SMatthias Ringwald 1253deb3ec6SMatthias Ringwald static hsp_hs_callback_t hsp_hs_callback; 1263deb3ec6SMatthias Ringwald static void dummy_notify(uint8_t * event, uint16_t size){} 1273deb3ec6SMatthias Ringwald 1283deb3ec6SMatthias Ringwald void hsp_hs_register_packet_handler(hsp_hs_callback_t callback){ 1293deb3ec6SMatthias Ringwald if (callback == NULL){ 1303deb3ec6SMatthias Ringwald callback = &dummy_notify; 1313deb3ec6SMatthias Ringwald } 1323deb3ec6SMatthias Ringwald hsp_hs_callback = callback; 1333deb3ec6SMatthias Ringwald } 1343deb3ec6SMatthias Ringwald 1353deb3ec6SMatthias Ringwald static void emit_event(uint8_t event_subtype, uint8_t value){ 1363deb3ec6SMatthias Ringwald if (!hsp_hs_callback) return; 1373deb3ec6SMatthias Ringwald uint8_t event[4]; 1383deb3ec6SMatthias Ringwald event[0] = HCI_EVENT_HSP_META; 1393deb3ec6SMatthias Ringwald event[1] = sizeof(event) - 2; 1403deb3ec6SMatthias Ringwald event[2] = event_subtype; 1413deb3ec6SMatthias Ringwald event[3] = value; // status 0 == OK 1423deb3ec6SMatthias Ringwald (*hsp_hs_callback)(event, sizeof(event)); 1433deb3ec6SMatthias Ringwald } 1444af9a48dSMatthias Ringwald 145eda0480fSMatthias Ringwald static void emit_ring_event(void){ 146eda0480fSMatthias Ringwald if (!hsp_hs_callback) return; 147eda0480fSMatthias Ringwald uint8_t event[3]; 148eda0480fSMatthias Ringwald event[0] = HCI_EVENT_HSP_META; 149eda0480fSMatthias Ringwald event[1] = sizeof(event) - 2; 150eda0480fSMatthias Ringwald event[2] = HSP_SUBEVENT_RING; 151eda0480fSMatthias Ringwald (*hsp_hs_callback)(event, sizeof(event)); 152eda0480fSMatthias Ringwald } 153eda0480fSMatthias Ringwald 1544af9a48dSMatthias Ringwald static void emit_event_audio_connected(uint8_t status, uint16_t handle){ 1554af9a48dSMatthias Ringwald if (!hsp_hs_callback) return; 1564af9a48dSMatthias Ringwald uint8_t event[6]; 1574af9a48dSMatthias Ringwald event[0] = HCI_EVENT_HSP_META; 1584af9a48dSMatthias Ringwald event[1] = sizeof(event) - 2; 1594af9a48dSMatthias Ringwald event[2] = HSP_SUBEVENT_AUDIO_CONNECTION_COMPLETE; 1604af9a48dSMatthias Ringwald event[3] = status; 161f8fbdce0SMatthias Ringwald little_endian_store_16(event, 4, handle); 1624af9a48dSMatthias Ringwald (*hsp_hs_callback)(event, sizeof(event)); 1634af9a48dSMatthias Ringwald } 1644af9a48dSMatthias Ringwald 1653deb3ec6SMatthias Ringwald // remote audio volume control 1663deb3ec6SMatthias Ringwald // AG +VGM=13 [0..15] ; HS AT+VGM=6 | AG OK 1673deb3ec6SMatthias Ringwald 1683deb3ec6SMatthias Ringwald static int hsp_hs_send_str_over_rfcomm(uint16_t cid, const char * command){ 1693deb3ec6SMatthias Ringwald if (!rfcomm_can_send_packet_now(rfcomm_cid)) return 1; 17028190c0bSMatthias Ringwald int err = rfcomm_send(cid, (uint8_t*) command, strlen(command)); 1713deb3ec6SMatthias Ringwald if (err){ 172a0ffb263SMatthias Ringwald log_info("rfcomm_send_internal -> error 0X%02x", err); 1733deb3ec6SMatthias Ringwald } 1743deb3ec6SMatthias Ringwald return err; 1753deb3ec6SMatthias Ringwald } 1763deb3ec6SMatthias Ringwald 17766a048abSMatthias Ringwald void hsp_hs_enable_custom_indications(int enable){ 1783deb3ec6SMatthias Ringwald hs_support_custom_indications = enable; 1793deb3ec6SMatthias Ringwald } 1803deb3ec6SMatthias Ringwald 18166a048abSMatthias Ringwald int hsp_hs_send_result(const char * result){ 1823deb3ec6SMatthias Ringwald if (!hs_support_custom_indications) return 1; 1833deb3ec6SMatthias Ringwald return hsp_hs_send_str_over_rfcomm(rfcomm_cid, result); 1843deb3ec6SMatthias Ringwald } 1853deb3ec6SMatthias Ringwald 1863deb3ec6SMatthias Ringwald 1874758dd0fSMatthias Ringwald void hsp_hs_create_sdp_record(uint8_t * service, uint32_t service_record_handle, int rfcomm_channel_nr, const char * name, uint8_t have_remote_audio_control){ 1883deb3ec6SMatthias Ringwald uint8_t* attribute; 1893deb3ec6SMatthias Ringwald de_create_sequence(service); 1903deb3ec6SMatthias Ringwald 1913deb3ec6SMatthias Ringwald // 0x0000 "Service Record Handle" 1923deb3ec6SMatthias Ringwald de_add_number(service, DE_UINT, DE_SIZE_16, SDP_ServiceRecordHandle); 1934bcb6098SMatthias Ringwald de_add_number(service, DE_UINT, DE_SIZE_32, service_record_handle); 1943deb3ec6SMatthias Ringwald 1953deb3ec6SMatthias Ringwald // 0x0001 "Service Class ID List" 1963deb3ec6SMatthias Ringwald de_add_number(service, DE_UINT, DE_SIZE_16, SDP_ServiceClassIDList); 1973deb3ec6SMatthias Ringwald attribute = de_push_sequence(service); 1983deb3ec6SMatthias Ringwald { 199d210d9c4SMatthias Ringwald // see Bluetooth Erratum #3507 2003deb3ec6SMatthias Ringwald de_add_number(attribute, DE_UUID, DE_SIZE_16, SDP_HSP); // 0x1108 2013deb3ec6SMatthias Ringwald de_add_number(attribute, DE_UUID, DE_SIZE_16, SDP_Headset_HS); // 0x1131 2023deb3ec6SMatthias Ringwald de_add_number(attribute, DE_UUID, DE_SIZE_16, SDP_GenericAudio); // 0x1203 2033deb3ec6SMatthias Ringwald } 2043deb3ec6SMatthias Ringwald de_pop_sequence(service, attribute); 2053deb3ec6SMatthias Ringwald 2063deb3ec6SMatthias Ringwald // 0x0004 "Protocol Descriptor List" 2073deb3ec6SMatthias Ringwald de_add_number(service, DE_UINT, DE_SIZE_16, SDP_ProtocolDescriptorList); 2083deb3ec6SMatthias Ringwald attribute = de_push_sequence(service); 2093deb3ec6SMatthias Ringwald { 2103deb3ec6SMatthias Ringwald uint8_t* l2cpProtocol = de_push_sequence(attribute); 2113deb3ec6SMatthias Ringwald { 2123deb3ec6SMatthias Ringwald de_add_number(l2cpProtocol, DE_UUID, DE_SIZE_16, SDP_L2CAPProtocol); 2133deb3ec6SMatthias Ringwald } 2143deb3ec6SMatthias Ringwald de_pop_sequence(attribute, l2cpProtocol); 2153deb3ec6SMatthias Ringwald 2163deb3ec6SMatthias Ringwald uint8_t* rfcomm = de_push_sequence(attribute); 2173deb3ec6SMatthias Ringwald { 2183deb3ec6SMatthias Ringwald de_add_number(rfcomm, DE_UUID, DE_SIZE_16, SDP_RFCOMMProtocol); // rfcomm_service 2193deb3ec6SMatthias Ringwald de_add_number(rfcomm, DE_UINT, DE_SIZE_8, rfcomm_channel_nr); // rfcomm channel 2203deb3ec6SMatthias Ringwald } 2213deb3ec6SMatthias Ringwald de_pop_sequence(attribute, rfcomm); 2223deb3ec6SMatthias Ringwald } 2233deb3ec6SMatthias Ringwald de_pop_sequence(service, attribute); 2243deb3ec6SMatthias Ringwald 2253deb3ec6SMatthias Ringwald // 0x0005 "Public Browse Group" 2263deb3ec6SMatthias Ringwald de_add_number(service, DE_UINT, DE_SIZE_16, SDP_BrowseGroupList); // public browse group 2273deb3ec6SMatthias Ringwald attribute = de_push_sequence(service); 2283deb3ec6SMatthias Ringwald { 2293deb3ec6SMatthias Ringwald de_add_number(attribute, DE_UUID, DE_SIZE_16, SDP_PublicBrowseGroup); 2303deb3ec6SMatthias Ringwald } 2313deb3ec6SMatthias Ringwald de_pop_sequence(service, attribute); 2323deb3ec6SMatthias Ringwald 2333deb3ec6SMatthias Ringwald // 0x0009 "Bluetooth Profile Descriptor List" 2343deb3ec6SMatthias Ringwald de_add_number(service, DE_UINT, DE_SIZE_16, SDP_BluetoothProfileDescriptorList); 2353deb3ec6SMatthias Ringwald attribute = de_push_sequence(service); 2363deb3ec6SMatthias Ringwald { 237d210d9c4SMatthias Ringwald uint8_t *hsp_profile = de_push_sequence(attribute); 2383deb3ec6SMatthias Ringwald { 239d210d9c4SMatthias Ringwald de_add_number(hsp_profile, DE_UUID, DE_SIZE_16, SDP_HSP); 240d210d9c4SMatthias Ringwald de_add_number(hsp_profile, DE_UINT, DE_SIZE_16, 0x0102); // Verision 1.2 2413deb3ec6SMatthias Ringwald } 242d210d9c4SMatthias Ringwald de_pop_sequence(attribute, hsp_profile); 2433deb3ec6SMatthias Ringwald } 2443deb3ec6SMatthias Ringwald de_pop_sequence(service, attribute); 2453deb3ec6SMatthias Ringwald 2463deb3ec6SMatthias Ringwald // 0x0100 "Service Name" 2473deb3ec6SMatthias Ringwald de_add_number(service, DE_UINT, DE_SIZE_16, 0x0100); 2483deb3ec6SMatthias Ringwald if (name){ 2493deb3ec6SMatthias Ringwald de_add_data(service, DE_STRING, strlen(name), (uint8_t *) name); 2503deb3ec6SMatthias Ringwald } else { 2513deb3ec6SMatthias Ringwald de_add_data(service, DE_STRING, strlen(default_hsp_hs_service_name), (uint8_t *) default_hsp_hs_service_name); 2523deb3ec6SMatthias Ringwald } 2533deb3ec6SMatthias Ringwald 2543deb3ec6SMatthias Ringwald // Remote audio volume control 2553deb3ec6SMatthias Ringwald de_add_number(service, DE_UINT, DE_SIZE_16, 0x030C); 2563deb3ec6SMatthias Ringwald de_add_number(service, DE_BOOL, DE_SIZE_8, have_remote_audio_control); 2573deb3ec6SMatthias Ringwald } 2583deb3ec6SMatthias Ringwald 2593deb3ec6SMatthias Ringwald static void hsp_hs_reset_state(void){ 2603deb3ec6SMatthias Ringwald hsp_state = HSP_IDLE; 2613deb3ec6SMatthias Ringwald hs_microphone_gain = -1; 2623deb3ec6SMatthias Ringwald hs_speaker_gain = -1; 2633deb3ec6SMatthias Ringwald 2643deb3ec6SMatthias Ringwald hs_send_button_press = 0; 26599a10067SMatthias Ringwald wait_ok = 0; 2663deb3ec6SMatthias Ringwald hs_support_custom_indications = 0; 267*fffdd288SMatthias Ringwald 268*fffdd288SMatthias Ringwald hsp_disconnect_rfcomm = 0; 269*fffdd288SMatthias Ringwald hsp_establish_audio_connection = 0; 270*fffdd288SMatthias Ringwald hsp_release_audio_connection = 0; 2713deb3ec6SMatthias Ringwald } 2723deb3ec6SMatthias Ringwald 2733deb3ec6SMatthias Ringwald void hsp_hs_init(uint8_t rfcomm_channel_nr){ 274c5b64319SMatthias Ringwald // register for HCI events 275d9a7306aSMatthias Ringwald hci_event_callback_registration.callback = &packet_handler; 276c5b64319SMatthias Ringwald hci_add_event_handler(&hci_event_callback_registration); 277c5b64319SMatthias Ringwald 2783deb3ec6SMatthias Ringwald // init L2CAP 2793deb3ec6SMatthias Ringwald l2cap_init(); 2803deb3ec6SMatthias Ringwald 2813deb3ec6SMatthias Ringwald rfcomm_init(); 282ccb8ddfbSMatthias Ringwald rfcomm_register_service(packet_handler, rfcomm_channel_nr, 0xffff); // reserved channel, mtu limited by l2cap 2833deb3ec6SMatthias Ringwald 2843deb3ec6SMatthias Ringwald hsp_hs_reset_state(); 2853deb3ec6SMatthias Ringwald } 2863deb3ec6SMatthias Ringwald 2873deb3ec6SMatthias Ringwald 2883deb3ec6SMatthias Ringwald void hsp_hs_connect(bd_addr_t bd_addr){ 2893deb3ec6SMatthias Ringwald if (hsp_state != HSP_IDLE) return; 2903deb3ec6SMatthias Ringwald hsp_state = HSP_SDP_QUERY_RFCOMM_CHANNEL; 2913deb3ec6SMatthias Ringwald memcpy(remote, bd_addr, 6); 2923deb3ec6SMatthias Ringwald hsp_run(); 2933deb3ec6SMatthias Ringwald } 2943deb3ec6SMatthias Ringwald 29599a10067SMatthias Ringwald void hsp_hs_disconnect(void){ 29699a10067SMatthias Ringwald hsp_hs_release_audio_connection(); 29799a10067SMatthias Ringwald 29899a10067SMatthias Ringwald if (hsp_state < HSP_W4_RFCOMM_CONNECTED){ 29999a10067SMatthias Ringwald hsp_state = HSP_IDLE; 30099a10067SMatthias Ringwald return; 30199a10067SMatthias Ringwald } 30299a10067SMatthias Ringwald 30399a10067SMatthias Ringwald if (hsp_state == HSP_W4_RFCOMM_CONNECTED){ 30499a10067SMatthias Ringwald hsp_state = HSP_W4_CONNECTION_ESTABLISHED_TO_SHUTDOWN; 30599a10067SMatthias Ringwald return; 30699a10067SMatthias Ringwald } 30799a10067SMatthias Ringwald 30899a10067SMatthias Ringwald if (hsp_state < HSP_W4_SCO_CONNECTED){ 30999a10067SMatthias Ringwald hsp_state = HSP_W2_DISCONNECT_RFCOMM; 31099a10067SMatthias Ringwald return; 31199a10067SMatthias Ringwald } 31299a10067SMatthias Ringwald 31399a10067SMatthias Ringwald hsp_disconnect_rfcomm = 1; 31499a10067SMatthias Ringwald hsp_run(); 31599a10067SMatthias Ringwald } 31699a10067SMatthias Ringwald 31799a10067SMatthias Ringwald 31899a10067SMatthias Ringwald void hsp_hs_establish_audio_connection(void){ 3193deb3ec6SMatthias Ringwald switch (hsp_state){ 32099a10067SMatthias Ringwald case HSP_RFCOMM_CONNECTION_ESTABLISHED: 32199a10067SMatthias Ringwald hsp_establish_audio_connection = 1; 32299a10067SMatthias Ringwald hsp_state = HSP_W4_SCO_CONNECTED; 3233deb3ec6SMatthias Ringwald break; 3243deb3ec6SMatthias Ringwald case HSP_W4_RFCOMM_CONNECTED: 3253deb3ec6SMatthias Ringwald hsp_state = HSP_W4_CONNECTION_ESTABLISHED_TO_SHUTDOWN; 3263deb3ec6SMatthias Ringwald break; 3273deb3ec6SMatthias Ringwald default: 32899a10067SMatthias Ringwald break; 3293deb3ec6SMatthias Ringwald } 3303deb3ec6SMatthias Ringwald hsp_run(); 3313deb3ec6SMatthias Ringwald } 3323deb3ec6SMatthias Ringwald 33399a10067SMatthias Ringwald void hsp_hs_release_audio_connection(void){ 33499a10067SMatthias Ringwald if (hsp_state >= HSP_W2_DISCONNECT_SCO) return; 33599a10067SMatthias Ringwald if (hsp_state < HSP_AUDIO_CONNECTION_ESTABLISHED) return; 33699a10067SMatthias Ringwald hsp_release_audio_connection = 1; 33799a10067SMatthias Ringwald hsp_run(); 33899a10067SMatthias Ringwald } 3393deb3ec6SMatthias Ringwald 3403deb3ec6SMatthias Ringwald void hsp_hs_set_microphone_gain(uint8_t gain){ 3413deb3ec6SMatthias Ringwald if (gain < 0 || gain >15) { 342a0ffb263SMatthias Ringwald log_info("Gain must be in interval [0..15], it is given %d", gain); 3433deb3ec6SMatthias Ringwald return; 3443deb3ec6SMatthias Ringwald } 3453deb3ec6SMatthias Ringwald hs_microphone_gain = gain; 3463deb3ec6SMatthias Ringwald hsp_run(); 3473deb3ec6SMatthias Ringwald } 3483deb3ec6SMatthias Ringwald 3493deb3ec6SMatthias Ringwald // AG +VGS=5 [0..15] ; HS AT+VGM=6 | AG OK 3503deb3ec6SMatthias Ringwald void hsp_hs_set_speaker_gain(uint8_t gain){ 3513deb3ec6SMatthias Ringwald if (gain < 0 || gain >15) { 352a0ffb263SMatthias Ringwald log_info("Gain must be in interval [0..15], it is given %d", gain); 3533deb3ec6SMatthias Ringwald return; 3543deb3ec6SMatthias Ringwald } 3553deb3ec6SMatthias Ringwald hs_speaker_gain = gain; 3563deb3ec6SMatthias Ringwald hsp_run(); 3573deb3ec6SMatthias Ringwald } 3583deb3ec6SMatthias Ringwald 3593deb3ec6SMatthias Ringwald 3603deb3ec6SMatthias Ringwald static void hsp_run(void){ 36199a10067SMatthias Ringwald if (!rfcomm_can_send_packet_now(rfcomm_cid)) return; 36299a10067SMatthias Ringwald if (wait_ok) return; 36399a10067SMatthias Ringwald 36499a10067SMatthias Ringwald if (hsp_release_audio_connection){ 36599a10067SMatthias Ringwald hsp_release_audio_connection = 0; 36699a10067SMatthias Ringwald wait_ok = 1; 36799a10067SMatthias Ringwald hsp_hs_send_str_over_rfcomm(rfcomm_cid, HSP_HS_AT_CKPD); 36899a10067SMatthias Ringwald return; 36999a10067SMatthias Ringwald } 37099a10067SMatthias Ringwald 37199a10067SMatthias Ringwald if (hsp_disconnect_rfcomm){ 37299a10067SMatthias Ringwald hsp_disconnect_rfcomm = 0; 37399a10067SMatthias Ringwald hsp_establish_audio_connection = 0; 37499a10067SMatthias Ringwald rfcomm_disconnect(rfcomm_cid); 37599a10067SMatthias Ringwald return; 37699a10067SMatthias Ringwald } 37799a10067SMatthias Ringwald 37899a10067SMatthias Ringwald if (hsp_establish_audio_connection){ 37999a10067SMatthias Ringwald hsp_establish_audio_connection = 0; 38099a10067SMatthias Ringwald wait_ok = 1; 38199a10067SMatthias Ringwald hsp_hs_send_str_over_rfcomm(rfcomm_cid, HSP_HS_AT_CKPD); 38299a10067SMatthias Ringwald return; 38399a10067SMatthias Ringwald } 3843deb3ec6SMatthias Ringwald 3853deb3ec6SMatthias Ringwald if (hs_send_button_press){ 3863deb3ec6SMatthias Ringwald hs_send_button_press = 0; 38799a10067SMatthias Ringwald wait_ok = 1; 38899a10067SMatthias Ringwald hsp_hs_send_str_over_rfcomm(rfcomm_cid, HSP_HS_AT_CKPD); 3893deb3ec6SMatthias Ringwald return; 3903deb3ec6SMatthias Ringwald } 3913deb3ec6SMatthias Ringwald 3923deb3ec6SMatthias Ringwald switch (hsp_state){ 3933deb3ec6SMatthias Ringwald case HSP_SDP_QUERY_RFCOMM_CHANNEL: 39499a10067SMatthias Ringwald hsp_state = HSP_W4_SDP_QUERY_COMPLETE; 3957fbb5f59SMatthias Ringwald sdp_client_query_rfcomm_channel_and_name_for_uuid(&handle_query_rfcomm_event, remote, SDP_Headset_AG); 3963deb3ec6SMatthias Ringwald break; 3973deb3ec6SMatthias Ringwald 39899a10067SMatthias Ringwald case HSP_AUDIO_CONNECTION_ESTABLISHED: 39999a10067SMatthias Ringwald case HSP_RFCOMM_CONNECTION_ESTABLISHED: 4003deb3ec6SMatthias Ringwald 4013deb3ec6SMatthias Ringwald if (hs_microphone_gain >= 0){ 4023deb3ec6SMatthias Ringwald char buffer[20]; 40399a10067SMatthias Ringwald sprintf(buffer, "%s=%d\r\n", HSP_HS_MICROPHONE_GAIN, hs_microphone_gain); 40499a10067SMatthias Ringwald hsp_hs_send_str_over_rfcomm(rfcomm_cid, buffer); 40599a10067SMatthias Ringwald hs_microphone_gain = -1; 4063deb3ec6SMatthias Ringwald break; 4073deb3ec6SMatthias Ringwald } 4083deb3ec6SMatthias Ringwald 4093deb3ec6SMatthias Ringwald if (hs_speaker_gain >= 0){ 4103deb3ec6SMatthias Ringwald char buffer[20]; 41199a10067SMatthias Ringwald sprintf(buffer, "%s=%d\r\n", HSP_HS_SPEAKER_GAIN, hs_speaker_gain); 41299a10067SMatthias Ringwald hsp_hs_send_str_over_rfcomm(rfcomm_cid, buffer); 41399a10067SMatthias Ringwald hs_speaker_gain = -1; 4143deb3ec6SMatthias Ringwald break; 4153deb3ec6SMatthias Ringwald } 41699a10067SMatthias Ringwald break; 41799a10067SMatthias Ringwald case HSP_W4_RFCOMM_DISCONNECTED: 41899a10067SMatthias Ringwald rfcomm_disconnect(rfcomm_cid); 4193deb3ec6SMatthias Ringwald break; 4203deb3ec6SMatthias Ringwald default: 4213deb3ec6SMatthias Ringwald break; 4223deb3ec6SMatthias Ringwald } 4233deb3ec6SMatthias Ringwald } 4243deb3ec6SMatthias Ringwald 4253deb3ec6SMatthias Ringwald 426e53943d7SMatthias Ringwald static void packet_handler (uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 4273deb3ec6SMatthias Ringwald // printf("packet_handler type %u, packet[0] %x\n", packet_type, packet[0]); 4283deb3ec6SMatthias Ringwald if (packet_type == RFCOMM_DATA_PACKET){ 429f5054c00SMatthias Ringwald // skip over leading newline 4303deb3ec6SMatthias Ringwald while (size > 0 && (packet[0] == '\n' || packet[0] == '\r')){ 4313deb3ec6SMatthias Ringwald size--; 4323deb3ec6SMatthias Ringwald packet++; 4333deb3ec6SMatthias Ringwald } 4343deb3ec6SMatthias Ringwald if (strncmp((char *)packet, HSP_AG_RING, strlen(HSP_AG_RING)) == 0){ 435eda0480fSMatthias Ringwald emit_ring_event(); 436f5054c00SMatthias Ringwald } else if (strncmp((char *)packet, HSP_AG_OK, strlen(HSP_AG_OK)) == 0){ 43799a10067SMatthias Ringwald wait_ok = 0; 4383deb3ec6SMatthias Ringwald } else if (strncmp((char *)packet, HSP_MICROPHONE_GAIN, strlen(HSP_MICROPHONE_GAIN)) == 0){ 4393deb3ec6SMatthias Ringwald uint8_t gain = (uint8_t)atoi((char*)&packet[strlen(HSP_MICROPHONE_GAIN)]); 4403deb3ec6SMatthias Ringwald emit_event(HSP_SUBEVENT_MICROPHONE_GAIN_CHANGED, gain); 4413deb3ec6SMatthias Ringwald 4423deb3ec6SMatthias Ringwald } else if (strncmp((char *)packet, HSP_SPEAKER_GAIN, strlen(HSP_SPEAKER_GAIN)) == 0){ 4433deb3ec6SMatthias Ringwald uint8_t gain = (uint8_t)atoi((char*)&packet[strlen(HSP_SPEAKER_GAIN)]); 4443deb3ec6SMatthias Ringwald emit_event(HSP_SUBEVENT_SPEAKER_GAIN_CHANGED, gain); 4453deb3ec6SMatthias Ringwald } else { 4463deb3ec6SMatthias Ringwald if (!hsp_hs_callback) return; 447f5054c00SMatthias Ringwald // strip trailing newline 448f5054c00SMatthias Ringwald while (size > 0 && (packet[size-1] == '\n' || packet[size-1] == '\r')){ 449f5054c00SMatthias Ringwald size--; 450f5054c00SMatthias Ringwald } 451f5054c00SMatthias Ringwald // add trailing \0 452f5054c00SMatthias Ringwald packet[size] = 0; 4533deb3ec6SMatthias Ringwald // re-use incoming buffer to avoid reserving large buffers - ugly but efficient 454eda0480fSMatthias Ringwald uint8_t * event = packet - 4; 4553deb3ec6SMatthias Ringwald event[0] = HCI_EVENT_HSP_META; 456eda0480fSMatthias Ringwald event[1] = size + 2; 4573deb3ec6SMatthias Ringwald event[2] = HSP_SUBEVENT_AG_INDICATION; 458eda0480fSMatthias Ringwald event[3] = size; 459eda0480fSMatthias Ringwald (*hsp_hs_callback)(event, size+4); 4603deb3ec6SMatthias Ringwald } 4613deb3ec6SMatthias Ringwald hsp_run(); 4623deb3ec6SMatthias Ringwald return; 4633deb3ec6SMatthias Ringwald } 4643deb3ec6SMatthias Ringwald 4653deb3ec6SMatthias Ringwald if (packet_type != HCI_EVENT_PACKET) return; 4660e2df43fSMatthias Ringwald uint8_t event = hci_event_packet_get_type(packet); 4673deb3ec6SMatthias Ringwald bd_addr_t event_addr; 4683deb3ec6SMatthias Ringwald uint16_t handle; 4693deb3ec6SMatthias Ringwald 4703deb3ec6SMatthias Ringwald switch (event) { 4713deb3ec6SMatthias Ringwald case HCI_EVENT_SYNCHRONOUS_CONNECTION_COMPLETE:{ 47299a10067SMatthias Ringwald if (hsp_state < HSP_RFCOMM_CONNECTION_ESTABLISHED) return; 4733deb3ec6SMatthias Ringwald int index = 2; 4743deb3ec6SMatthias Ringwald uint8_t status = packet[index++]; 475f8fbdce0SMatthias Ringwald sco_handle = little_endian_read_16(packet, index); 4763deb3ec6SMatthias Ringwald index+=2; 4773deb3ec6SMatthias Ringwald bd_addr_t address; 4783deb3ec6SMatthias Ringwald memcpy(address, &packet[index], 6); 4793deb3ec6SMatthias Ringwald index+=6; 4803deb3ec6SMatthias Ringwald uint8_t link_type = packet[index++]; 4813deb3ec6SMatthias Ringwald uint8_t transmission_interval = packet[index++]; // measured in slots 4823deb3ec6SMatthias Ringwald uint8_t retransmission_interval = packet[index++];// measured in slots 483f8fbdce0SMatthias Ringwald uint16_t rx_packet_length = little_endian_read_16(packet, index); // measured in bytes 4843deb3ec6SMatthias Ringwald index+=2; 485f8fbdce0SMatthias Ringwald uint16_t tx_packet_length = little_endian_read_16(packet, index); // measured in bytes 4863deb3ec6SMatthias Ringwald index+=2; 4873deb3ec6SMatthias Ringwald uint8_t air_mode = packet[index]; 4883deb3ec6SMatthias Ringwald 4893deb3ec6SMatthias Ringwald if (status != 0){ 4904af9a48dSMatthias Ringwald log_error("(e)SCO Connection failed, status %u", status); 4914af9a48dSMatthias Ringwald emit_event_audio_connected(status, sco_handle); 49299a10067SMatthias Ringwald hsp_state = HSP_RFCOMM_CONNECTION_ESTABLISHED ; 4933deb3ec6SMatthias Ringwald break; 4943deb3ec6SMatthias Ringwald } 49599a10067SMatthias Ringwald 4963deb3ec6SMatthias Ringwald switch (link_type){ 4973deb3ec6SMatthias Ringwald case 0x00: 498a0ffb263SMatthias Ringwald log_info("SCO Connection established."); 4993deb3ec6SMatthias Ringwald if (transmission_interval != 0) log_error("SCO Connection: transmission_interval not zero: %d.", transmission_interval); 5003deb3ec6SMatthias Ringwald if (retransmission_interval != 0) log_error("SCO Connection: retransmission_interval not zero: %d.", retransmission_interval); 5013deb3ec6SMatthias Ringwald if (rx_packet_length != 0) log_error("SCO Connection: rx_packet_length not zero: %d.", rx_packet_length); 5023deb3ec6SMatthias Ringwald if (tx_packet_length != 0) log_error("SCO Connection: tx_packet_length not zero: %d.", tx_packet_length); 5033deb3ec6SMatthias Ringwald break; 5043deb3ec6SMatthias Ringwald case 0x02: 505a0ffb263SMatthias Ringwald log_info("eSCO Connection established."); 5063deb3ec6SMatthias Ringwald break; 5073deb3ec6SMatthias Ringwald default: 5083deb3ec6SMatthias Ringwald log_error("(e)SCO reserved link_type 0x%2x", link_type); 5093deb3ec6SMatthias Ringwald break; 5103deb3ec6SMatthias Ringwald } 5113deb3ec6SMatthias Ringwald log_info("sco_handle 0x%2x, address %s, transmission_interval %u slots, retransmission_interval %u slots, " 5123deb3ec6SMatthias Ringwald " rx_packet_length %u bytes, tx_packet_length %u bytes, air_mode 0x%2x (0x02 == CVSD)", sco_handle, 5133deb3ec6SMatthias Ringwald bd_addr_to_str(address), transmission_interval, retransmission_interval, rx_packet_length, tx_packet_length, air_mode); 5143deb3ec6SMatthias Ringwald 5153deb3ec6SMatthias Ringwald // forward event to app 5163deb3ec6SMatthias Ringwald hsp_hs_callback(packet, size); 5173deb3ec6SMatthias Ringwald 51899a10067SMatthias Ringwald hsp_state = HSP_AUDIO_CONNECTION_ESTABLISHED; 51999a10067SMatthias Ringwald emit_event_audio_connected(status, sco_handle); 5203deb3ec6SMatthias Ringwald break; 5213deb3ec6SMatthias Ringwald } 5223deb3ec6SMatthias Ringwald 5233deb3ec6SMatthias Ringwald case RFCOMM_EVENT_INCOMING_CONNECTION: 5243deb3ec6SMatthias Ringwald // data: event (8), len(8), address(48), channel (8), rfcomm_cid (16) 5253deb3ec6SMatthias Ringwald if (hsp_state != HSP_IDLE) return; 5263deb3ec6SMatthias Ringwald 527724d70a2SMatthias Ringwald reverse_bd_addr(&packet[2], event_addr); 528f8fbdce0SMatthias Ringwald rfcomm_cid = little_endian_read_16(packet, 9); 529a0ffb263SMatthias Ringwald log_info("RFCOMM channel %u requested for %s", packet[8], bd_addr_to_str(event_addr)); 5303deb3ec6SMatthias Ringwald hsp_state = HSP_W4_RFCOMM_CONNECTED; 53199a10067SMatthias Ringwald rfcomm_accept_connection(rfcomm_cid); 5323deb3ec6SMatthias Ringwald break; 5333deb3ec6SMatthias Ringwald 5343deb3ec6SMatthias Ringwald case RFCOMM_EVENT_OPEN_CHANNEL_COMPLETE: 535a0ffb263SMatthias Ringwald // printf("RFCOMM_EVENT_OPEN_CHANNEL_COMPLETE packet_handler type %u, packet[0] %x\n", packet_type, packet[0]); 5363deb3ec6SMatthias Ringwald // data: event(8), len(8), status (8), address (48), handle(16), server channel(8), rfcomm_cid(16), max frame size(16) 53799a10067SMatthias Ringwald if (hsp_state != HSP_W4_RFCOMM_CONNECTED) return; 5383deb3ec6SMatthias Ringwald if (packet[2]) { 539a0ffb263SMatthias Ringwald log_info("RFCOMM channel open failed, status %u", packet[2]); 54099a10067SMatthias Ringwald hsp_state = HSP_IDLE; 5413deb3ec6SMatthias Ringwald hsp_hs_reset_state(); 5423deb3ec6SMatthias Ringwald } else { 5433deb3ec6SMatthias Ringwald // data: event(8) , len(8), status (8), address (48), handle (16), server channel(8), rfcomm_cid(16), max frame size(16) 544f8fbdce0SMatthias Ringwald rfcomm_handle = little_endian_read_16(packet, 9); 545f8fbdce0SMatthias Ringwald rfcomm_cid = little_endian_read_16(packet, 12); 546f8fbdce0SMatthias Ringwald mtu = little_endian_read_16(packet, 14); 54799a10067SMatthias Ringwald log_info("RFCOMM channel open succeeded. New RFCOMM Channel ID %u, max frame size %u, handle %02x", rfcomm_cid, mtu, rfcomm_handle); 54899a10067SMatthias Ringwald hsp_state = HSP_RFCOMM_CONNECTION_ESTABLISHED; 549f5054c00SMatthias Ringwald } 55099a10067SMatthias Ringwald emit_event(HSP_SUBEVENT_RFCOMM_CONNECTION_COMPLETE, packet[2]); 5513deb3ec6SMatthias Ringwald break; 5521b89a84bSMatthias Ringwald 5531b89a84bSMatthias Ringwald case RFCOMM_EVENT_CAN_SEND_NOW: 5543deb3ec6SMatthias Ringwald hsp_hs_callback(packet, size); 5553deb3ec6SMatthias Ringwald break; 5563deb3ec6SMatthias Ringwald 5573deb3ec6SMatthias Ringwald case HCI_EVENT_DISCONNECTION_COMPLETE: 558f8fbdce0SMatthias Ringwald handle = little_endian_read_16(packet,3); 5593deb3ec6SMatthias Ringwald if (handle == sco_handle){ 5603deb3ec6SMatthias Ringwald sco_handle = 0; 56199a10067SMatthias Ringwald hsp_state = HSP_RFCOMM_CONNECTION_ESTABLISHED; 56299a10067SMatthias Ringwald emit_event(HSP_SUBEVENT_AUDIO_DISCONNECTION_COMPLETE,0); 5633deb3ec6SMatthias Ringwald break; 5643deb3ec6SMatthias Ringwald } 56599a10067SMatthias Ringwald if (handle == rfcomm_handle) { 56699a10067SMatthias Ringwald rfcomm_handle = 0; 56799a10067SMatthias Ringwald hsp_state = HSP_IDLE; 568*fffdd288SMatthias Ringwald emit_event(HSP_SUBEVENT_RFCOMM_DISCONNECTION_COMPLETE,0); 56999a10067SMatthias Ringwald hsp_hs_reset_state(); 57099a10067SMatthias Ringwald } 5713deb3ec6SMatthias Ringwald break; 5723deb3ec6SMatthias Ringwald case RFCOMM_EVENT_CHANNEL_CLOSED: 5733deb3ec6SMatthias Ringwald hsp_hs_reset_state(); 57499a10067SMatthias Ringwald hsp_hs_callback(packet, size); 5753deb3ec6SMatthias Ringwald break; 5763deb3ec6SMatthias Ringwald default: 5773deb3ec6SMatthias Ringwald break; 5783deb3ec6SMatthias Ringwald } 5793deb3ec6SMatthias Ringwald hsp_run(); 5803deb3ec6SMatthias Ringwald } 5813deb3ec6SMatthias Ringwald 5826c927b22SMatthias Ringwald static void handle_query_rfcomm_event(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 5830e2df43fSMatthias Ringwald switch (hci_event_packet_get_type(packet)){ 5845611a760SMatthias Ringwald case SDP_EVENT_QUERY_RFCOMM_SERVICE: 58572b50801SMatthias Ringwald channel_nr = sdp_event_query_rfcomm_service_get_rfcomm_channel(packet); 586d63c37a1SMatthias Ringwald log_info("** Service name: '%s', RFCOMM port %u", sdp_event_query_rfcomm_service_get_name(packet), channel_nr); 5873deb3ec6SMatthias Ringwald break; 5885611a760SMatthias Ringwald case SDP_EVENT_QUERY_COMPLETE: 5893deb3ec6SMatthias Ringwald if (channel_nr > 0){ 5903deb3ec6SMatthias Ringwald hsp_state = HSP_W4_RFCOMM_CONNECTED; 59199a10067SMatthias Ringwald log_info("HSP: SDP_QUERY_COMPLETE. RFCOMM create channel, addr %s, rfcomm channel nr %d", bd_addr_to_str(remote), channel_nr); 592ccb8ddfbSMatthias Ringwald rfcomm_create_channel(packet_handler, remote, channel_nr, NULL); 5933deb3ec6SMatthias Ringwald break; 5943deb3ec6SMatthias Ringwald } 5953deb3ec6SMatthias Ringwald hsp_hs_reset_state(); 596a0ffb263SMatthias Ringwald log_info("Service not found, status %u.", sdp_event_query_complete_get_status(packet)); 5973deb3ec6SMatthias Ringwald break; 5983deb3ec6SMatthias Ringwald } 5993deb3ec6SMatthias Ringwald } 6003deb3ec6SMatthias Ringwald 60166a048abSMatthias Ringwald void hsp_hs_send_button_press(void){ 60299a10067SMatthias Ringwald if (hsp_state < HSP_RFCOMM_CONNECTION_ESTABLISHED || hsp_state >= HSP_W4_RFCOMM_DISCONNECTED) return; 603f5054c00SMatthias Ringwald hs_send_button_press = 1; 604f5054c00SMatthias Ringwald hsp_run(); 605f5054c00SMatthias Ringwald } 606