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 384dc98401SMilanka 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. 604dc98401SMilanka Ringwald */ 614dc98401SMilanka Ringwald // ***************************************************************************** 6264421eb6SMilanka Ringwald 63173fff9bSMatthias Ringwald #include <inttypes.h> 6464421eb6SMilanka Ringwald #include <stdint.h> 6564421eb6SMilanka Ringwald #include <stdio.h> 6664421eb6SMilanka Ringwald #include <stdlib.h> 6764421eb6SMilanka Ringwald #include <string.h> 6864421eb6SMilanka Ringwald 6901dc6e35SMilanka Ringwald #include "btstack.h" 70e9c5f44eSMatthias Ringwald #include "btstack_resample.h" 7164421eb6SMilanka Ringwald 724f0111ebSMilanka Ringwald //#define AVRCP_BROWSING_ENABLED 7364421eb6SMilanka Ringwald 7464421eb6SMilanka Ringwald #ifdef HAVE_BTSTACK_STDIN 7564421eb6SMilanka Ringwald #include "btstack_stdin.h" 7664421eb6SMilanka Ringwald #endif 7764421eb6SMilanka Ringwald 7864421eb6SMilanka Ringwald #include "btstack_ring_buffer.h" 7964421eb6SMilanka Ringwald 8064421eb6SMilanka Ringwald #ifdef HAVE_POSIX_FILE_IO 8164421eb6SMilanka Ringwald #include "wav_util.h" 8264421eb6SMilanka Ringwald #define STORE_SBC_TO_SBC_FILE 8364421eb6SMilanka Ringwald #define STORE_SBC_TO_WAV_FILE 8464421eb6SMilanka Ringwald #endif 8564421eb6SMilanka Ringwald 8664421eb6SMilanka Ringwald #define NUM_CHANNELS 2 8764421eb6SMilanka Ringwald #define BYTES_PER_FRAME (2*NUM_CHANNELS) 8864421eb6SMilanka Ringwald #define MAX_SBC_FRAME_SIZE 120 8964421eb6SMilanka Ringwald 90b23b09a5SMatthias Ringwald // SBC Decoder for WAV file or live playback 9164421eb6SMilanka Ringwald static btstack_sbc_decoder_state_t state; 9264421eb6SMilanka Ringwald static btstack_sbc_mode_t mode = SBC_MODE_STANDARD; 9364421eb6SMilanka Ringwald 94b23b09a5SMatthias Ringwald // ring buffer for SBC Frames 9564421eb6SMilanka Ringwald // below 30: add samples, 30-40: fine, above 40: drop samples 9664421eb6SMilanka Ringwald #define OPTIMAL_FRAMES_MIN 30 9764421eb6SMilanka Ringwald #define OPTIMAL_FRAMES_MAX 40 98e9c5f44eSMatthias Ringwald #define ADDITIONAL_FRAMES 20 99b23b09a5SMatthias Ringwald static uint8_t sbc_frame_storage[(OPTIMAL_FRAMES_MAX + ADDITIONAL_FRAMES) * MAX_SBC_FRAME_SIZE]; 100b23b09a5SMatthias Ringwald static btstack_ring_buffer_t sbc_frame_ring_buffer; 101b23b09a5SMatthias Ringwald static unsigned int sbc_frame_size; 10264421eb6SMilanka Ringwald 103e9c5f44eSMatthias Ringwald // rest buffer for not fully used sbc frames, with additional frames for resampling 104e9c5f44eSMatthias Ringwald static uint8_t decoded_audio_storage[(128+16) * BYTES_PER_FRAME]; 105b23b09a5SMatthias Ringwald static btstack_ring_buffer_t decoded_audio_ring_buffer; 106b23b09a5SMatthias Ringwald 107b23b09a5SMatthias Ringwald // 108b23b09a5SMatthias Ringwald static int audio_stream_started; 109b23b09a5SMatthias Ringwald 110b23b09a5SMatthias Ringwald // temp storage of lower-layer request 111b23b09a5SMatthias Ringwald static int16_t * request_buffer; 112e9c5f44eSMatthias Ringwald static int request_frames; 113e9c5f44eSMatthias Ringwald 114e9c5f44eSMatthias Ringwald #define STORE_FROM_PLAYBACK 11564421eb6SMilanka Ringwald 11664421eb6SMilanka Ringwald // WAV File 11764421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_WAV_FILE 11864421eb6SMilanka Ringwald static int frame_count = 0; 11964421eb6SMilanka Ringwald static char * wav_filename = "avdtp_sink.wav"; 12064421eb6SMilanka Ringwald #endif 12164421eb6SMilanka Ringwald 12264421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_SBC_FILE 12364421eb6SMilanka Ringwald static FILE * sbc_file; 12464421eb6SMilanka Ringwald static char * sbc_filename = "avdtp_sink.sbc"; 12564421eb6SMilanka Ringwald #endif 12664421eb6SMilanka Ringwald 127*f55e1e38SMilanka Ringwald static int volume_percentage = 0; 128*f55e1e38SMilanka Ringwald 12964421eb6SMilanka Ringwald typedef struct { 13064421eb6SMilanka Ringwald // bitmaps 13164421eb6SMilanka Ringwald uint8_t sampling_frequency_bitmap; 13264421eb6SMilanka Ringwald uint8_t channel_mode_bitmap; 13364421eb6SMilanka Ringwald uint8_t block_length_bitmap; 13464421eb6SMilanka Ringwald uint8_t subbands_bitmap; 13564421eb6SMilanka Ringwald uint8_t allocation_method_bitmap; 13664421eb6SMilanka Ringwald uint8_t min_bitpool_value; 13764421eb6SMilanka Ringwald uint8_t max_bitpool_value; 13864421eb6SMilanka Ringwald } adtvp_media_codec_information_sbc_t; 13964421eb6SMilanka Ringwald 14064421eb6SMilanka Ringwald typedef struct { 14164421eb6SMilanka Ringwald int reconfigure; 14264421eb6SMilanka Ringwald int num_channels; 14364421eb6SMilanka Ringwald int sampling_frequency; 14464421eb6SMilanka Ringwald int channel_mode; 14564421eb6SMilanka Ringwald int block_length; 14664421eb6SMilanka Ringwald int subbands; 14764421eb6SMilanka Ringwald int allocation_method; 14864421eb6SMilanka Ringwald int min_bitpool_value; 14964421eb6SMilanka Ringwald int max_bitpool_value; 15064421eb6SMilanka Ringwald int frames_per_buffer; 15164421eb6SMilanka Ringwald } avdtp_media_codec_configuration_sbc_t; 15264421eb6SMilanka Ringwald 15314e3e2c2SMilanka Ringwald static uint8_t events_num = 1; 15414e3e2c2SMilanka Ringwald 15514e3e2c2SMilanka Ringwald static uint8_t events[] = { 15614e3e2c2SMilanka Ringwald AVRCP_NOTIFICATION_EVENT_VOLUME_CHANGED 15714e3e2c2SMilanka Ringwald }; 15814e3e2c2SMilanka Ringwald 15914e3e2c2SMilanka Ringwald static uint8_t companies_num = 1; 16014e3e2c2SMilanka Ringwald static uint8_t companies[] = { 16114e3e2c2SMilanka Ringwald 0x00, 0x19, 0x58 //BT SIG registered CompanyID 16214e3e2c2SMilanka Ringwald }; 16364421eb6SMilanka Ringwald #ifdef HAVE_BTSTACK_STDIN 16464421eb6SMilanka Ringwald // pts: static bd_addr_t remote = {0x00, 0x1B, 0xDC, 0x08, 0x0A, 0xA5}; 1655e3d4d2bSMilanka Ringwald // mac 2013: static const char * device_addr_string = "84:38:35:65:d1:15"; 166b23b09a5SMatthias Ringwald // iPhone 5S: 167b23b09a5SMatthias Ringwald static const char * device_addr_string = "54:E4:3A:26:A2:39"; 16864421eb6SMilanka Ringwald #endif 16964421eb6SMilanka Ringwald 17064421eb6SMilanka Ringwald static uint8_t sdp_avdtp_sink_service_buffer[150]; 17114e3e2c2SMilanka Ringwald static uint8_t sdp_avrcp_target_service_buffer[150]; 17264421eb6SMilanka Ringwald static avdtp_media_codec_configuration_sbc_t sbc_configuration; 1734567cc17SMilanka Ringwald static uint16_t a2dp_cid = 0; 174*f55e1e38SMilanka Ringwald static uint8_t a2dp_local_seid = 0; 1751bf7a74fSMilanka Ringwald static uint8_t value[100]; 1767050d2caSMilanka Ringwald 17764421eb6SMilanka Ringwald static btstack_packet_callback_registration_t hci_event_callback_registration; 17864421eb6SMilanka Ringwald 17964421eb6SMilanka Ringwald static int media_initialized = 0; 18064421eb6SMilanka Ringwald 1814fb249f8SMatthias Ringwald #ifdef HAVE_BTSTACK_STDIN 18264421eb6SMilanka Ringwald static bd_addr_t device_addr; 1834fb249f8SMatthias Ringwald #endif 1844fb249f8SMatthias Ringwald 18514e3e2c2SMilanka Ringwald static uint16_t avrcp_controller_cid = 0; 18614e3e2c2SMilanka Ringwald static uint16_t avrcp_target_cid = 0; 1876c333d06SMilanka Ringwald static uint8_t avrcp_connected = 0; 18864421eb6SMilanka Ringwald static uint8_t sdp_avrcp_controller_service_buffer[200]; 18964421eb6SMilanka Ringwald 1904dc98401SMilanka Ringwald static uint8_t media_sbc_codec_capabilities[] = { 1914dc98401SMilanka Ringwald 0xFF,//(AVDTP_SBC_44100 << 4) | AVDTP_SBC_STEREO, 1924dc98401SMilanka Ringwald 0xFF,//(AVDTP_SBC_BLOCK_LENGTH_16 << 4) | (AVDTP_SBC_SUBBANDS_8 << 2) | AVDTP_SBC_ALLOCATION_METHOD_LOUDNESS, 1934dc98401SMilanka Ringwald 2, 53 1944dc98401SMilanka Ringwald }; 1954dc98401SMilanka Ringwald 1964dc98401SMilanka Ringwald static uint8_t media_sbc_codec_configuration[] = { 1974dc98401SMilanka Ringwald (AVDTP_SBC_44100 << 4) | AVDTP_SBC_STEREO, 1984dc98401SMilanka Ringwald (AVDTP_SBC_BLOCK_LENGTH_16 << 4) | (AVDTP_SBC_SUBBANDS_8 << 2) | AVDTP_SBC_ALLOCATION_METHOD_LOUDNESS, 1994dc98401SMilanka Ringwald 2, 53 2004dc98401SMilanka Ringwald }; 2014dc98401SMilanka Ringwald 202e9c5f44eSMatthias Ringwald static btstack_resample_t resample_instance; 2034dc98401SMilanka Ringwald 2044dc98401SMilanka Ringwald /* @section Main Application Setup 2054dc98401SMilanka Ringwald * 2064dc98401SMilanka Ringwald * @text The Listing MainConfiguration shows how to setup AD2P Sink and AVRCP controller services. 2074dc98401SMilanka Ringwald * To announce A2DP Sink and AVRCP Controller services, you need to create corresponding 2084dc98401SMilanka Ringwald * SDP records and register them with the SDP service. 2094dc98401SMilanka Ringwald * You'll also need to register several packet handlers: 2104dc98401SMilanka 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). 2114dc98401SMilanka Ringwald * - handle_l2cap_media_data_packet - used to receive streaming data. If HAVE_PORTAUDIO or STORE_SBC_TO_WAV_FILE directives (check btstack_config.h) are 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. 2124dc98401SMilanka 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. 2134dc98401SMilanka Ringwald * - avrcp_controller_packet_handler - used to receive answers for AVRCP commands, 2144dc98401SMilanka Ringwald * 2154dc98401SMilanka Ringwald * @text Note, currently only the SBC codec is supported. 2164dc98401SMilanka Ringwald * If you want to store the audio data in a file, you'll need to define STORE_SBC_TO_WAV_FILE. The HAVE_PORTAUDIO directive indicates if the audio is played back via PortAudio. 2174dc98401SMilanka Ringwald * If HAVE_PORTAUDIO or STORE_SBC_TO_WAV_FILE directives is defined, the SBC decoder needs to get initialized when a2dp_sink_packet_handler receives event A2DP_SUBEVENT_STREAM_STARTED. 2184dc98401SMilanka Ringwald * The initialization of the SBC decoder requires a callback that handles PCM data: 2194dc98401SMilanka Ringwald * - handle_pcm_data - handles PCM audio frames. Here, they are stored a in wav file if STORE_SBC_TO_WAV_FILE is defined, and/or played using the PortAudio library if HAVE_PORTAUDIO is defined. 2204dc98401SMilanka Ringwald */ 2214dc98401SMilanka Ringwald 2226fa8d4c7SMilanka Ringwald /* LISTING_START(MainConfiguration): Setup Audio Sink and AVRCP Controller services */ 2234dc98401SMilanka Ringwald static void a2dp_sink_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t * event, uint16_t event_size); 2244dc98401SMilanka Ringwald static void avrcp_controller_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size); 22514e3e2c2SMilanka Ringwald static void avrcp_target_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size); 226b23b09a5SMatthias Ringwald static void hci_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size); 2274dc98401SMilanka Ringwald static void handle_l2cap_media_data_packet(uint8_t seid, uint8_t *packet, uint16_t size); 2284dc98401SMilanka Ringwald 229b23b09a5SMatthias Ringwald static int a2dp_and_avrcp_setup(void){ 230b23b09a5SMatthias Ringwald 2314dc98401SMilanka Ringwald l2cap_init(); 232b23b09a5SMatthias Ringwald // Initialize AVDTP Sink 2334dc98401SMilanka Ringwald a2dp_sink_init(); 2344dc98401SMilanka Ringwald a2dp_sink_register_packet_handler(&a2dp_sink_packet_handler); 2354dc98401SMilanka Ringwald a2dp_sink_register_media_handler(&handle_l2cap_media_data_packet); 236b23b09a5SMatthias Ringwald 237*f55e1e38SMilanka Ringwald uint8_t status = a2dp_sink_create_stream_endpoint(AVDTP_AUDIO, 238*f55e1e38SMilanka Ringwald AVDTP_CODEC_SBC, media_sbc_codec_capabilities, sizeof(media_sbc_codec_capabilities), 239*f55e1e38SMilanka Ringwald media_sbc_codec_configuration, sizeof(media_sbc_codec_configuration), &a2dp_local_seid); 2404dc98401SMilanka Ringwald if (status != ERROR_CODE_SUCCESS){ 2414dc98401SMilanka Ringwald printf("A2DP Sink: not enough memory to create local stream endpoint\n"); 2424dc98401SMilanka Ringwald return 1; 2434dc98401SMilanka Ringwald } 24414e3e2c2SMilanka Ringwald // Initialize AVRCP Controller 2454dc98401SMilanka Ringwald avrcp_controller_init(); 2464dc98401SMilanka Ringwald avrcp_controller_register_packet_handler(&avrcp_controller_packet_handler); 2474dc98401SMilanka Ringwald 24814e3e2c2SMilanka Ringwald // Initialize AVRCP Target 24914e3e2c2SMilanka Ringwald avrcp_target_init(); 25014e3e2c2SMilanka Ringwald avrcp_target_register_packet_handler(&avrcp_target_packet_handler); 25114e3e2c2SMilanka Ringwald 252b23b09a5SMatthias Ringwald // Initialize SDP 2534dc98401SMilanka Ringwald sdp_init(); 254b23b09a5SMatthias Ringwald // setup AVDTP sink 2554dc98401SMilanka Ringwald memset(sdp_avdtp_sink_service_buffer, 0, sizeof(sdp_avdtp_sink_service_buffer)); 2564dc98401SMilanka Ringwald a2dp_sink_create_sdp_record(sdp_avdtp_sink_service_buffer, 0x10001, 1, NULL, NULL); 2574dc98401SMilanka Ringwald sdp_register_service(sdp_avdtp_sink_service_buffer); 2584dc98401SMilanka Ringwald 25914e3e2c2SMilanka Ringwald // setup AVRCP Controller 2604dc98401SMilanka Ringwald memset(sdp_avrcp_controller_service_buffer, 0, sizeof(sdp_avrcp_controller_service_buffer)); 26114e3e2c2SMilanka Ringwald uint16_t controller_supported_features = (1 << AVRCP_TARGET_SUPPORTED_FEATURE_CATEGORY_MONITOR_OR_AMPLIFIER); 2624f0111ebSMilanka Ringwald #ifdef AVRCP_BROWSING_ENABLED 26314e3e2c2SMilanka Ringwald controller_supported_features |= (1 << AVRCP_CONTROLLER_SUPPORTED_FEATURE_BROWSING); 2644f0111ebSMilanka Ringwald #endif 26514e3e2c2SMilanka Ringwald avrcp_controller_create_sdp_record(sdp_avrcp_controller_service_buffer, 0x10002, controller_supported_features, NULL, NULL); 2664dc98401SMilanka Ringwald sdp_register_service(sdp_avrcp_controller_service_buffer); 2674dc98401SMilanka Ringwald 26814e3e2c2SMilanka Ringwald // setup AVRCP Target 26914e3e2c2SMilanka Ringwald memset(sdp_avrcp_target_service_buffer, 0, sizeof(sdp_avrcp_target_service_buffer)); 27014e3e2c2SMilanka Ringwald uint16_t target_supported_features = (1 << AVRCP_TARGET_SUPPORTED_FEATURE_CATEGORY_MONITOR_OR_AMPLIFIER); 27114e3e2c2SMilanka Ringwald avrcp_target_create_sdp_record(sdp_avrcp_target_service_buffer, 0x10003, target_supported_features, NULL, NULL); 27214e3e2c2SMilanka Ringwald sdp_register_service(sdp_avrcp_target_service_buffer); 27314e3e2c2SMilanka Ringwald 2744dc98401SMilanka Ringwald gap_set_local_name("A2DP Sink Demo 00:00:00:00:00:00"); 2754dc98401SMilanka Ringwald gap_discoverable_control(1); 2764dc98401SMilanka Ringwald gap_set_class_of_device(0x200408); 2774dc98401SMilanka Ringwald 278a4fe6467SMatthias Ringwald /* Register for HCI events */ 279a4fe6467SMatthias Ringwald hci_event_callback_registration.callback = &hci_packet_handler; 280a4fe6467SMatthias Ringwald hci_add_event_handler(&hci_event_callback_registration); 281a4fe6467SMatthias Ringwald 2824dc98401SMilanka Ringwald return 0; 2834dc98401SMilanka Ringwald } 2844dc98401SMilanka Ringwald 285e9c5f44eSMatthias Ringwald static void playback_handler(int16_t * buffer, uint16_t num_frames){ 286e9c5f44eSMatthias Ringwald 287e9c5f44eSMatthias Ringwald #ifdef STORE_FROM_PLAYBACK 288e9c5f44eSMatthias Ringwald #ifdef STORE_SBC_TO_WAV_FILE 289e9c5f44eSMatthias Ringwald int wav_samples = num_frames * NUM_CHANNELS; 290e9c5f44eSMatthias Ringwald int16_t * wav_buffer = buffer; 291e9c5f44eSMatthias Ringwald #endif 292e9c5f44eSMatthias Ringwald #endif 29364421eb6SMilanka Ringwald 294b23b09a5SMatthias Ringwald // called from lower-layer but guaranteed to be on main thread 29564421eb6SMilanka Ringwald 296e9c5f44eSMatthias Ringwald // first fill from resampled audio 297b23b09a5SMatthias Ringwald uint32_t bytes_read; 298e9c5f44eSMatthias Ringwald btstack_ring_buffer_read(&decoded_audio_ring_buffer, (uint8_t *) buffer, num_frames * BYTES_PER_FRAME, &bytes_read); 299b23b09a5SMatthias Ringwald buffer += bytes_read / NUM_CHANNELS; 300e9c5f44eSMatthias Ringwald num_frames -= bytes_read / BYTES_PER_FRAME; 30164421eb6SMilanka Ringwald 302b23b09a5SMatthias Ringwald // then start decoding sbc frames using request_* globals 303b23b09a5SMatthias Ringwald request_buffer = buffer; 304e9c5f44eSMatthias Ringwald request_frames = num_frames; 305e9c5f44eSMatthias Ringwald while (request_frames){ 306e9c5f44eSMatthias Ringwald if (btstack_ring_buffer_bytes_available(&sbc_frame_ring_buffer) >= sbc_frame_size){ 307b23b09a5SMatthias Ringwald // decode frame 308e9c5f44eSMatthias Ringwald uint8_t sbc_frame[MAX_SBC_FRAME_SIZE]; 309e9c5f44eSMatthias Ringwald btstack_ring_buffer_read(&sbc_frame_ring_buffer, sbc_frame, sbc_frame_size, &bytes_read); 310e9c5f44eSMatthias Ringwald btstack_sbc_decoder_process_data(&state, 0, sbc_frame, sbc_frame_size); 311e9c5f44eSMatthias Ringwald } else { 312e9c5f44eSMatthias Ringwald printf("Error: no SBC frame ready in ring buffer\n"); 31364421eb6SMilanka Ringwald } 314b23b09a5SMatthias Ringwald } 31564421eb6SMilanka Ringwald 316e9c5f44eSMatthias Ringwald #ifdef STORE_FROM_PLAYBACK 317e9c5f44eSMatthias Ringwald #ifdef STORE_SBC_TO_WAV_FILE 318e9c5f44eSMatthias Ringwald wav_writer_write_int16(wav_samples, wav_buffer); 319e9c5f44eSMatthias Ringwald #endif 320e9c5f44eSMatthias Ringwald #endif 321e9c5f44eSMatthias Ringwald } 322e9c5f44eSMatthias Ringwald 323e9c5f44eSMatthias Ringwald static void handle_pcm_data(int16_t * data, int num_frames, int num_channels, int sample_rate, void * context){ 324b23b09a5SMatthias Ringwald UNUSED(sample_rate); 325b23b09a5SMatthias Ringwald UNUSED(context); 326b23b09a5SMatthias Ringwald UNUSED(num_channels); // must be stereo == 2 327b23b09a5SMatthias Ringwald 328e9c5f44eSMatthias Ringwald #ifdef STORE_DECODED 329e9c5f44eSMatthias Ringwald wav_writer_write_int16(num_frames * NUM_CHANNELS, data); 33064421eb6SMilanka Ringwald #endif 33164421eb6SMilanka Ringwald 332e9c5f44eSMatthias Ringwald // resample into request buffer - add some additional space for resampling 333e9c5f44eSMatthias Ringwald int16_t output_buffer[(128+16) * NUM_CHANNELS]; // 16 * 8 * 2 334e9c5f44eSMatthias Ringwald uint32_t resampled_frames = btstack_resample_block(&resample_instance, data, num_frames, output_buffer); 335b23b09a5SMatthias Ringwald 336e9c5f44eSMatthias Ringwald #ifdef STORE_RESAMPLED 337e9c5f44eSMatthias Ringwald #ifdef STORE_SBC_TO_WAV_FILE 338e9c5f44eSMatthias Ringwald wav_writer_write_int16(resampled_frames * NUM_CHANNELS, output_buffer); 339e9c5f44eSMatthias Ringwald frame_count++; 340e9c5f44eSMatthias Ringwald #endif 341e9c5f44eSMatthias Ringwald #endif 342e9c5f44eSMatthias Ringwald 343e9c5f44eSMatthias Ringwald const btstack_audio_t * audio = btstack_audio_get_instance(); 344e9c5f44eSMatthias Ringwald if (!audio) return; 345b23b09a5SMatthias Ringwald 346b23b09a5SMatthias Ringwald // store data in btstack_audio buffer first 347e9c5f44eSMatthias Ringwald int frames_to_copy = btstack_min(resampled_frames, request_frames); 348e9c5f44eSMatthias Ringwald memcpy(request_buffer, output_buffer, frames_to_copy * BYTES_PER_FRAME); 349e9c5f44eSMatthias Ringwald request_frames -= frames_to_copy; 350e9c5f44eSMatthias Ringwald request_buffer += frames_to_copy * NUM_CHANNELS; 351b23b09a5SMatthias Ringwald 352e9c5f44eSMatthias Ringwald #ifdef STORE_BEFORE_PLAYBACK 353e9c5f44eSMatthias Ringwald #ifdef STORE_SBC_TO_WAV_FILE 354e9c5f44eSMatthias Ringwald wav_writer_write_int16(frames_to_copy * NUM_CHANNELS, output_buffer); 355e9c5f44eSMatthias Ringwald frame_count++; 356e9c5f44eSMatthias Ringwald #endif 357e9c5f44eSMatthias Ringwald #endif 358b23b09a5SMatthias Ringwald 359b23b09a5SMatthias Ringwald // and rest in ring buffer 360e9c5f44eSMatthias Ringwald int frames_to_store = resampled_frames - frames_to_copy; 361e9c5f44eSMatthias Ringwald if (frames_to_store){ 362e9c5f44eSMatthias 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); 363e9c5f44eSMatthias Ringwald if (status){ 364e9c5f44eSMatthias Ringwald printf("Error storing samples in PCM ring buffer!!!\n"); 365b23b09a5SMatthias Ringwald } 366e9c5f44eSMatthias Ringwald #ifdef STORE_BEFORE_PLAYBACK 367e9c5f44eSMatthias Ringwald #ifdef STORE_SBC_TO_WAV_FILE 368e9c5f44eSMatthias Ringwald wav_writer_write_int16(frames_to_store * NUM_CHANNELS, &output_buffer[frames_to_copy * NUM_CHANNELS]); 369e9c5f44eSMatthias Ringwald frame_count++; 370e9c5f44eSMatthias Ringwald #endif 371e9c5f44eSMatthias Ringwald #endif 372b23b09a5SMatthias Ringwald } 373b23b09a5SMatthias Ringwald } 374b23b09a5SMatthias Ringwald 37564421eb6SMilanka Ringwald static int media_processing_init(avdtp_media_codec_configuration_sbc_t configuration){ 376c63d45a5SMatthias Ringwald if (media_initialized) return 0; 377b23b09a5SMatthias Ringwald 37864421eb6SMilanka Ringwald btstack_sbc_decoder_init(&state, mode, handle_pcm_data, NULL); 37964421eb6SMilanka Ringwald 38064421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_WAV_FILE 38164421eb6SMilanka Ringwald wav_writer_open(wav_filename, configuration.num_channels, configuration.sampling_frequency); 38264421eb6SMilanka Ringwald #endif 38364421eb6SMilanka Ringwald 38464421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_SBC_FILE 38564421eb6SMilanka Ringwald sbc_file = fopen(sbc_filename, "wb"); 38664421eb6SMilanka Ringwald #endif 38764421eb6SMilanka Ringwald 388b23b09a5SMatthias Ringwald btstack_ring_buffer_init(&sbc_frame_ring_buffer, sbc_frame_storage, sizeof(sbc_frame_storage)); 389b23b09a5SMatthias Ringwald btstack_ring_buffer_init(&decoded_audio_ring_buffer, decoded_audio_storage, sizeof(decoded_audio_storage)); 390e9c5f44eSMatthias Ringwald btstack_resample_init(&resample_instance, configuration.num_channels); 39164421eb6SMilanka Ringwald 392b23b09a5SMatthias Ringwald // setup audio playback 393b23b09a5SMatthias Ringwald const btstack_audio_t * audio = btstack_audio_get_instance(); 394b23b09a5SMatthias Ringwald if (audio){ 395b23b09a5SMatthias Ringwald audio->init(NUM_CHANNELS, configuration.sampling_frequency, &playback_handler, NULL); 39664421eb6SMilanka Ringwald } 39764421eb6SMilanka Ringwald 39864421eb6SMilanka Ringwald audio_stream_started = 0; 39964421eb6SMilanka Ringwald media_initialized = 1; 40064421eb6SMilanka Ringwald return 0; 40164421eb6SMilanka Ringwald } 40264421eb6SMilanka Ringwald 40364421eb6SMilanka Ringwald static void media_processing_close(void){ 40432ea0426SMatthias Ringwald 40564421eb6SMilanka Ringwald if (!media_initialized) return; 40664421eb6SMilanka Ringwald media_initialized = 0; 407b23b09a5SMatthias Ringwald audio_stream_started = 0; 408c63d45a5SMatthias Ringwald 40964421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_WAV_FILE 41064421eb6SMilanka Ringwald wav_writer_close(); 41164421eb6SMilanka Ringwald int total_frames_nr = state.good_frames_nr + state.bad_frames_nr + state.zero_frames_nr; 41264421eb6SMilanka Ringwald 413813397eaSMilanka Ringwald printf("WAV Writer: Decoding done. Processed totaly %d frames:\n - %d good\n - %d bad\n", total_frames_nr, state.good_frames_nr, total_frames_nr - state.good_frames_nr); 414c63d45a5SMatthias Ringwald printf("WAV Writer: Written %d frames to wav file: %s\n", frame_count, wav_filename); 41564421eb6SMilanka Ringwald #endif 416c63d45a5SMatthias Ringwald 41764421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_SBC_FILE 41864421eb6SMilanka Ringwald fclose(sbc_file); 41964421eb6SMilanka Ringwald #endif 42064421eb6SMilanka Ringwald 421b23b09a5SMatthias Ringwald // stop audio playback 422b23b09a5SMatthias Ringwald const btstack_audio_t * audio = btstack_audio_get_instance(); 423b23b09a5SMatthias Ringwald if (audio){ 424b23b09a5SMatthias Ringwald audio->close(); 42564421eb6SMilanka Ringwald } 42664421eb6SMilanka Ringwald } 4274dc98401SMilanka Ringwald 4284dc98401SMilanka Ringwald /* @section Handle Media Data Packet 4294dc98401SMilanka Ringwald * 4304dc98401SMilanka Ringwald * @text Media data packets, in this case the audio data, are received through the handle_l2cap_media_data_packet callback. 4314dc98401SMilanka Ringwald * Currently, only the SBC media codec is supported. Hence, the media data consists of the media packet header and the SBC packet. 432b23b09a5SMatthias 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) 433b23b09a5SMatthias Ringwald * If the audio stream wasn't started already and there are enough SBC frames in the ring buffer, start playback. 4344dc98401SMilanka Ringwald */ 4354dc98401SMilanka Ringwald 4364dc98401SMilanka Ringwald static int read_media_data_header(uint8_t * packet, int size, int * offset, avdtp_media_packet_header_t * media_header); 4374dc98401SMilanka Ringwald static int read_sbc_header(uint8_t * packet, int size, int * offset, avdtp_sbc_codec_header_t * sbc_header); 4384dc98401SMilanka Ringwald 439fd58c900SMilanka Ringwald static void handle_l2cap_media_data_packet(uint8_t seid, uint8_t *packet, uint16_t size){ 440fd58c900SMilanka Ringwald UNUSED(seid); 44164421eb6SMilanka Ringwald int pos = 0; 44264421eb6SMilanka Ringwald 44364421eb6SMilanka Ringwald avdtp_media_packet_header_t media_header; 4444dc98401SMilanka Ringwald if (!read_media_data_header(packet, size, &pos, &media_header)) return; 44564421eb6SMilanka Ringwald 44664421eb6SMilanka Ringwald avdtp_sbc_codec_header_t sbc_header; 4474dc98401SMilanka Ringwald if (!read_sbc_header(packet, size, &pos, &sbc_header)) return; 44864421eb6SMilanka Ringwald 44932ea0426SMatthias Ringwald const btstack_audio_t * audio = btstack_audio_get_instance(); 45032ea0426SMatthias Ringwald 45132ea0426SMatthias Ringwald // process data right away if there's no audio implementation active, e.g. on posix systems to store as .wav 45232ea0426SMatthias Ringwald if (!audio){ 45332ea0426SMatthias Ringwald btstack_sbc_decoder_process_data(&state, 0, packet+pos, size-pos); 45432ea0426SMatthias Ringwald return; 45532ea0426SMatthias Ringwald } 45632ea0426SMatthias Ringwald 45764421eb6SMilanka Ringwald // store sbc frame size for buffer management 45864421eb6SMilanka Ringwald sbc_frame_size = (size-pos)/ sbc_header.num_frames; 45964421eb6SMilanka Ringwald 460e9c5f44eSMatthias Ringwald int status = btstack_ring_buffer_write(&sbc_frame_ring_buffer, packet+pos, size-pos); 461e9c5f44eSMatthias Ringwald if (status){ 462e9c5f44eSMatthias Ringwald printf("Error storing samples in SBC ring buffer!!!\n"); 463e9c5f44eSMatthias Ringwald } 46464421eb6SMilanka Ringwald 46564421eb6SMilanka Ringwald // decide on audio sync drift based on number of sbc frames in queue 466b23b09a5SMatthias Ringwald int sbc_frames_in_buffer = btstack_ring_buffer_bytes_available(&sbc_frame_ring_buffer) / sbc_frame_size; 467e9c5f44eSMatthias Ringwald uint32_t resampling_factor; 468c5fccf8bSMatthias Ringwald 469c5fccf8bSMatthias Ringwald // nomimal factor (fixed-point 2^16) and compensation offset 470c5fccf8bSMatthias Ringwald uint32_t nomimal_factor = 0x0FF80; 471c5fccf8bSMatthias Ringwald uint32_t compensation = 0x00100; 472c5fccf8bSMatthias Ringwald 47364421eb6SMilanka Ringwald if (sbc_frames_in_buffer < OPTIMAL_FRAMES_MIN){ 474c5fccf8bSMatthias Ringwald resampling_factor = nomimal_factor - compensation; // stretch samples 47564421eb6SMilanka Ringwald } else if (sbc_frames_in_buffer <= OPTIMAL_FRAMES_MAX){ 476c5fccf8bSMatthias Ringwald resampling_factor = nomimal_factor; // nothing to do 47764421eb6SMilanka Ringwald } else { 478c5fccf8bSMatthias Ringwald resampling_factor = nomimal_factor + compensation; // compress samples 47964421eb6SMilanka Ringwald } 48064421eb6SMilanka Ringwald 481e9c5f44eSMatthias Ringwald btstack_resample_set_factor(&resample_instance, resampling_factor); 482e9c5f44eSMatthias Ringwald 48364421eb6SMilanka Ringwald // dump 484*f55e1e38SMilanka Ringwald // printf("%6u %03u %05x\n", (int) btstack_run_loop_get_time_ms(), sbc_frames_in_buffer, resampling_factor); 485e9c5f44eSMatthias Ringwald // log_info("%03u %05x", sbc_frames_in_buffer, resampling_factor); 48664421eb6SMilanka Ringwald 48764421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_SBC_FILE 48864421eb6SMilanka Ringwald fwrite(packet+pos, size-pos, 1, sbc_file); 48964421eb6SMilanka Ringwald #endif 49064421eb6SMilanka Ringwald 491b23b09a5SMatthias Ringwald // start stream if enough frames buffered 492e9c5f44eSMatthias Ringwald if (!audio_stream_started && sbc_frames_in_buffer >= OPTIMAL_FRAMES_MIN){ 4934dc98401SMilanka Ringwald audio_stream_started = 1; 494b23b09a5SMatthias Ringwald // setup audio playback 495b23b09a5SMatthias Ringwald if (audio){ 496b23b09a5SMatthias Ringwald audio->start_stream(); 4974dc98401SMilanka Ringwald } 4984dc98401SMilanka Ringwald } 4994dc98401SMilanka Ringwald } 5004dc98401SMilanka Ringwald 5014dc98401SMilanka Ringwald static int read_sbc_header(uint8_t * packet, int size, int * offset, avdtp_sbc_codec_header_t * sbc_header){ 5024dc98401SMilanka Ringwald int sbc_header_len = 12; // without crc 5034dc98401SMilanka Ringwald int pos = *offset; 5044dc98401SMilanka Ringwald 5054dc98401SMilanka Ringwald if (size - pos < sbc_header_len){ 5064dc98401SMilanka Ringwald printf("Not enough data to read SBC header, expected %d, received %d\n", sbc_header_len, size-pos); 5073290eaa8SMilanka Ringwald return 0; 5084dc98401SMilanka Ringwald } 5094dc98401SMilanka Ringwald 5104dc98401SMilanka Ringwald sbc_header->fragmentation = get_bit16(packet[pos], 7); 5114dc98401SMilanka Ringwald sbc_header->starting_packet = get_bit16(packet[pos], 6); 5124dc98401SMilanka Ringwald sbc_header->last_packet = get_bit16(packet[pos], 5); 5134dc98401SMilanka Ringwald sbc_header->num_frames = packet[pos] & 0x0f; 5144dc98401SMilanka Ringwald pos++; 5154dc98401SMilanka 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); 5164dc98401SMilanka Ringwald *offset = pos; 5173290eaa8SMilanka Ringwald return 1; 5184dc98401SMilanka Ringwald } 5194dc98401SMilanka Ringwald 5204dc98401SMilanka Ringwald static int read_media_data_header(uint8_t *packet, int size, int *offset, avdtp_media_packet_header_t *media_header){ 5214dc98401SMilanka Ringwald int media_header_len = 12; // without crc 5224dc98401SMilanka Ringwald int pos = *offset; 5234dc98401SMilanka Ringwald 5244dc98401SMilanka Ringwald if (size - pos < media_header_len){ 5254dc98401SMilanka Ringwald printf("Not enough data to read media packet header, expected %d, received %d\n", media_header_len, size-pos); 5263290eaa8SMilanka Ringwald return 0; 5274dc98401SMilanka Ringwald } 5284dc98401SMilanka Ringwald 5294dc98401SMilanka Ringwald media_header->version = packet[pos] & 0x03; 5304dc98401SMilanka Ringwald media_header->padding = get_bit16(packet[pos],2); 5314dc98401SMilanka Ringwald media_header->extension = get_bit16(packet[pos],3); 5324dc98401SMilanka Ringwald media_header->csrc_count = (packet[pos] >> 4) & 0x0F; 5334dc98401SMilanka Ringwald pos++; 5344dc98401SMilanka Ringwald 5354dc98401SMilanka Ringwald media_header->marker = get_bit16(packet[pos],0); 5364dc98401SMilanka Ringwald media_header->payload_type = (packet[pos] >> 1) & 0x7F; 5374dc98401SMilanka Ringwald pos++; 5384dc98401SMilanka Ringwald 5394dc98401SMilanka Ringwald media_header->sequence_number = big_endian_read_16(packet, pos); 5404dc98401SMilanka Ringwald pos+=2; 5414dc98401SMilanka Ringwald 5424dc98401SMilanka Ringwald media_header->timestamp = big_endian_read_32(packet, pos); 5434dc98401SMilanka Ringwald pos+=4; 5444dc98401SMilanka Ringwald 5454dc98401SMilanka Ringwald media_header->synchronization_source = big_endian_read_32(packet, pos); 5464dc98401SMilanka Ringwald pos+=4; 5474dc98401SMilanka Ringwald *offset = pos; 5483290eaa8SMilanka Ringwald return 1; 5494dc98401SMilanka Ringwald } 5504dc98401SMilanka Ringwald 55164421eb6SMilanka Ringwald static void dump_sbc_configuration(avdtp_media_codec_configuration_sbc_t configuration){ 5524dc98401SMilanka Ringwald printf("Received SBC configuration:\n"); 55364421eb6SMilanka Ringwald printf(" - num_channels: %d\n", configuration.num_channels); 55464421eb6SMilanka Ringwald printf(" - sampling_frequency: %d\n", configuration.sampling_frequency); 55564421eb6SMilanka Ringwald printf(" - channel_mode: %d\n", configuration.channel_mode); 55664421eb6SMilanka Ringwald printf(" - block_length: %d\n", configuration.block_length); 55764421eb6SMilanka Ringwald printf(" - subbands: %d\n", configuration.subbands); 55864421eb6SMilanka Ringwald printf(" - allocation_method: %d\n", configuration.allocation_method); 55964421eb6SMilanka Ringwald printf(" - bitpool_value [%d, %d] \n", configuration.min_bitpool_value, configuration.max_bitpool_value); 560f1042e9dSMilanka Ringwald printf("\n"); 56164421eb6SMilanka Ringwald } 56264421eb6SMilanka Ringwald 56301dc6e35SMilanka Ringwald static void avrcp_controller_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 56464421eb6SMilanka Ringwald UNUSED(channel); 56564421eb6SMilanka Ringwald UNUSED(size); 56664421eb6SMilanka Ringwald uint16_t local_cid; 56764421eb6SMilanka Ringwald uint8_t status = 0xFF; 568ef5ad9d6SMilanka Ringwald bd_addr_t adress; 56901dc6e35SMilanka Ringwald 57001dc6e35SMilanka Ringwald if (packet_type != HCI_EVENT_PACKET) return; 57101dc6e35SMilanka Ringwald if (hci_event_packet_get_type(packet) != HCI_EVENT_AVRCP_META) return; 57264421eb6SMilanka Ringwald switch (packet[2]){ 57364421eb6SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_ESTABLISHED: { 57464421eb6SMilanka Ringwald local_cid = avrcp_subevent_connection_established_get_avrcp_cid(packet); 57514e3e2c2SMilanka Ringwald if (avrcp_controller_cid != 0 && avrcp_controller_cid != local_cid) { 57614e3e2c2SMilanka Ringwald printf("AVRCP Controller: Connection failed, expected 0x%02X l2cap cid, received 0x%02X\n", avrcp_controller_cid, local_cid); 577df642728SMilanka Ringwald return; 57864421eb6SMilanka Ringwald } 57964421eb6SMilanka Ringwald 58064421eb6SMilanka Ringwald status = avrcp_subevent_connection_established_get_status(packet); 58164421eb6SMilanka Ringwald if (status != ERROR_CODE_SUCCESS){ 58214e3e2c2SMilanka Ringwald printf("AVRCP Controller: Connection failed: status 0x%02x\n", status); 58314e3e2c2SMilanka Ringwald avrcp_controller_cid = 0; 584df642728SMilanka Ringwald return; 58564421eb6SMilanka Ringwald } 5864b338011SMilanka Ringwald 58714e3e2c2SMilanka Ringwald avrcp_controller_cid = local_cid; 5886c333d06SMilanka Ringwald avrcp_connected = 1; 589ef5ad9d6SMilanka Ringwald avrcp_subevent_connection_established_get_bd_addr(packet, adress); 59014e3e2c2SMilanka Ringwald printf("AVRCP Controller: Channel successfully opened: %s, avrcp_controller_cid 0x%02x\n", bd_addr_to_str(adress), avrcp_controller_cid); 591df642728SMilanka Ringwald 59264421eb6SMilanka Ringwald // automatically enable notifications 59314e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_PLAYBACK_STATUS_CHANGED); 59414e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_NOW_PLAYING_CONTENT_CHANGED); 59514e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_TRACK_CHANGED); 59664421eb6SMilanka Ringwald return; 59764421eb6SMilanka Ringwald } 59864421eb6SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_RELEASED: 59914e3e2c2SMilanka Ringwald printf("AVRCP Controller: Channel released: avrcp_controller_cid 0x%02x\n", avrcp_subevent_connection_released_get_avrcp_cid(packet)); 60014e3e2c2SMilanka Ringwald avrcp_controller_cid = 0; 6016c333d06SMilanka Ringwald avrcp_connected = 0; 60264421eb6SMilanka Ringwald return; 60364421eb6SMilanka Ringwald default: 60464421eb6SMilanka Ringwald break; 60564421eb6SMilanka Ringwald } 60664421eb6SMilanka Ringwald 60764421eb6SMilanka Ringwald status = packet[5]; 60814e3e2c2SMilanka Ringwald if (!avrcp_controller_cid) return; 60964421eb6SMilanka Ringwald 6104dc98401SMilanka Ringwald // ignore INTERIM status 6118177fff3SMilanka Ringwald if (status == AVRCP_CTYPE_RESPONSE_INTERIM){ 6126fa3dbf2SMilanka Ringwald switch (packet[2]){ 6136fa3dbf2SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_PLAYBACK_POS_CHANGED:{ 6146fa3dbf2SMilanka Ringwald uint32_t playback_position_ms = avrcp_subevent_notification_playback_pos_changed_get_playback_position_ms(packet); 6156fa3dbf2SMilanka Ringwald if (playback_position_ms == AVRCP_NO_TRACK_SELECTED_PLAYBACK_POSITION_CHANGED){ 616*f55e1e38SMilanka Ringwald printf("AVRCP Controller: playback position changed, no track is selected\n"); 6176fa3dbf2SMilanka Ringwald } 6186fa3dbf2SMilanka Ringwald break; 6196fa3dbf2SMilanka Ringwald } 6206fa3dbf2SMilanka Ringwald default: 6216fa3dbf2SMilanka Ringwald break; 6226fa3dbf2SMilanka Ringwald } 6238177fff3SMilanka Ringwald return; 6248177fff3SMilanka Ringwald } 62564421eb6SMilanka Ringwald 62614e3e2c2SMilanka Ringwald memset(value, 0, sizeof(value)); 62764421eb6SMilanka Ringwald switch (packet[2]){ 6286fa3dbf2SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_PLAYBACK_POS_CHANGED: 629*f55e1e38SMilanka Ringwald printf("AVRCP Controller: playback position changed, position %d ms\n", (unsigned int) avrcp_subevent_notification_playback_pos_changed_get_playback_position_ms(packet)); 6306fa3dbf2SMilanka Ringwald break; 63164421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_PLAYBACK_STATUS_CHANGED: 632*f55e1e38SMilanka Ringwald printf("AVRCP Controller: playback status changed %s\n", avrcp_play_status2str(avrcp_subevent_notification_playback_status_changed_get_play_status(packet))); 63364421eb6SMilanka Ringwald return; 63464421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_NOW_PLAYING_CONTENT_CHANGED: 635*f55e1e38SMilanka Ringwald printf("AVRCP Controller: playing content changed\n"); 63664421eb6SMilanka Ringwald return; 63764421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_TRACK_CHANGED: 638*f55e1e38SMilanka Ringwald printf("AVRCP Controller: track changed\n"); 63964421eb6SMilanka Ringwald return; 64064421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_VOLUME_CHANGED: 641*f55e1e38SMilanka Ringwald printf("AVRCP Controller: absolute volume changed %d\n", avrcp_subevent_notification_volume_changed_get_absolute_volume(packet)); 64264421eb6SMilanka Ringwald return; 64364421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_AVAILABLE_PLAYERS_CHANGED: 644*f55e1e38SMilanka Ringwald printf("AVRCP Controller: changed\n"); 64564421eb6SMilanka Ringwald return; 64664421eb6SMilanka Ringwald case AVRCP_SUBEVENT_SHUFFLE_AND_REPEAT_MODE:{ 64764421eb6SMilanka Ringwald uint8_t shuffle_mode = avrcp_subevent_shuffle_and_repeat_mode_get_shuffle_mode(packet); 64864421eb6SMilanka Ringwald uint8_t repeat_mode = avrcp_subevent_shuffle_and_repeat_mode_get_repeat_mode(packet); 649*f55e1e38SMilanka Ringwald printf("AVRCP Controller: %s, %s\n", avrcp_shuffle2str(shuffle_mode), avrcp_repeat2str(repeat_mode)); 65064421eb6SMilanka Ringwald break; 65164421eb6SMilanka Ringwald } 65214e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_TRACK_INFO: 653*f55e1e38SMilanka Ringwald printf("AVRCP Controller: Track: %d\n", avrcp_subevent_now_playing_track_info_get_track(packet)); 65414e3e2c2SMilanka Ringwald break; 65514e3e2c2SMilanka Ringwald 65614e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_TOTAL_TRACKS_INFO: 657*f55e1e38SMilanka Ringwald printf("AVRCP Controller: Total Tracks: %d\n", avrcp_subevent_now_playing_total_tracks_info_get_total_tracks(packet)); 65814e3e2c2SMilanka Ringwald break; 65914e3e2c2SMilanka Ringwald 6601bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_TITLE_INFO: 6611bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_title_info_get_value_len(packet) > 0){ 6621bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_title_info_get_value(packet), avrcp_subevent_now_playing_title_info_get_value_len(packet)); 663*f55e1e38SMilanka Ringwald printf("AVRCP Controller: Title: %s\n", value); 66464421eb6SMilanka Ringwald } 66564421eb6SMilanka Ringwald break; 6661bf7a74fSMilanka Ringwald 6671bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_ARTIST_INFO: 6681bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_artist_info_get_value_len(packet) > 0){ 6691bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_artist_info_get_value(packet), avrcp_subevent_now_playing_artist_info_get_value_len(packet)); 670*f55e1e38SMilanka Ringwald printf("AVRCP Controller: Artist: %s\n", value); 67164421eb6SMilanka Ringwald } 6721bf7a74fSMilanka Ringwald break; 6731bf7a74fSMilanka Ringwald 6741bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_ALBUM_INFO: 6751bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_album_info_get_value_len(packet) > 0){ 6761bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_album_info_get_value(packet), avrcp_subevent_now_playing_album_info_get_value_len(packet)); 677*f55e1e38SMilanka Ringwald printf("AVRCP Controller: Album: %s\n", value); 6781bf7a74fSMilanka Ringwald } 6791bf7a74fSMilanka Ringwald break; 6801bf7a74fSMilanka Ringwald 6811bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_GENRE_INFO: 6821bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_genre_info_get_value_len(packet) > 0){ 6831bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_genre_info_get_value(packet), avrcp_subevent_now_playing_genre_info_get_value_len(packet)); 684*f55e1e38SMilanka Ringwald printf("AVRCP Controller: Genre: %s\n", value); 6851bf7a74fSMilanka Ringwald } 6861bf7a74fSMilanka Ringwald break; 6871bf7a74fSMilanka Ringwald 68864421eb6SMilanka Ringwald case AVRCP_SUBEVENT_PLAY_STATUS: 689*f55e1e38SMilanka Ringwald printf("AVRCP Controller: song length: %"PRIu32" ms, song position: %"PRIu32" ms, play status: %s\n", 69064421eb6SMilanka Ringwald avrcp_subevent_play_status_get_song_length(packet), 69164421eb6SMilanka Ringwald avrcp_subevent_play_status_get_song_position(packet), 69264421eb6SMilanka Ringwald avrcp_play_status2str(avrcp_subevent_play_status_get_play_status(packet))); 69364421eb6SMilanka Ringwald break; 69464421eb6SMilanka Ringwald case AVRCP_SUBEVENT_OPERATION_COMPLETE: 695*f55e1e38SMilanka Ringwald printf("AVRCP Controller: operation done %s\n", avrcp_operation2str(avrcp_subevent_operation_complete_get_operation_id(packet))); 69664421eb6SMilanka Ringwald break; 69764421eb6SMilanka Ringwald case AVRCP_SUBEVENT_OPERATION_START: 698*f55e1e38SMilanka Ringwald printf("AVRCP Controller: operation start %s\n", avrcp_operation2str(avrcp_subevent_operation_complete_get_operation_id(packet))); 69964421eb6SMilanka Ringwald break; 70064421eb6SMilanka Ringwald case AVRCP_SUBEVENT_PLAYER_APPLICATION_VALUE_RESPONSE: 70164421eb6SMilanka Ringwald // response to set shuffle and repeat mode 70264421eb6SMilanka Ringwald printf("\n"); 70364421eb6SMilanka Ringwald break; 70464421eb6SMilanka Ringwald default: 70514e3e2c2SMilanka Ringwald printf("AVRCP Controller: event 0x%02x is not parsed\n", packet[2]); 70664421eb6SMilanka Ringwald break; 70764421eb6SMilanka Ringwald } 70864421eb6SMilanka Ringwald } 70964421eb6SMilanka Ringwald 71014e3e2c2SMilanka Ringwald 71114e3e2c2SMilanka Ringwald static void avrcp_target_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 71214e3e2c2SMilanka Ringwald UNUSED(channel); 71314e3e2c2SMilanka Ringwald UNUSED(size); 71414e3e2c2SMilanka Ringwald bd_addr_t event_addr; 71514e3e2c2SMilanka Ringwald uint16_t local_cid; 71614e3e2c2SMilanka Ringwald uint8_t status = ERROR_CODE_SUCCESS; 71714e3e2c2SMilanka Ringwald 71814e3e2c2SMilanka Ringwald if (packet_type != HCI_EVENT_PACKET) return; 71914e3e2c2SMilanka Ringwald if (hci_event_packet_get_type(packet) != HCI_EVENT_AVRCP_META) return; 72014e3e2c2SMilanka Ringwald 721*f55e1e38SMilanka Ringwald int volume; 722*f55e1e38SMilanka Ringwald 72314e3e2c2SMilanka Ringwald switch (packet[2]){ 72414e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_VOLUME_CHANGED: 725*f55e1e38SMilanka Ringwald volume = avrcp_subevent_notification_volume_changed_get_absolute_volume(packet); 726*f55e1e38SMilanka Ringwald volume_percentage = volume * 100 / 127; 727*f55e1e38SMilanka Ringwald printf("AVRCP Target: new volume %d%% (%d)\n", volume_percentage, volume); 72814e3e2c2SMilanka Ringwald break; 72914e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_ESTABLISHED: 73014e3e2c2SMilanka Ringwald local_cid = avrcp_subevent_connection_established_get_avrcp_cid(packet); 73114e3e2c2SMilanka Ringwald if (avrcp_target_cid != 0 && avrcp_target_cid != local_cid) { 73214e3e2c2SMilanka Ringwald printf("AVRCP Target: Connection failed, expected 0x%02X l2cap cid, received 0x%02X\n", avrcp_target_cid, local_cid); 73314e3e2c2SMilanka Ringwald return; 73414e3e2c2SMilanka Ringwald } 73514e3e2c2SMilanka Ringwald 73614e3e2c2SMilanka Ringwald status = avrcp_subevent_connection_established_get_status(packet); 73714e3e2c2SMilanka Ringwald if (status != ERROR_CODE_SUCCESS){ 73814e3e2c2SMilanka Ringwald printf("AVRCP Target: Connection failed: status 0x%02x\n", status); 73914e3e2c2SMilanka Ringwald avrcp_target_cid = 0; 74014e3e2c2SMilanka Ringwald return; 74114e3e2c2SMilanka Ringwald } 74214e3e2c2SMilanka Ringwald avrcp_target_cid = local_cid; 74314e3e2c2SMilanka Ringwald printf("AVRCP Target: Connected to %s, avrcp_cid 0x%02x\n", bd_addr_to_str(event_addr), local_cid); 74414e3e2c2SMilanka Ringwald break; 74514e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_EVENT_IDS_QUERY: 74614e3e2c2SMilanka Ringwald printf("AVRCP Target: get supported events\n"); 74714e3e2c2SMilanka Ringwald status = avrcp_target_supported_events(avrcp_target_cid, events_num, events, sizeof(events)); 74814e3e2c2SMilanka Ringwald break; 74914e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_COMPANY_IDS_QUERY: 75014e3e2c2SMilanka Ringwald status = avrcp_target_supported_companies(avrcp_target_cid, companies_num, companies, sizeof(companies)); 75114e3e2c2SMilanka Ringwald break; 75214e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_OPERATION:{ 75314e3e2c2SMilanka Ringwald avrcp_operation_id_t operation_id = avrcp_subevent_operation_get_operation_id(packet); 75414e3e2c2SMilanka Ringwald // if (!media_tracker.connected) break; 75514e3e2c2SMilanka Ringwald switch (operation_id){ 75614e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_PLAY: 75714e3e2c2SMilanka Ringwald printf("AVRCP Target: PLAY\n"); 75814e3e2c2SMilanka Ringwald break; 75914e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_PAUSE: 76014e3e2c2SMilanka Ringwald printf("AVRCP Target: PAUSE\n"); 76114e3e2c2SMilanka Ringwald break; 76214e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_STOP: 76314e3e2c2SMilanka Ringwald printf("AVRCP Target: STOP\n"); 76414e3e2c2SMilanka Ringwald break; 76514e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_REWIND: 76614e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation REWIND\n"); 76714e3e2c2SMilanka Ringwald break; 76814e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_FAST_FORWARD: 76914e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation FAST_FORWARD\n"); 77014e3e2c2SMilanka Ringwald break; 77114e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_FORWARD: 77214e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation FORWARD\n"); 77314e3e2c2SMilanka Ringwald break; 77414e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_BACKWARD: 77514e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation BACKWARD\n"); 77614e3e2c2SMilanka Ringwald break; 77714e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_SKIP: 77814e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation SKIP\n"); 77914e3e2c2SMilanka Ringwald break; 78014e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_MUTE: 78114e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation MUTE\n"); 78214e3e2c2SMilanka Ringwald break; 78314e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_CHANNEL_UP: 78414e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation CHANNEL_UP\n"); 78514e3e2c2SMilanka Ringwald break; 78614e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_CHANNEL_DOWN: 78714e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation CHANNEL_DOWN\n"); 78814e3e2c2SMilanka Ringwald break; 78914e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_SELECT: 79014e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation SELECT\n"); 79114e3e2c2SMilanka Ringwald break; 79214e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_UP: 79314e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation UP\n"); 79414e3e2c2SMilanka Ringwald break; 79514e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_DOWN: 79614e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation DOWN\n"); 79714e3e2c2SMilanka Ringwald break; 79814e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_LEFT: 79914e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation LEFT\n"); 80014e3e2c2SMilanka Ringwald break; 80114e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_RIGHT: 80214e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation RIGTH\n"); 80314e3e2c2SMilanka Ringwald break; 80414e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_ROOT_MENU: 80514e3e2c2SMilanka Ringwald printf("AVRCP Target: received operation ROOT_MENU\n"); 80614e3e2c2SMilanka Ringwald break; 80714e3e2c2SMilanka Ringwald default: 80814e3e2c2SMilanka Ringwald return; 80914e3e2c2SMilanka Ringwald } 81014e3e2c2SMilanka Ringwald break; 81114e3e2c2SMilanka Ringwald } 81214e3e2c2SMilanka Ringwald 81314e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_RELEASED: 81414e3e2c2SMilanka Ringwald printf("AVRCP Target: Disconnected, avrcp_cid 0x%02x\n", avrcp_subevent_connection_released_get_avrcp_cid(packet)); 81514e3e2c2SMilanka Ringwald return; 81614e3e2c2SMilanka Ringwald default: 81714e3e2c2SMilanka Ringwald printf("AVRCP Target: event 0x%02x is not parsed\n", packet[2]); 81814e3e2c2SMilanka Ringwald break; 81914e3e2c2SMilanka Ringwald } 82014e3e2c2SMilanka Ringwald } 82114e3e2c2SMilanka Ringwald 82214e3e2c2SMilanka Ringwald 823b23b09a5SMatthias Ringwald static void hci_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 824b23b09a5SMatthias Ringwald UNUSED(channel); 825b23b09a5SMatthias Ringwald UNUSED(size); 826b23b09a5SMatthias Ringwald if (packet_type != HCI_EVENT_PACKET) return; 827b23b09a5SMatthias Ringwald if (hci_event_packet_get_type(packet) == HCI_EVENT_PIN_CODE_REQUEST) { 828b23b09a5SMatthias Ringwald bd_addr_t address; 829b23b09a5SMatthias Ringwald printf("Pin code request - using '0000'\n"); 830b23b09a5SMatthias Ringwald hci_event_pin_code_request_get_bd_addr(packet, address); 831b23b09a5SMatthias Ringwald gap_pin_code_response(address, "0000"); 832b23b09a5SMatthias Ringwald } 833b23b09a5SMatthias Ringwald } 834b23b09a5SMatthias Ringwald 8354dc98401SMilanka Ringwald static void a2dp_sink_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 83664421eb6SMilanka Ringwald UNUSED(channel); 83764421eb6SMilanka Ringwald UNUSED(size); 8384ccacc40SMilanka Ringwald uint16_t cid; 839ef5ad9d6SMilanka Ringwald bd_addr_t address; 840326e5cedSMilanka Ringwald uint8_t status; 84164421eb6SMilanka Ringwald 842ef5ad9d6SMilanka Ringwald if (packet_type != HCI_EVENT_PACKET) return; 843ef5ad9d6SMilanka Ringwald if (hci_event_packet_get_type(packet) != HCI_EVENT_A2DP_META) return; 844ef5ad9d6SMilanka Ringwald 84564421eb6SMilanka Ringwald switch (packet[2]){ 846f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_SIGNALING_MEDIA_CODEC_OTHER_CONFIGURATION: 84714e3e2c2SMilanka Ringwald printf("A2DP Sink Demo: received non SBC codec. not implemented.\n"); 84864421eb6SMilanka Ringwald break; 849f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_SIGNALING_MEDIA_CODEC_SBC_CONFIGURATION:{ 85014e3e2c2SMilanka Ringwald printf("A2DP Sink Demo: received SBC codec configuration.\n"); 851f1042e9dSMilanka Ringwald sbc_configuration.reconfigure = a2dp_subevent_signaling_media_codec_sbc_configuration_get_reconfigure(packet); 852f1042e9dSMilanka Ringwald sbc_configuration.num_channels = a2dp_subevent_signaling_media_codec_sbc_configuration_get_num_channels(packet); 853f1042e9dSMilanka Ringwald sbc_configuration.sampling_frequency = a2dp_subevent_signaling_media_codec_sbc_configuration_get_sampling_frequency(packet); 854f1042e9dSMilanka Ringwald sbc_configuration.channel_mode = a2dp_subevent_signaling_media_codec_sbc_configuration_get_channel_mode(packet); 855f1042e9dSMilanka Ringwald sbc_configuration.block_length = a2dp_subevent_signaling_media_codec_sbc_configuration_get_block_length(packet); 856f1042e9dSMilanka Ringwald sbc_configuration.subbands = a2dp_subevent_signaling_media_codec_sbc_configuration_get_subbands(packet); 857f1042e9dSMilanka Ringwald sbc_configuration.allocation_method = a2dp_subevent_signaling_media_codec_sbc_configuration_get_allocation_method(packet); 858f1042e9dSMilanka Ringwald sbc_configuration.min_bitpool_value = a2dp_subevent_signaling_media_codec_sbc_configuration_get_min_bitpool_value(packet); 859f1042e9dSMilanka Ringwald sbc_configuration.max_bitpool_value = a2dp_subevent_signaling_media_codec_sbc_configuration_get_max_bitpool_value(packet); 86064421eb6SMilanka Ringwald sbc_configuration.frames_per_buffer = sbc_configuration.subbands * sbc_configuration.block_length; 86164421eb6SMilanka Ringwald dump_sbc_configuration(sbc_configuration); 86264421eb6SMilanka Ringwald 86364421eb6SMilanka Ringwald if (sbc_configuration.reconfigure){ 86464421eb6SMilanka Ringwald media_processing_close(); 86564421eb6SMilanka Ringwald } 866c63d45a5SMatthias Ringwald // prepare media processing 867c63d45a5SMatthias Ringwald media_processing_init(sbc_configuration); 86864421eb6SMilanka Ringwald break; 86964421eb6SMilanka Ringwald } 870f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_ESTABLISHED: 871ef5ad9d6SMilanka Ringwald a2dp_subevent_stream_established_get_bd_addr(packet, address); 872326e5cedSMilanka Ringwald status = a2dp_subevent_stream_established_get_status(packet); 8734ccacc40SMilanka Ringwald cid = a2dp_subevent_stream_established_get_a2dp_cid(packet); 874596b7fdcSMilanka Ringwald if (!a2dp_cid){ 875596b7fdcSMilanka Ringwald // incoming connection 876596b7fdcSMilanka Ringwald a2dp_cid = cid; 877596b7fdcSMilanka Ringwald } else if (cid != a2dp_cid) { 878596b7fdcSMilanka Ringwald break; 879596b7fdcSMilanka Ringwald } 880326e5cedSMilanka Ringwald if (status){ 881*f55e1e38SMilanka Ringwald printf("A2DP Sink: streaming connection failed, status 0x%02x\n", status); 882326e5cedSMilanka Ringwald break; 883326e5cedSMilanka Ringwald } 8849635072eSMilanka Ringwald 8859635072eSMilanka Ringwald memcpy(device_addr, address, 6); 886*f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_established_get_local_seid(packet); 887*f55e1e38SMilanka Ringwald printf("A2DP Sink: streaming connection is established, address %s, a2dp cid 0x%02X, a2dp local seid %d\n", bd_addr_to_str(address), a2dp_cid, a2dp_local_seid); 88864421eb6SMilanka Ringwald break; 889f1042e9dSMilanka Ringwald 890f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_STARTED: 8914ccacc40SMilanka Ringwald cid = a2dp_subevent_stream_started_get_a2dp_cid(packet); 8924ccacc40SMilanka Ringwald if (cid != a2dp_cid) break; 893*f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_started_get_local_seid(packet); 894*f55e1e38SMilanka Ringwald printf("A2DP Sink: stream started\n"); 89572c514e8SMilanka Ringwald media_processing_init(sbc_configuration); 89664421eb6SMilanka Ringwald break; 897f1042e9dSMilanka Ringwald 898f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_SUSPENDED: 8994ccacc40SMilanka Ringwald cid = a2dp_subevent_stream_suspended_get_a2dp_cid(packet); 9004ccacc40SMilanka Ringwald if (cid != a2dp_cid) break; 901*f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_suspended_get_local_seid(packet); 902*f55e1e38SMilanka Ringwald printf("A2DP Sink: stream paused\n"); 903*f55e1e38SMilanka Ringwald // media_processing_close(); 904f1042e9dSMilanka Ringwald break; 905f1042e9dSMilanka Ringwald 906f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_RELEASED: 907*f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_released_get_local_seid(packet); 908*f55e1e38SMilanka Ringwald printf("A2DP Sink: stream released\n"); 909f1042e9dSMilanka Ringwald media_processing_close(); 910f1042e9dSMilanka Ringwald break; 911a466d508SMilanka Ringwald case A2DP_SUBEVENT_SIGNALING_CONNECTION_RELEASED: 912a466d508SMilanka Ringwald cid = a2dp_subevent_signaling_connection_released_get_a2dp_cid(packet); 913*f55e1e38SMilanka Ringwald printf("A2DP Sink: signaling connection released\n"); 91432ea0426SMatthias Ringwald media_processing_close(); 915a466d508SMilanka Ringwald break; 91664421eb6SMilanka Ringwald default: 917*f55e1e38SMilanka Ringwald printf("A2DP Sink: not parsed 0x%02x\n", packet[2]); 91864421eb6SMilanka Ringwald break; 91964421eb6SMilanka Ringwald } 92064421eb6SMilanka Ringwald } 92164421eb6SMilanka Ringwald 92264421eb6SMilanka Ringwald #ifdef HAVE_BTSTACK_STDIN 92364421eb6SMilanka Ringwald static void show_usage(void){ 92464421eb6SMilanka Ringwald bd_addr_t iut_address; 92564421eb6SMilanka Ringwald gap_local_bd_addr(iut_address); 92664421eb6SMilanka Ringwald printf("\n--- Bluetooth AVDTP Sink/AVRCP Connection Test Console %s ---\n", bd_addr_to_str(iut_address)); 9279635072eSMilanka Ringwald printf("b - AVDTP Sink create connection to addr %s\n", bd_addr_to_str(device_addr)); 92864421eb6SMilanka Ringwald printf("B - AVDTP Sink disconnect\n"); 92914e3e2c2SMilanka Ringwald printf("c - AVRCP Controller create connection to addr %s\n", bd_addr_to_str(device_addr)); 93014e3e2c2SMilanka Ringwald printf("C - AVRCP Controller disconnect\n"); 93114e3e2c2SMilanka Ringwald printf("d - AVRCP Target create connection to addr %s\n", bd_addr_to_str(device_addr)); 93214e3e2c2SMilanka Ringwald printf("D - AVRCP Target disconnect\n"); 93364421eb6SMilanka Ringwald 93464421eb6SMilanka Ringwald printf("\n--- Bluetooth AVRCP Commands %s ---\n", bd_addr_to_str(iut_address)); 93564421eb6SMilanka Ringwald printf("O - get play status\n"); 93664421eb6SMilanka Ringwald printf("j - get now playing info\n"); 93764421eb6SMilanka Ringwald printf("k - play\n"); 93864421eb6SMilanka Ringwald printf("K - stop\n"); 9392d46c2e6SMilanka Ringwald printf("L - pause\n"); 9402d46c2e6SMilanka Ringwald printf("u - start fast forward\n"); 9412d46c2e6SMilanka Ringwald printf("U - stop fast forward\n"); 94264421eb6SMilanka Ringwald printf("n - start rewind\n"); 94364421eb6SMilanka Ringwald printf("N - stop rewind\n"); 94464421eb6SMilanka Ringwald printf("i - forward\n"); 94564421eb6SMilanka Ringwald printf("I - backward\n"); 94664421eb6SMilanka Ringwald printf("M - mute\n"); 94764421eb6SMilanka Ringwald printf("r - skip\n"); 94864421eb6SMilanka Ringwald printf("q - query repeat and shuffle mode\n"); 94964421eb6SMilanka Ringwald printf("v - repeat single track\n"); 95064421eb6SMilanka Ringwald printf("x - repeat all tracks\n"); 95164421eb6SMilanka Ringwald printf("X - disable repeat mode\n"); 95264421eb6SMilanka Ringwald printf("z - shuffle all tracks\n"); 95364421eb6SMilanka Ringwald printf("Z - disable shuffle mode\n"); 9548177fff3SMilanka Ringwald 9558177fff3SMilanka Ringwald printf("a/A - register/deregister TRACK_CHANGED\n"); 95614e3e2c2SMilanka Ringwald printf("R/P - register/deregister PLAYBACK_POS_CHANGED\n"); 9578177fff3SMilanka Ringwald 958*f55e1e38SMilanka Ringwald printf("\n--- Volume Control ---\n"); 959*f55e1e38SMilanka Ringwald printf("t - volume up for 10 percent\n"); 960*f55e1e38SMilanka Ringwald printf("T - volume down for 10 percent\n"); 961*f55e1e38SMilanka Ringwald 96264421eb6SMilanka Ringwald printf("---\n"); 96364421eb6SMilanka Ringwald } 96464421eb6SMilanka Ringwald #endif 96564421eb6SMilanka Ringwald 9664fb249f8SMatthias Ringwald #ifdef HAVE_BTSTACK_STDIN 96764421eb6SMilanka Ringwald static void stdin_process(char cmd){ 9684567cc17SMilanka Ringwald uint8_t status = ERROR_CODE_SUCCESS; 9696c333d06SMilanka Ringwald 97064421eb6SMilanka Ringwald switch (cmd){ 97164421eb6SMilanka Ringwald case 'b': 972*f55e1e38SMilanka Ringwald status = a2dp_sink_establish_stream(device_addr, a2dp_local_seid, &a2dp_cid); 973*f55e1e38SMilanka 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); 97464421eb6SMilanka Ringwald break; 97564421eb6SMilanka Ringwald case 'B': 976a466d508SMilanka Ringwald printf(" - AVDTP disconnect from addr %s.\n", bd_addr_to_str(device_addr)); 9774567cc17SMilanka Ringwald status = avdtp_sink_disconnect(a2dp_cid); 97864421eb6SMilanka Ringwald break; 97964421eb6SMilanka Ringwald case 'c': 98014e3e2c2SMilanka Ringwald printf(" - Create AVRCP Controller connection to addr %s.\n", bd_addr_to_str(device_addr)); 98114e3e2c2SMilanka Ringwald status = avrcp_controller_connect(device_addr, &avrcp_controller_cid); 98264421eb6SMilanka Ringwald break; 98364421eb6SMilanka Ringwald case 'C': 98414e3e2c2SMilanka Ringwald printf(" - AVRCP Controller disconnect from addr %s.\n", bd_addr_to_str(device_addr)); 98514e3e2c2SMilanka Ringwald status = avrcp_controller_disconnect(avrcp_controller_cid); 98614e3e2c2SMilanka Ringwald break; 98714e3e2c2SMilanka Ringwald case 'd': 98814e3e2c2SMilanka Ringwald printf(" - Create AVRCP Target connection to addr %s.\n", bd_addr_to_str(device_addr)); 98914e3e2c2SMilanka Ringwald status = avrcp_target_connect(device_addr, &avrcp_target_cid); 99014e3e2c2SMilanka Ringwald break; 99114e3e2c2SMilanka Ringwald case 'D': 99214e3e2c2SMilanka Ringwald printf(" - AVRCP Target disconnect from addr %s.\n", bd_addr_to_str(device_addr)); 99314e3e2c2SMilanka Ringwald status = avrcp_target_disconnect(avrcp_target_cid); 99464421eb6SMilanka Ringwald break; 99564421eb6SMilanka Ringwald 99664421eb6SMilanka Ringwald case '\n': 99764421eb6SMilanka Ringwald case '\r': 99864421eb6SMilanka Ringwald break; 999*f55e1e38SMilanka Ringwald // Volume Control 1000*f55e1e38SMilanka Ringwald case 't': 1001*f55e1e38SMilanka Ringwald volume_percentage = volume_percentage <= 90 ? volume_percentage + 10 : volume_percentage; 1002*f55e1e38SMilanka Ringwald printf(" - volume up for 10 percent, %d%% (%d) \n", volume_percentage, volume_percentage * 127 / 100); 1003*f55e1e38SMilanka Ringwald status = avrcp_target_volume_changed(avrcp_target_cid, volume_percentage * 127 / 100); 1004*f55e1e38SMilanka Ringwald break; 1005*f55e1e38SMilanka Ringwald case 'T': 1006*f55e1e38SMilanka Ringwald volume_percentage = volume_percentage >= 10 ? volume_percentage - 10 : volume_percentage; 1007*f55e1e38SMilanka Ringwald printf(" - volume down for 10 percent, %d%% (%d) \n", volume_percentage, volume_percentage * 127 / 100); 1008*f55e1e38SMilanka Ringwald status = avrcp_target_volume_changed(avrcp_target_cid, volume_percentage * 127 / 100); 1009*f55e1e38SMilanka Ringwald break; 1010*f55e1e38SMilanka Ringwald 101164421eb6SMilanka Ringwald case 'O': 1012*f55e1e38SMilanka Ringwald printf(" - get play status\n"); 101314e3e2c2SMilanka Ringwald status = avrcp_controller_get_play_status(avrcp_controller_cid); 101464421eb6SMilanka Ringwald break; 101564421eb6SMilanka Ringwald case 'j': 1016*f55e1e38SMilanka Ringwald printf(" - get now playing info\n"); 101714e3e2c2SMilanka Ringwald status = avrcp_controller_get_now_playing_info(avrcp_controller_cid); 101864421eb6SMilanka Ringwald break; 101964421eb6SMilanka Ringwald case 'k': 1020*f55e1e38SMilanka Ringwald printf(" - play\n"); 102114e3e2c2SMilanka Ringwald status = avrcp_controller_play(avrcp_controller_cid); 102264421eb6SMilanka Ringwald break; 102364421eb6SMilanka Ringwald case 'K': 1024*f55e1e38SMilanka Ringwald printf(" - stop\n"); 102514e3e2c2SMilanka Ringwald status = avrcp_controller_stop(avrcp_controller_cid); 102664421eb6SMilanka Ringwald break; 102764421eb6SMilanka Ringwald case 'L': 1028*f55e1e38SMilanka Ringwald printf(" - pause\n"); 102914e3e2c2SMilanka Ringwald status = avrcp_controller_pause(avrcp_controller_cid); 103064421eb6SMilanka Ringwald break; 103164421eb6SMilanka Ringwald case 'u': 1032*f55e1e38SMilanka Ringwald printf(" - start fast forward\n"); 103314e3e2c2SMilanka Ringwald status = avrcp_controller_press_and_hold_fast_forward(avrcp_controller_cid); 103464421eb6SMilanka Ringwald break; 103564421eb6SMilanka Ringwald case 'U': 1036*f55e1e38SMilanka Ringwald printf(" - stop fast forward\n"); 103714e3e2c2SMilanka Ringwald status = avrcp_controller_release_press_and_hold_cmd(avrcp_controller_cid); 103864421eb6SMilanka Ringwald break; 103964421eb6SMilanka Ringwald case 'n': 1040*f55e1e38SMilanka Ringwald printf(" - start rewind\n"); 104114e3e2c2SMilanka Ringwald status = avrcp_controller_press_and_hold_rewind(avrcp_controller_cid); 104264421eb6SMilanka Ringwald break; 104364421eb6SMilanka Ringwald case 'N': 1044*f55e1e38SMilanka Ringwald printf(" - stop rewind\n"); 104514e3e2c2SMilanka Ringwald status = avrcp_controller_release_press_and_hold_cmd(avrcp_controller_cid); 104664421eb6SMilanka Ringwald break; 104764421eb6SMilanka Ringwald case 'i': 1048*f55e1e38SMilanka Ringwald printf(" - forward\n"); 104914e3e2c2SMilanka Ringwald status = avrcp_controller_forward(avrcp_controller_cid); 105064421eb6SMilanka Ringwald break; 105164421eb6SMilanka Ringwald case 'I': 1052*f55e1e38SMilanka Ringwald printf(" - backward\n"); 105314e3e2c2SMilanka Ringwald status = avrcp_controller_backward(avrcp_controller_cid); 105464421eb6SMilanka Ringwald break; 105564421eb6SMilanka Ringwald case 'M': 1056*f55e1e38SMilanka Ringwald printf(" - mute\n"); 105714e3e2c2SMilanka Ringwald status = avrcp_controller_mute(avrcp_controller_cid); 105864421eb6SMilanka Ringwald break; 105964421eb6SMilanka Ringwald case 'r': 1060*f55e1e38SMilanka Ringwald printf(" - skip\n"); 106114e3e2c2SMilanka Ringwald status = avrcp_controller_skip(avrcp_controller_cid); 106264421eb6SMilanka Ringwald break; 106364421eb6SMilanka Ringwald case 'q': 1064*f55e1e38SMilanka Ringwald printf(" - query repeat and shuffle mode\n"); 106514e3e2c2SMilanka Ringwald status = avrcp_controller_query_shuffle_and_repeat_modes(avrcp_controller_cid); 106664421eb6SMilanka Ringwald break; 106764421eb6SMilanka Ringwald case 'v': 1068*f55e1e38SMilanka Ringwald printf(" - repeat single track\n"); 106914e3e2c2SMilanka Ringwald status = avrcp_controller_set_repeat_mode(avrcp_controller_cid, AVRCP_REPEAT_MODE_SINGLE_TRACK); 107064421eb6SMilanka Ringwald break; 107164421eb6SMilanka Ringwald case 'x': 1072*f55e1e38SMilanka Ringwald printf(" - repeat all tracks\n"); 107314e3e2c2SMilanka Ringwald status = avrcp_controller_set_repeat_mode(avrcp_controller_cid, AVRCP_REPEAT_MODE_ALL_TRACKS); 107464421eb6SMilanka Ringwald break; 107564421eb6SMilanka Ringwald case 'X': 1076*f55e1e38SMilanka Ringwald printf(" - disable repeat mode\n"); 107714e3e2c2SMilanka Ringwald status = avrcp_controller_set_repeat_mode(avrcp_controller_cid, AVRCP_REPEAT_MODE_OFF); 107864421eb6SMilanka Ringwald break; 107964421eb6SMilanka Ringwald case 'z': 1080*f55e1e38SMilanka Ringwald printf(" - shuffle all tracks\n"); 108114e3e2c2SMilanka Ringwald status = avrcp_controller_set_shuffle_mode(avrcp_controller_cid, AVRCP_SHUFFLE_MODE_ALL_TRACKS); 108264421eb6SMilanka Ringwald break; 108364421eb6SMilanka Ringwald case 'Z': 1084*f55e1e38SMilanka Ringwald printf(" - disable shuffle mode\n"); 108514e3e2c2SMilanka Ringwald status = avrcp_controller_set_shuffle_mode(avrcp_controller_cid, AVRCP_SHUFFLE_MODE_OFF); 108664421eb6SMilanka Ringwald break; 10878177fff3SMilanka Ringwald case 'a': 1088*f55e1e38SMilanka Ringwald printf("AVRCP: enable notification TRACK_CHANGED\n"); 108914e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_TRACK_CHANGED); 10908177fff3SMilanka Ringwald break; 10918177fff3SMilanka Ringwald case 'A': 1092*f55e1e38SMilanka Ringwald printf("AVRCP: disable notification TRACK_CHANGED\n"); 109314e3e2c2SMilanka Ringwald avrcp_controller_disable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_TRACK_CHANGED); 10948177fff3SMilanka Ringwald break; 109514e3e2c2SMilanka Ringwald case 'R': 1096*f55e1e38SMilanka Ringwald printf("AVRCP: enable notification PLAYBACK_POS_CHANGED\n"); 109714e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_PLAYBACK_POS_CHANGED); 10986fa3dbf2SMilanka Ringwald break; 109914e3e2c2SMilanka Ringwald case 'P': 1100*f55e1e38SMilanka Ringwald printf("AVRCP: disable notification PLAYBACK_POS_CHANGED\n"); 110114e3e2c2SMilanka Ringwald avrcp_controller_disable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_PLAYBACK_POS_CHANGED); 11026fa3dbf2SMilanka Ringwald break; 11038177fff3SMilanka Ringwald 110464421eb6SMilanka Ringwald default: 110564421eb6SMilanka Ringwald show_usage(); 11064567cc17SMilanka Ringwald return; 11074567cc17SMilanka Ringwald } 11084567cc17SMilanka Ringwald if (status != ERROR_CODE_SUCCESS){ 11094567cc17SMilanka Ringwald printf("Could not perform command, status 0x%2x\n", status); 111064421eb6SMilanka Ringwald } 111164421eb6SMilanka Ringwald } 111264421eb6SMilanka Ringwald #endif 111364421eb6SMilanka Ringwald 111464421eb6SMilanka Ringwald int btstack_main(int argc, const char * argv[]); 111564421eb6SMilanka Ringwald int btstack_main(int argc, const char * argv[]){ 1116b23b09a5SMatthias Ringwald UNUSED(argc); 111764421eb6SMilanka Ringwald (void)argv; 111864421eb6SMilanka Ringwald 1119b23b09a5SMatthias Ringwald a2dp_and_avrcp_setup(); 1120b23b09a5SMatthias Ringwald 1121b23b09a5SMatthias Ringwald #ifdef HAVE_BTSTACK_STDIN 1122b23b09a5SMatthias Ringwald // parse human readable Bluetooth address 1123b23b09a5SMatthias Ringwald sscanf_bd_addr(device_addr_string, device_addr); 1124b23b09a5SMatthias Ringwald btstack_stdin_setup(stdin_process); 1125b23b09a5SMatthias Ringwald #endif 1126b23b09a5SMatthias Ringwald 112764421eb6SMilanka Ringwald // turn on! 11284dc98401SMilanka Ringwald printf("Starting BTstack ...\n"); 112964421eb6SMilanka Ringwald hci_power_control(HCI_POWER_ON); 113064421eb6SMilanka Ringwald return 0; 113164421eb6SMilanka Ringwald } 1132