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 127f55e1e38SMilanka Ringwald static int volume_percentage = 0; 128f55e1e38SMilanka 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; 174f55e1e38SMilanka 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 237f55e1e38SMilanka Ringwald uint8_t status = a2dp_sink_create_stream_endpoint(AVDTP_AUDIO, 238f55e1e38SMilanka Ringwald AVDTP_CODEC_SBC, media_sbc_codec_capabilities, sizeof(media_sbc_codec_capabilities), 239f55e1e38SMilanka 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; 305bcbbbb42SMatthias Ringwald while (request_frames && btstack_ring_buffer_bytes_available(&sbc_frame_ring_buffer) >= sbc_frame_size){ 306b23b09a5SMatthias Ringwald // decode frame 307e9c5f44eSMatthias Ringwald uint8_t sbc_frame[MAX_SBC_FRAME_SIZE]; 308e9c5f44eSMatthias Ringwald btstack_ring_buffer_read(&sbc_frame_ring_buffer, sbc_frame, sbc_frame_size, &bytes_read); 309e9c5f44eSMatthias Ringwald btstack_sbc_decoder_process_data(&state, 0, sbc_frame, sbc_frame_size); 310b23b09a5SMatthias Ringwald } 31164421eb6SMilanka Ringwald 312e9c5f44eSMatthias Ringwald #ifdef STORE_FROM_PLAYBACK 313e9c5f44eSMatthias Ringwald #ifdef STORE_SBC_TO_WAV_FILE 314e9c5f44eSMatthias Ringwald wav_writer_write_int16(wav_samples, wav_buffer); 315e9c5f44eSMatthias Ringwald #endif 316e9c5f44eSMatthias Ringwald #endif 317e9c5f44eSMatthias Ringwald } 318e9c5f44eSMatthias Ringwald 319e9c5f44eSMatthias Ringwald static void handle_pcm_data(int16_t * data, int num_frames, int num_channels, int sample_rate, void * context){ 320b23b09a5SMatthias Ringwald UNUSED(sample_rate); 321b23b09a5SMatthias Ringwald UNUSED(context); 322b23b09a5SMatthias Ringwald UNUSED(num_channels); // must be stereo == 2 323b23b09a5SMatthias Ringwald 324e9c5f44eSMatthias Ringwald #ifdef STORE_DECODED 325e9c5f44eSMatthias Ringwald wav_writer_write_int16(num_frames * NUM_CHANNELS, data); 32664421eb6SMilanka Ringwald #endif 32764421eb6SMilanka Ringwald 328e9c5f44eSMatthias Ringwald // resample into request buffer - add some additional space for resampling 329e9c5f44eSMatthias Ringwald int16_t output_buffer[(128+16) * NUM_CHANNELS]; // 16 * 8 * 2 330e9c5f44eSMatthias Ringwald uint32_t resampled_frames = btstack_resample_block(&resample_instance, data, num_frames, output_buffer); 331b23b09a5SMatthias Ringwald 332e9c5f44eSMatthias Ringwald #ifdef STORE_RESAMPLED 333e9c5f44eSMatthias Ringwald #ifdef STORE_SBC_TO_WAV_FILE 334e9c5f44eSMatthias Ringwald wav_writer_write_int16(resampled_frames * NUM_CHANNELS, output_buffer); 335e9c5f44eSMatthias Ringwald frame_count++; 336e9c5f44eSMatthias Ringwald #endif 337e9c5f44eSMatthias Ringwald #endif 338e9c5f44eSMatthias Ringwald 339e9c5f44eSMatthias Ringwald const btstack_audio_t * audio = btstack_audio_get_instance(); 340e9c5f44eSMatthias Ringwald if (!audio) return; 341b23b09a5SMatthias Ringwald 342b23b09a5SMatthias Ringwald // store data in btstack_audio buffer first 343e9c5f44eSMatthias Ringwald int frames_to_copy = btstack_min(resampled_frames, request_frames); 344e9c5f44eSMatthias Ringwald memcpy(request_buffer, output_buffer, frames_to_copy * BYTES_PER_FRAME); 345e9c5f44eSMatthias Ringwald request_frames -= frames_to_copy; 346e9c5f44eSMatthias Ringwald request_buffer += frames_to_copy * NUM_CHANNELS; 347b23b09a5SMatthias Ringwald 348e9c5f44eSMatthias Ringwald #ifdef STORE_BEFORE_PLAYBACK 349e9c5f44eSMatthias Ringwald #ifdef STORE_SBC_TO_WAV_FILE 350e9c5f44eSMatthias Ringwald wav_writer_write_int16(frames_to_copy * NUM_CHANNELS, output_buffer); 351e9c5f44eSMatthias Ringwald frame_count++; 352e9c5f44eSMatthias Ringwald #endif 353e9c5f44eSMatthias Ringwald #endif 354b23b09a5SMatthias Ringwald 355b23b09a5SMatthias Ringwald // and rest in ring buffer 356e9c5f44eSMatthias Ringwald int frames_to_store = resampled_frames - frames_to_copy; 357e9c5f44eSMatthias Ringwald if (frames_to_store){ 358e9c5f44eSMatthias 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); 359e9c5f44eSMatthias Ringwald if (status){ 360e9c5f44eSMatthias Ringwald printf("Error storing samples in PCM ring buffer!!!\n"); 361b23b09a5SMatthias Ringwald } 362e9c5f44eSMatthias Ringwald #ifdef STORE_BEFORE_PLAYBACK 363e9c5f44eSMatthias Ringwald #ifdef STORE_SBC_TO_WAV_FILE 364e9c5f44eSMatthias Ringwald wav_writer_write_int16(frames_to_store * NUM_CHANNELS, &output_buffer[frames_to_copy * NUM_CHANNELS]); 365e9c5f44eSMatthias Ringwald frame_count++; 366e9c5f44eSMatthias Ringwald #endif 367e9c5f44eSMatthias Ringwald #endif 368b23b09a5SMatthias Ringwald } 369b23b09a5SMatthias Ringwald } 370b23b09a5SMatthias Ringwald 37164421eb6SMilanka Ringwald static int media_processing_init(avdtp_media_codec_configuration_sbc_t configuration){ 372c63d45a5SMatthias Ringwald if (media_initialized) return 0; 373b23b09a5SMatthias Ringwald 37464421eb6SMilanka Ringwald btstack_sbc_decoder_init(&state, mode, handle_pcm_data, NULL); 37564421eb6SMilanka Ringwald 37664421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_WAV_FILE 37764421eb6SMilanka Ringwald wav_writer_open(wav_filename, configuration.num_channels, configuration.sampling_frequency); 37864421eb6SMilanka Ringwald #endif 37964421eb6SMilanka Ringwald 38064421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_SBC_FILE 38164421eb6SMilanka Ringwald sbc_file = fopen(sbc_filename, "wb"); 38264421eb6SMilanka Ringwald #endif 38364421eb6SMilanka Ringwald 384b23b09a5SMatthias Ringwald btstack_ring_buffer_init(&sbc_frame_ring_buffer, sbc_frame_storage, sizeof(sbc_frame_storage)); 385b23b09a5SMatthias Ringwald btstack_ring_buffer_init(&decoded_audio_ring_buffer, decoded_audio_storage, sizeof(decoded_audio_storage)); 386e9c5f44eSMatthias Ringwald btstack_resample_init(&resample_instance, configuration.num_channels); 38764421eb6SMilanka Ringwald 388b23b09a5SMatthias Ringwald // setup audio playback 389*e39d945bSDirk Helbig const btstack_audio_sink_t * audio = btstack_audio_sink_get_instance(); 390b23b09a5SMatthias Ringwald if (audio){ 391*e39d945bSDirk Helbig audio->init(NUM_CHANNELS, configuration.sampling_frequency, &playback_handler); 39264421eb6SMilanka Ringwald } 39364421eb6SMilanka Ringwald 39464421eb6SMilanka Ringwald audio_stream_started = 0; 39564421eb6SMilanka Ringwald media_initialized = 1; 39664421eb6SMilanka Ringwald return 0; 39764421eb6SMilanka Ringwald } 39864421eb6SMilanka Ringwald 39964421eb6SMilanka Ringwald static void media_processing_close(void){ 40032ea0426SMatthias Ringwald 40164421eb6SMilanka Ringwald if (!media_initialized) return; 40264421eb6SMilanka Ringwald media_initialized = 0; 403b23b09a5SMatthias Ringwald audio_stream_started = 0; 404c63d45a5SMatthias Ringwald 40564421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_WAV_FILE 40664421eb6SMilanka Ringwald wav_writer_close(); 40764421eb6SMilanka Ringwald int total_frames_nr = state.good_frames_nr + state.bad_frames_nr + state.zero_frames_nr; 40864421eb6SMilanka Ringwald 409813397eaSMilanka 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); 410c63d45a5SMatthias Ringwald printf("WAV Writer: Written %d frames to wav file: %s\n", frame_count, wav_filename); 41164421eb6SMilanka Ringwald #endif 412c63d45a5SMatthias Ringwald 41364421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_SBC_FILE 41464421eb6SMilanka Ringwald fclose(sbc_file); 41564421eb6SMilanka Ringwald #endif 41664421eb6SMilanka Ringwald 417b23b09a5SMatthias Ringwald // stop audio playback 418*e39d945bSDirk Helbig const btstack_audio_sink_t * audio = btstack_audio_sink_get_instance(); 419b23b09a5SMatthias Ringwald if (audio){ 420b23b09a5SMatthias Ringwald audio->close(); 42164421eb6SMilanka Ringwald } 42264421eb6SMilanka Ringwald } 4234dc98401SMilanka Ringwald 4244dc98401SMilanka Ringwald /* @section Handle Media Data Packet 4254dc98401SMilanka Ringwald * 4264dc98401SMilanka Ringwald * @text Media data packets, in this case the audio data, are received through the handle_l2cap_media_data_packet callback. 4274dc98401SMilanka Ringwald * Currently, only the SBC media codec is supported. Hence, the media data consists of the media packet header and the SBC packet. 428b23b09a5SMatthias 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) 429b23b09a5SMatthias Ringwald * If the audio stream wasn't started already and there are enough SBC frames in the ring buffer, start playback. 4304dc98401SMilanka Ringwald */ 4314dc98401SMilanka Ringwald 4324dc98401SMilanka Ringwald static int read_media_data_header(uint8_t * packet, int size, int * offset, avdtp_media_packet_header_t * media_header); 4334dc98401SMilanka Ringwald static int read_sbc_header(uint8_t * packet, int size, int * offset, avdtp_sbc_codec_header_t * sbc_header); 4344dc98401SMilanka Ringwald 435fd58c900SMilanka Ringwald static void handle_l2cap_media_data_packet(uint8_t seid, uint8_t *packet, uint16_t size){ 436fd58c900SMilanka Ringwald UNUSED(seid); 43764421eb6SMilanka Ringwald int pos = 0; 43864421eb6SMilanka Ringwald 43964421eb6SMilanka Ringwald avdtp_media_packet_header_t media_header; 4404dc98401SMilanka Ringwald if (!read_media_data_header(packet, size, &pos, &media_header)) return; 44164421eb6SMilanka Ringwald 44264421eb6SMilanka Ringwald avdtp_sbc_codec_header_t sbc_header; 4434dc98401SMilanka Ringwald if (!read_sbc_header(packet, size, &pos, &sbc_header)) return; 44464421eb6SMilanka Ringwald 445*e39d945bSDirk Helbig const btstack_audio_sink_t * audio = btstack_audio_sink_get_instance(); 44632ea0426SMatthias Ringwald 44732ea0426SMatthias Ringwald // process data right away if there's no audio implementation active, e.g. on posix systems to store as .wav 44832ea0426SMatthias Ringwald if (!audio){ 44932ea0426SMatthias Ringwald btstack_sbc_decoder_process_data(&state, 0, packet+pos, size-pos); 45032ea0426SMatthias Ringwald return; 45132ea0426SMatthias Ringwald } 45232ea0426SMatthias Ringwald 45364421eb6SMilanka Ringwald // store sbc frame size for buffer management 45464421eb6SMilanka Ringwald sbc_frame_size = (size-pos)/ sbc_header.num_frames; 45564421eb6SMilanka Ringwald 456e9c5f44eSMatthias Ringwald int status = btstack_ring_buffer_write(&sbc_frame_ring_buffer, packet+pos, size-pos); 457e9c5f44eSMatthias Ringwald if (status){ 458e9c5f44eSMatthias Ringwald printf("Error storing samples in SBC ring buffer!!!\n"); 459e9c5f44eSMatthias Ringwald } 46064421eb6SMilanka Ringwald 46164421eb6SMilanka Ringwald // decide on audio sync drift based on number of sbc frames in queue 462b23b09a5SMatthias Ringwald int sbc_frames_in_buffer = btstack_ring_buffer_bytes_available(&sbc_frame_ring_buffer) / sbc_frame_size; 463e9c5f44eSMatthias Ringwald uint32_t resampling_factor; 464c5fccf8bSMatthias Ringwald 465c5fccf8bSMatthias Ringwald // nomimal factor (fixed-point 2^16) and compensation offset 466c5fccf8bSMatthias Ringwald uint32_t nomimal_factor = 0x0FF80; 467c5fccf8bSMatthias Ringwald uint32_t compensation = 0x00100; 468c5fccf8bSMatthias Ringwald 46964421eb6SMilanka Ringwald if (sbc_frames_in_buffer < OPTIMAL_FRAMES_MIN){ 470c5fccf8bSMatthias Ringwald resampling_factor = nomimal_factor - compensation; // stretch samples 47164421eb6SMilanka Ringwald } else if (sbc_frames_in_buffer <= OPTIMAL_FRAMES_MAX){ 472c5fccf8bSMatthias Ringwald resampling_factor = nomimal_factor; // nothing to do 47364421eb6SMilanka Ringwald } else { 474c5fccf8bSMatthias Ringwald resampling_factor = nomimal_factor + compensation; // compress samples 47564421eb6SMilanka Ringwald } 47664421eb6SMilanka Ringwald 477e9c5f44eSMatthias Ringwald btstack_resample_set_factor(&resample_instance, resampling_factor); 478e9c5f44eSMatthias Ringwald 47964421eb6SMilanka Ringwald // dump 480f55e1e38SMilanka Ringwald // printf("%6u %03u %05x\n", (int) btstack_run_loop_get_time_ms(), sbc_frames_in_buffer, resampling_factor); 481e9c5f44eSMatthias Ringwald // log_info("%03u %05x", sbc_frames_in_buffer, resampling_factor); 48264421eb6SMilanka Ringwald 48364421eb6SMilanka Ringwald #ifdef STORE_SBC_TO_SBC_FILE 48464421eb6SMilanka Ringwald fwrite(packet+pos, size-pos, 1, sbc_file); 48564421eb6SMilanka Ringwald #endif 48664421eb6SMilanka Ringwald 487b23b09a5SMatthias Ringwald // start stream if enough frames buffered 488e9c5f44eSMatthias Ringwald if (!audio_stream_started && sbc_frames_in_buffer >= OPTIMAL_FRAMES_MIN){ 4894dc98401SMilanka Ringwald audio_stream_started = 1; 490b23b09a5SMatthias Ringwald // setup audio playback 491b23b09a5SMatthias Ringwald if (audio){ 492b23b09a5SMatthias Ringwald audio->start_stream(); 4934dc98401SMilanka Ringwald } 4944dc98401SMilanka Ringwald } 4954dc98401SMilanka Ringwald } 4964dc98401SMilanka Ringwald 4974dc98401SMilanka Ringwald static int read_sbc_header(uint8_t * packet, int size, int * offset, avdtp_sbc_codec_header_t * sbc_header){ 4984dc98401SMilanka Ringwald int sbc_header_len = 12; // without crc 4994dc98401SMilanka Ringwald int pos = *offset; 5004dc98401SMilanka Ringwald 5014dc98401SMilanka Ringwald if (size - pos < sbc_header_len){ 5024dc98401SMilanka Ringwald printf("Not enough data to read SBC header, expected %d, received %d\n", sbc_header_len, size-pos); 5033290eaa8SMilanka Ringwald return 0; 5044dc98401SMilanka Ringwald } 5054dc98401SMilanka Ringwald 5064dc98401SMilanka Ringwald sbc_header->fragmentation = get_bit16(packet[pos], 7); 5074dc98401SMilanka Ringwald sbc_header->starting_packet = get_bit16(packet[pos], 6); 5084dc98401SMilanka Ringwald sbc_header->last_packet = get_bit16(packet[pos], 5); 5094dc98401SMilanka Ringwald sbc_header->num_frames = packet[pos] & 0x0f; 5104dc98401SMilanka Ringwald pos++; 5114dc98401SMilanka 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); 5124dc98401SMilanka Ringwald *offset = pos; 5133290eaa8SMilanka Ringwald return 1; 5144dc98401SMilanka Ringwald } 5154dc98401SMilanka Ringwald 5164dc98401SMilanka Ringwald static int read_media_data_header(uint8_t *packet, int size, int *offset, avdtp_media_packet_header_t *media_header){ 5174dc98401SMilanka Ringwald int media_header_len = 12; // without crc 5184dc98401SMilanka Ringwald int pos = *offset; 5194dc98401SMilanka Ringwald 5204dc98401SMilanka Ringwald if (size - pos < media_header_len){ 5214dc98401SMilanka Ringwald printf("Not enough data to read media packet header, expected %d, received %d\n", media_header_len, size-pos); 5223290eaa8SMilanka Ringwald return 0; 5234dc98401SMilanka Ringwald } 5244dc98401SMilanka Ringwald 5254dc98401SMilanka Ringwald media_header->version = packet[pos] & 0x03; 5264dc98401SMilanka Ringwald media_header->padding = get_bit16(packet[pos],2); 5274dc98401SMilanka Ringwald media_header->extension = get_bit16(packet[pos],3); 5284dc98401SMilanka Ringwald media_header->csrc_count = (packet[pos] >> 4) & 0x0F; 5294dc98401SMilanka Ringwald pos++; 5304dc98401SMilanka Ringwald 5314dc98401SMilanka Ringwald media_header->marker = get_bit16(packet[pos],0); 5324dc98401SMilanka Ringwald media_header->payload_type = (packet[pos] >> 1) & 0x7F; 5334dc98401SMilanka Ringwald pos++; 5344dc98401SMilanka Ringwald 5354dc98401SMilanka Ringwald media_header->sequence_number = big_endian_read_16(packet, pos); 5364dc98401SMilanka Ringwald pos+=2; 5374dc98401SMilanka Ringwald 5384dc98401SMilanka Ringwald media_header->timestamp = big_endian_read_32(packet, pos); 5394dc98401SMilanka Ringwald pos+=4; 5404dc98401SMilanka Ringwald 5414dc98401SMilanka Ringwald media_header->synchronization_source = big_endian_read_32(packet, pos); 5424dc98401SMilanka Ringwald pos+=4; 5434dc98401SMilanka Ringwald *offset = pos; 5443290eaa8SMilanka Ringwald return 1; 5454dc98401SMilanka Ringwald } 5464dc98401SMilanka Ringwald 54764421eb6SMilanka Ringwald static void dump_sbc_configuration(avdtp_media_codec_configuration_sbc_t configuration){ 54864421eb6SMilanka Ringwald printf(" - num_channels: %d\n", configuration.num_channels); 54964421eb6SMilanka Ringwald printf(" - sampling_frequency: %d\n", configuration.sampling_frequency); 55064421eb6SMilanka Ringwald printf(" - channel_mode: %d\n", configuration.channel_mode); 55164421eb6SMilanka Ringwald printf(" - block_length: %d\n", configuration.block_length); 55264421eb6SMilanka Ringwald printf(" - subbands: %d\n", configuration.subbands); 55364421eb6SMilanka Ringwald printf(" - allocation_method: %d\n", configuration.allocation_method); 55464421eb6SMilanka Ringwald printf(" - bitpool_value [%d, %d] \n", configuration.min_bitpool_value, configuration.max_bitpool_value); 555f1042e9dSMilanka Ringwald printf("\n"); 55664421eb6SMilanka Ringwald } 55764421eb6SMilanka Ringwald 55801dc6e35SMilanka Ringwald static void avrcp_controller_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 55964421eb6SMilanka Ringwald UNUSED(channel); 56064421eb6SMilanka Ringwald UNUSED(size); 56164421eb6SMilanka Ringwald uint16_t local_cid; 56264421eb6SMilanka Ringwald uint8_t status = 0xFF; 563ef5ad9d6SMilanka Ringwald bd_addr_t adress; 56401dc6e35SMilanka Ringwald 56501dc6e35SMilanka Ringwald if (packet_type != HCI_EVENT_PACKET) return; 56601dc6e35SMilanka Ringwald if (hci_event_packet_get_type(packet) != HCI_EVENT_AVRCP_META) return; 56764421eb6SMilanka Ringwald switch (packet[2]){ 56864421eb6SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_ESTABLISHED: { 56964421eb6SMilanka Ringwald local_cid = avrcp_subevent_connection_established_get_avrcp_cid(packet); 57014e3e2c2SMilanka Ringwald if (avrcp_controller_cid != 0 && avrcp_controller_cid != local_cid) { 571f386e134SMilanka Ringwald printf("AVRCP Controller: Connection failed, expected 0x%02X cid, received 0x%02X\n", avrcp_controller_cid, local_cid); 572df642728SMilanka Ringwald return; 57364421eb6SMilanka Ringwald } 57464421eb6SMilanka Ringwald 57564421eb6SMilanka Ringwald status = avrcp_subevent_connection_established_get_status(packet); 57664421eb6SMilanka Ringwald if (status != ERROR_CODE_SUCCESS){ 57714e3e2c2SMilanka Ringwald printf("AVRCP Controller: Connection failed: status 0x%02x\n", status); 57814e3e2c2SMilanka Ringwald avrcp_controller_cid = 0; 579df642728SMilanka Ringwald return; 58064421eb6SMilanka Ringwald } 5814b338011SMilanka Ringwald 58214e3e2c2SMilanka Ringwald avrcp_controller_cid = local_cid; 5836c333d06SMilanka Ringwald avrcp_connected = 1; 584ef5ad9d6SMilanka Ringwald avrcp_subevent_connection_established_get_bd_addr(packet, adress); 585f386e134SMilanka Ringwald printf("AVRCP Controller: Connected to %s, cid 0x%02x\n", bd_addr_to_str(adress), avrcp_controller_cid); 586df642728SMilanka Ringwald 58764421eb6SMilanka Ringwald // automatically enable notifications 58814e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_PLAYBACK_STATUS_CHANGED); 58914e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_NOW_PLAYING_CONTENT_CHANGED); 59014e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_TRACK_CHANGED); 59164421eb6SMilanka Ringwald return; 59264421eb6SMilanka Ringwald } 59364421eb6SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_RELEASED: 594f386e134SMilanka Ringwald printf("AVRCP Controller: Channel released: cid 0x%02x\n", avrcp_subevent_connection_released_get_avrcp_cid(packet)); 59514e3e2c2SMilanka Ringwald avrcp_controller_cid = 0; 5966c333d06SMilanka Ringwald avrcp_connected = 0; 59764421eb6SMilanka Ringwald return; 59864421eb6SMilanka Ringwald default: 59964421eb6SMilanka Ringwald break; 60064421eb6SMilanka Ringwald } 60164421eb6SMilanka Ringwald 60264421eb6SMilanka Ringwald status = packet[5]; 60314e3e2c2SMilanka Ringwald if (!avrcp_controller_cid) return; 60464421eb6SMilanka Ringwald 6054dc98401SMilanka Ringwald // ignore INTERIM status 6068177fff3SMilanka Ringwald if (status == AVRCP_CTYPE_RESPONSE_INTERIM){ 6076fa3dbf2SMilanka Ringwald switch (packet[2]){ 6086fa3dbf2SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_PLAYBACK_POS_CHANGED:{ 6096fa3dbf2SMilanka Ringwald uint32_t playback_position_ms = avrcp_subevent_notification_playback_pos_changed_get_playback_position_ms(packet); 6106fa3dbf2SMilanka Ringwald if (playback_position_ms == AVRCP_NO_TRACK_SELECTED_PLAYBACK_POSITION_CHANGED){ 611f55e1e38SMilanka Ringwald printf("AVRCP Controller: playback position changed, no track is selected\n"); 6126fa3dbf2SMilanka Ringwald } 6136fa3dbf2SMilanka Ringwald break; 6146fa3dbf2SMilanka Ringwald } 6156fa3dbf2SMilanka Ringwald default: 6166fa3dbf2SMilanka Ringwald break; 6176fa3dbf2SMilanka Ringwald } 6188177fff3SMilanka Ringwald return; 6198177fff3SMilanka Ringwald } 62064421eb6SMilanka Ringwald 62114e3e2c2SMilanka Ringwald memset(value, 0, sizeof(value)); 62264421eb6SMilanka Ringwald switch (packet[2]){ 6236fa3dbf2SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_PLAYBACK_POS_CHANGED: 624f55e1e38SMilanka Ringwald printf("AVRCP Controller: playback position changed, position %d ms\n", (unsigned int) avrcp_subevent_notification_playback_pos_changed_get_playback_position_ms(packet)); 6256fa3dbf2SMilanka Ringwald break; 62664421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_PLAYBACK_STATUS_CHANGED: 627f55e1e38SMilanka Ringwald printf("AVRCP Controller: playback status changed %s\n", avrcp_play_status2str(avrcp_subevent_notification_playback_status_changed_get_play_status(packet))); 62864421eb6SMilanka Ringwald return; 62964421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_NOW_PLAYING_CONTENT_CHANGED: 630f55e1e38SMilanka Ringwald printf("AVRCP Controller: playing content changed\n"); 63164421eb6SMilanka Ringwald return; 63264421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_TRACK_CHANGED: 633f55e1e38SMilanka Ringwald printf("AVRCP Controller: track changed\n"); 63464421eb6SMilanka Ringwald return; 63564421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_VOLUME_CHANGED: 636f55e1e38SMilanka Ringwald printf("AVRCP Controller: absolute volume changed %d\n", avrcp_subevent_notification_volume_changed_get_absolute_volume(packet)); 63764421eb6SMilanka Ringwald return; 63864421eb6SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_AVAILABLE_PLAYERS_CHANGED: 639f55e1e38SMilanka Ringwald printf("AVRCP Controller: changed\n"); 64064421eb6SMilanka Ringwald return; 64164421eb6SMilanka Ringwald case AVRCP_SUBEVENT_SHUFFLE_AND_REPEAT_MODE:{ 64264421eb6SMilanka Ringwald uint8_t shuffle_mode = avrcp_subevent_shuffle_and_repeat_mode_get_shuffle_mode(packet); 64364421eb6SMilanka Ringwald uint8_t repeat_mode = avrcp_subevent_shuffle_and_repeat_mode_get_repeat_mode(packet); 644f55e1e38SMilanka Ringwald printf("AVRCP Controller: %s, %s\n", avrcp_shuffle2str(shuffle_mode), avrcp_repeat2str(repeat_mode)); 64564421eb6SMilanka Ringwald break; 64664421eb6SMilanka Ringwald } 64714e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_TRACK_INFO: 648f55e1e38SMilanka Ringwald printf("AVRCP Controller: Track: %d\n", avrcp_subevent_now_playing_track_info_get_track(packet)); 64914e3e2c2SMilanka Ringwald break; 65014e3e2c2SMilanka Ringwald 65114e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_TOTAL_TRACKS_INFO: 652f55e1e38SMilanka Ringwald printf("AVRCP Controller: Total Tracks: %d\n", avrcp_subevent_now_playing_total_tracks_info_get_total_tracks(packet)); 65314e3e2c2SMilanka Ringwald break; 65414e3e2c2SMilanka Ringwald 6551bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_TITLE_INFO: 6561bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_title_info_get_value_len(packet) > 0){ 6571bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_title_info_get_value(packet), avrcp_subevent_now_playing_title_info_get_value_len(packet)); 658f55e1e38SMilanka Ringwald printf("AVRCP Controller: Title: %s\n", value); 65964421eb6SMilanka Ringwald } 66064421eb6SMilanka Ringwald break; 6611bf7a74fSMilanka Ringwald 6621bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_ARTIST_INFO: 6631bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_artist_info_get_value_len(packet) > 0){ 6641bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_artist_info_get_value(packet), avrcp_subevent_now_playing_artist_info_get_value_len(packet)); 665f55e1e38SMilanka Ringwald printf("AVRCP Controller: Artist: %s\n", value); 66664421eb6SMilanka Ringwald } 6671bf7a74fSMilanka Ringwald break; 6681bf7a74fSMilanka Ringwald 6691bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_ALBUM_INFO: 6701bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_album_info_get_value_len(packet) > 0){ 6711bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_album_info_get_value(packet), avrcp_subevent_now_playing_album_info_get_value_len(packet)); 672f55e1e38SMilanka Ringwald printf("AVRCP Controller: Album: %s\n", value); 6731bf7a74fSMilanka Ringwald } 6741bf7a74fSMilanka Ringwald break; 6751bf7a74fSMilanka Ringwald 6761bf7a74fSMilanka Ringwald case AVRCP_SUBEVENT_NOW_PLAYING_GENRE_INFO: 6771bf7a74fSMilanka Ringwald if (avrcp_subevent_now_playing_genre_info_get_value_len(packet) > 0){ 6781bf7a74fSMilanka Ringwald memcpy(value, avrcp_subevent_now_playing_genre_info_get_value(packet), avrcp_subevent_now_playing_genre_info_get_value_len(packet)); 679f55e1e38SMilanka Ringwald printf("AVRCP Controller: Genre: %s\n", value); 6801bf7a74fSMilanka Ringwald } 6811bf7a74fSMilanka Ringwald break; 6821bf7a74fSMilanka Ringwald 68364421eb6SMilanka Ringwald case AVRCP_SUBEVENT_PLAY_STATUS: 684f386e134SMilanka Ringwald printf("AVRCP Controller: Song length %"PRIu32" ms, Song position %"PRIu32" ms, Play status %s\n", 68564421eb6SMilanka Ringwald avrcp_subevent_play_status_get_song_length(packet), 68664421eb6SMilanka Ringwald avrcp_subevent_play_status_get_song_position(packet), 68764421eb6SMilanka Ringwald avrcp_play_status2str(avrcp_subevent_play_status_get_play_status(packet))); 68864421eb6SMilanka Ringwald break; 689f386e134SMilanka Ringwald 69064421eb6SMilanka Ringwald case AVRCP_SUBEVENT_OPERATION_COMPLETE: 691f386e134SMilanka Ringwald printf("AVRCP Controller: %s done\n", avrcp_operation2str(avrcp_subevent_operation_complete_get_operation_id(packet))); 69264421eb6SMilanka Ringwald break; 693f386e134SMilanka Ringwald 69464421eb6SMilanka Ringwald case AVRCP_SUBEVENT_OPERATION_START: 695f386e134SMilanka Ringwald printf("AVRCP Controller: Start %s\n", avrcp_operation2str(avrcp_subevent_operation_complete_get_operation_id(packet))); 69664421eb6SMilanka Ringwald break; 697f386e134SMilanka Ringwald 69864421eb6SMilanka Ringwald default: 69914e3e2c2SMilanka Ringwald printf("AVRCP Controller: event 0x%02x is not parsed\n", packet[2]); 70064421eb6SMilanka Ringwald break; 70164421eb6SMilanka Ringwald } 70264421eb6SMilanka Ringwald } 70364421eb6SMilanka Ringwald 70414e3e2c2SMilanka Ringwald 70514e3e2c2SMilanka Ringwald static void avrcp_target_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 70614e3e2c2SMilanka Ringwald UNUSED(channel); 70714e3e2c2SMilanka Ringwald UNUSED(size); 708f386e134SMilanka Ringwald bd_addr_t address; 70914e3e2c2SMilanka Ringwald uint16_t local_cid; 71014e3e2c2SMilanka Ringwald uint8_t status = ERROR_CODE_SUCCESS; 71114e3e2c2SMilanka Ringwald 71214e3e2c2SMilanka Ringwald if (packet_type != HCI_EVENT_PACKET) return; 71314e3e2c2SMilanka Ringwald if (hci_event_packet_get_type(packet) != HCI_EVENT_AVRCP_META) return; 71414e3e2c2SMilanka Ringwald 715f55e1e38SMilanka Ringwald int volume; 716f55e1e38SMilanka Ringwald 71714e3e2c2SMilanka Ringwald switch (packet[2]){ 71814e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_NOTIFICATION_VOLUME_CHANGED: 719f55e1e38SMilanka Ringwald volume = avrcp_subevent_notification_volume_changed_get_absolute_volume(packet); 720f55e1e38SMilanka Ringwald volume_percentage = volume * 100 / 127; 721f386e134SMilanka Ringwald printf("AVRCP Target : Volume set to %d%% (%d)\n", volume_percentage, volume); 72214e3e2c2SMilanka Ringwald break; 72314e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_ESTABLISHED: 72414e3e2c2SMilanka Ringwald local_cid = avrcp_subevent_connection_established_get_avrcp_cid(packet); 72514e3e2c2SMilanka Ringwald if (avrcp_target_cid != 0 && avrcp_target_cid != local_cid) { 726f386e134SMilanka Ringwald printf("AVRCP Target : Connection failed, expected 0x%02X cid, received 0x%02X\n", avrcp_target_cid, local_cid); 72714e3e2c2SMilanka Ringwald return; 72814e3e2c2SMilanka Ringwald } 72914e3e2c2SMilanka Ringwald 73014e3e2c2SMilanka Ringwald status = avrcp_subevent_connection_established_get_status(packet); 73114e3e2c2SMilanka Ringwald if (status != ERROR_CODE_SUCCESS){ 73214e3e2c2SMilanka Ringwald printf("AVRCP Target : Connection failed: status 0x%02x\n", status); 73314e3e2c2SMilanka Ringwald avrcp_target_cid = 0; 73414e3e2c2SMilanka Ringwald return; 73514e3e2c2SMilanka Ringwald } 73614e3e2c2SMilanka Ringwald avrcp_target_cid = local_cid; 737f386e134SMilanka Ringwald avrcp_subevent_connection_established_get_bd_addr(packet, address); 738f386e134SMilanka Ringwald printf("AVRCP Target : Connected to %s, cid 0x%02x\n", bd_addr_to_str(address), avrcp_target_cid); 73914e3e2c2SMilanka Ringwald break; 74014e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_EVENT_IDS_QUERY: 74114e3e2c2SMilanka Ringwald status = avrcp_target_supported_events(avrcp_target_cid, events_num, events, sizeof(events)); 74214e3e2c2SMilanka Ringwald break; 74314e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_COMPANY_IDS_QUERY: 74414e3e2c2SMilanka Ringwald status = avrcp_target_supported_companies(avrcp_target_cid, companies_num, companies, sizeof(companies)); 74514e3e2c2SMilanka Ringwald break; 74614e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_OPERATION:{ 74714e3e2c2SMilanka Ringwald avrcp_operation_id_t operation_id = avrcp_subevent_operation_get_operation_id(packet); 74814e3e2c2SMilanka Ringwald // if (!media_tracker.connected) break; 74914e3e2c2SMilanka Ringwald switch (operation_id){ 75014e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_PLAY: 75114e3e2c2SMilanka Ringwald printf("AVRCP Target : PLAY\n"); 75214e3e2c2SMilanka Ringwald break; 75314e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_PAUSE: 75414e3e2c2SMilanka Ringwald printf("AVRCP Target : PAUSE\n"); 75514e3e2c2SMilanka Ringwald break; 75614e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_STOP: 75714e3e2c2SMilanka Ringwald printf("AVRCP Target : STOP\n"); 75814e3e2c2SMilanka Ringwald break; 75914e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_REWIND: 760f386e134SMilanka Ringwald printf("AVRCP Target : REWIND\n"); 76114e3e2c2SMilanka Ringwald break; 76214e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_FAST_FORWARD: 763f386e134SMilanka Ringwald printf("AVRCP Target : FAST_FORWARD\n"); 76414e3e2c2SMilanka Ringwald break; 76514e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_FORWARD: 766f386e134SMilanka Ringwald printf("AVRCP Target : FORWARD\n"); 76714e3e2c2SMilanka Ringwald break; 76814e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_BACKWARD: 769f386e134SMilanka Ringwald printf("AVRCP Target : BACKWARD\n"); 77014e3e2c2SMilanka Ringwald break; 77114e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_SKIP: 772f386e134SMilanka Ringwald printf("AVRCP Target : SKIP\n"); 77314e3e2c2SMilanka Ringwald break; 77414e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_MUTE: 775f386e134SMilanka Ringwald printf("AVRCP Target : MUTE\n"); 77614e3e2c2SMilanka Ringwald break; 77714e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_CHANNEL_UP: 778f386e134SMilanka Ringwald printf("AVRCP Target : CHANNEL_UP\n"); 77914e3e2c2SMilanka Ringwald break; 78014e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_CHANNEL_DOWN: 781f386e134SMilanka Ringwald printf("AVRCP Target : CHANNEL_DOWN\n"); 78214e3e2c2SMilanka Ringwald break; 78314e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_SELECT: 784f386e134SMilanka Ringwald printf("AVRCP Target : SELECT\n"); 78514e3e2c2SMilanka Ringwald break; 78614e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_UP: 787f386e134SMilanka Ringwald printf("AVRCP Target : UP\n"); 78814e3e2c2SMilanka Ringwald break; 78914e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_DOWN: 790f386e134SMilanka Ringwald printf("AVRCP Target : DOWN\n"); 79114e3e2c2SMilanka Ringwald break; 79214e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_LEFT: 793f386e134SMilanka Ringwald printf("AVRCP Target : LEFT\n"); 79414e3e2c2SMilanka Ringwald break; 79514e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_RIGHT: 796f386e134SMilanka Ringwald printf("AVRCP Target : RIGTH\n"); 79714e3e2c2SMilanka Ringwald break; 79814e3e2c2SMilanka Ringwald case AVRCP_OPERATION_ID_ROOT_MENU: 799f386e134SMilanka Ringwald printf("AVRCP Target : ROOT_MENU\n"); 80014e3e2c2SMilanka Ringwald break; 80114e3e2c2SMilanka Ringwald default: 80214e3e2c2SMilanka Ringwald return; 80314e3e2c2SMilanka Ringwald } 80414e3e2c2SMilanka Ringwald break; 80514e3e2c2SMilanka Ringwald } 80614e3e2c2SMilanka Ringwald case AVRCP_SUBEVENT_CONNECTION_RELEASED: 807f386e134SMilanka Ringwald printf("AVRCP Target : Disconnected, cid 0x%02x\n", avrcp_subevent_connection_released_get_avrcp_cid(packet)); 80814e3e2c2SMilanka Ringwald return; 80914e3e2c2SMilanka Ringwald default: 810f386e134SMilanka Ringwald printf("AVRCP Target : Event 0x%02x is not parsed\n", packet[2]); 81114e3e2c2SMilanka Ringwald break; 81214e3e2c2SMilanka Ringwald } 81314e3e2c2SMilanka Ringwald } 81414e3e2c2SMilanka Ringwald 815b23b09a5SMatthias Ringwald static void hci_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 816b23b09a5SMatthias Ringwald UNUSED(channel); 817b23b09a5SMatthias Ringwald UNUSED(size); 818b23b09a5SMatthias Ringwald if (packet_type != HCI_EVENT_PACKET) return; 819b23b09a5SMatthias Ringwald if (hci_event_packet_get_type(packet) == HCI_EVENT_PIN_CODE_REQUEST) { 820b23b09a5SMatthias Ringwald bd_addr_t address; 821b23b09a5SMatthias Ringwald printf("Pin code request - using '0000'\n"); 822b23b09a5SMatthias Ringwald hci_event_pin_code_request_get_bd_addr(packet, address); 823b23b09a5SMatthias Ringwald gap_pin_code_response(address, "0000"); 824b23b09a5SMatthias Ringwald } 825b23b09a5SMatthias Ringwald } 826b23b09a5SMatthias Ringwald 8274dc98401SMilanka Ringwald static void a2dp_sink_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){ 82864421eb6SMilanka Ringwald UNUSED(channel); 82964421eb6SMilanka Ringwald UNUSED(size); 8304ccacc40SMilanka Ringwald uint16_t cid; 831ef5ad9d6SMilanka Ringwald bd_addr_t address; 832326e5cedSMilanka Ringwald uint8_t status; 83364421eb6SMilanka Ringwald 834ef5ad9d6SMilanka Ringwald if (packet_type != HCI_EVENT_PACKET) return; 835ef5ad9d6SMilanka Ringwald if (hci_event_packet_get_type(packet) != HCI_EVENT_A2DP_META) return; 836ef5ad9d6SMilanka Ringwald 83764421eb6SMilanka Ringwald switch (packet[2]){ 838f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_SIGNALING_MEDIA_CODEC_OTHER_CONFIGURATION: 839f386e134SMilanka Ringwald printf("A2DP Sink : Received non SBC codec - not implemented\n"); 84064421eb6SMilanka Ringwald break; 841f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_SIGNALING_MEDIA_CODEC_SBC_CONFIGURATION:{ 842f386e134SMilanka Ringwald printf("A2DP Sink : Received SBC codec configuration\n"); 843f1042e9dSMilanka Ringwald sbc_configuration.reconfigure = a2dp_subevent_signaling_media_codec_sbc_configuration_get_reconfigure(packet); 844f1042e9dSMilanka Ringwald sbc_configuration.num_channels = a2dp_subevent_signaling_media_codec_sbc_configuration_get_num_channels(packet); 845f1042e9dSMilanka Ringwald sbc_configuration.sampling_frequency = a2dp_subevent_signaling_media_codec_sbc_configuration_get_sampling_frequency(packet); 846f1042e9dSMilanka Ringwald sbc_configuration.channel_mode = a2dp_subevent_signaling_media_codec_sbc_configuration_get_channel_mode(packet); 847f1042e9dSMilanka Ringwald sbc_configuration.block_length = a2dp_subevent_signaling_media_codec_sbc_configuration_get_block_length(packet); 848f1042e9dSMilanka Ringwald sbc_configuration.subbands = a2dp_subevent_signaling_media_codec_sbc_configuration_get_subbands(packet); 849f1042e9dSMilanka Ringwald sbc_configuration.allocation_method = a2dp_subevent_signaling_media_codec_sbc_configuration_get_allocation_method(packet); 850f1042e9dSMilanka Ringwald sbc_configuration.min_bitpool_value = a2dp_subevent_signaling_media_codec_sbc_configuration_get_min_bitpool_value(packet); 851f1042e9dSMilanka Ringwald sbc_configuration.max_bitpool_value = a2dp_subevent_signaling_media_codec_sbc_configuration_get_max_bitpool_value(packet); 85264421eb6SMilanka Ringwald sbc_configuration.frames_per_buffer = sbc_configuration.subbands * sbc_configuration.block_length; 85364421eb6SMilanka Ringwald dump_sbc_configuration(sbc_configuration); 85464421eb6SMilanka Ringwald 85564421eb6SMilanka Ringwald if (sbc_configuration.reconfigure){ 85664421eb6SMilanka Ringwald media_processing_close(); 85764421eb6SMilanka Ringwald } 858c63d45a5SMatthias Ringwald // prepare media processing 859c63d45a5SMatthias Ringwald media_processing_init(sbc_configuration); 86064421eb6SMilanka Ringwald break; 86164421eb6SMilanka Ringwald } 862f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_ESTABLISHED: 863ef5ad9d6SMilanka Ringwald a2dp_subevent_stream_established_get_bd_addr(packet, address); 864326e5cedSMilanka Ringwald status = a2dp_subevent_stream_established_get_status(packet); 8654ccacc40SMilanka Ringwald cid = a2dp_subevent_stream_established_get_a2dp_cid(packet); 866596b7fdcSMilanka Ringwald if (!a2dp_cid){ 867596b7fdcSMilanka Ringwald // incoming connection 868596b7fdcSMilanka Ringwald a2dp_cid = cid; 869596b7fdcSMilanka Ringwald } else if (cid != a2dp_cid) { 870596b7fdcSMilanka Ringwald break; 871596b7fdcSMilanka Ringwald } 872326e5cedSMilanka Ringwald if (status){ 873f386e134SMilanka Ringwald printf("A2DP Sink : Streaming connection failed, status 0x%02x\n", status); 874326e5cedSMilanka Ringwald break; 875326e5cedSMilanka Ringwald } 8769635072eSMilanka Ringwald 8779635072eSMilanka Ringwald memcpy(device_addr, address, 6); 878f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_established_get_local_seid(packet); 879f386e134SMilanka 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); 88064421eb6SMilanka Ringwald break; 881f1042e9dSMilanka Ringwald 882f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_STARTED: 8834ccacc40SMilanka Ringwald cid = a2dp_subevent_stream_started_get_a2dp_cid(packet); 8844ccacc40SMilanka Ringwald if (cid != a2dp_cid) break; 885f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_started_get_local_seid(packet); 886f55e1e38SMilanka Ringwald printf("A2DP Sink : stream started\n"); 88772c514e8SMilanka Ringwald media_processing_init(sbc_configuration); 88864421eb6SMilanka Ringwald break; 889f1042e9dSMilanka Ringwald 890f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_SUSPENDED: 8914ccacc40SMilanka Ringwald cid = a2dp_subevent_stream_suspended_get_a2dp_cid(packet); 8924ccacc40SMilanka Ringwald if (cid != a2dp_cid) break; 893f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_suspended_get_local_seid(packet); 894f55e1e38SMilanka Ringwald printf("A2DP Sink : stream paused\n"); 895bcbbbb42SMatthias Ringwald // TODO: pause stream 896f1042e9dSMilanka Ringwald break; 897f1042e9dSMilanka Ringwald 898f1042e9dSMilanka Ringwald case A2DP_SUBEVENT_STREAM_RELEASED: 899f55e1e38SMilanka Ringwald a2dp_local_seid = a2dp_subevent_stream_released_get_local_seid(packet); 900f55e1e38SMilanka Ringwald printf("A2DP Sink : stream released\n"); 901f1042e9dSMilanka Ringwald media_processing_close(); 902f1042e9dSMilanka Ringwald break; 903a466d508SMilanka Ringwald case A2DP_SUBEVENT_SIGNALING_CONNECTION_RELEASED: 904a466d508SMilanka Ringwald cid = a2dp_subevent_signaling_connection_released_get_a2dp_cid(packet); 905f55e1e38SMilanka Ringwald printf("A2DP Sink : signaling connection released\n"); 90632ea0426SMatthias Ringwald media_processing_close(); 907a466d508SMilanka Ringwald break; 90864421eb6SMilanka Ringwald default: 909f55e1e38SMilanka Ringwald printf("A2DP Sink : not parsed 0x%02x\n", packet[2]); 91064421eb6SMilanka Ringwald break; 91164421eb6SMilanka Ringwald } 91264421eb6SMilanka Ringwald } 91364421eb6SMilanka Ringwald 91464421eb6SMilanka Ringwald #ifdef HAVE_BTSTACK_STDIN 91564421eb6SMilanka Ringwald static void show_usage(void){ 91664421eb6SMilanka Ringwald bd_addr_t iut_address; 91764421eb6SMilanka Ringwald gap_local_bd_addr(iut_address); 91864421eb6SMilanka Ringwald printf("\n--- Bluetooth AVDTP Sink/AVRCP Connection Test Console %s ---\n", bd_addr_to_str(iut_address)); 9199635072eSMilanka Ringwald printf("b - AVDTP Sink create connection to addr %s\n", bd_addr_to_str(device_addr)); 92064421eb6SMilanka Ringwald printf("B - AVDTP Sink disconnect\n"); 92114e3e2c2SMilanka Ringwald printf("c - AVRCP Controller create connection to addr %s\n", bd_addr_to_str(device_addr)); 92214e3e2c2SMilanka Ringwald printf("C - AVRCP Controller disconnect\n"); 92314e3e2c2SMilanka Ringwald printf("d - AVRCP Target create connection to addr %s\n", bd_addr_to_str(device_addr)); 92414e3e2c2SMilanka Ringwald printf("D - AVRCP Target disconnect\n"); 92564421eb6SMilanka Ringwald 92664421eb6SMilanka Ringwald printf("\n--- Bluetooth AVRCP Commands %s ---\n", bd_addr_to_str(iut_address)); 92764421eb6SMilanka Ringwald printf("O - get play status\n"); 92864421eb6SMilanka Ringwald printf("j - get now playing info\n"); 92964421eb6SMilanka Ringwald printf("k - play\n"); 93064421eb6SMilanka Ringwald printf("K - stop\n"); 9312d46c2e6SMilanka Ringwald printf("L - pause\n"); 9322d46c2e6SMilanka Ringwald printf("u - start fast forward\n"); 9332d46c2e6SMilanka Ringwald printf("U - stop fast forward\n"); 93464421eb6SMilanka Ringwald printf("n - start rewind\n"); 93564421eb6SMilanka Ringwald printf("N - stop rewind\n"); 93664421eb6SMilanka Ringwald printf("i - forward\n"); 93764421eb6SMilanka Ringwald printf("I - backward\n"); 93864421eb6SMilanka Ringwald printf("M - mute\n"); 93964421eb6SMilanka Ringwald printf("r - skip\n"); 94064421eb6SMilanka Ringwald printf("q - query repeat and shuffle mode\n"); 94164421eb6SMilanka Ringwald printf("v - repeat single track\n"); 94264421eb6SMilanka Ringwald printf("x - repeat all tracks\n"); 94364421eb6SMilanka Ringwald printf("X - disable repeat mode\n"); 94464421eb6SMilanka Ringwald printf("z - shuffle all tracks\n"); 94564421eb6SMilanka Ringwald printf("Z - disable shuffle mode\n"); 9468177fff3SMilanka Ringwald 9478177fff3SMilanka Ringwald printf("a/A - register/deregister TRACK_CHANGED\n"); 94814e3e2c2SMilanka Ringwald printf("R/P - register/deregister PLAYBACK_POS_CHANGED\n"); 9498177fff3SMilanka Ringwald 950f55e1e38SMilanka Ringwald printf("\n--- Volume Control ---\n"); 951f55e1e38SMilanka Ringwald printf("t - volume up for 10 percent\n"); 952f55e1e38SMilanka Ringwald printf("T - volume down for 10 percent\n"); 953f55e1e38SMilanka Ringwald 95464421eb6SMilanka Ringwald printf("---\n"); 95564421eb6SMilanka Ringwald } 95664421eb6SMilanka Ringwald #endif 95764421eb6SMilanka Ringwald 9584fb249f8SMatthias Ringwald #ifdef HAVE_BTSTACK_STDIN 95964421eb6SMilanka Ringwald static void stdin_process(char cmd){ 9604567cc17SMilanka Ringwald uint8_t status = ERROR_CODE_SUCCESS; 9616c333d06SMilanka Ringwald 96264421eb6SMilanka Ringwald switch (cmd){ 96364421eb6SMilanka Ringwald case 'b': 964f55e1e38SMilanka Ringwald status = a2dp_sink_establish_stream(device_addr, a2dp_local_seid, &a2dp_cid); 965f55e1e38SMilanka 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); 96664421eb6SMilanka Ringwald break; 96764421eb6SMilanka Ringwald case 'B': 968a466d508SMilanka Ringwald printf(" - AVDTP disconnect from addr %s.\n", bd_addr_to_str(device_addr)); 9694567cc17SMilanka Ringwald status = avdtp_sink_disconnect(a2dp_cid); 97064421eb6SMilanka Ringwald break; 97164421eb6SMilanka Ringwald case 'c': 97214e3e2c2SMilanka Ringwald printf(" - Create AVRCP Controller connection to addr %s.\n", bd_addr_to_str(device_addr)); 97314e3e2c2SMilanka Ringwald status = avrcp_controller_connect(device_addr, &avrcp_controller_cid); 97464421eb6SMilanka Ringwald break; 97564421eb6SMilanka Ringwald case 'C': 97614e3e2c2SMilanka Ringwald printf(" - AVRCP Controller disconnect from addr %s.\n", bd_addr_to_str(device_addr)); 97714e3e2c2SMilanka Ringwald status = avrcp_controller_disconnect(avrcp_controller_cid); 97814e3e2c2SMilanka Ringwald break; 97914e3e2c2SMilanka Ringwald case 'd': 98014e3e2c2SMilanka Ringwald printf(" - Create AVRCP Target connection to addr %s.\n", bd_addr_to_str(device_addr)); 98114e3e2c2SMilanka Ringwald status = avrcp_target_connect(device_addr, &avrcp_target_cid); 98214e3e2c2SMilanka Ringwald break; 98314e3e2c2SMilanka Ringwald case 'D': 98414e3e2c2SMilanka Ringwald printf(" - AVRCP Target disconnect from addr %s.\n", bd_addr_to_str(device_addr)); 98514e3e2c2SMilanka Ringwald status = avrcp_target_disconnect(avrcp_target_cid); 98664421eb6SMilanka Ringwald break; 98764421eb6SMilanka Ringwald 98864421eb6SMilanka Ringwald case '\n': 98964421eb6SMilanka Ringwald case '\r': 99064421eb6SMilanka Ringwald break; 991f55e1e38SMilanka Ringwald // Volume Control 992f55e1e38SMilanka Ringwald case 't': 993bcbbbb42SMatthias Ringwald volume_percentage = volume_percentage <= 90 ? volume_percentage + 10 : 100; 994f55e1e38SMilanka Ringwald printf(" - volume up for 10 percent, %d%% (%d) \n", volume_percentage, volume_percentage * 127 / 100); 995f55e1e38SMilanka Ringwald status = avrcp_target_volume_changed(avrcp_target_cid, volume_percentage * 127 / 100); 996f55e1e38SMilanka Ringwald break; 997f55e1e38SMilanka Ringwald case 'T': 998bcbbbb42SMatthias Ringwald volume_percentage = volume_percentage >= 10 ? volume_percentage - 10 : 0; 999f55e1e38SMilanka Ringwald printf(" - volume down for 10 percent, %d%% (%d) \n", volume_percentage, volume_percentage * 127 / 100); 1000f55e1e38SMilanka Ringwald status = avrcp_target_volume_changed(avrcp_target_cid, volume_percentage * 127 / 100); 1001f55e1e38SMilanka Ringwald break; 1002f55e1e38SMilanka Ringwald 100364421eb6SMilanka Ringwald case 'O': 1004f55e1e38SMilanka Ringwald printf(" - get play status\n"); 100514e3e2c2SMilanka Ringwald status = avrcp_controller_get_play_status(avrcp_controller_cid); 100664421eb6SMilanka Ringwald break; 100764421eb6SMilanka Ringwald case 'j': 1008f55e1e38SMilanka Ringwald printf(" - get now playing info\n"); 100914e3e2c2SMilanka Ringwald status = avrcp_controller_get_now_playing_info(avrcp_controller_cid); 101064421eb6SMilanka Ringwald break; 101164421eb6SMilanka Ringwald case 'k': 1012f55e1e38SMilanka Ringwald printf(" - play\n"); 101314e3e2c2SMilanka Ringwald status = avrcp_controller_play(avrcp_controller_cid); 101464421eb6SMilanka Ringwald break; 101564421eb6SMilanka Ringwald case 'K': 1016f55e1e38SMilanka Ringwald printf(" - stop\n"); 101714e3e2c2SMilanka Ringwald status = avrcp_controller_stop(avrcp_controller_cid); 101864421eb6SMilanka Ringwald break; 101964421eb6SMilanka Ringwald case 'L': 1020f55e1e38SMilanka Ringwald printf(" - pause\n"); 102114e3e2c2SMilanka Ringwald status = avrcp_controller_pause(avrcp_controller_cid); 102264421eb6SMilanka Ringwald break; 102364421eb6SMilanka Ringwald case 'u': 1024f55e1e38SMilanka Ringwald printf(" - start fast forward\n"); 102514e3e2c2SMilanka Ringwald status = avrcp_controller_press_and_hold_fast_forward(avrcp_controller_cid); 102664421eb6SMilanka Ringwald break; 102764421eb6SMilanka Ringwald case 'U': 1028f55e1e38SMilanka Ringwald printf(" - stop fast forward\n"); 102914e3e2c2SMilanka Ringwald status = avrcp_controller_release_press_and_hold_cmd(avrcp_controller_cid); 103064421eb6SMilanka Ringwald break; 103164421eb6SMilanka Ringwald case 'n': 1032f55e1e38SMilanka Ringwald printf(" - start rewind\n"); 103314e3e2c2SMilanka Ringwald status = avrcp_controller_press_and_hold_rewind(avrcp_controller_cid); 103464421eb6SMilanka Ringwald break; 103564421eb6SMilanka Ringwald case 'N': 1036f55e1e38SMilanka Ringwald printf(" - stop rewind\n"); 103714e3e2c2SMilanka Ringwald status = avrcp_controller_release_press_and_hold_cmd(avrcp_controller_cid); 103864421eb6SMilanka Ringwald break; 103964421eb6SMilanka Ringwald case 'i': 1040f55e1e38SMilanka Ringwald printf(" - forward\n"); 104114e3e2c2SMilanka Ringwald status = avrcp_controller_forward(avrcp_controller_cid); 104264421eb6SMilanka Ringwald break; 104364421eb6SMilanka Ringwald case 'I': 1044f55e1e38SMilanka Ringwald printf(" - backward\n"); 104514e3e2c2SMilanka Ringwald status = avrcp_controller_backward(avrcp_controller_cid); 104664421eb6SMilanka Ringwald break; 104764421eb6SMilanka Ringwald case 'M': 1048f55e1e38SMilanka Ringwald printf(" - mute\n"); 104914e3e2c2SMilanka Ringwald status = avrcp_controller_mute(avrcp_controller_cid); 105064421eb6SMilanka Ringwald break; 105164421eb6SMilanka Ringwald case 'r': 1052f55e1e38SMilanka Ringwald printf(" - skip\n"); 105314e3e2c2SMilanka Ringwald status = avrcp_controller_skip(avrcp_controller_cid); 105464421eb6SMilanka Ringwald break; 105564421eb6SMilanka Ringwald case 'q': 1056f55e1e38SMilanka Ringwald printf(" - query repeat and shuffle mode\n"); 105714e3e2c2SMilanka Ringwald status = avrcp_controller_query_shuffle_and_repeat_modes(avrcp_controller_cid); 105864421eb6SMilanka Ringwald break; 105964421eb6SMilanka Ringwald case 'v': 1060f55e1e38SMilanka Ringwald printf(" - repeat single track\n"); 106114e3e2c2SMilanka Ringwald status = avrcp_controller_set_repeat_mode(avrcp_controller_cid, AVRCP_REPEAT_MODE_SINGLE_TRACK); 106264421eb6SMilanka Ringwald break; 106364421eb6SMilanka Ringwald case 'x': 1064f55e1e38SMilanka Ringwald printf(" - repeat all tracks\n"); 106514e3e2c2SMilanka Ringwald status = avrcp_controller_set_repeat_mode(avrcp_controller_cid, AVRCP_REPEAT_MODE_ALL_TRACKS); 106664421eb6SMilanka Ringwald break; 106764421eb6SMilanka Ringwald case 'X': 1068f55e1e38SMilanka Ringwald printf(" - disable repeat mode\n"); 106914e3e2c2SMilanka Ringwald status = avrcp_controller_set_repeat_mode(avrcp_controller_cid, AVRCP_REPEAT_MODE_OFF); 107064421eb6SMilanka Ringwald break; 107164421eb6SMilanka Ringwald case 'z': 1072f55e1e38SMilanka Ringwald printf(" - shuffle all tracks\n"); 107314e3e2c2SMilanka Ringwald status = avrcp_controller_set_shuffle_mode(avrcp_controller_cid, AVRCP_SHUFFLE_MODE_ALL_TRACKS); 107464421eb6SMilanka Ringwald break; 107564421eb6SMilanka Ringwald case 'Z': 1076f55e1e38SMilanka Ringwald printf(" - disable shuffle mode\n"); 107714e3e2c2SMilanka Ringwald status = avrcp_controller_set_shuffle_mode(avrcp_controller_cid, AVRCP_SHUFFLE_MODE_OFF); 107864421eb6SMilanka Ringwald break; 10798177fff3SMilanka Ringwald case 'a': 1080f55e1e38SMilanka Ringwald printf("AVRCP: enable notification TRACK_CHANGED\n"); 108114e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_TRACK_CHANGED); 10828177fff3SMilanka Ringwald break; 10838177fff3SMilanka Ringwald case 'A': 1084f55e1e38SMilanka Ringwald printf("AVRCP: disable notification TRACK_CHANGED\n"); 108514e3e2c2SMilanka Ringwald avrcp_controller_disable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_TRACK_CHANGED); 10868177fff3SMilanka Ringwald break; 108714e3e2c2SMilanka Ringwald case 'R': 1088f55e1e38SMilanka Ringwald printf("AVRCP: enable notification PLAYBACK_POS_CHANGED\n"); 108914e3e2c2SMilanka Ringwald avrcp_controller_enable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_PLAYBACK_POS_CHANGED); 10906fa3dbf2SMilanka Ringwald break; 109114e3e2c2SMilanka Ringwald case 'P': 1092f55e1e38SMilanka Ringwald printf("AVRCP: disable notification PLAYBACK_POS_CHANGED\n"); 109314e3e2c2SMilanka Ringwald avrcp_controller_disable_notification(avrcp_controller_cid, AVRCP_NOTIFICATION_EVENT_PLAYBACK_POS_CHANGED); 10946fa3dbf2SMilanka Ringwald break; 10958177fff3SMilanka Ringwald 109664421eb6SMilanka Ringwald default: 109764421eb6SMilanka Ringwald show_usage(); 10984567cc17SMilanka Ringwald return; 10994567cc17SMilanka Ringwald } 11004567cc17SMilanka Ringwald if (status != ERROR_CODE_SUCCESS){ 11014567cc17SMilanka Ringwald printf("Could not perform command, status 0x%2x\n", status); 110264421eb6SMilanka Ringwald } 110364421eb6SMilanka Ringwald } 110464421eb6SMilanka Ringwald #endif 110564421eb6SMilanka Ringwald 110664421eb6SMilanka Ringwald int btstack_main(int argc, const char * argv[]); 110764421eb6SMilanka Ringwald int btstack_main(int argc, const char * argv[]){ 1108b23b09a5SMatthias Ringwald UNUSED(argc); 110964421eb6SMilanka Ringwald (void)argv; 111064421eb6SMilanka Ringwald 1111b23b09a5SMatthias Ringwald a2dp_and_avrcp_setup(); 1112b23b09a5SMatthias Ringwald 1113b23b09a5SMatthias Ringwald #ifdef HAVE_BTSTACK_STDIN 1114b23b09a5SMatthias Ringwald // parse human readable Bluetooth address 1115b23b09a5SMatthias Ringwald sscanf_bd_addr(device_addr_string, device_addr); 1116b23b09a5SMatthias Ringwald btstack_stdin_setup(stdin_process); 1117b23b09a5SMatthias Ringwald #endif 1118b23b09a5SMatthias Ringwald 111964421eb6SMilanka Ringwald // turn on! 11204dc98401SMilanka Ringwald printf("Starting BTstack ...\n"); 112164421eb6SMilanka Ringwald hci_power_control(HCI_POWER_ON); 112264421eb6SMilanka Ringwald return 0; 112364421eb6SMilanka Ringwald } 1124