xref: /btstack/example/a2dp_source_demo.c (revision 0c2b8870c4cf8ac5151dd4766b09eac243962a2c)
13fb2c90bSMilanka Ringwald /*
23fb2c90bSMilanka Ringwald  * Copyright (C) 2016 BlueKitchen GmbH
33fb2c90bSMilanka Ringwald  *
43fb2c90bSMilanka Ringwald  * Redistribution and use in source and binary forms, with or without
53fb2c90bSMilanka Ringwald  * modification, are permitted provided that the following conditions
63fb2c90bSMilanka Ringwald  * are met:
73fb2c90bSMilanka Ringwald  *
83fb2c90bSMilanka Ringwald  * 1. Redistributions of source code must retain the above copyright
93fb2c90bSMilanka Ringwald  *    notice, this list of conditions and the following disclaimer.
103fb2c90bSMilanka Ringwald  * 2. Redistributions in binary form must reproduce the above copyright
113fb2c90bSMilanka Ringwald  *    notice, this list of conditions and the following disclaimer in the
123fb2c90bSMilanka Ringwald  *    documentation and/or other materials provided with the distribution.
133fb2c90bSMilanka Ringwald  * 3. Neither the name of the copyright holders nor the names of
143fb2c90bSMilanka Ringwald  *    contributors may be used to endorse or promote products derived
153fb2c90bSMilanka Ringwald  *    from this software without specific prior written permission.
163fb2c90bSMilanka Ringwald  * 4. Any redistribution, use, or modification is done solely for
173fb2c90bSMilanka Ringwald  *    personal benefit and not for any commercial purpose or for
183fb2c90bSMilanka Ringwald  *    monetary gain.
193fb2c90bSMilanka Ringwald  *
203fb2c90bSMilanka Ringwald  * THIS SOFTWARE IS PROVIDED BY BLUEKITCHEN GMBH AND CONTRIBUTORS
213fb2c90bSMilanka Ringwald  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
223fb2c90bSMilanka Ringwald  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
233fb2c90bSMilanka Ringwald  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MATTHIAS
243fb2c90bSMilanka Ringwald  * RINGWALD OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
253fb2c90bSMilanka Ringwald  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
263fb2c90bSMilanka Ringwald  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
273fb2c90bSMilanka Ringwald  * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
283fb2c90bSMilanka Ringwald  * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
293fb2c90bSMilanka Ringwald  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
303fb2c90bSMilanka Ringwald  * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
313fb2c90bSMilanka Ringwald  * SUCH DAMAGE.
323fb2c90bSMilanka Ringwald  *
333fb2c90bSMilanka Ringwald  * Please inquire about commercial licensing options at
343fb2c90bSMilanka Ringwald  * [email protected]
353fb2c90bSMilanka Ringwald  *
363fb2c90bSMilanka Ringwald  */
373fb2c90bSMilanka Ringwald 
383fb2c90bSMilanka Ringwald 
393fb2c90bSMilanka Ringwald #include <stdint.h>
403fb2c90bSMilanka Ringwald #include <stdio.h>
413fb2c90bSMilanka Ringwald #include <stdlib.h>
423fb2c90bSMilanka Ringwald #include <string.h>
433fb2c90bSMilanka Ringwald 
443fb2c90bSMilanka Ringwald #include "btstack.h"
453fb2c90bSMilanka Ringwald 
463fb2c90bSMilanka Ringwald #include "hxcmod.h"
473fb2c90bSMilanka Ringwald #include "mods/mod.h"
483fb2c90bSMilanka Ringwald 
493fb2c90bSMilanka Ringwald #define NUM_CHANNELS                2
503fb2c90bSMilanka Ringwald #define A2DP_SAMPLE_RATE            44100
513fb2c90bSMilanka Ringwald #define BYTES_PER_AUDIO_SAMPLE      (2*NUM_CHANNELS)
5267673f1cSMilanka Ringwald #define AUDIO_TIMEOUT_MS            10
533fb2c90bSMilanka Ringwald #define TABLE_SIZE_441HZ            100
543fb2c90bSMilanka Ringwald 
553fb2c90bSMilanka Ringwald typedef enum {
563fb2c90bSMilanka Ringwald     STREAM_SINE,
573fb2c90bSMilanka Ringwald     STREAM_MOD
583fb2c90bSMilanka Ringwald } stream_data_source_t;
593fb2c90bSMilanka Ringwald 
6067673f1cSMilanka Ringwald typedef struct {
6167673f1cSMilanka Ringwald     uint16_t a2dp_cid;
6267673f1cSMilanka Ringwald     uint8_t  local_seid;
6367673f1cSMilanka Ringwald 
6467673f1cSMilanka Ringwald     uint32_t time_audio_data_sent; // ms
6567673f1cSMilanka Ringwald     uint32_t acc_num_missed_samples;
6667673f1cSMilanka Ringwald     uint32_t samples_ready;
6767673f1cSMilanka Ringwald     btstack_timer_source_t audio_timer;
6867673f1cSMilanka Ringwald     uint8_t  streaming;
6967673f1cSMilanka Ringwald     int      max_media_payload_size;
7067673f1cSMilanka Ringwald 
7167673f1cSMilanka Ringwald     uint8_t  sbc_storage[1030];
7267673f1cSMilanka Ringwald     uint16_t sbc_storage_count;
7367673f1cSMilanka Ringwald     uint8_t  sbc_ready_to_send;
7467673f1cSMilanka Ringwald } a2dp_media_sending_context_t;
7567673f1cSMilanka Ringwald 
763fb2c90bSMilanka Ringwald static  uint8_t media_sbc_codec_capabilities[] = {
773fb2c90bSMilanka Ringwald     (AVDTP_SBC_44100 << 4) | AVDTP_SBC_STEREO,
783fb2c90bSMilanka Ringwald     0xFF,//(AVDTP_SBC_BLOCK_LENGTH_16 << 4) | (AVDTP_SBC_SUBBANDS_8 << 2) | AVDTP_SBC_ALLOCATION_METHOD_LOUDNESS,
793fb2c90bSMilanka Ringwald     2, 53
803fb2c90bSMilanka Ringwald };
813fb2c90bSMilanka Ringwald 
823fb2c90bSMilanka Ringwald static const int16_t sine_int16[] = {
833fb2c90bSMilanka Ringwald      0,    2057,    4107,    6140,    8149,   10126,   12062,   13952,   15786,   17557,
843fb2c90bSMilanka Ringwald  19260,   20886,   22431,   23886,   25247,   26509,   27666,   28714,   29648,   30466,
853fb2c90bSMilanka Ringwald  31163,   31738,   32187,   32509,   32702,   32767,   32702,   32509,   32187,   31738,
863fb2c90bSMilanka Ringwald  31163,   30466,   29648,   28714,   27666,   26509,   25247,   23886,   22431,   20886,
873fb2c90bSMilanka Ringwald  19260,   17557,   15786,   13952,   12062,   10126,    8149,    6140,    4107,    2057,
883fb2c90bSMilanka Ringwald      0,   -2057,   -4107,   -6140,   -8149,  -10126,  -12062,  -13952,  -15786,  -17557,
893fb2c90bSMilanka Ringwald -19260,  -20886,  -22431,  -23886,  -25247,  -26509,  -27666,  -28714,  -29648,  -30466,
903fb2c90bSMilanka Ringwald -31163,  -31738,  -32187,  -32509,  -32702,  -32767,  -32702,  -32509,  -32187,  -31738,
913fb2c90bSMilanka Ringwald -31163,  -30466,  -29648,  -28714,  -27666,  -26509,  -25247,  -23886,  -22431,  -20886,
923fb2c90bSMilanka Ringwald -19260,  -17557,  -15786,  -13952,  -12062,  -10126,   -8149,   -6140,   -4107,   -2057,
933fb2c90bSMilanka Ringwald };
943fb2c90bSMilanka Ringwald 
95*0c2b8870SMatthias Ringwald static const char * device_name = "A2DP Source Demo 00:00:00:00:00:00";
963fb2c90bSMilanka Ringwald 
973fb2c90bSMilanka Ringwald #ifdef HAVE_BTSTACK_STDIN
9867673f1cSMilanka Ringwald // mac 2011:    static const char * device_addr_string = "04:0C:CE:E4:85:D3";
99adaba9f3SMatthias Ringwald // pts:         static const char * device_addr_string = "00:1B:DC:08:0A:A5";
10067673f1cSMilanka Ringwald // mac 2013:    static const char * device_addr_string = "84:38:35:65:d1:15";
10167673f1cSMilanka Ringwald // phone 2013:  static const char * device_addr_string = "D8:BB:2C:DF:F0:F2";
102adaba9f3SMatthias Ringwald // minijambox:
103adaba9f3SMatthias Ringwald static const char * device_addr_string = "00:21:3C:AC:F7:38";
10467673f1cSMilanka Ringwald // head phones: static const char * device_addr_string = "00:18:09:28:50:18";
10567673f1cSMilanka Ringwald // bt dongle:   static const char * device_addr_string = "00:15:83:5F:9D:46";
1063fb2c90bSMilanka Ringwald #endif
1073fb2c90bSMilanka Ringwald 
10867673f1cSMilanka Ringwald static bd_addr_t device_addr;
10967673f1cSMilanka Ringwald static uint8_t sdp_a2dp_source_service_buffer[150];
1103fb2c90bSMilanka Ringwald static uint8_t media_sbc_codec_configuration[4];
1113fb2c90bSMilanka Ringwald static a2dp_media_sending_context_t media_tracker;
1123fb2c90bSMilanka Ringwald 
11301dc6e35SMilanka Ringwald static uint16_t avrcp_cid;
11401dc6e35SMilanka Ringwald 
11567673f1cSMilanka Ringwald static stream_data_source_t data_source;
1163fb2c90bSMilanka Ringwald 
11767673f1cSMilanka Ringwald static int sine_phase;
11867673f1cSMilanka Ringwald 
11967673f1cSMilanka Ringwald static int hxcmod_initialized;
1203fb2c90bSMilanka Ringwald static modcontext mod_context;
1213fb2c90bSMilanka Ringwald static tracker_buffer_state trkbuf;
1223fb2c90bSMilanka Ringwald 
123c045af99SMilanka Ringwald 
124c045af99SMilanka Ringwald /* AVRCP Target context START */
125c045af99SMilanka Ringwald static const uint8_t subunit_info[] = {
126c045af99SMilanka Ringwald     0,0,0,0,
127c045af99SMilanka Ringwald     1,1,1,1,
128c045af99SMilanka Ringwald     2,2,2,2,
129c045af99SMilanka Ringwald     3,3,3,3,
130c045af99SMilanka Ringwald     4,4,4,4,
131c045af99SMilanka Ringwald     5,5,5,5,
132c045af99SMilanka Ringwald     6,6,6,6,
133c045af99SMilanka Ringwald     7,7,7,7
134c045af99SMilanka Ringwald };
135c045af99SMilanka Ringwald 
1364b338011SMilanka Ringwald static uint32_t company_id = 0x112233;
137e0bbf3edSMilanka Ringwald static uint8_t companies_num = 1;
138e0bbf3edSMilanka Ringwald static uint8_t companies[] = {
139e0bbf3edSMilanka Ringwald     0x00, 0x19, 0x58 //BT SIG registered CompanyID
140e0bbf3edSMilanka Ringwald };
141e0bbf3edSMilanka Ringwald 
142e0bbf3edSMilanka Ringwald static uint8_t events_num = 13;
143e0bbf3edSMilanka Ringwald static uint8_t events[] = {
144e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_PLAYBACK_STATUS_CHANGED,
145e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_TRACK_CHANGED,
146e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_TRACK_REACHED_END,
147e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_TRACK_REACHED_START,
148e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_PLAYBACK_POS_CHANGED,
149e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_BATT_STATUS_CHANGED,
150e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_SYSTEM_STATUS_CHANGED,
151e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_PLAYER_APPLICATION_SETTING_CHANGED,
152e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_NOW_PLAYING_CONTENT_CHANGED,
153e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_AVAILABLE_PLAYERS_CHANGED,
154e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_ADDRESSED_PLAYER_CHANGED,
155e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_UIDS_CHANGED,
156e0bbf3edSMilanka Ringwald     AVRCP_NOTIFICATION_EVENT_VOLUME_CHANGED
157e0bbf3edSMilanka Ringwald };
158e0bbf3edSMilanka Ringwald 
159c045af99SMilanka Ringwald typedef struct {
1605e3d4d2bSMilanka Ringwald     char title[40];
1615e3d4d2bSMilanka Ringwald     char artist[40];
1625e3d4d2bSMilanka Ringwald     char album[40];
1635e3d4d2bSMilanka Ringwald     char genre[40];
1645e3d4d2bSMilanka Ringwald     uint32_t song_length_ms;
1655e3d4d2bSMilanka Ringwald     int total_tracks;
1665e3d4d2bSMilanka Ringwald     int track_nr;
1675e3d4d2bSMilanka Ringwald } avrcp_now_playing_info_t;
1685e3d4d2bSMilanka Ringwald 
1695e3d4d2bSMilanka Ringwald typedef struct {
170c045af99SMilanka Ringwald     avrcp_play_status_t status;
171c045af99SMilanka Ringwald     uint32_t song_length_ms;   // 0xFFFFFFFF if not supported
172c045af99SMilanka Ringwald     uint32_t song_position_ms; // 0xFFFFFFFF if not supported
173c045af99SMilanka Ringwald } avrcp_play_status_info_t;
174c045af99SMilanka Ringwald 
1755e3d4d2bSMilanka Ringwald avrcp_now_playing_info_t now_playing_info;
176c045af99SMilanka Ringwald avrcp_play_status_info_t play_info;
177c045af99SMilanka Ringwald 
178c045af99SMilanka Ringwald /* AVRCP Target context END */
179c045af99SMilanka Ringwald 
18067673f1cSMilanka Ringwald static void a2dp_demo_send_media_packet(void){
1813fb2c90bSMilanka Ringwald     int num_bytes_in_frame = btstack_sbc_encoder_sbc_buffer_length();
1823fb2c90bSMilanka Ringwald     int bytes_in_storage = media_tracker.sbc_storage_count;
1833fb2c90bSMilanka Ringwald     uint8_t num_frames = bytes_in_storage / num_bytes_in_frame;
1843fb2c90bSMilanka Ringwald     a2dp_source_stream_send_media_payload(media_tracker.local_seid, media_tracker.sbc_storage, bytes_in_storage, num_frames, 0);
1853fb2c90bSMilanka Ringwald     media_tracker.sbc_storage_count = 0;
1863fb2c90bSMilanka Ringwald     media_tracker.sbc_ready_to_send = 0;
1873fb2c90bSMilanka Ringwald }
1883fb2c90bSMilanka Ringwald 
18967673f1cSMilanka Ringwald static void produce_sine_audio(int16_t * pcm_buffer, int num_samples_to_write){
1903fb2c90bSMilanka Ringwald     int count;
1913fb2c90bSMilanka Ringwald     for (count = 0; count < num_samples_to_write ; count++){
19267673f1cSMilanka Ringwald         pcm_buffer[count * 2]     = sine_int16[sine_phase];
19367673f1cSMilanka Ringwald         pcm_buffer[count * 2 + 1] = sine_int16[sine_phase];
19467673f1cSMilanka Ringwald         sine_phase++;
19567673f1cSMilanka Ringwald         if (sine_phase >= TABLE_SIZE_441HZ){
19667673f1cSMilanka Ringwald             sine_phase -= TABLE_SIZE_441HZ;
1973fb2c90bSMilanka Ringwald         }
1983fb2c90bSMilanka Ringwald     }
1993fb2c90bSMilanka Ringwald }
2003fb2c90bSMilanka Ringwald 
2013fb2c90bSMilanka Ringwald static void produce_mod_audio(int16_t * pcm_buffer, int num_samples_to_write){
2023fb2c90bSMilanka Ringwald     hxcmod_fillbuffer(&mod_context, (unsigned short *) &pcm_buffer[0], num_samples_to_write, &trkbuf);
2033fb2c90bSMilanka Ringwald }
2043fb2c90bSMilanka Ringwald 
2053fb2c90bSMilanka Ringwald static void produce_audio(int16_t * pcm_buffer, int num_samples){
2063fb2c90bSMilanka Ringwald     switch (data_source){
2073fb2c90bSMilanka Ringwald         case STREAM_SINE:
20867673f1cSMilanka Ringwald             produce_sine_audio(pcm_buffer, num_samples);
2093fb2c90bSMilanka Ringwald             break;
2103fb2c90bSMilanka Ringwald         case STREAM_MOD:
2113fb2c90bSMilanka Ringwald             produce_mod_audio(pcm_buffer, num_samples);
2123fb2c90bSMilanka Ringwald             break;
2133fb2c90bSMilanka Ringwald     }
2143fb2c90bSMilanka Ringwald }
2153fb2c90bSMilanka Ringwald 
216319b19ccSMilanka Ringwald static int a2dp_demo_fill_sbc_audio_buffer(a2dp_media_sending_context_t * context){
2173fb2c90bSMilanka Ringwald     // perform sbc encodin
2183fb2c90bSMilanka Ringwald     int total_num_bytes_read = 0;
219249d94cfSMatthias Ringwald     unsigned int num_audio_samples_per_sbc_buffer = btstack_sbc_encoder_num_audio_frames();
2203fb2c90bSMilanka Ringwald     while (context->samples_ready >= num_audio_samples_per_sbc_buffer
2213fb2c90bSMilanka Ringwald         && (context->max_media_payload_size - context->sbc_storage_count) >= btstack_sbc_encoder_sbc_buffer_length()){
2223fb2c90bSMilanka Ringwald 
223adaba9f3SMatthias Ringwald         int16_t pcm_frame[256*NUM_CHANNELS];
2243fb2c90bSMilanka Ringwald 
225adaba9f3SMatthias Ringwald         produce_audio(pcm_frame, num_audio_samples_per_sbc_buffer);
226adaba9f3SMatthias Ringwald         btstack_sbc_encoder_process_data(pcm_frame);
2273fb2c90bSMilanka Ringwald 
2283fb2c90bSMilanka Ringwald         uint16_t sbc_frame_size = btstack_sbc_encoder_sbc_buffer_length();
2293fb2c90bSMilanka Ringwald         uint8_t * sbc_frame = btstack_sbc_encoder_sbc_buffer();
2303fb2c90bSMilanka Ringwald 
2313fb2c90bSMilanka Ringwald         total_num_bytes_read += num_audio_samples_per_sbc_buffer;
2323fb2c90bSMilanka Ringwald         memcpy(&context->sbc_storage[context->sbc_storage_count], sbc_frame, sbc_frame_size);
2333fb2c90bSMilanka Ringwald         context->sbc_storage_count += sbc_frame_size;
2343fb2c90bSMilanka Ringwald         context->samples_ready -= num_audio_samples_per_sbc_buffer;
2353fb2c90bSMilanka Ringwald     }
2363fb2c90bSMilanka Ringwald     return total_num_bytes_read;
2373fb2c90bSMilanka Ringwald }
2383fb2c90bSMilanka Ringwald 
239319b19ccSMilanka Ringwald static void a2dp_demo_audio_timeout_handler(btstack_timer_source_t * timer){
2403fb2c90bSMilanka Ringwald     a2dp_media_sending_context_t * context = (a2dp_media_sending_context_t *) btstack_run_loop_get_timer_context(timer);
24167673f1cSMilanka Ringwald     btstack_run_loop_set_timer(&context->audio_timer, AUDIO_TIMEOUT_MS);
24267673f1cSMilanka Ringwald     btstack_run_loop_add_timer(&context->audio_timer);
2433fb2c90bSMilanka Ringwald     uint32_t now = btstack_run_loop_get_time_ms();
2443fb2c90bSMilanka Ringwald 
24567673f1cSMilanka Ringwald     uint32_t update_period_ms = AUDIO_TIMEOUT_MS;
2463fb2c90bSMilanka Ringwald     if (context->time_audio_data_sent > 0){
2473fb2c90bSMilanka Ringwald         update_period_ms = now - context->time_audio_data_sent;
2483fb2c90bSMilanka Ringwald     }
2493fb2c90bSMilanka Ringwald 
2503fb2c90bSMilanka Ringwald     uint32_t num_samples = (update_period_ms * A2DP_SAMPLE_RATE) / 1000;
2513fb2c90bSMilanka Ringwald     context->acc_num_missed_samples += (update_period_ms * A2DP_SAMPLE_RATE) % 1000;
2523fb2c90bSMilanka Ringwald 
2533fb2c90bSMilanka Ringwald     while (context->acc_num_missed_samples >= 1000){
2543fb2c90bSMilanka Ringwald         num_samples++;
2553fb2c90bSMilanka Ringwald         context->acc_num_missed_samples -= 1000;
2563fb2c90bSMilanka Ringwald     }
2573fb2c90bSMilanka Ringwald     context->time_audio_data_sent = now;
2583fb2c90bSMilanka Ringwald     context->samples_ready += num_samples;
2593fb2c90bSMilanka Ringwald 
2603fb2c90bSMilanka Ringwald     if (context->sbc_ready_to_send) return;
2613fb2c90bSMilanka Ringwald 
262319b19ccSMilanka Ringwald     a2dp_demo_fill_sbc_audio_buffer(context);
2633fb2c90bSMilanka Ringwald 
2643fb2c90bSMilanka Ringwald     if ((context->sbc_storage_count + btstack_sbc_encoder_sbc_buffer_length()) > context->max_media_payload_size){
2653fb2c90bSMilanka Ringwald         // schedule sending
2663fb2c90bSMilanka Ringwald         context->sbc_ready_to_send = 1;
2673fb2c90bSMilanka Ringwald         a2dp_source_stream_endpoint_request_can_send_now(context->local_seid);
2683fb2c90bSMilanka Ringwald     }
2693fb2c90bSMilanka Ringwald }
2703fb2c90bSMilanka Ringwald 
27167673f1cSMilanka Ringwald static void a2dp_demo_timer_start(a2dp_media_sending_context_t * context){
2723fb2c90bSMilanka Ringwald     context->max_media_payload_size = a2dp_max_media_payload_size(context->local_seid);
2733fb2c90bSMilanka Ringwald     context->sbc_storage_count = 0;
2743fb2c90bSMilanka Ringwald     context->sbc_ready_to_send = 0;
2753fb2c90bSMilanka Ringwald     context->streaming = 1;
27667673f1cSMilanka Ringwald     btstack_run_loop_remove_timer(&context->audio_timer);
277319b19ccSMilanka Ringwald     btstack_run_loop_set_timer_handler(&context->audio_timer, a2dp_demo_audio_timeout_handler);
27867673f1cSMilanka Ringwald     btstack_run_loop_set_timer_context(&context->audio_timer, context);
27967673f1cSMilanka Ringwald     btstack_run_loop_set_timer(&context->audio_timer, AUDIO_TIMEOUT_MS);
28067673f1cSMilanka Ringwald     btstack_run_loop_add_timer(&context->audio_timer);
2813fb2c90bSMilanka Ringwald }
2823fb2c90bSMilanka Ringwald 
28367673f1cSMilanka Ringwald static void a2dp_demo_timer_stop(a2dp_media_sending_context_t * context){
2843fb2c90bSMilanka Ringwald     context->time_audio_data_sent = 0;
2853fb2c90bSMilanka Ringwald     context->acc_num_missed_samples = 0;
2863fb2c90bSMilanka Ringwald     context->samples_ready = 0;
2873fb2c90bSMilanka Ringwald     context->streaming = 1;
2883fb2c90bSMilanka Ringwald     context->sbc_storage_count = 0;
2893fb2c90bSMilanka Ringwald     context->sbc_ready_to_send = 0;
29067673f1cSMilanka Ringwald     btstack_run_loop_remove_timer(&context->audio_timer);
2913fb2c90bSMilanka Ringwald }
2923fb2c90bSMilanka Ringwald 
29367673f1cSMilanka Ringwald static void a2dp_demo_timer_pause(a2dp_media_sending_context_t * context){
29467673f1cSMilanka Ringwald     btstack_run_loop_remove_timer(&context->audio_timer);
29567673f1cSMilanka Ringwald }
29667673f1cSMilanka Ringwald 
29767673f1cSMilanka Ringwald 
29867673f1cSMilanka Ringwald static void packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){
29967673f1cSMilanka Ringwald     UNUSED(channel);
30067673f1cSMilanka Ringwald     UNUSED(size);
30167673f1cSMilanka Ringwald     uint8_t status;
30267673f1cSMilanka Ringwald     uint8_t local_seid;
303ef5ad9d6SMilanka Ringwald     bd_addr_t address;
30467673f1cSMilanka Ringwald 
305ef5ad9d6SMilanka Ringwald     if (packet_type != HCI_EVENT_PACKET) return;
306ef5ad9d6SMilanka Ringwald     if (hci_event_packet_get_type(packet) != HCI_EVENT_A2DP_META) return;
30767673f1cSMilanka Ringwald 
30867673f1cSMilanka Ringwald     switch (packet[2]){
3095448c259SMilanka Ringwald         case A2DP_SUBEVENT_INCOMING_CONNECTION_ESTABLISHED:
3105448c259SMilanka Ringwald             a2dp_subevent_incoming_connection_established_get_bd_addr(packet, address);
3115448c259SMilanka Ringwald             media_tracker.a2dp_cid = a2dp_subevent_incoming_connection_established_get_a2dp_cid(packet);
3125448c259SMilanka Ringwald             printf("A2DP: Incoming connection established: address %s, a2dp cid 0x%02x. Create stream on local seid %d.\n",
3135448c259SMilanka Ringwald                 bd_addr_to_str(address), media_tracker.a2dp_cid, media_tracker.local_seid);
3145448c259SMilanka Ringwald             status = a2dp_source_establish_stream(device_addr, media_tracker.local_seid, &media_tracker.a2dp_cid);
3155448c259SMilanka Ringwald             if (status != ERROR_CODE_SUCCESS){
3165448c259SMilanka Ringwald                 printf("Could not perform command, status 0x%2x\n", status);
3175448c259SMilanka Ringwald             }
3185448c259SMilanka Ringwald             break;
31967673f1cSMilanka Ringwald         case A2DP_SUBEVENT_STREAM_ESTABLISHED:
320ef5ad9d6SMilanka Ringwald             a2dp_subevent_stream_established_get_bd_addr(packet, address);
32167673f1cSMilanka Ringwald             status = a2dp_subevent_stream_established_get_status(packet);
32267673f1cSMilanka Ringwald             if (status){
3231e1ae2bcSMilanka Ringwald                 printf("A2DP: Stream establishment failed: status 0x%02x.\n", status);
32467673f1cSMilanka Ringwald                 break;
32567673f1cSMilanka Ringwald             }
32667673f1cSMilanka Ringwald             local_seid = a2dp_subevent_stream_established_get_local_seid(packet);
32767673f1cSMilanka Ringwald             if (local_seid != media_tracker.local_seid){
3281e1ae2bcSMilanka Ringwald                 printf("A2DP: Stream establishment failed: wrong local seid %d, expected %d.\n", local_seid, media_tracker.local_seid);
32967673f1cSMilanka Ringwald                 break;
33067673f1cSMilanka Ringwald             }
33167673f1cSMilanka Ringwald             media_tracker.a2dp_cid = a2dp_subevent_stream_established_get_a2dp_cid(packet);
3321e1ae2bcSMilanka Ringwald             printf("A2DP: Stream established: address %s, a2dp cid 0x%02x, local seid %d, remote seid %d.\n", bd_addr_to_str(address),
33367673f1cSMilanka Ringwald                 media_tracker.a2dp_cid, media_tracker.local_seid, a2dp_subevent_stream_established_get_remote_seid(packet));
3345448c259SMilanka Ringwald             printf("Start playing mod.\n");
3355448c259SMilanka Ringwald             data_source = STREAM_MOD;
3365448c259SMilanka Ringwald             status = a2dp_source_start_stream(media_tracker.a2dp_cid, media_tracker.local_seid);
33767673f1cSMilanka Ringwald             break;
33867673f1cSMilanka Ringwald 
33967673f1cSMilanka Ringwald         case A2DP_SUBEVENT_STREAM_STARTED:
340c045af99SMilanka Ringwald             play_info.status = AVRCP_PLAY_STATUS_PLAYING;
34167673f1cSMilanka Ringwald             a2dp_demo_timer_start(&media_tracker);
3421e1ae2bcSMilanka Ringwald             printf("A2DP: Stream started.\n");
34367673f1cSMilanka Ringwald             break;
34467673f1cSMilanka Ringwald 
34567673f1cSMilanka Ringwald         case A2DP_SUBEVENT_STREAMING_CAN_SEND_MEDIA_PACKET_NOW:
34667673f1cSMilanka Ringwald             a2dp_demo_send_media_packet();
34767673f1cSMilanka Ringwald             break;
34867673f1cSMilanka Ringwald 
34967673f1cSMilanka Ringwald         case A2DP_SUBEVENT_STREAM_SUSPENDED:
350c045af99SMilanka Ringwald             play_info.status = AVRCP_PLAY_STATUS_PAUSED;
3511e1ae2bcSMilanka Ringwald             printf("A2DP: Stream paused.\n");
35267673f1cSMilanka Ringwald             a2dp_demo_timer_pause(&media_tracker);
35367673f1cSMilanka Ringwald             break;
35467673f1cSMilanka Ringwald 
35567673f1cSMilanka Ringwald         case A2DP_SUBEVENT_STREAM_RELEASED:
356c045af99SMilanka Ringwald             play_info.status = AVRCP_PLAY_STATUS_STOPPED;
3571e1ae2bcSMilanka Ringwald             printf("A2DP: Stream released.\n");
35867673f1cSMilanka Ringwald             a2dp_demo_timer_stop(&media_tracker);
35967673f1cSMilanka Ringwald             break;
36067673f1cSMilanka Ringwald         default:
3611e1ae2bcSMilanka Ringwald             printf("A2DP: event 0x%02x is not implemented\n", packet[2]);
36267673f1cSMilanka Ringwald             break;
36367673f1cSMilanka Ringwald     }
3643fb2c90bSMilanka Ringwald }
3653fb2c90bSMilanka Ringwald 
36601dc6e35SMilanka Ringwald static void avrcp_target_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){
36701dc6e35SMilanka Ringwald     UNUSED(channel);
36801dc6e35SMilanka Ringwald     UNUSED(size);
36901dc6e35SMilanka Ringwald     bd_addr_t event_addr;
37001dc6e35SMilanka Ringwald     uint16_t local_cid;
37101dc6e35SMilanka Ringwald     uint8_t  status = 0xFF;
3723fb2c90bSMilanka Ringwald 
37301dc6e35SMilanka Ringwald     if (packet_type != HCI_EVENT_PACKET) return;
37401dc6e35SMilanka Ringwald     if (hci_event_packet_get_type(packet) != HCI_EVENT_AVRCP_META) return;
37501dc6e35SMilanka Ringwald     switch (packet[2]){
37601dc6e35SMilanka Ringwald         case AVRCP_SUBEVENT_CONNECTION_ESTABLISHED: {
37701dc6e35SMilanka Ringwald             local_cid = avrcp_subevent_connection_established_get_avrcp_cid(packet);
37801dc6e35SMilanka Ringwald             if (avrcp_cid != 0 && avrcp_cid != local_cid) {
3791e1ae2bcSMilanka Ringwald                 printf("AVRCP: Connection failed, expected 0x%02X l2cap cid, received 0x%02X\n", avrcp_cid, local_cid);
38001dc6e35SMilanka Ringwald                 return;
38101dc6e35SMilanka Ringwald             }
38201dc6e35SMilanka Ringwald 
38301dc6e35SMilanka Ringwald             status = avrcp_subevent_connection_established_get_status(packet);
38401dc6e35SMilanka Ringwald             if (status != ERROR_CODE_SUCCESS){
3851e1ae2bcSMilanka Ringwald                 printf("AVRCP: Connection failed: status 0x%02x\n", status);
38601dc6e35SMilanka Ringwald                 avrcp_cid = 0;
38701dc6e35SMilanka Ringwald                 return;
38801dc6e35SMilanka Ringwald             }
38901dc6e35SMilanka Ringwald             avrcp_cid = local_cid;
390c045af99SMilanka Ringwald             play_info.song_length_ms = 0xFFFFFFFF;
391c045af99SMilanka Ringwald             play_info.song_position_ms = 0xFFFFFFFF;
392c045af99SMilanka Ringwald             play_info.status = AVRCP_PLAY_STATUS_ERROR;
393c045af99SMilanka Ringwald 
39401dc6e35SMilanka Ringwald             avrcp_subevent_connection_established_get_bd_addr(packet, event_addr);
3951e1ae2bcSMilanka Ringwald             printf("AVRCP: connected to %s, avrcp_cid 0x%02x\n", bd_addr_to_str(event_addr), local_cid);
39601dc6e35SMilanka Ringwald             return;
39701dc6e35SMilanka Ringwald         }
3984b338011SMilanka Ringwald 
3994b338011SMilanka Ringwald         case AVRCP_SUBEVENT_UNIT_INFO_QUERY:
4004b338011SMilanka Ringwald             avrcp_target_unit_info(avrcp_cid, AVRCP_SUBUNIT_TYPE_AUDIO, company_id);
4014b338011SMilanka Ringwald             break;
4024b338011SMilanka Ringwald         case AVRCP_SUBEVENT_SUBUNIT_INFO_QUERY:
4034b338011SMilanka Ringwald             avrcp_target_subunit_info(avrcp_cid, AVRCP_SUBUNIT_TYPE_UNIT, avrcp_subevent_subunit_info_query_get_offset(packet), (uint8_t *)subunit_info);
4044b338011SMilanka Ringwald             break;
405e0bbf3edSMilanka Ringwald         case AVRCP_SUBEVENT_EVENT_IDS_QUERY:
406e0bbf3edSMilanka Ringwald             avrcp_target_supported_events(avrcp_cid, events_num, events, sizeof(events));
407e0bbf3edSMilanka Ringwald             break;
408e0bbf3edSMilanka Ringwald         case AVRCP_SUBEVENT_COMPANY_IDS_QUERY:
409e0bbf3edSMilanka Ringwald             avrcp_target_supported_companies(avrcp_cid, companies_num, companies, sizeof(companies));
410e0bbf3edSMilanka Ringwald             break;
411c045af99SMilanka Ringwald         case AVRCP_SUBEVENT_PLAY_STATUS_QUERY:
412c045af99SMilanka Ringwald             avrcp_target_play_status(avrcp_cid, play_info.song_length_ms, play_info.song_position_ms, play_info.status);
413c045af99SMilanka Ringwald             break;
4145e3d4d2bSMilanka Ringwald         case AVRCP_SUBEVENT_NOW_PLAYING_INFO_QUERY:
4155e3d4d2bSMilanka Ringwald             avrcp_target_set_now_playing_title(avrcp_cid, now_playing_info.title);
4165e3d4d2bSMilanka Ringwald             avrcp_target_set_now_playing_artist(avrcp_cid, now_playing_info.artist);
4175e3d4d2bSMilanka Ringwald             avrcp_target_set_now_playing_album(avrcp_cid, now_playing_info.album);
4185e3d4d2bSMilanka Ringwald             avrcp_target_set_now_playing_genre(avrcp_cid, now_playing_info.genre);
4195e3d4d2bSMilanka Ringwald             avrcp_target_set_now_playing_track_nr(avrcp_cid, now_playing_info.track_nr);
4205e3d4d2bSMilanka Ringwald             avrcp_target_set_now_playing_total_tracks(avrcp_cid, now_playing_info.total_tracks);
4215e3d4d2bSMilanka Ringwald             avrcp_target_set_now_playing_song_length_ms(avrcp_cid, now_playing_info.song_length_ms);
4225e3d4d2bSMilanka Ringwald 
4235e3d4d2bSMilanka Ringwald             avrcp_target_now_playing_info(avrcp_cid);
4245e3d4d2bSMilanka Ringwald             break;
42501dc6e35SMilanka Ringwald         case AVRCP_SUBEVENT_CONNECTION_RELEASED:
4261e1ae2bcSMilanka Ringwald             printf("AVRCP: Channel released: avrcp_cid 0x%02x\n", avrcp_subevent_connection_released_get_avrcp_cid(packet));
42701dc6e35SMilanka Ringwald             avrcp_cid = 0;
42801dc6e35SMilanka Ringwald             return;
42901dc6e35SMilanka Ringwald         default:
4301e1ae2bcSMilanka Ringwald             printf("AVRCP: event not parsed %02x\n", packet[2]);
43101dc6e35SMilanka Ringwald             break;
43201dc6e35SMilanka Ringwald     }
43301dc6e35SMilanka Ringwald }
43401dc6e35SMilanka Ringwald 
43501dc6e35SMilanka Ringwald #ifdef HAVE_BTSTACK_STDIN
4363fb2c90bSMilanka Ringwald static void show_usage(void){
4373fb2c90bSMilanka Ringwald     bd_addr_t      iut_address;
4383fb2c90bSMilanka Ringwald     gap_local_bd_addr(iut_address);
43901dc6e35SMilanka Ringwald     printf("\n--- Bluetooth A2DP Source/AVRCP Target Demo %s ---\n", bd_addr_to_str(iut_address));
44001dc6e35SMilanka Ringwald     printf("b      - AVDTP Source create  connection to addr %s\n", device_addr_string);
44101dc6e35SMilanka Ringwald     printf("B      - AVDTP Source disconnect\n");
44201dc6e35SMilanka Ringwald     printf("c      - AVRCP Target create connection to addr %s\n", device_addr_string);
44301dc6e35SMilanka Ringwald     printf("C      - AVRCP Target disconnect\n");
44401dc6e35SMilanka Ringwald 
4453fb2c90bSMilanka Ringwald     printf("x      - start streaming sine\n");
4463fb2c90bSMilanka Ringwald     if (hxcmod_initialized){
4473fb2c90bSMilanka Ringwald         printf("z      - start streaming '%s'\n", mod_name);
4483fb2c90bSMilanka Ringwald     }
4493fb2c90bSMilanka Ringwald     printf("p      - pause streaming\n");
45001dc6e35SMilanka Ringwald 
45101dc6e35SMilanka Ringwald     printf("\n--- Bluetooth  AVRCP Target Commands %s ---\n", bd_addr_to_str(iut_address));
4523fb2c90bSMilanka Ringwald     printf("---\n");
4533fb2c90bSMilanka Ringwald }
4543fb2c90bSMilanka Ringwald 
4553fb2c90bSMilanka Ringwald static void stdin_process(char cmd){
4564567cc17SMilanka Ringwald     uint8_t status = ERROR_CODE_SUCCESS;
4573fb2c90bSMilanka Ringwald     switch (cmd){
45801dc6e35SMilanka Ringwald         case 'b':
45901dc6e35SMilanka Ringwald             printf(" - Create AVDTP Source connection to addr %s.\n", bd_addr_to_str(device_addr));
4604567cc17SMilanka Ringwald             status = a2dp_source_establish_stream(device_addr, media_tracker.local_seid, &media_tracker.a2dp_cid);
4613fb2c90bSMilanka Ringwald             break;
46201dc6e35SMilanka Ringwald         case 'B':
46301dc6e35SMilanka Ringwald             printf(" - AVDTP Source Disconnect\n");
4644567cc17SMilanka Ringwald             status = a2dp_source_disconnect(media_tracker.a2dp_cid);
46501dc6e35SMilanka Ringwald             break;
46601dc6e35SMilanka Ringwald         case 'c':
46701dc6e35SMilanka Ringwald             printf(" - Create AVRCP Target connection to addr %s.\n", bd_addr_to_str(device_addr));
4684567cc17SMilanka Ringwald             status = avrcp_target_connect(device_addr, &avrcp_cid);
46901dc6e35SMilanka Ringwald             break;
47001dc6e35SMilanka Ringwald         case 'C':
47101dc6e35SMilanka Ringwald             printf(" - AVRCP Target disconnect\n");
4724567cc17SMilanka Ringwald             status = avrcp_target_disconnect(avrcp_cid);
47301dc6e35SMilanka Ringwald             break;
47401dc6e35SMilanka Ringwald 
47501dc6e35SMilanka Ringwald         case '\n':
47601dc6e35SMilanka Ringwald         case '\r':
47701dc6e35SMilanka Ringwald             break;
47801dc6e35SMilanka Ringwald 
4793fb2c90bSMilanka Ringwald         case 'x':
4803fb2c90bSMilanka Ringwald             printf("Playing sine.\n");
4813fb2c90bSMilanka Ringwald             data_source = STREAM_SINE;
4824567cc17SMilanka Ringwald             status = a2dp_source_start_stream(media_tracker.a2dp_cid, media_tracker.local_seid);
4833fb2c90bSMilanka Ringwald             break;
4843fb2c90bSMilanka Ringwald         case 'z':
4853fb2c90bSMilanka Ringwald             printf("Playing mod.\n");
4863fb2c90bSMilanka Ringwald             data_source = STREAM_MOD;
4874567cc17SMilanka Ringwald             status = a2dp_source_start_stream(media_tracker.a2dp_cid, media_tracker.local_seid);
4883fb2c90bSMilanka Ringwald             break;
4893fb2c90bSMilanka Ringwald         case 'p':
4903fb2c90bSMilanka Ringwald             printf("Pause stream.\n");
4914567cc17SMilanka Ringwald             status = a2dp_source_pause_stream(media_tracker.a2dp_cid, media_tracker.local_seid);
4923fb2c90bSMilanka Ringwald             break;
49301dc6e35SMilanka Ringwald 
4943fb2c90bSMilanka Ringwald         default:
4953fb2c90bSMilanka Ringwald             show_usage();
4964567cc17SMilanka Ringwald             return;
4974567cc17SMilanka Ringwald     }
4984567cc17SMilanka Ringwald     if (status != ERROR_CODE_SUCCESS){
4994567cc17SMilanka Ringwald         printf("Could not perform command, status 0x%2x\n", status);
5003fb2c90bSMilanka Ringwald     }
5013fb2c90bSMilanka Ringwald }
5023fb2c90bSMilanka Ringwald #endif
5033fb2c90bSMilanka Ringwald 
5043fb2c90bSMilanka Ringwald 
5053fb2c90bSMilanka Ringwald int btstack_main(int argc, const char * argv[]);
5063fb2c90bSMilanka Ringwald int btstack_main(int argc, const char * argv[]){
5073fb2c90bSMilanka Ringwald     UNUSED(argc);
5083fb2c90bSMilanka Ringwald     (void)argv;
5093fb2c90bSMilanka Ringwald 
5103fb2c90bSMilanka Ringwald     l2cap_init();
5113fb2c90bSMilanka Ringwald     // Initialize AVDTP Source
5123fb2c90bSMilanka Ringwald     a2dp_source_init();
5133fb2c90bSMilanka Ringwald     a2dp_source_register_packet_handler(&packet_handler);
5143fb2c90bSMilanka Ringwald 
5154567cc17SMilanka Ringwald     avdtp_stream_endpoint_t * local_stream_endpoint = a2dp_source_create_stream_endpoint(AVDTP_AUDIO, AVDTP_CODEC_SBC, media_sbc_codec_capabilities, sizeof(media_sbc_codec_capabilities), media_sbc_codec_configuration, sizeof(media_sbc_codec_configuration));
5164567cc17SMilanka Ringwald     if (!local_stream_endpoint){
5174567cc17SMilanka Ringwald         printf("A2DP source demo: not enough memory to create local stream endpoint\n");
5184567cc17SMilanka Ringwald         return 1;
5194567cc17SMilanka Ringwald     }
5204567cc17SMilanka Ringwald     media_tracker.local_seid = avdtp_local_seid(local_stream_endpoint);
5213fb2c90bSMilanka Ringwald 
52201dc6e35SMilanka Ringwald     // Initialize AVRCP Target
52301dc6e35SMilanka Ringwald     avrcp_target_init();
52401dc6e35SMilanka Ringwald     avrcp_target_register_packet_handler(&avrcp_target_packet_handler);
52501dc6e35SMilanka Ringwald 
5263fb2c90bSMilanka Ringwald     // Initialize SDP
5273fb2c90bSMilanka Ringwald     sdp_init();
52867673f1cSMilanka Ringwald     memset(sdp_a2dp_source_service_buffer, 0, sizeof(sdp_a2dp_source_service_buffer));
52967673f1cSMilanka Ringwald     a2dp_source_create_sdp_record(sdp_a2dp_source_service_buffer, 0x10002, 1, NULL, NULL);
53067673f1cSMilanka Ringwald     sdp_register_service(sdp_a2dp_source_service_buffer);
5313fb2c90bSMilanka Ringwald 
5323fb2c90bSMilanka Ringwald     gap_set_local_name(device_name);
5333fb2c90bSMilanka Ringwald     gap_discoverable_control(1);
5343fb2c90bSMilanka Ringwald     gap_set_class_of_device(0x200408);
5353fb2c90bSMilanka Ringwald 
5363fb2c90bSMilanka Ringwald     hxcmod_initialized = hxcmod_init(&mod_context);
5373fb2c90bSMilanka Ringwald     if (hxcmod_initialized){
5383fb2c90bSMilanka Ringwald         hxcmod_setcfg(&mod_context, A2DP_SAMPLE_RATE, 16, 1, 1, 1);
5393fb2c90bSMilanka Ringwald         hxcmod_load(&mod_context, (void *) &mod_data, mod_len);
5403fb2c90bSMilanka Ringwald         printf("loaded mod '%s', size %u\n", mod_name, mod_len);
5413fb2c90bSMilanka Ringwald     }
5423fb2c90bSMilanka Ringwald 
5435e3d4d2bSMilanka Ringwald     // For PTS test
5445e3d4d2bSMilanka Ringwald     memcpy(now_playing_info.title,  "Title  1", 8);
5455e3d4d2bSMilanka Ringwald     memcpy(now_playing_info.artist, "Artist 1", 8);
5465e3d4d2bSMilanka Ringwald     memcpy(now_playing_info.album,  "Album  1", 8);
5475e3d4d2bSMilanka Ringwald     memcpy(now_playing_info.genre,  "Genre  1", 8);
5485e3d4d2bSMilanka Ringwald     now_playing_info.track_nr = 1;
5495e3d4d2bSMilanka Ringwald     now_playing_info.total_tracks = 10;
5505e3d4d2bSMilanka Ringwald     now_playing_info.song_length_ms = 3655;
5515e3d4d2bSMilanka Ringwald 
5523fb2c90bSMilanka Ringwald #ifdef HAVE_BTSTACK_STDIN
55367673f1cSMilanka Ringwald     // parse human readable Bluetooth address
55467673f1cSMilanka Ringwald     sscanf_bd_addr(device_addr_string, device_addr);
5553fb2c90bSMilanka Ringwald     btstack_stdin_setup(stdin_process);
5563fb2c90bSMilanka Ringwald #endif
55767673f1cSMilanka Ringwald     // turn on!
55867673f1cSMilanka Ringwald     hci_power_control(HCI_POWER_ON);
5593fb2c90bSMilanka Ringwald     return 0;
5603fb2c90bSMilanka Ringwald }
561