164421eb6SMilanka Ringwald /* 264421eb6SMilanka Ringwald * Copyright (C) 2016 BlueKitchen GmbH 364421eb6SMilanka Ringwald * 464421eb6SMilanka Ringwald * Redistribution and use in source and binary forms, with or without 564421eb6SMilanka Ringwald * modification, are permitted provided that the following conditions 664421eb6SMilanka Ringwald * are met: 764421eb6SMilanka Ringwald * 864421eb6SMilanka Ringwald * 1. Redistributions of source code must retain the above copyright 964421eb6SMilanka Ringwald * notice, this list of conditions and the following disclaimer. 1064421eb6SMilanka Ringwald * 2. Redistributions in binary form must reproduce the above copyright 1164421eb6SMilanka Ringwald * notice, this list of conditions and the following disclaimer in the 1264421eb6SMilanka Ringwald * documentation and/or other materials provided with the distribution. 1364421eb6SMilanka Ringwald * 3. Neither the name of the copyright holders nor the names of 1464421eb6SMilanka Ringwald * contributors may be used to endorse or promote products derived 1564421eb6SMilanka Ringwald * from this software without specific prior written permission. 1664421eb6SMilanka Ringwald * 4. Any redistribution, use, or modification is done solely for 1764421eb6SMilanka Ringwald * personal benefit and not for any commercial purpose or for 1864421eb6SMilanka Ringwald * monetary gain. 1964421eb6SMilanka Ringwald * 2064421eb6SMilanka Ringwald * THIS SOFTWARE IS PROVIDED BY BLUEKITCHEN GMBH AND CONTRIBUTORS 2164421eb6SMilanka Ringwald * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 2264421eb6SMilanka Ringwald * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS 2364421eb6SMilanka Ringwald * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MATTHIAS 2464421eb6SMilanka Ringwald * RINGWALD OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 2564421eb6SMilanka Ringwald * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, 2664421eb6SMilanka Ringwald * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS 2764421eb6SMilanka Ringwald * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED 2864421eb6SMilanka Ringwald * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, 2964421eb6SMilanka Ringwald * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF 3064421eb6SMilanka Ringwald * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 3164421eb6SMilanka Ringwald * SUCH DAMAGE. 3264421eb6SMilanka Ringwald * 3364421eb6SMilanka Ringwald * Please inquire about commercial licensing options at 3464421eb6SMilanka Ringwald * [email protected] 3564421eb6SMilanka Ringwald * 3664421eb6SMilanka Ringwald */ 3764421eb6SMilanka Ringwald 38e501bae0SMatthias Ringwald #define BTSTACK_FILE__ "a2dp_sink_demo.c" 394dc98401SMilanka Ringwald 404dc98401SMilanka Ringwald /* 414dc98401SMilanka Ringwald * a2dp_sink_demo.c 424dc98401SMilanka Ringwald */ 434dc98401SMilanka Ringwald 444dc98401SMilanka Ringwald // ***************************************************************************** 456fa8d4c7SMilanka Ringwald /* EXAMPLE_START(a2dp_sink_demo): Receive audio stream and control its playback. 464dc98401SMilanka Ringwald * 474dc98401SMilanka Ringwald * @text This A2DP Sink example demonstrates how to use the A2DP Sink service to 484dc98401SMilanka Ringwald * receive an audio data stream from a remote A2DP Source device. In addition, 494dc98401SMilanka Ringwald * the AVRCP Controller is used to get information on currently played media, 504dc98401SMilanka Ringwald * such are title, artist and album, as well as to control the playback, 514dc98401SMilanka Ringwald * i.e. to play, stop, repeat, etc. 52d5e631f6SMilanka Ringwald * 53d5e631f6SMilanka Ringwald * @test To test with a remote device, e.g. a mobile phone, 54d5e631f6SMilanka Ringwald * pair from the remote device with the demo, then start playing music on the remote device. 55d5e631f6SMilanka Ringwald * Alternatively, set the device_addr_string to the Bluetooth address of your 56d5e631f6SMilanka Ringwald * remote device in the code, and call connect from the UI. 57d5e631f6SMilanka Ringwald * 58d5e631f6SMilanka Ringwald * @test To controll the playback, tap SPACE on the console to show the available 59d5e631f6SMilanka Ringwald * AVRCP commands. 606ff556f6SMilanka Ringwald * 616ff556f6SMilanka Ringwald * For more info on BTstack audio, see our blog post 626ff556f6SMilanka Ringwald * [A2DP Sink and Source on STM32 F4 Discovery Board](http://bluekitchen-gmbh.com/a2dp-sink-and-source-on-stm32-f4-discovery-board/). 636ff556f6SMilanka Ringwald * 644dc98401SMilanka Ringwald */ 654dc98401SMilanka Ringwald // ***************************************************************************** 6664421eb6SMilanka Ringwald 67173fff9bSMatthias Ringwald #include <inttypes.h> 6864421eb6SMilanka Ringwald #include <stdint.h> 6964421eb6SMilanka Ringwald #include <stdio.h> 7064421eb6SMilanka Ringwald #include <stdlib.h> 7164421eb6SMilanka Ringwald #include <string.h> 7264421eb6SMilanka Ringwald 7301dc6e35SMilanka Ringwald #include "btstack.h" 74e9c5f44eSMatthias Ringwald #include "btstack_resample.h" 7564421eb6SMilanka Ringwald 764f0111ebSMilanka Ringwald //#define AVRCP_BROWSING_ENABLED 7764421eb6SMilanka Ringwald 7864421eb6SMilanka Ringwald #ifdef HAVE_BTSTACK_STDIN 7964421eb6SMilanka Ringwald #include "btstack_stdin.h" 8064421eb6SMilanka Ringwald #endif 8164421eb6SMilanka Ringwald 8264421eb6SMilanka Ringwald #include "btstack_ring_buffer.h" 8364421eb6SMilanka Ringwald 8464421eb6SMilanka Ringwald #ifdef HAVE_POSIX_FILE_IO 8564421eb6SMilanka Ringwald #include "wav_util.h" 86492f2541SMilanka Ringwald #define STORE_TO_SBC_FILE 879045ed00SMilanka Ringwald #define STORE_TO_WAV_FILE 8864421eb6SMilanka Ringwald #endif 8964421eb6SMilanka Ringwald 9064421eb6SMilanka Ringwald #define NUM_CHANNELS 2 9164421eb6SMilanka Ringwald #define BYTES_PER_FRAME (2*NUM_CHANNELS) 9264421eb6SMilanka Ringwald #define MAX_SBC_FRAME_SIZE 120 9364421eb6SMilanka Ringwald 94b23b09a5SMatthias Ringwald // SBC Decoder for WAV file or live playback 9564421eb6SMilanka Ringwald static btstack_sbc_decoder_state_t state; 9664421eb6SMilanka Ringwald static btstack_sbc_mode_t mode = SBC_MODE_STANDARD; 9764421eb6SMilanka Ringwald 98b23b09a5SMatthias Ringwald // ring buffer for SBC Frames 9964421eb6SMilanka Ringwald // below 30: add samples, 30-40: fine, above 40: drop samples 10064421eb6SMilanka Ringwald #define OPTIMAL_FRAMES_MIN 30 10164421eb6SMilanka Ringwald #define OPTIMAL_FRAMES_MAX 40 102e9c5f44eSMatthias Ringwald #define ADDITIONAL_FRAMES 20 103b23b09a5SMatthias Ringwald static uint8_t sbc_frame_storage[(OPTIMAL_FRAMES_MAX + ADDITIONAL_FRAMES) * MAX_SBC_FRAME_SIZE]; 104b23b09a5SMatthias Ringwald static btstack_ring_buffer_t sbc_frame_ring_buffer; 105b23b09a5SMatthias Ringwald static unsigned int sbc_frame_size; 10664421eb6SMilanka Ringwald 107e9c5f44eSMatthias Ringwald // rest buffer for not fully used sbc frames, with additional frames for resampling 108e9c5f44eSMatthias Ringwald static uint8_t decoded_audio_storage[(128+16) * BYTES_PER_FRAME]; 109b23b09a5SMatthias Ringwald static btstack_ring_buffer_t decoded_audio_ring_buffer; 110b23b09a5SMatthias Ringwald 111b23b09a5SMatthias Ringwald // 112b23b09a5SMatthias Ringwald static int audio_stream_started; 113b23b09a5SMatthias Ringwald 114b23b09a5SMatthias Ringwald // temp storage of lower-layer request 115b23b09a5SMatthias Ringwald static int16_t * request_buffer; 116e9c5f44eSMatthias Ringwald static int request_frames; 117e9c5f44eSMatthias Ringwald 118e9c5f44eSMatthias Ringwald #define STORE_FROM_PLAYBACK 11964421eb6SMilanka Ringwald 12064421eb6SMilanka Ringwald // WAV File 1219045ed00SMilanka Ringwald #ifdef STORE_TO_WAV_FILE 1225c99b5e7SMatthias Ringwald static uint32_t audio_frame_count = 0; 1235c99b5e7SMatthias Ringwald static char * wav_filename = "av2dp_sink_demo.wav"; 12464421eb6SMilanka Ringwald #endif 12564421eb6SMilanka Ringwald 126492f2541SMilanka Ringwald #ifdef STORE_TO_SBC_FILE 12764421eb6SMilanka Ringwald static FILE * sbc_file; 1285c99b5e7SMatthias Ringwald static char * sbc_filename = "av2dp_sink_demo.sbc"; 12964421eb6SMilanka Ringwald #endif 13064421eb6SMilanka Ringwald 131f55e1e38SMilanka Ringwald static int volume_percentage = 0; 132f55e1e38SMilanka Ringwald 13364421eb6SMilanka Ringwald typedef struct { 13464421eb6SMilanka Ringwald // bitmaps 13564421eb6SMilanka Ringwald uint8_t sampling_frequency_bitmap; 13664421eb6SMilanka Ringwald uint8_t channel_mode_bitmap; 13764421eb6SMilanka Ringwald uint8_t block_length_bitmap; 13864421eb6SMilanka Ringwald uint8_t subbands_bitmap; 13964421eb6SMilanka Ringwald uint8_t allocation_method_bitmap; 14064421eb6SMilanka Ringwald uint8_t min_bitpool_value; 14164421eb6SMilanka Ringwald uint8_t max_bitpool_value; 14264421eb6SMilanka Ringwald } adtvp_media_codec_information_sbc_t; 14364421eb6SMilanka Ringwald 14464421eb6SMilanka Ringwald typedef struct { 14564421eb6SMilanka Ringwald int reconfigure; 14664421eb6SMilanka Ringwald int num_channels; 14764421eb6SMilanka Ringwald int sampling_frequency; 14864421eb6SMilanka Ringwald int channel_mode; 14964421eb6SMilanka Ringwald int block_length; 15064421eb6SMilanka Ringwald int subbands; 15164421eb6SMilanka Ringwald int allocation_method; 15264421eb6SMilanka Ringwald int min_bitpool_value; 15364421eb6SMilanka Ringwald int max_bitpool_value; 15464421eb6SMilanka Ringwald int frames_per_buffer; 15564421eb6SMilanka Ringwald } avdtp_media_codec_configuration_sbc_t; 15664421eb6SMilanka Ringwald 15714e3e2c2SMilanka Ringwald static uint8_t events_num = 1; 15814e3e2c2SMilanka Ringwald 15914e3e2c2SMilanka Ringwald static uint8_t events[] = { 16014e3e2c2SMilanka Ringwald AVRCP_NOTIFICATION_EVENT_VOLUME_CHANGED 16114e3e2c2SMilanka Ringwald }; 16214e3e2c2SMilanka Ringwald 16314e3e2c2SMilanka Ringwald static uint8_t companies_num = 1; 16414e3e2c2SMilanka Ringwald static uint8_t companies[] = { 16514e3e2c2SMilanka Ringwald 0x00, 0x19, 0x58 //BT SIG registered CompanyID 16614e3e2c2SMilanka Ringwald }; 16764421eb6SMilanka Ringwald #ifdef HAVE_BTSTACK_STDIN 1688b94010eSMilanka Ringwald // pts: 1698b94010eSMilanka Ringwald static const char * device_addr_string = "00:1B:DC:08:E2:72"; 1705e3d4d2bSMilanka Ringwald // mac 2013: static const char * device_addr_string = "84:38:35:65:d1:15"; 171b23b09a5SMatthias Ringwald // iPhone 5S: 1728b94010eSMilanka Ringwald // static const char * device_addr_string = "54:E4:3A:26:A2:39"; 17364421eb6SMilanka Ringwald #endif 17464421eb6SMilanka Ringwald 17564421eb6SMilanka Ringwald static uint8_t sdp_avdtp_sink_service_buffer[150]; 17614e3e2c2SMilanka Ringwald static uint8_t sdp_avrcp_target_service_buffer[150]; 17764421eb6SMilanka Ringwald static avdtp_media_codec_configuration_sbc_t sbc_configuration; 1784567cc17SMilanka Ringwald static uint16_t a2dp_cid = 0; 179f55e1e38SMilanka Ringwald static uint8_t a2dp_local_seid = 0; 1801bf7a74fSMilanka Ringwald static uint8_t value[100]; 1817050d2caSMilanka Ringwald 18264421eb6SMilanka Ringwald static btstack_packet_callback_registration_t hci_event_callback_registration; 18364421eb6SMilanka Ringwald 18464421eb6SMilanka Ringwald static int media_initialized = 0; 18564421eb6SMilanka Ringwald 1864fb249f8SMatthias Ringwald #ifdef HAVE_BTSTACK_STDIN 18764421eb6SMilanka Ringwald static bd_addr_t device_addr; 1884fb249f8SMatthias Ringwald #endif 1894fb249f8SMatthias Ringwald 19014e3e2c2SMilanka Ringwald static uint16_t avrcp_controller_cid = 0; 19114e3e2c2SMilanka Ringwald static uint16_t avrcp_target_cid = 0; 1926c333d06SMilanka Ringwald static uint8_t avrcp_connected = 0; 19364421eb6SMilanka Ringwald static uint8_t sdp_avrcp_controller_service_buffer[200]; 19464421eb6SMilanka Ringwald 1954dc98401SMilanka Ringwald static uint8_t media_sbc_codec_capabilities[] = { 1964dc98401SMilanka Ringwald 0xFF,//(AVDTP_SBC_44100 << 4) | AVDTP_SBC_STEREO, 1974dc98401SMilanka Ringwald 0xFF,//(AVDTP_SBC_BLOCK_LENGTH_16 << 4) | (AVDTP_SBC_SUBBANDS_8 << 2) | AVDTP_SBC_ALLOCATION_METHOD_LOUDNESS, 1984dc98401SMilanka Ringwald 2, 53 1994dc98401SMilanka Ringwald }; 2004dc98401SMilanka Ringwald 2014dc98401SMilanka Ringwald static uint8_t media_sbc_codec_configuration[] = { 2024dc98401SMilanka Ringwald (AVDTP_SBC_44100 << 4) | AVDTP_SBC_STEREO, 2034dc98401SMilanka Ringwald (AVDTP_SBC_BLOCK_LENGTH_16 << 4) | (AVDTP_SBC_SUBBANDS_8 << 2) | AVDTP_SBC_ALLOCATION_METHOD_LOUDNESS, 2044dc98401SMilanka Ringwald 2, 53 2054dc98401SMilanka Ringwald }; 2064dc98401SMilanka Ringwald 207e9c5f44eSMatthias Ringwald static btstack_resample_t resample_instance; 2084dc98401SMilanka Ringwald 2094dc98401SMilanka Ringwald /* @section Main Application Setup 2104dc98401SMilanka Ringwald * 2114dc98401SMilanka Ringwald * @text The Listing MainConfiguration shows how to setup AD2P Sink and AVRCP controller services. 2124dc98401SMilanka Ringwald * To announce A2DP Sink and AVRCP Controller services, you need to create corresponding 2134dc98401SMilanka Ringwald * SDP records and register them with the SDP service. 2144dc98401SMilanka Ringwald * You'll also need to register several packet handlers: 2154dc98401SMilanka Ringwald * - a2dp_sink_packet_handler - handles events on stream connection status (established, released), the media codec configuration, and, the status of the stream itself (opened, paused, stopped). 2169045ed00SMilanka Ringwald * - handle_l2cap_media_data_packet - used to receive streaming data. If STORE_TO_WAV_FILE directive (check btstack_config.h) is used, the SBC decoder will be used to decode the SBC data into PCM frames. The resulting PCM frames are then processed in the SBC Decoder callback. 2174dc98401SMilanka Ringwald * - stdin_process callback - used to trigger AVRCP commands to the A2DP Source device, such are get now playing info, start, stop, volume control. Requires HAVE_BTSTACK_STDIN. 2184dc98401SMilanka Ringwald * - avrcp_controller_packet_handler - used to receive answers for AVRCP commands, 2194dc98401SMilanka Ringwald * 2204dc98401SMilanka Ringwald * @text Note, currently only the SBC codec is supported. 2219045ed00SMilanka Ringwald * If you want to store the audio data in a file, you'll need to define STORE_TO_WAV_FILE. 2229045ed00SMilanka Ringwald * If STORE_TO_WAV_FILE directive is defined, the SBC decoder needs to get initialized when a2dp_sink_packet_handler receives event A2DP_SUBEVENT_STREAM_STARTED. 2234dc98401SMilanka Ringwald * The initialization of the SBC decoder requires a callback that handles PCM data: 2249045ed00SMilanka Ringwald * - handle_pcm_data - handles PCM audio frames. Here, they are stored a in wav file if STORE_TO_WAV_FILE is defined, and/or played using the audio library. 2254dc98401SMilanka Ringwald */ 2264dc98401SMilanka Ringwald 2276fa8d4c7SMilanka Ringwald /* LISTING_START(MainConfiguration): Setup Audio Sink and AVRCP Controller services */ 2284dc98401SMilanka Ringwald static void a2dp_sink_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t * event, uint16_t event_size); 2294dc98401SMilanka Ringwald static void avrcp_controller_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size); 23014e3e2c2SMilanka Ringwald static void avrcp_target_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size); 231b23b09a5SMatthias Ringwald static void hci_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size); 2324dc98401SMilanka Ringwald static void handle_l2cap_media_data_packet(uint8_t seid, uint8_t *packet, uint16_t size); 2334dc98401SMilanka Ringwald 234b23b09a5SMatthias Ringwald static int a2dp_and_avrcp_setup(void){ 235b23b09a5SMatthias Ringwald 2364dc98401SMilanka Ringwald l2cap_init(); 237b23b09a5SMatthias Ringwald // Initialize AVDTP Sink 2384dc98401SMilanka Ringwald a2dp_sink_init(); 2394dc98401SMilanka Ringwald a2dp_sink_register_packet_handler(&a2dp_sink_packet_handler); 2404dc98401SMilanka Ringwald a2dp_sink_register_media_handler(&handle_l2cap_media_data_packet); 241b23b09a5SMatthias Ringwald 2428b94010eSMilanka Ringwald avdtp_stream_endpoint_t * local_stream_endpoint = a2dp_sink_create_stream_endpoint(AVDTP_AUDIO, 243f55e1e38SMilanka Ringwald AVDTP_CODEC_SBC, media_sbc_codec_capabilities, sizeof(media_sbc_codec_capabilities), 2448b94010eSMilanka Ringwald media_sbc_codec_configuration, sizeof(media_sbc_codec_configuration)); 2458b94010eSMilanka Ringwald if (!local_stream_endpoint){ 2464dc98401SMilanka Ringwald printf("A2DP Sink: not enough memory to create local stream endpoint\n"); 2474dc98401SMilanka Ringwald return 1; 2484dc98401SMilanka Ringwald } 2498b94010eSMilanka Ringwald a2dp_local_seid = avdtp_local_seid(local_stream_endpoint); 250*19691e0aSMilanka Ringwald 251*19691e0aSMilanka Ringwald // Initialize AVRCP service. 252*19691e0aSMilanka Ringwald avrcp_init(); 253*19691e0aSMilanka Ringwald 25414e3e2c2SMilanka Ringwald // Initialize AVRCP Controller 2554dc98401SMilanka Ringwald avrcp_controller_init(); 2564dc98401SMilanka Ringwald avrcp_controller_register_packet_handler(&avrcp_controller_packet_handler); 2574dc98401SMilanka Ringwald 25814e3e2c2SMilanka Ringwald // Initialize AVRCP Target 25914e3e2c2SMilanka Ringwald avrcp_target_init(); 26014e3e2c2SMilanka Ringwald avrcp_target_register_packet_handler(&avrcp_target_packet_handler); 26114e3e2c2SMilanka Ringwald 262b23b09a5SMatthias Ringwald // Initialize SDP 2634dc98401SMilanka Ringwald sdp_init(); 264b23b09a5SMatthias Ringwald // setup AVDTP sink 2654dc98401SMilanka Ringwald memset(sdp_avdtp_sink_service_buffer, 0, sizeof(sdp_avdtp_sink_service_buffer)); 2664dc98401SMilanka Ringwald a2dp_sink_create_sdp_record(sdp_avdtp_sink_service_buffer, 0x10001, 1, NULL, NULL); 2674dc98401SMilanka Ringwald sdp_register_service(sdp_avdtp_sink_service_buffer); 2684dc98401SMilanka Ringwald 26914e3e2c2SMilanka Ringwald // setup AVRCP Controller 2704dc98401SMilanka Ringwald memset(sdp_avrcp_controller_service_buffer, 0, sizeof(sdp_avrcp_controller_service_buffer)); 271a62edf8aSMilanka Ringwald uint16_t controller_supported_features = (1 << AVRCP_CONTROLLER_SUPPORTED_FEATURE_CATEGORY_PLAYER_OR_RECORDER); 2724f0111ebSMilanka Ringwald #ifdef AVRCP_BROWSING_ENABLED 27314e3e2c2SMilanka Ringwald controller_supported_features |= (1 << AVRCP_CONTROLLER_SUPPORTED_FEATURE_BROWSING); 2744f0111ebSMilanka Ringwald #endif 27514e3e2c2SMilanka Ringwald avrcp_controller_create_sdp_record(sdp_avrcp_controller_service_buffer, 0x10002, controller_supported_features, NULL, NULL); 2764dc98401SMilanka Ringwald sdp_register_service(sdp_avrcp_controller_service_buffer); 2774dc98401SMilanka Ringwald 27814e3e2c2SMilanka Ringwald // setup AVRCP Target 27914e3e2c2SMilanka Ringwald memset(sdp_avrcp_target_service_buffer, 0, sizeof(sdp_avrcp_target_service_buffer)); 28014e3e2c2SMilanka Ringwald uint16_t target_supported_features = (1 << AVRCP_TARGET_SUPPORTED_FEATURE_CATEGORY_MONITOR_OR_AMPLIFIER); 28114e3e2c2SMilanka Ringwald avrcp_target_create_sdp_record(sdp_avrcp_target_service_buffer, 0x10003, target_supported_features, NULL, NULL); 28214e3e2c2SMilanka Ringwald sdp_register_service(sdp_avrcp_target_service_buffer); 28314e3e2c2SMilanka Ringwald 2844dc98401SMilanka Ringwald gap_set_local_name("A2DP Sink Demo 00:00:00:00:00:00"); 2854dc98401SMilanka Ringwald gap_discoverable_control(1); 2864dc98401SMilanka Ringwald gap_set_class_of_device(0x200408); 2874dc98401SMilanka Ringwald 288a4fe6467SMatthias Ringwald /* Register for HCI events */ 289a4fe6467SMatthias Ringwald hci_event_callback_registration.callback = &hci_packet_handler; 290a4fe6467SMatthias Ringwald hci_add_event_handler(&hci_event_callback_registration); 291a4fe6467SMatthias Ringwald 2921bf4f2abSMilanka Ringwald #ifdef HAVE_POSIX_FILE_IO 2931bf4f2abSMilanka Ringwald if (!btstack_audio_sink_get_instance()){ 2941bf4f2abSMilanka Ringwald printf("No audio playback.\n"); 2951bf4f2abSMilanka Ringwald } else { 2961bf4f2abSMilanka Ringwald printf("Audio playback supported.\n"); 2971bf4f2abSMilanka Ringwald } 2989045ed00SMilanka Ringwald #ifdef STORE_TO_WAV_FILE 2991bf4f2abSMilanka Ringwald printf("Audio will be stored to \'%s\' file.\n", wav_filename); 3001bf4f2abSMilanka Ringwald #endif 3011bf4f2abSMilanka Ringwald #endif 3024dc98401SMilanka Ringwald return 0; 3034dc98401SMilanka Ringwald } 3044dc98401SMilanka Ringwald 3055c99b5e7SMatthias Ringwald static void playback_handler(int16_t * buffer, uint16_t num_audio_frames){ 306e9c5f44eSMatthias Ringwald 3079045ed00SMilanka Ringwald #ifdef STORE_TO_WAV_FILE 3085c99b5e7SMatthias Ringwald int wav_samples = num_audio_frames * NUM_CHANNELS; 309e9c5f44eSMatthias Ringwald int16_t * wav_buffer = buffer; 310e9c5f44eSMatthias Ringwald #endif 31164421eb6SMilanka Ringwald 312b23b09a5SMatthias Ringwald // called from lower-layer but guaranteed to be on main thread 3131bf4f2abSMilanka Ringwald if (sbc_frame_size == 0){ 3145c99b5e7SMatthias Ringwald memset(buffer, 0, num_audio_frames * BYTES_PER_FRAME); 3151bf4f2abSMilanka Ringwald return; 3161bf4f2abSMilanka Ringwald } 3171bf4f2abSMilanka Ringwald 318e9c5f44eSMatthias Ringwald // first fill from resampled audio 319b23b09a5SMatthias Ringwald uint32_t bytes_read; 3205c99b5e7SMatthias Ringwald btstack_ring_buffer_read(&decoded_audio_ring_buffer, (uint8_t *) buffer, num_audio_frames * BYTES_PER_FRAME, &bytes_read); 321b23b09a5SMatthias Ringwald buffer += bytes_read / NUM_CHANNELS; 3225c99b5e7SMatthias Ringwald num_audio_frames -= bytes_read / BYTES_PER_FRAME; 32364421eb6SMilanka Ringwald 324b23b09a5SMatthias Ringwald // then start decoding sbc frames using request_* globals 325b23b09a5SMatthias Ringwald request_buffer = buffer; 3265c99b5e7SMatthias Ringwald request_frames = num_audio_frames; 327bcbbbb42SMatthias Ringwald while (request_frames && btstack_ring_buffer_bytes_available(&sbc_frame_ring_buffer) >= sbc_frame_size){ 328b23b09a5SMatthias Ringwald // decode frame 329e9c5f44eSMatthias Ringwald uint8_t sbc_frame[MAX_SBC_FRAME_SIZE]; 330e9c5f44eSMatthias Ringwald btstack_ring_buffer_read(&sbc_frame_ring_buffer, sbc_frame, sbc_frame_size, &bytes_read); 331e9c5f44eSMatthias Ringwald btstack_sbc_decoder_process_data(&state, 0, sbc_frame, sbc_frame_size); 332b23b09a5SMatthias Ringwald } 33364421eb6SMilanka Ringwald 3349045ed00SMilanka Ringwald #ifdef STORE_TO_WAV_FILE 3355c99b5e7SMatthias Ringwald audio_frame_count += num_audio_frames; 336e9c5f44eSMatthias Ringwald wav_writer_write_int16(wav_samples, wav_buffer); 337e9c5f44eSMatthias Ringwald #endif 338e9c5f44eSMatthias Ringwald } 339e9c5f44eSMatthias Ringwald 3405c99b5e7SMatthias Ringwald static void handle_pcm_data(int16_t * data, int num_audio_frames, int num_channels, int sample_rate, void * context){ 341b23b09a5SMatthias Ringwald UNUSED(sample_rate); 342b23b09a5SMatthias Ringwald UNUSED(context); 343b23b09a5SMatthias Ringwald UNUSED(num_channels); // must be stereo == 2 344b23b09a5SMatthias Ringwald 3459045ed00SMilanka Ringwald const btstack_audio_sink_t * audio_sink = btstack_audio_sink_get_instance(); 3469045ed00SMilanka Ringwald if (!audio_sink){ 3479045ed00SMilanka Ringwald #ifdef STORE_TO_WAV_FILE 3485c99b5e7SMatthias Ringwald audio_frame_count += num_audio_frames; 3495c99b5e7SMatthias Ringwald wav_writer_write_int16(num_audio_frames * NUM_CHANNELS, data); 35064421eb6SMilanka Ringwald #endif 3519045ed00SMilanka Ringwald return; 3529045ed00SMilanka Ringwald } 35364421eb6SMilanka Ringwald 354e9c5f44eSMatthias Ringwald // resample into request buffer - add some additional space for resampling 355e9c5f44eSMatthias Ringwald int16_t output_buffer[(128+16) * NUM_CHANNELS]; // 16 * 8 * 2 3565c99b5e7SMatthias Ringwald uint32_t resampled_frames = btstack_resample_block(&resample_instance, data, num_audio_frames, output_buffer); 357b23b09a5SMatthias Ringwald 358b23b09a5SMatthias Ringwald // store data in btstack_audio buffer first 359e9c5f44eSMatthias Ringwald int frames_to_copy = btstack_min(resampled_frames, request_frames); 360e9c5f44eSMatthias Ringwald memcpy(request_buffer, output_buffer, frames_to_copy * BYTES_PER_FRAME); 361e9c5f44eSMatthias Ringwald request_frames -= frames_to_copy; 362e9c5f44eSMatthias Ringwald request_buffer += frames_to_copy * NUM_CHANNELS; 363b23b09a5SMatthias Ringwald 364b23b09a5SMatthias Ringwald // and rest in ring buffer 365e9c5f44eSMatthias Ringwald int frames_to_store = resampled_frames - frames_to_copy; 366e9c5f44eSMatthias Ringwald if (frames_to_store){ 367e9c5f44eSMatthias Ringwald int status = btstack_ring_buffer_write(&decoded_audio_ring_buffer, (uint8_t *)&output_buffer[frames_to_copy * NUM_CHANNELS], frames_to_store * BYTES_PER_FRAME); 368e9c5f44eSMatthias Ringwald if (status){ 369e9c5f44eSMatthias Ringwald printf("Error storing samples in PCM ring buffer!!!\n"); 370b23b09a5SMatthias Ringwald } 371b23b09a5SMatthias Ringwald } 372b23b09a5SMatthias Ringwald } 373b23b09a5SMatthias Ringwald 37464421eb6SMilanka Ringwald static int media_processing_init(avdtp_media_codec_configuration_sbc_t configuration){ 375c63d45a5SMatthias Ringwald if (media_initialized) return 0; 376b23b09a5SMatthias Ringwald 37764421eb6SMilanka Ringwald btstack_sbc_decoder_init(&state, mode, handle_pcm_data, NULL); 37864421eb6SMilanka Ringwald 3799045ed00SMilanka Ringwald #ifdef STORE_TO_WAV_FILE 38064421eb6SMilanka Ringwald wav_writer_open(wav_filename, configuration.num_channels, configuration.sampling_frequency); 38164421eb6SMilanka Ringwald #endif 38264421eb6SMilanka Ringwald 383492f2541SMilanka Ringwald #ifdef STORE_TO_SBC_FILE 38464421eb6SMilanka Ringwald sbc_file = fopen(sbc_filename, "wb"); 38564421eb6SMilanka Ringwald #endif 38664421eb6SMilanka Ringwald 387b23b09a5SMatthias Ringwald btstack_ring_buffer_init(&sbc_frame_ring_buffer, sbc_frame_storage, sizeof(sbc_frame_storage)); 388b23b09a5SMatthias Ringwald btstack_ring_buffer_init(&decoded_audio_ring_buffer, decoded_audio_storage, sizeof(decoded_audio_storage)); 389e9c5f44eSMatthias Ringwald btstack_resample_init(&resample_instance, configuration.num_channels); 39064421eb6SMilanka Ringwald 391b23b09a5SMatthias Ringwald // setup audio playback 392e39d945bSDirk Helbig const btstack_audio_sink_t * audio = btstack_audio_sink_get_instance(); 393b23b09a5SMatthias Ringwald if (audio){ 394e39d945bSDirk Helbig audio->init(NUM_CHANNELS, configuration.sampling_frequency, &playback_handler); 39564421eb6SMilanka Ringwald } 39664421eb6SMilanka Ringwald 39764421eb6SMilanka Ringwald audio_stream_started = 0; 39864421eb6SMilanka Ringwald media_initialized = 1; 39964421eb6SMilanka Ringwald return 0; 40064421eb6SMilanka Ringwald } 40164421eb6SMilanka Ringwald 4021bf4f2abSMilanka Ringwald static void media_processing_start(void){ 4031bf4f2abSMilanka Ringwald if (!media_initialized) return; 4041bf4f2abSMilanka Ringwald // setup audio playback 4051bf4f2abSMilanka Ringwald const btstack_audio_sink_t * audio = btstack_audio_sink_get_instance(); 4061bf4f2abSMilanka Ringwald if (audio){ 4071bf4f2abSMilanka Ringwald audio->start_stream(); 4081bf4f2abSMilanka Ringwald } 4091bf4f2abSMilanka Ringwald audio_stream_started = 1; 4101bf4f2abSMilanka Ringwald } 41132ea0426SMatthias Ringwald 4121bf4f2abSMilanka Ringwald static void media_processing_pause(void){ 4131bf4f2abSMilanka Ringwald if (!media_initialized) return; 4141bf4f2abSMilanka Ringwald // stop audio playback 4151bf4f2abSMilanka Ringwald audio_stream_started = 0; 4161bf4f2abSMilanka Ringwald const btstack_audio_sink_t * audio = btstack_audio_sink_get_instance(); 4171bf4f2abSMilanka Ringwald if (audio){ 4181bf4f2abSMilanka Ringwald audio->stop_stream(); 4191bf4f2abSMilanka Ringwald } 4201bf4f2abSMilanka Ringwald } 4211bf4f2abSMilanka Ringwald 4221bf4f2abSMilanka Ringwald static void media_processing_close(void){ 42364421eb6SMilanka Ringwald if (!media_initialized) return; 42464421eb6SMilanka Ringwald media_initialized = 0; 425b23b09a5SMatthias Ringwald audio_stream_started = 0; 4261bf4f2abSMilanka Ringwald sbc_frame_size = 0; 427c63d45a5SMatthias Ringwald 4289045ed00SMilanka Ringwald #ifdef STORE_TO_WAV_FILE 42964421eb6SMilanka Ringwald wav_writer_close(); 4305c99b5e7SMatthias Ringwald uint32_t total_frames_nr = state.good_frames_nr + state.bad_frames_nr + state.zero_frames_nr; 43164421eb6SMilanka Ringwald 4325c99b5e7SMatthias Ringwald printf("WAV Writer: Decoding done. Processed %u SBC frames:\n - %d good\n - %d bad\n", total_frames_nr, state.good_frames_nr, total_frames_nr - state.good_frames_nr); 4335c99b5e7SMatthias Ringwald printf("WAV Writer: Wrote %u audio frames to wav file: %s\n", audio_frame_count, wav_filename); 43464421eb6SMilanka Ringwald #endif 435c63d45a5SMatthias Ringwald 436492f2541SMilanka Ringwald #ifdef STORE_TO_SBC_FILE 43764421eb6SMilanka Ringwald fclose(sbc_file); 43864421eb6SMilanka Ringwald #endif 43964421eb6SMilanka Ringwald 440b23b09a5SMatthias Ringwald // stop audio playback 441e39d945bSDirk Helbig const btstack_audio_sink_t * audio = btstack_audio_sink_get_instance(); 442b23b09a5SMatthias Ringwald if (audio){ 4431bf4f2abSMilanka Ringwald printf("close stream\n"); 444b23b09a5SMatthias Ringwald audio->close(); 44564421eb6SMilanka Ringwald } 44664421eb6SMilanka Ringwald } 4474dc98401SMilanka Ringwald 4484dc98401SMilanka Ringwald /* @section Handle Media Data Packet 4494dc98401SMilanka Ringwald * 4504dc98401SMilanka Ringwald * @text Media data packets, in this case the audio data, are received through the handle_l2cap_media_data_packet callback. 4514dc98401SMilanka Ringwald * Currently, only the SBC media codec is supported. Hence, the media data consists of the media packet header and the SBC packet. 452b23b09a5SMatthias Ringwald * The SBC frame will be stored in a ring buffer for later processing (instead of decoding it to PCM right away which would require a much larger buffer) 453b23b09a5SMatthias Ringwald * If the audio stream wasn't started already and there are enough SBC frames in the ring buffer, start playback. 4544dc98401SMilanka Ringwald */ 4554dc98401SMilanka Ringwald 4564dc98401SMilanka Ringwald static int read_media_data_header(uint8_t * packet, int size, int * offset, avdtp_media_packet_header_t * media_header); 4574dc98401SMilanka Ringwald static int read_sbc_header(uint8_t * packet, int size, int * offset, avdtp_sbc_codec_header_t * sbc_header); 4584dc98401SMilanka Ringwald 459fd58c900SMilanka Ringwald static void handle_l2cap_media_data_packet(uint8_t seid, uint8_t *packet, uint16_t size){ 460fd58c900SMilanka Ringwald UNUSED(seid); 46164421eb6SMilanka Ringwald int pos = 0; 46264421eb6SMilanka Ringwald 46364421eb6SMilanka Ringwald avdtp_media_packet_header_t media_header; 4644dc98401SMilanka Ringwald if (!read_media_data_header(packet, size, &pos, &media_header)) return; 46564421eb6SMilanka Ringwald 46664421eb6SMilanka Ringwald avdtp_sbc_codec_header_t sbc_header; 4674dc98401SMilanka Ringwald if (!read_sbc_header(packet, size, &pos, &sbc_header)) return; 46864421eb6SMilanka Ringwald 469492f2541SMilanka Ringwald #ifdef STORE_TO_SBC_FILE 470492f2541SMilanka Ringwald fwrite(packet+pos, size-pos, 1, sbc_file); 471492f2541SMilanka Ringwald #endif 47232ea0426SMatthias Ringwald 473492f2541SMilanka Ringwald const btstack_audio_sink_t * audio = btstack_audio_sink_get_instance(); 47432ea0426SMatthias Ringwald // process data right away if there's no audio implementation active, e.g. on posix systems to store as .wav 47532ea0426SMatthias Ringwald if (!audio){ 47632ea0426SMatthias Ringwald btstack_sbc_decoder_process_data(&state, 0, packet+pos, size-pos); 47732ea0426SMatthias Ringwald return; 47832ea0426SMatthias Ringwald } 47932ea0426SMatthias Ringwald 48064421eb6SMilanka Ringwald // store sbc frame size for buffer management 48164421eb6SMilanka Ringwald sbc_frame_size = (size-pos)/ sbc_header.num_frames; 48264421eb6SMilanka Ringwald 483e9c5f44eSMatthias Ringwald int status = btstack_ring_buffer_write(&sbc_frame_ring_buffer, packet+pos, size-pos); 484e9c5f44eSMatthias Ringwald if (status){ 485e9c5f44eSMatthias Ringwald printf("Error storing samples in SBC ring buffer!!!\n"); 486e9c5f44eSMatthias Ringwald } 48764421eb6SMilanka Ringwald 48864421eb6SMilanka Ringwald // decide on audio sync drift based on number of sbc frames in queue 489b23b09a5SMatthias Ringwald int sbc_frames_in_buffer = btstack_ring_buffer_bytes_available(&sbc_frame_ring_buffer) / sbc_frame_size; 490e9c5f44eSMatthias Ringwald uint32_t resampling_factor; 491c5fccf8bSMatthias Ringwald 492c5fccf8bSMatthias Ringwald // nomimal factor (fixed-point 2^16) and compensation offset 493f2597df9SMatthias Ringwald uint32_t nomimal_factor = 0x10000; 494c5fccf8bSMatthias Ringwald uint32_t compensation = 0x00100; 495c5fccf8bSMatthias Ringwald 49664421eb6SMilanka Ringwald if (sbc_frames_in_buffer < OPTIMAL_FRAMES_MIN){ 497c5fccf8bSMatthias Ringwald resampling_factor = nomimal_factor - compensation; // stretch samples 49864421eb6SMilanka Ringwald } else if (sbc_frames_in_buffer <= OPTIMAL_FRAMES_MAX){ 499c5fccf8bSMatthias Ringwald resampling_factor = nomimal_factor; // nothing to do 50064421eb6SMilanka Ringwald } else { 501c5fccf8bSMatthias Ringwald resampling_factor = nomimal_factor + compensation; // compress samples 50264421eb6SMilanka Ringwald } 50364421eb6SMilanka Ringwald 504e9c5f44eSMatthias Ringwald btstack_resample_set_factor(&resample_instance, resampling_factor); 505e9c5f44eSMatthias Ringwald 50664421eb6SMilanka Ringwald // dump 507f55e1e38SMilanka Ringwald // printf("%6u %03u %05x\n", (int) btstack_run_loop_get_time_ms(), sbc_frames_in_buffer, resampling_factor); 508e9c5f44eSMatthias Ringwald // log_info("%03u %05x", sbc_frames_in_buffer, resampling_factor); 50964421eb6SMilanka Ringwald 510b23b09a5SMatthias Ringwald // start stream if enough frames buffered 511e9c5f44eSMatthias Ringwald if (!audio_stream_started && sbc_frames_in_buffer >= OPTIMAL_FRAMES_MIN){ 5124dc98401SMilanka Ringwald audio_stream_started = 1; 513b23b09a5SMatthias Ringwald // setup audio playback 514b23b09a5SMatthias Ringwald if (audio){ 515b23b09a5SMatthias Ringwald audio->start_stream(); 5164dc98401SMilanka Ringwald } 5174dc98401SMilanka Ringwald } 5184dc98401SMilanka Ringwald } 5194dc98401SMilanka Ringwald 5204dc98401SMilanka Ringwald static int read_sbc_header(uint8_t * packet, int size, int * offset, avdtp_sbc_codec_header_t * sbc_header){ 5214dc98401SMilanka Ringwald int sbc_header_len = 12; // without crc 5224dc98401SMilanka Ringwald int pos = *offset; 5234dc98401SMilanka Ringwald 5244dc98401SMilanka Ringwald if (size - pos < sbc_header_len){ 5254dc98401SMilanka Ringwald printf("Not enough data to read SBC header, expected %d, received %d\n", sbc_header_len, size-pos); 5263290eaa8SMilanka Ringwald return 0; 5274dc98401SMilanka Ringwald } 5284dc98401SMilanka Ringwald 5294dc98401SMilanka Ringwald sbc_header->fragmentation = get_bit16(packet[pos], 7); 5304dc98401SMilanka Ringwald sbc_header->starting_packet = get_bit16(packet[pos], 6); 5314dc98401SMilanka Ringwald sbc_header->last_packet = get_bit16(packet[pos], 5); 5324dc98401SMilanka Ringwald sbc_header->num_frames = packet[pos] & 0x0f; 5334dc98401SMilanka Ringwald pos++; 5344dc98401SMilanka Ringwald // printf("SBC HEADER: num_frames %u, fragmented %u, start %u, stop %u\n", sbc_header.num_frames, sbc_header.fragmentation, sbc_header.starting_packet, sbc_header.last_packet); 5354dc98401SMilanka Ringwald *offset = pos; 5363290eaa8SMilanka Ringwald return 1; 5374dc98401SMilanka Ringwald } 5384dc98401SMilanka Ringwald 5394dc98401SMilanka Ringwald static int read_media_data_header(uint8_t *packet, int size, int *offset, avdtp_media_packet_header_t *media_header){ 5404dc98401SMilanka Ringwald int media_header_len = 12; // without crc 5414dc98401SMilanka Ringwald int pos = *offset; 5424dc98401SMilanka Ringwald 5434dc98401SMilanka Ringwald if (size - pos < media_header_len){ 5444dc98401SMilanka Ringwald printf("Not enough data to read media packet header, expected %d, received %d\n", media_header_len, size-pos); 5453290eaa8SMilanka Ringwald return 0; 5464dc98401SMilanka Ringwald } 5474dc98401SMilanka Ringwald 5484dc98401SMilanka Ringwald media_header->version = packet[pos] & 0x03; 5494dc98401SMilanka Ringwald media_header->padding = get_bit16(packet[pos],2); 5504dc98401SMilanka Ringwald media_header->extension = get_bit16(packet[pos],3); 5514dc98401SMilanka Ringwald media_header->csrc_count = (packet[pos] >> 4) & 0x0F; 5524dc98401SMilanka Ringwald pos++; 5534dc98401SMilanka Ringwald 5544dc98401SMilanka Ringwald media_header->marker = get_bit16(packet[pos],0); 5554dc98401SMilanka Ringwald media_header->payload_type = (packet[pos] >> 1) & 0x7F; 5564dc98401SMilanka Ringwald pos++; 5574dc98401SMilanka Ringwald 5584dc98401SMilanka Ringwald media_header->sequence_number = big_endian_read_16(packet, pos); 5594dc98401SMilanka Ringwald pos+=2; 5604dc98401SMilanka Ringwald 5614dc98401SMilanka Ringwald media_header->timestamp = big_endian_read_32(packet, pos); 5624dc98401SMilanka Ringwald pos+=4; 5634dc98401SMilanka Ringwald 5644dc98401SMilanka Ringwald media_header->synchronization_source = big_endian_read_32(packet, pos); 5654dc98401SMilanka Ringwald pos+=4; 5664dc98401SMilanka Ringwald *offset = pos; 5673290eaa8SMilanka Ringwald return 1; 5684dc98401SMilanka Ringwald } 5694dc98401SMilanka Ringwald 57064421eb6SMilanka Ringwald static void dump_sbc_configuration(avdtp_media_codec_configuration_sbc_t configuration){ 57164421eb6SMilanka Ringwald printf(" - num_channels: %d\n", configuration.num_channels); 57264421eb6SMilanka Ringwald printf(" - sampling_frequency: %d\n", configuration.sampling_frequency); 57364421eb6SMilanka Ringwald printf(" - channel_mode: %d\n", configuration.channel_mode); 57464421eb6SMilanka Ringwald printf(" - block_length: %d\n", configuration.block_length); 57564421eb6SMilanka Ringwald printf(" - subbands: %d\n", configuration.subbands); 57664421eb6SMilanka Ringwald printf(" - allocation_method: %d\n", configuration.allocation_method); 57764421eb6SMilanka Ringwald printf(" - bitpool_value [%d, %d] \n", configuration.min_bitpool_value, configuration.max_bitpool_value); 578f1042e9dSMilanka Ringwald printf("\n"); 57964421eb6SMilanka Ringwald } 58064421eb6SMilanka Ringwald 58101dc6e35SMilanka Ringwald static void avrcp_controller_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 58264421eb6SMilanka Ringwald UNUSED(channel); 58364421eb6SMilanka Ringwald UNUSED(size); 58464421eb6SMilanka Ringwald uint16_t local_cid; 58564421eb6SMilanka Ringwald uint8_t status = 0xFF; 586ef5ad9d6SMilanka Ringwald bd_addr_t adress; 58701dc6e35SMilanka Ringwald 58801dc6e35SMilanka Ringwald if (packet_type != HCI_EVENT_PACKET) return; 58901dc6e35SMilanka Ringwald if (hci_event_packet_get_type(packet) != HCI_EVENT_AVRCP_META) return; 59064421eb6SMilanka Ringwald switch (packet[2]){ 59164421eb6SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_ESTABLISHED: { 59264421eb6SMilanka Ringwald local_cid = avrcp_subevent_connection_established_get_avrcp_cid(packet); 59314e3e2c2SMilanka Ringwald if (avrcp_controller_cid != 0 && avrcp_controller_cid != local_cid) { 594f386e134SMilanka Ringwald printf("AVRCP Controller: Connection failed, expected 0x%02X cid, received 0x%02X\n", avrcp_controller_cid, local_cid); 595df642728SMilanka Ringwald return; 59664421eb6SMilanka Ringwald } 59764421eb6SMilanka Ringwald 59864421eb6SMilanka Ringwald status = avrcp_subevent_connection_established_get_status(packet); 59964421eb6SMilanka Ringwald if (status != ERROR_CODE_SUCCESS){ 60014e3e2c2SMilanka Ringwald printf("AVRCP Controller: Connection failed: status 0x%02x\n", status); 60114e3e2c2SMilanka Ringwald avrcp_controller_cid = 0; 602df642728SMilanka Ringwald return; 60364421eb6SMilanka Ringwald } 6044b338011SMilanka Ringwald 60514e3e2c2SMilanka Ringwald avrcp_controller_cid = local_cid; 6066c333d06SMilanka Ringwald avrcp_connected = 1; 607ef5ad9d6SMilanka Ringwald avrcp_subevent_connection_established_get_bd_addr(packet, adress); 608f386e134SMilanka Ringwald printf("AVRCP Controller: Connected to %s, cid 0x%02x\n", bd_addr_to_str(adress), avrcp_controller_cid); 609df642728SMilanka Ringwald 61064421eb6SMilanka Ringwald // automatically enable notifications 61114e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_PLAYBACK_STATUS_CHANGED); 61214e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_NOW_PLAYING_CONTENT_CHANGED); 61314e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_TRACK_CHANGED); 61464421eb6SMilanka Ringwald return; 61564421eb6SMilanka Ringwald } 61664421eb6SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_RELEASED: 617f386e134SMilanka Ringwald printf("AVRCP Controller: Channel released: cid 0x%02x\n", avrcp_subevent_connection_released_get_avrcp_cid(packet)); 61814e3e2c2SMilanka Ringwald avrcp_controller_cid = 0; 6196c333d06SMilanka Ringwald avrcp_connected = 0; 62064421eb6SMilanka Ringwald return; 62164421eb6SMilanka Ringwald default: 62264421eb6SMilanka Ringwald break; 62364421eb6SMilanka Ringwald } 62464421eb6SMilanka Ringwald 62564421eb6SMilanka Ringwald status = packet[5]; 62614e3e2c2SMilanka Ringwald if (!avrcp_controller_cid) return; 62764421eb6SMilanka Ringwald 6284dc98401SMilanka Ringwald // ignore INTERIM status 6298177fff3SMilanka Ringwald if (status == AVRCP_CTYPE_RESPONSE_INTERIM){ 6306fa3dbf2SMilanka Ringwald switch (packet[2]){ 6316fa3dbf2SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_PLAYBACK_POS_CHANGED:{ 6326fa3dbf2SMilanka Ringwald uint32_t playback_position_ms = avrcp_subevent_notification_playback_pos_changed_get_playback_position_ms(packet); 6336fa3dbf2SMilanka Ringwald if (playback_position_ms == AVRCP_NO_TRACK_SELECTED_PLAYBACK_POSITION_CHANGED){ 634f55e1e38SMilanka Ringwald printf("AVRCP Controller: playback position changed, no track is selected\n"); 6356fa3dbf2SMilanka Ringwald } 6366fa3dbf2SMilanka Ringwald break; 6376fa3dbf2SMilanka Ringwald } 6386fa3dbf2SMilanka Ringwald default: 6396fa3dbf2SMilanka Ringwald break; 6406fa3dbf2SMilanka Ringwald } 6418177fff3SMilanka Ringwald return; 6428177fff3SMilanka Ringwald } 64364421eb6SMilanka Ringwald 64414e3e2c2SMilanka Ringwald memset(value, 0, sizeof(value)); 64564421eb6SMilanka Ringwald switch (packet[2]){ 6466fa3dbf2SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_PLAYBACK_POS_CHANGED: 6471bf4f2abSMilanka Ringwald printf("AVRCP Controller: Playback position changed, position %d ms\n", (unsigned int) avrcp_subevent_notification_playback_pos_changed_get_playback_position_ms(packet)); 6486fa3dbf2SMilanka Ringwald break; 64964421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_PLAYBACK_STATUS_CHANGED: 6501bf4f2abSMilanka Ringwald printf("AVRCP Controller: Playback status changed %s\n", avrcp_play_status2str(avrcp_subevent_notification_playback_status_changed_get_play_status(packet))); 65164421eb6SMilanka Ringwald return; 65264421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_NOW_PLAYING_CONTENT_CHANGED: 6531bf4f2abSMilanka Ringwald printf("AVRCP Controller: Playing content changed\n"); 65464421eb6SMilanka Ringwald return; 65564421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_TRACK_CHANGED: 6561bf4f2abSMilanka Ringwald printf("AVRCP Controller: Track changed\n"); 65764421eb6SMilanka Ringwald return; 65864421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_VOLUME_CHANGED: 6591bf4f2abSMilanka Ringwald printf("AVRCP Controller: Absolute volume changed %d\n", avrcp_subevent_notification_volume_changed_get_absolute_volume(packet)); 66064421eb6SMilanka Ringwald return; 66164421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_AVAILABLE_PLAYERS_CHANGED: 6621bf4f2abSMilanka Ringwald printf("AVRCP Controller: Changed\n"); 66364421eb6SMilanka Ringwald return; 66464421eb6SMilanka Ringwald case AVRCP_SUBEVENT_SHUFFLE_AND_REPEAT_MODE:{ 66564421eb6SMilanka Ringwald uint8_t shuffle_mode = avrcp_subevent_shuffle_and_repeat_mode_get_shuffle_mode(packet); 66664421eb6SMilanka Ringwald uint8_t repeat_mode = avrcp_subevent_shuffle_and_repeat_mode_get_repeat_mode(packet); 667f55e1e38SMilanka Ringwald printf("AVRCP Controller: %s, %s\n", avrcp_shuffle2str(shuffle_mode), avrcp_repeat2str(repeat_mode)); 66864421eb6SMilanka Ringwald break; 66964421eb6SMilanka Ringwald } 67014e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_TRACK_INFO: 671f55e1e38SMilanka Ringwald printf("AVRCP Controller: Track: %d\n", avrcp_subevent_now_playing_track_info_get_track(packet)); 67214e3e2c2SMilanka Ringwald break; 67314e3e2c2SMilanka Ringwald 67414e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_TOTAL_TRACKS_INFO: 675f55e1e38SMilanka Ringwald printf("AVRCP Controller: Total Tracks: %d\n", avrcp_subevent_now_playing_total_tracks_info_get_total_tracks(packet)); 67614e3e2c2SMilanka Ringwald break; 67714e3e2c2SMilanka Ringwald 6781bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_TITLE_INFO: 6791bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_title_info_get_value_len(packet) > 0){ 6801bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_title_info_get_value(packet), avrcp_subevent_now_playing_title_info_get_value_len(packet)); 681f55e1e38SMilanka Ringwald printf("AVRCP Controller: Title: %s\n", value); 68264421eb6SMilanka Ringwald } 68364421eb6SMilanka Ringwald break; 6841bf7a74fSMilanka Ringwald 6851bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_ARTIST_INFO: 6861bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_artist_info_get_value_len(packet) > 0){ 6871bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_artist_info_get_value(packet), avrcp_subevent_now_playing_artist_info_get_value_len(packet)); 688f55e1e38SMilanka Ringwald printf("AVRCP Controller: Artist: %s\n", value); 68964421eb6SMilanka Ringwald } 6901bf7a74fSMilanka Ringwald break; 6911bf7a74fSMilanka Ringwald 6921bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_ALBUM_INFO: 6931bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_album_info_get_value_len(packet) > 0){ 6941bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_album_info_get_value(packet), avrcp_subevent_now_playing_album_info_get_value_len(packet)); 695f55e1e38SMilanka Ringwald printf("AVRCP Controller: Album: %s\n", value); 6961bf7a74fSMilanka Ringwald } 6971bf7a74fSMilanka Ringwald break; 6981bf7a74fSMilanka Ringwald 6991bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_GENRE_INFO: 7001bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_genre_info_get_value_len(packet) > 0){ 7011bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_genre_info_get_value(packet), avrcp_subevent_now_playing_genre_info_get_value_len(packet)); 702f55e1e38SMilanka Ringwald printf("AVRCP Controller: Genre: %s\n", value); 7031bf7a74fSMilanka Ringwald } 7041bf7a74fSMilanka Ringwald break; 7051bf7a74fSMilanka Ringwald 70664421eb6SMilanka Ringwald case AVRCP_SUBEVENT_PLAY_STATUS: 707f386e134SMilanka Ringwald printf("AVRCP Controller: Song length %"PRIu32" ms, Song position %"PRIu32" ms, Play status %s\n", 70864421eb6SMilanka Ringwald avrcp_subevent_play_status_get_song_length(packet), 70964421eb6SMilanka Ringwald avrcp_subevent_play_status_get_song_position(packet), 71064421eb6SMilanka Ringwald avrcp_play_status2str(avrcp_subevent_play_status_get_play_status(packet))); 71164421eb6SMilanka Ringwald break; 712f386e134SMilanka Ringwald 71364421eb6SMilanka Ringwald case AVRCP_SUBEVENT_OPERATION_COMPLETE: 714f386e134SMilanka Ringwald printf("AVRCP Controller: %s done\n", avrcp_operation2str(avrcp_subevent_operation_complete_get_operation_id(packet))); 71564421eb6SMilanka Ringwald break; 716f386e134SMilanka Ringwald 71764421eb6SMilanka Ringwald case AVRCP_SUBEVENT_OPERATION_START: 718f386e134SMilanka Ringwald printf("AVRCP Controller: Start %s\n", avrcp_operation2str(avrcp_subevent_operation_complete_get_operation_id(packet))); 71964421eb6SMilanka Ringwald break; 720f386e134SMilanka Ringwald 72164421eb6SMilanka Ringwald default: 7221bf4f2abSMilanka Ringwald printf("AVRCP Controller: Event 0x%02x is not parsed\n", packet[2]); 72364421eb6SMilanka Ringwald break; 72464421eb6SMilanka Ringwald } 72564421eb6SMilanka Ringwald } 72664421eb6SMilanka Ringwald 72714e3e2c2SMilanka Ringwald 72814e3e2c2SMilanka Ringwald static void avrcp_target_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 72914e3e2c2SMilanka Ringwald UNUSED(channel); 73014e3e2c2SMilanka Ringwald UNUSED(size); 731f386e134SMilanka Ringwald bd_addr_t address; 73214e3e2c2SMilanka Ringwald uint16_t local_cid; 73314e3e2c2SMilanka Ringwald uint8_t status = ERROR_CODE_SUCCESS; 73414e3e2c2SMilanka Ringwald 73514e3e2c2SMilanka Ringwald if (packet_type != HCI_EVENT_PACKET) return; 73614e3e2c2SMilanka Ringwald if (hci_event_packet_get_type(packet) != HCI_EVENT_AVRCP_META) return; 73714e3e2c2SMilanka Ringwald 738f55e1e38SMilanka Ringwald int volume; 739f55e1e38SMilanka Ringwald 74014e3e2c2SMilanka Ringwald switch (packet[2]){ 74114e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_VOLUME_CHANGED: 742f55e1e38SMilanka Ringwald volume = avrcp_subevent_notification_volume_changed_get_absolute_volume(packet); 743f55e1e38SMilanka Ringwald volume_percentage = volume * 100 / 127; 744f386e134SMilanka Ringwald printf("AVRCP Target : Volume set to %d%% (%d)\n", volume_percentage, volume); 74514e3e2c2SMilanka Ringwald break; 74614e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_ESTABLISHED: 74714e3e2c2SMilanka Ringwald local_cid = avrcp_subevent_connection_established_get_avrcp_cid(packet); 74814e3e2c2SMilanka Ringwald if (avrcp_target_cid != 0 && avrcp_target_cid != local_cid) { 749f386e134SMilanka Ringwald printf("AVRCP Target : Connection failed, expected 0x%02X cid, received 0x%02X\n", avrcp_target_cid, local_cid); 75014e3e2c2SMilanka Ringwald return; 75114e3e2c2SMilanka Ringwald } 75214e3e2c2SMilanka Ringwald 75314e3e2c2SMilanka Ringwald status = avrcp_subevent_connection_established_get_status(packet); 75414e3e2c2SMilanka Ringwald if (status != ERROR_CODE_SUCCESS){ 75514e3e2c2SMilanka Ringwald printf("AVRCP Target : Connection failed: status 0x%02x\n", status); 75614e3e2c2SMilanka Ringwald avrcp_target_cid = 0; 75714e3e2c2SMilanka Ringwald return; 75814e3e2c2SMilanka Ringwald } 75914e3e2c2SMilanka Ringwald avrcp_target_cid = local_cid; 760f386e134SMilanka Ringwald avrcp_subevent_connection_established_get_bd_addr(packet, address); 761f386e134SMilanka Ringwald printf("AVRCP Target : Connected to %s, cid 0x%02x\n", bd_addr_to_str(address), avrcp_target_cid); 76214e3e2c2SMilanka Ringwald break; 76314e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_EVENT_IDS_QUERY: 76414e3e2c2SMilanka Ringwald status = avrcp_target_supported_events(avrcp_target_cid, events_num, events, sizeof(events)); 76514e3e2c2SMilanka Ringwald break; 76614e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_COMPANY_IDS_QUERY: 76714e3e2c2SMilanka Ringwald status = avrcp_target_supported_companies(avrcp_target_cid, companies_num, companies, sizeof(companies)); 76814e3e2c2SMilanka Ringwald break; 76914e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_OPERATION:{ 77014e3e2c2SMilanka Ringwald avrcp_operation_id_t operation_id = avrcp_subevent_operation_get_operation_id(packet); 77114e3e2c2SMilanka Ringwald // if (!media_tracker.connected) break; 77214e3e2c2SMilanka Ringwald switch (operation_id){ 77314e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_PLAY: 77414e3e2c2SMilanka Ringwald printf("AVRCP Target : PLAY\n"); 77514e3e2c2SMilanka Ringwald break; 77614e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_PAUSE: 77714e3e2c2SMilanka Ringwald printf("AVRCP Target : PAUSE\n"); 77814e3e2c2SMilanka Ringwald break; 77914e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_STOP: 78014e3e2c2SMilanka Ringwald printf("AVRCP Target : STOP\n"); 78114e3e2c2SMilanka Ringwald break; 78214e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_REWIND: 783f386e134SMilanka Ringwald printf("AVRCP Target : REWIND\n"); 78414e3e2c2SMilanka Ringwald break; 78514e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_FAST_FORWARD: 786f386e134SMilanka Ringwald printf("AVRCP Target : FAST_FORWARD\n"); 78714e3e2c2SMilanka Ringwald break; 78814e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_FORWARD: 789f386e134SMilanka Ringwald printf("AVRCP Target : FORWARD\n"); 79014e3e2c2SMilanka Ringwald break; 79114e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_BACKWARD: 792f386e134SMilanka Ringwald printf("AVRCP Target : BACKWARD\n"); 79314e3e2c2SMilanka Ringwald break; 79414e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_SKIP: 795f386e134SMilanka Ringwald printf("AVRCP Target : SKIP\n"); 79614e3e2c2SMilanka Ringwald break; 79714e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_MUTE: 798f386e134SMilanka Ringwald printf("AVRCP Target : MUTE\n"); 79914e3e2c2SMilanka Ringwald break; 80014e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_CHANNEL_UP: 801f386e134SMilanka Ringwald printf("AVRCP Target : CHANNEL_UP\n"); 80214e3e2c2SMilanka Ringwald break; 80314e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_CHANNEL_DOWN: 804f386e134SMilanka Ringwald printf("AVRCP Target : CHANNEL_DOWN\n"); 80514e3e2c2SMilanka Ringwald break; 80614e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_SELECT: 807f386e134SMilanka Ringwald printf("AVRCP Target : SELECT\n"); 80814e3e2c2SMilanka Ringwald break; 80914e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_UP: 810f386e134SMilanka Ringwald printf("AVRCP Target : UP\n"); 81114e3e2c2SMilanka Ringwald break; 81214e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_DOWN: 813f386e134SMilanka Ringwald printf("AVRCP Target : DOWN\n"); 81414e3e2c2SMilanka Ringwald break; 81514e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_LEFT: 816f386e134SMilanka Ringwald printf("AVRCP Target : LEFT\n"); 81714e3e2c2SMilanka Ringwald break; 81814e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_RIGHT: 819f386e134SMilanka Ringwald printf("AVRCP Target : RIGTH\n"); 82014e3e2c2SMilanka Ringwald break; 82114e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_ROOT_MENU: 822f386e134SMilanka Ringwald printf("AVRCP Target : ROOT_MENU\n"); 82314e3e2c2SMilanka Ringwald break; 82414e3e2c2SMilanka Ringwald default: 82514e3e2c2SMilanka Ringwald return; 82614e3e2c2SMilanka Ringwald } 82714e3e2c2SMilanka Ringwald break; 82814e3e2c2SMilanka Ringwald } 82914e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_RELEASED: 830f386e134SMilanka Ringwald printf("AVRCP Target : Disconnected, cid 0x%02x\n", avrcp_subevent_connection_released_get_avrcp_cid(packet)); 83114e3e2c2SMilanka Ringwald return; 83214e3e2c2SMilanka Ringwald default: 833f386e134SMilanka Ringwald printf("AVRCP Target : Event 0x%02x is not parsed\n", packet[2]); 83414e3e2c2SMilanka Ringwald break; 83514e3e2c2SMilanka Ringwald } 83614e3e2c2SMilanka Ringwald } 83714e3e2c2SMilanka Ringwald 838b23b09a5SMatthias Ringwald static void hci_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 839b23b09a5SMatthias Ringwald UNUSED(channel); 840b23b09a5SMatthias Ringwald UNUSED(size); 841b23b09a5SMatthias Ringwald if (packet_type != HCI_EVENT_PACKET) return; 842b23b09a5SMatthias Ringwald if (hci_event_packet_get_type(packet) == HCI_EVENT_PIN_CODE_REQUEST) { 843b23b09a5SMatthias Ringwald bd_addr_t address; 844b23b09a5SMatthias Ringwald printf("Pin code request - using '0000'\n"); 845b23b09a5SMatthias Ringwald hci_event_pin_code_request_get_bd_addr(packet, address); 846b23b09a5SMatthias Ringwald gap_pin_code_response(address, "0000"); 847b23b09a5SMatthias Ringwald } 848b23b09a5SMatthias Ringwald } 849b23b09a5SMatthias Ringwald 8504dc98401SMilanka Ringwald static void a2dp_sink_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 85164421eb6SMilanka Ringwald UNUSED(channel); 85264421eb6SMilanka Ringwald UNUSED(size); 8534ccacc40SMilanka Ringwald uint16_t cid; 854ef5ad9d6SMilanka Ringwald bd_addr_t address; 855326e5cedSMilanka Ringwald uint8_t status; 85664421eb6SMilanka Ringwald 857ef5ad9d6SMilanka Ringwald if (packet_type != HCI_EVENT_PACKET) return; 858ef5ad9d6SMilanka Ringwald if (hci_event_packet_get_type(packet) != HCI_EVENT_A2DP_META) return; 859ef5ad9d6SMilanka Ringwald 86064421eb6SMilanka Ringwald switch (packet[2]){ 861f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_SIGNALING_MEDIA_CODEC_OTHER_CONFIGURATION: 862f386e134SMilanka Ringwald printf("A2DP Sink : Received non SBC codec - not implemented\n"); 86364421eb6SMilanka Ringwald break; 864f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_SIGNALING_MEDIA_CODEC_SBC_CONFIGURATION:{ 865f386e134SMilanka Ringwald printf("A2DP Sink : Received SBC codec configuration\n"); 866f1042e9dSMilanka Ringwald sbc_configuration.reconfigure = a2dp_subevent_signaling_media_codec_sbc_configuration_get_reconfigure(packet); 867f1042e9dSMilanka Ringwald sbc_configuration.num_channels = a2dp_subevent_signaling_media_codec_sbc_configuration_get_num_channels(packet); 868f1042e9dSMilanka Ringwald sbc_configuration.sampling_frequency = a2dp_subevent_signaling_media_codec_sbc_configuration_get_sampling_frequency(packet); 869f1042e9dSMilanka Ringwald sbc_configuration.channel_mode = a2dp_subevent_signaling_media_codec_sbc_configuration_get_channel_mode(packet); 870f1042e9dSMilanka Ringwald sbc_configuration.block_length = a2dp_subevent_signaling_media_codec_sbc_configuration_get_block_length(packet); 871f1042e9dSMilanka Ringwald sbc_configuration.subbands = a2dp_subevent_signaling_media_codec_sbc_configuration_get_subbands(packet); 872f1042e9dSMilanka Ringwald sbc_configuration.allocation_method = a2dp_subevent_signaling_media_codec_sbc_configuration_get_allocation_method(packet); 873f1042e9dSMilanka Ringwald sbc_configuration.min_bitpool_value = a2dp_subevent_signaling_media_codec_sbc_configuration_get_min_bitpool_value(packet); 874f1042e9dSMilanka Ringwald sbc_configuration.max_bitpool_value = a2dp_subevent_signaling_media_codec_sbc_configuration_get_max_bitpool_value(packet); 87564421eb6SMilanka Ringwald sbc_configuration.frames_per_buffer = sbc_configuration.subbands * sbc_configuration.block_length; 87664421eb6SMilanka Ringwald dump_sbc_configuration(sbc_configuration); 87764421eb6SMilanka Ringwald 87864421eb6SMilanka Ringwald if (sbc_configuration.reconfigure){ 87964421eb6SMilanka Ringwald media_processing_close(); 88064421eb6SMilanka Ringwald } 881c63d45a5SMatthias Ringwald // prepare media processing 882c63d45a5SMatthias Ringwald media_processing_init(sbc_configuration); 88364421eb6SMilanka Ringwald break; 88464421eb6SMilanka Ringwald } 885f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_ESTABLISHED: 886ef5ad9d6SMilanka Ringwald a2dp_subevent_stream_established_get_bd_addr(packet, address); 887326e5cedSMilanka Ringwald status = a2dp_subevent_stream_established_get_status(packet); 8884ccacc40SMilanka Ringwald cid = a2dp_subevent_stream_established_get_a2dp_cid(packet); 889596b7fdcSMilanka Ringwald if (!a2dp_cid){ 890596b7fdcSMilanka Ringwald // incoming connection 891596b7fdcSMilanka Ringwald a2dp_cid = cid; 892596b7fdcSMilanka Ringwald } else if (cid != a2dp_cid) { 893596b7fdcSMilanka Ringwald break; 894596b7fdcSMilanka Ringwald } 895326e5cedSMilanka Ringwald if (status){ 896f386e134SMilanka Ringwald printf("A2DP Sink : Streaming connection failed, status 0x%02x\n", status); 897326e5cedSMilanka Ringwald break; 898326e5cedSMilanka Ringwald } 8999635072eSMilanka Ringwald 9009635072eSMilanka Ringwald memcpy(device_addr, address, 6); 901f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_established_get_local_seid(packet); 902f386e134SMilanka Ringwald printf("A2DP Sink : Streaming connection is established, address %s, cid 0x%02X, local seid %d\n", bd_addr_to_str(address), a2dp_cid, a2dp_local_seid); 90364421eb6SMilanka Ringwald break; 904f1042e9dSMilanka Ringwald 905f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_STARTED: 9064ccacc40SMilanka Ringwald cid = a2dp_subevent_stream_started_get_a2dp_cid(packet); 9074ccacc40SMilanka Ringwald if (cid != a2dp_cid) break; 908f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_started_get_local_seid(packet); 9091bf4f2abSMilanka Ringwald printf("A2DP Sink : Stream started\n"); 9101bf4f2abSMilanka Ringwald media_processing_start(); 91164421eb6SMilanka Ringwald break; 912f1042e9dSMilanka Ringwald 913f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_SUSPENDED: 9144ccacc40SMilanka Ringwald cid = a2dp_subevent_stream_suspended_get_a2dp_cid(packet); 9154ccacc40SMilanka Ringwald if (cid != a2dp_cid) break; 916f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_suspended_get_local_seid(packet); 9171bf4f2abSMilanka Ringwald printf("A2DP Sink : Stream paused\n"); 9181bf4f2abSMilanka Ringwald media_processing_pause(); 919f1042e9dSMilanka Ringwald break; 920f1042e9dSMilanka Ringwald 921f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_RELEASED: 922f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_released_get_local_seid(packet); 9231bf4f2abSMilanka Ringwald printf("A2DP Sink : Stream released\n"); 924f1042e9dSMilanka Ringwald media_processing_close(); 925f1042e9dSMilanka Ringwald break; 926a466d508SMilanka Ringwald case A2DP_SUBEVENT_SIGNALING_CONNECTION_RELEASED: 927a466d508SMilanka Ringwald cid = a2dp_subevent_signaling_connection_released_get_a2dp_cid(packet); 9281bf4f2abSMilanka Ringwald printf("A2DP Sink : Signaling connection released\n"); 92932ea0426SMatthias Ringwald media_processing_close(); 930a466d508SMilanka Ringwald break; 93164421eb6SMilanka Ringwald default: 9321bf4f2abSMilanka Ringwald printf("A2DP Sink : Not parsed 0x%02x\n", packet[2]); 93364421eb6SMilanka Ringwald break; 93464421eb6SMilanka Ringwald } 93564421eb6SMilanka Ringwald } 93664421eb6SMilanka Ringwald 93764421eb6SMilanka Ringwald #ifdef HAVE_BTSTACK_STDIN 93864421eb6SMilanka Ringwald static void show_usage(void){ 93964421eb6SMilanka Ringwald bd_addr_t iut_address; 94064421eb6SMilanka Ringwald gap_local_bd_addr(iut_address); 94164421eb6SMilanka Ringwald printf("\n--- Bluetooth AVDTP Sink/AVRCP Connection Test Console %s ---\n", bd_addr_to_str(iut_address)); 9429635072eSMilanka Ringwald printf("b - AVDTP Sink create connection to addr %s\n", bd_addr_to_str(device_addr)); 94364421eb6SMilanka Ringwald printf("B - AVDTP Sink disconnect\n"); 94414e3e2c2SMilanka Ringwald printf("c - AVRCP Controller create connection to addr %s\n", bd_addr_to_str(device_addr)); 94514e3e2c2SMilanka Ringwald printf("C - AVRCP Controller disconnect\n"); 94614e3e2c2SMilanka Ringwald printf("d - AVRCP Target create connection to addr %s\n", bd_addr_to_str(device_addr)); 94714e3e2c2SMilanka Ringwald printf("D - AVRCP Target disconnect\n"); 94864421eb6SMilanka Ringwald 9498b94010eSMilanka Ringwald printf("w - delay report\n"); 9508b94010eSMilanka Ringwald 95164421eb6SMilanka Ringwald printf("\n--- Bluetooth AVRCP Commands %s ---\n", bd_addr_to_str(iut_address)); 95264421eb6SMilanka Ringwald printf("O - get play status\n"); 95364421eb6SMilanka Ringwald printf("j - get now playing info\n"); 95464421eb6SMilanka Ringwald printf("k - play\n"); 95564421eb6SMilanka Ringwald printf("K - stop\n"); 9562d46c2e6SMilanka Ringwald printf("L - pause\n"); 9572d46c2e6SMilanka Ringwald printf("u - start fast forward\n"); 9582d46c2e6SMilanka Ringwald printf("U - stop fast forward\n"); 95964421eb6SMilanka Ringwald printf("n - start rewind\n"); 96064421eb6SMilanka Ringwald printf("N - stop rewind\n"); 96164421eb6SMilanka Ringwald printf("i - forward\n"); 96264421eb6SMilanka Ringwald printf("I - backward\n"); 96364421eb6SMilanka Ringwald printf("M - mute\n"); 96464421eb6SMilanka Ringwald printf("r - skip\n"); 96564421eb6SMilanka Ringwald printf("q - query repeat and shuffle mode\n"); 96664421eb6SMilanka Ringwald printf("v - repeat single track\n"); 96764421eb6SMilanka Ringwald printf("x - repeat all tracks\n"); 96864421eb6SMilanka Ringwald printf("X - disable repeat mode\n"); 96964421eb6SMilanka Ringwald printf("z - shuffle all tracks\n"); 97064421eb6SMilanka Ringwald printf("Z - disable shuffle mode\n"); 9718177fff3SMilanka Ringwald 9728177fff3SMilanka Ringwald printf("a/A - register/deregister TRACK_CHANGED\n"); 97314e3e2c2SMilanka Ringwald printf("R/P - register/deregister PLAYBACK_POS_CHANGED\n"); 9748177fff3SMilanka Ringwald 975f55e1e38SMilanka Ringwald printf("\n--- Volume Control ---\n"); 976f55e1e38SMilanka Ringwald printf("t - volume up for 10 percent\n"); 977f55e1e38SMilanka Ringwald printf("T - volume down for 10 percent\n"); 978f55e1e38SMilanka Ringwald 97964421eb6SMilanka Ringwald printf("---\n"); 98064421eb6SMilanka Ringwald } 98164421eb6SMilanka Ringwald #endif 98264421eb6SMilanka Ringwald 9834fb249f8SMatthias Ringwald #ifdef HAVE_BTSTACK_STDIN 98464421eb6SMilanka Ringwald static void stdin_process(char cmd){ 9854567cc17SMilanka Ringwald uint8_t status = ERROR_CODE_SUCCESS; 9866c333d06SMilanka Ringwald 98764421eb6SMilanka Ringwald switch (cmd){ 98864421eb6SMilanka Ringwald case 'b': 989f55e1e38SMilanka Ringwald status = a2dp_sink_establish_stream(device_addr, a2dp_local_seid, &a2dp_cid); 990f55e1e38SMilanka Ringwald printf(" - Create AVDTP connection to addr %s, and local seid %d, expected cid 0x%02x.\n", bd_addr_to_str(device_addr), a2dp_local_seid, a2dp_cid); 99164421eb6SMilanka Ringwald break; 99264421eb6SMilanka Ringwald case 'B': 993a466d508SMilanka Ringwald printf(" - AVDTP disconnect from addr %s.\n", bd_addr_to_str(device_addr)); 9944567cc17SMilanka Ringwald status = avdtp_sink_disconnect(a2dp_cid); 99564421eb6SMilanka Ringwald break; 99664421eb6SMilanka Ringwald case 'c': 99714e3e2c2SMilanka Ringwald printf(" - Create AVRCP Controller connection to addr %s.\n", bd_addr_to_str(device_addr)); 99814e3e2c2SMilanka Ringwald status = avrcp_controller_connect(device_addr, &avrcp_controller_cid); 99964421eb6SMilanka Ringwald break; 100064421eb6SMilanka Ringwald case 'C': 100114e3e2c2SMilanka Ringwald printf(" - AVRCP Controller disconnect from addr %s.\n", bd_addr_to_str(device_addr)); 100214e3e2c2SMilanka Ringwald status = avrcp_controller_disconnect(avrcp_controller_cid); 100314e3e2c2SMilanka Ringwald break; 100414e3e2c2SMilanka Ringwald case 'd': 100514e3e2c2SMilanka Ringwald printf(" - Create AVRCP Target connection to addr %s.\n", bd_addr_to_str(device_addr)); 100614e3e2c2SMilanka Ringwald status = avrcp_target_connect(device_addr, &avrcp_target_cid); 100714e3e2c2SMilanka Ringwald break; 100814e3e2c2SMilanka Ringwald case 'D': 100914e3e2c2SMilanka Ringwald printf(" - AVRCP Target disconnect from addr %s.\n", bd_addr_to_str(device_addr)); 101014e3e2c2SMilanka Ringwald status = avrcp_target_disconnect(avrcp_target_cid); 101164421eb6SMilanka Ringwald break; 101264421eb6SMilanka Ringwald 101364421eb6SMilanka Ringwald case '\n': 101464421eb6SMilanka Ringwald case '\r': 101564421eb6SMilanka Ringwald break; 10168b94010eSMilanka Ringwald case 'w': 10178b94010eSMilanka Ringwald printf("Send delay report\n"); 10188b94010eSMilanka Ringwald avdtp_sink_delay_report(a2dp_cid, a2dp_local_seid, 100); 10198b94010eSMilanka Ringwald break; 1020f55e1e38SMilanka Ringwald // Volume Control 1021f55e1e38SMilanka Ringwald case 't': 1022bcbbbb42SMatthias Ringwald volume_percentage = volume_percentage <= 90 ? volume_percentage + 10 : 100; 1023f55e1e38SMilanka Ringwald printf(" - volume up for 10 percent, %d%% (%d) \n", volume_percentage, volume_percentage * 127 / 100); 1024f55e1e38SMilanka Ringwald status = avrcp_target_volume_changed(avrcp_target_cid, volume_percentage * 127 / 100); 1025f55e1e38SMilanka Ringwald break; 1026f55e1e38SMilanka Ringwald case 'T': 1027bcbbbb42SMatthias Ringwald volume_percentage = volume_percentage >= 10 ? volume_percentage - 10 : 0; 1028f55e1e38SMilanka Ringwald printf(" - volume down for 10 percent, %d%% (%d) \n", volume_percentage, volume_percentage * 127 / 100); 1029f55e1e38SMilanka Ringwald status = avrcp_target_volume_changed(avrcp_target_cid, volume_percentage * 127 / 100); 1030f55e1e38SMilanka Ringwald break; 1031f55e1e38SMilanka Ringwald 103264421eb6SMilanka Ringwald case 'O': 1033f55e1e38SMilanka Ringwald printf(" - get play status\n"); 103414e3e2c2SMilanka Ringwald status = avrcp_controller_get_play_status(avrcp_controller_cid); 103564421eb6SMilanka Ringwald break; 103664421eb6SMilanka Ringwald case 'j': 1037f55e1e38SMilanka Ringwald printf(" - get now playing info\n"); 103814e3e2c2SMilanka Ringwald status = avrcp_controller_get_now_playing_info(avrcp_controller_cid); 103964421eb6SMilanka Ringwald break; 104064421eb6SMilanka Ringwald case 'k': 1041f55e1e38SMilanka Ringwald printf(" - play\n"); 104214e3e2c2SMilanka Ringwald status = avrcp_controller_play(avrcp_controller_cid); 104364421eb6SMilanka Ringwald break; 104464421eb6SMilanka Ringwald case 'K': 1045f55e1e38SMilanka Ringwald printf(" - stop\n"); 104614e3e2c2SMilanka Ringwald status = avrcp_controller_stop(avrcp_controller_cid); 104764421eb6SMilanka Ringwald break; 104864421eb6SMilanka Ringwald case 'L': 1049f55e1e38SMilanka Ringwald printf(" - pause\n"); 105014e3e2c2SMilanka Ringwald status = avrcp_controller_pause(avrcp_controller_cid); 105164421eb6SMilanka Ringwald break; 105264421eb6SMilanka Ringwald case 'u': 1053f55e1e38SMilanka Ringwald printf(" - start fast forward\n"); 105414e3e2c2SMilanka Ringwald status = avrcp_controller_press_and_hold_fast_forward(avrcp_controller_cid); 105564421eb6SMilanka Ringwald break; 105664421eb6SMilanka Ringwald case 'U': 1057f55e1e38SMilanka Ringwald printf(" - stop fast forward\n"); 105814e3e2c2SMilanka Ringwald status = avrcp_controller_release_press_and_hold_cmd(avrcp_controller_cid); 105964421eb6SMilanka Ringwald break; 106064421eb6SMilanka Ringwald case 'n': 1061f55e1e38SMilanka Ringwald printf(" - start rewind\n"); 106214e3e2c2SMilanka Ringwald status = avrcp_controller_press_and_hold_rewind(avrcp_controller_cid); 106364421eb6SMilanka Ringwald break; 106464421eb6SMilanka Ringwald case 'N': 1065f55e1e38SMilanka Ringwald printf(" - stop rewind\n"); 106614e3e2c2SMilanka Ringwald status = avrcp_controller_release_press_and_hold_cmd(avrcp_controller_cid); 106764421eb6SMilanka Ringwald break; 106864421eb6SMilanka Ringwald case 'i': 1069f55e1e38SMilanka Ringwald printf(" - forward\n"); 107014e3e2c2SMilanka Ringwald status = avrcp_controller_forward(avrcp_controller_cid); 107164421eb6SMilanka Ringwald break; 107264421eb6SMilanka Ringwald case 'I': 1073f55e1e38SMilanka Ringwald printf(" - backward\n"); 107414e3e2c2SMilanka Ringwald status = avrcp_controller_backward(avrcp_controller_cid); 107564421eb6SMilanka Ringwald break; 107664421eb6SMilanka Ringwald case 'M': 1077f55e1e38SMilanka Ringwald printf(" - mute\n"); 107814e3e2c2SMilanka Ringwald status = avrcp_controller_mute(avrcp_controller_cid); 107964421eb6SMilanka Ringwald break; 108064421eb6SMilanka Ringwald case 'r': 1081f55e1e38SMilanka Ringwald printf(" - skip\n"); 108214e3e2c2SMilanka Ringwald status = avrcp_controller_skip(avrcp_controller_cid); 108364421eb6SMilanka Ringwald break; 108464421eb6SMilanka Ringwald case 'q': 1085f55e1e38SMilanka Ringwald printf(" - query repeat and shuffle mode\n"); 108614e3e2c2SMilanka Ringwald status = avrcp_controller_query_shuffle_and_repeat_modes(avrcp_controller_cid); 108764421eb6SMilanka Ringwald break; 108864421eb6SMilanka Ringwald case 'v': 1089f55e1e38SMilanka Ringwald printf(" - repeat single track\n"); 109014e3e2c2SMilanka Ringwald status = avrcp_controller_set_repeat_mode(avrcp_controller_cid, AVRCP_REPEAT_MODE_SINGLE_TRACK); 109164421eb6SMilanka Ringwald break; 109264421eb6SMilanka Ringwald case 'x': 1093f55e1e38SMilanka Ringwald printf(" - repeat all tracks\n"); 109414e3e2c2SMilanka Ringwald status = avrcp_controller_set_repeat_mode(avrcp_controller_cid, AVRCP_REPEAT_MODE_ALL_TRACKS); 109564421eb6SMilanka Ringwald break; 109664421eb6SMilanka Ringwald case 'X': 1097f55e1e38SMilanka Ringwald printf(" - disable repeat mode\n"); 109814e3e2c2SMilanka Ringwald status = avrcp_controller_set_repeat_mode(avrcp_controller_cid, AVRCP_REPEAT_MODE_OFF); 109964421eb6SMilanka Ringwald break; 110064421eb6SMilanka Ringwald case 'z': 1101f55e1e38SMilanka Ringwald printf(" - shuffle all tracks\n"); 110214e3e2c2SMilanka Ringwald status = avrcp_controller_set_shuffle_mode(avrcp_controller_cid, AVRCP_SHUFFLE_MODE_ALL_TRACKS); 110364421eb6SMilanka Ringwald break; 110464421eb6SMilanka Ringwald case 'Z': 1105f55e1e38SMilanka Ringwald printf(" - disable shuffle mode\n"); 110614e3e2c2SMilanka Ringwald status = avrcp_controller_set_shuffle_mode(avrcp_controller_cid, AVRCP_SHUFFLE_MODE_OFF); 110764421eb6SMilanka Ringwald break; 11088177fff3SMilanka Ringwald case 'a': 1109f55e1e38SMilanka Ringwald printf("AVRCP: enable notification TRACK_CHANGED\n"); 111014e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_TRACK_CHANGED); 11118177fff3SMilanka Ringwald break; 11128177fff3SMilanka Ringwald case 'A': 1113f55e1e38SMilanka Ringwald printf("AVRCP: disable notification TRACK_CHANGED\n"); 111414e3e2c2SMilanka Ringwald avrcp_controller_disable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_TRACK_CHANGED); 11158177fff3SMilanka Ringwald break; 111614e3e2c2SMilanka Ringwald case 'R': 1117f55e1e38SMilanka Ringwald printf("AVRCP: enable notification PLAYBACK_POS_CHANGED\n"); 111814e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_PLAYBACK_POS_CHANGED); 11196fa3dbf2SMilanka Ringwald break; 112014e3e2c2SMilanka Ringwald case 'P': 1121f55e1e38SMilanka Ringwald printf("AVRCP: disable notification PLAYBACK_POS_CHANGED\n"); 112214e3e2c2SMilanka Ringwald avrcp_controller_disable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_PLAYBACK_POS_CHANGED); 11236fa3dbf2SMilanka Ringwald break; 11248177fff3SMilanka Ringwald 112564421eb6SMilanka Ringwald default: 112664421eb6SMilanka Ringwald show_usage(); 11274567cc17SMilanka Ringwald return; 11284567cc17SMilanka Ringwald } 11294567cc17SMilanka Ringwald if (status != ERROR_CODE_SUCCESS){ 11304567cc17SMilanka Ringwald printf("Could not perform command, status 0x%2x\n", status); 113164421eb6SMilanka Ringwald } 113264421eb6SMilanka Ringwald } 113364421eb6SMilanka Ringwald #endif 113464421eb6SMilanka Ringwald 113564421eb6SMilanka Ringwald int btstack_main(int argc, const char * argv[]); 113664421eb6SMilanka Ringwald int btstack_main(int argc, const char * argv[]){ 1137b23b09a5SMatthias Ringwald UNUSED(argc); 113864421eb6SMilanka Ringwald (void)argv; 113964421eb6SMilanka Ringwald 1140b23b09a5SMatthias Ringwald a2dp_and_avrcp_setup(); 1141b23b09a5SMatthias Ringwald 1142b23b09a5SMatthias Ringwald #ifdef HAVE_BTSTACK_STDIN 1143b23b09a5SMatthias Ringwald // parse human readable Bluetooth address 1144b23b09a5SMatthias Ringwald sscanf_bd_addr(device_addr_string, device_addr); 1145b23b09a5SMatthias Ringwald btstack_stdin_setup(stdin_process); 1146b23b09a5SMatthias Ringwald #endif 1147b23b09a5SMatthias Ringwald 114864421eb6SMilanka Ringwald // turn on! 11494dc98401SMilanka Ringwald printf("Starting BTstack ...\n"); 115064421eb6SMilanka Ringwald hci_power_control(HCI_POWER_ON); 115164421eb6SMilanka Ringwald return 0; 115264421eb6SMilanka Ringwald } 1153