xref: /btstack/example/a2dp_source_demo.c (revision cfd54eb73cd29e7bf738f261fb454a84a1bb66b0)
1 /*
2  * Copyright (C) 2016 BlueKitchen GmbH
3  *
4  * Redistribution and use in source and binary forms, with or without
5  * modification, are permitted provided that the following conditions
6  * are met:
7  *
8  * 1. Redistributions of source code must retain the above copyright
9  *    notice, this list of conditions and the following disclaimer.
10  * 2. Redistributions in binary form must reproduce the above copyright
11  *    notice, this list of conditions and the following disclaimer in the
12  *    documentation and/or other materials provided with the distribution.
13  * 3. Neither the name of the copyright holders nor the names of
14  *    contributors may be used to endorse or promote products derived
15  *    from this software without specific prior written permission.
16  * 4. Any redistribution, use, or modification is done solely for
17  *    personal benefit and not for any commercial purpose or for
18  *    monetary gain.
19  *
20  * THIS SOFTWARE IS PROVIDED BY BLUEKITCHEN GMBH AND CONTRIBUTORS
21  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
22  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
23  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MATTHIAS
24  * RINGWALD OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
25  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
26  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
27  * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
28  * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
29  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
30  * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31  * SUCH DAMAGE.
32  *
33  * Please inquire about commercial licensing options at
34  * [email protected]
35  *
36  */
37 
38 #define BTSTACK_FILE__ "a2dp_source_demo.c"
39 
40 /*
41  * a2dp_source_demo.c
42  */
43 
44 // *****************************************************************************
45 /* EXAMPLE_START(a2dp_source_demo): Serve audio stream and handle remote playback control and queries.
46  *
47  * @text This A2DP Source example demonstrates how to send an audio data stream
48  * to a remote A2DP Sink device and how to switch between two audio data sources.
49  * In addition, the AVRCP Target is used to answer queries on currently played media,
50  * as well as to handle remote playback control, i.e. play, stop, repeat, etc. If HAVE_BTSTACK_STDIN
51  * is set, press SPACE on the console to show the available AVDTP and AVRCP commands.
52  *
53  * @text To test with a remote device, e.g. a Bluetooth speaker,
54  * set the device_addr_string to the Bluetooth address of your
55  * remote device in the code, and use the UI to connect and start playback.
56  *
57  * @text For more info on BTstack audio, see our blog post
58  * [A2DP Sink and Source on STM32 F4 Discovery Board](http://bluekitchen-gmbh.com/a2dp-sink-and-source-on-stm32-f4-discovery-board/).
59  *
60  */
61 // *****************************************************************************
62 
63 
64 #include <stdint.h>
65 #include <stdio.h>
66 #include <stdlib.h>
67 #include <string.h>
68 
69 #include "btstack.h"
70 #include "hxcmod.h"
71 #include "mods/mod.h"
72 
73 // logarithmic volume reduction, samples are divided by 2^x
74 // #define VOLUME_REDUCTION 3
75 // #undef  HAVE_BTSTACK_STDIN
76 
77 //#define AVRCP_BROWSING_ENABLED
78 
79 #define NUM_CHANNELS                2
80 #define BYTES_PER_AUDIO_SAMPLE      (2*NUM_CHANNELS)
81 #define AUDIO_TIMEOUT_MS            10
82 #define TABLE_SIZE_441HZ            100
83 
84 #define SBC_STORAGE_SIZE 1030
85 
86 typedef enum {
87     STREAM_SINE = 0,
88     STREAM_MOD,
89     STREAM_PTS_TEST
90 } stream_data_source_t;
91 
92 typedef struct {
93     uint16_t a2dp_cid;
94     uint8_t  local_seid;
95     uint8_t  remote_seid;
96     uint8_t  stream_opened;
97     uint16_t avrcp_cid;
98 
99     uint32_t time_audio_data_sent; // ms
100     uint32_t acc_num_missed_samples;
101     uint32_t samples_ready;
102     btstack_timer_source_t audio_timer;
103     uint8_t  streaming;
104     int      max_media_payload_size;
105 
106     uint8_t  sbc_storage[SBC_STORAGE_SIZE];
107     uint16_t sbc_storage_count;
108     uint8_t  sbc_ready_to_send;
109 
110     uint16_t volume;
111 } a2dp_media_sending_context_t;
112 
113 static  uint8_t media_sbc_codec_capabilities[] = {
114     (AVDTP_SBC_44100 << 4) | AVDTP_SBC_STEREO,
115     0xFF,//(AVDTP_SBC_BLOCK_LENGTH_16 << 4) | (AVDTP_SBC_SUBBANDS_8 << 2) | AVDTP_SBC_ALLOCATION_METHOD_LOUDNESS,
116     2, 53
117 };
118 
119 // input signal: pre-computed int16 sine wave, 44100 Hz at 441 Hz
120 static const int16_t sine_int16_44100[] = {
121      0,    2057,    4107,    6140,    8149,   10126,   12062,   13952,   15786,   17557,
122  19260,   20886,   22431,   23886,   25247,   26509,   27666,   28714,   29648,   30466,
123  31163,   31738,   32187,   32509,   32702,   32767,   32702,   32509,   32187,   31738,
124  31163,   30466,   29648,   28714,   27666,   26509,   25247,   23886,   22431,   20886,
125  19260,   17557,   15786,   13952,   12062,   10126,    8149,    6140,    4107,    2057,
126      0,   -2057,   -4107,   -6140,   -8149,  -10126,  -12062,  -13952,  -15786,  -17557,
127 -19260,  -20886,  -22431,  -23886,  -25247,  -26509,  -27666,  -28714,  -29648,  -30466,
128 -31163,  -31738,  -32187,  -32509,  -32702,  -32767,  -32702,  -32509,  -32187,  -31738,
129 -31163,  -30466,  -29648,  -28714,  -27666,  -26509,  -25247,  -23886,  -22431,  -20886,
130 -19260,  -17557,  -15786,  -13952,  -12062,  -10126,   -8149,   -6140,   -4107,   -2057,
131 };
132 
133 static const int num_samples_sine_int16_44100 = sizeof(sine_int16_44100) / 2;
134 
135 // input signal: pre-computed int16 sine wave, 48000 Hz at 441 Hz
136 static const int16_t sine_int16_48000[] = {
137      0,    1905,    3804,    5690,    7557,    9398,   11207,   12978,   14706,   16383,
138  18006,   19567,   21062,   22486,   23834,   25101,   26283,   27376,   28377,   29282,
139  30087,   30791,   31390,   31884,   32269,   32545,   32712,   32767,   32712,   32545,
140  32269,   31884,   31390,   30791,   30087,   29282,   28377,   27376,   26283,   25101,
141  23834,   22486,   21062,   19567,   18006,   16383,   14706,   12978,   11207,    9398,
142   7557,    5690,    3804,    1905,       0,   -1905,   -3804,   -5690,   -7557,   -9398,
143 -11207,  -12978,  -14706,  -16384,  -18006,  -19567,  -21062,  -22486,  -23834,  -25101,
144 -26283,  -27376,  -28377,  -29282,  -30087,  -30791,  -31390,  -31884,  -32269,  -32545,
145 -32712,  -32767,  -32712,  -32545,  -32269,  -31884,  -31390,  -30791,  -30087,  -29282,
146 -28377,  -27376,  -26283,  -25101,  -23834,  -22486,  -21062,  -19567,  -18006,  -16384,
147 -14706,  -12978,  -11207,   -9398,   -7557,   -5690,   -3804,   -1905,  };
148 
149 static const int num_samples_sine_int16_48000 = sizeof(sine_int16_48000) / 2;
150 
151 typedef struct {
152     int reconfigure;
153     int num_channels;
154     int sampling_frequency;
155     int channel_mode;
156     int block_length;
157     int subbands;
158     int allocation_method;
159     int min_bitpool_value;
160     int max_bitpool_value;
161     int frames_per_buffer;
162 } avdtp_media_codec_configuration_sbc_t;
163 
164 static btstack_packet_callback_registration_t hci_event_callback_registration;
165 
166 // pts:             static const char * device_addr_string = "00:1B:DC:08:0A:A5";
167 // pts:             static const char * device_addr_string = "00:1B:DC:08:E2:72";
168 // mac 2013:        static const char * device_addr_string = "84:38:35:65:d1:15";
169 // phone 2013:      static const char * device_addr_string = "D8:BB:2C:DF:F0:F2";
170 // Minijambox:
171 static const char * device_addr_string = "00:21:3C:AC:F7:38";
172 // Philips SHB9100: static const char * device_addr_string = "00:22:37:05:FD:E8";
173 // RT-B6:           static const char * device_addr_string = "00:75:58:FF:C9:7D";
174 // BT dongle:       static const char * device_addr_string = "00:1A:7D:DA:71:0A";
175 // Sony MDR-ZX330BT static const char * device_addr_string = "00:18:09:28:50:18";
176 // Panda (BM6)      static const char * device_addr_string = "4F:3F:66:52:8B:E0";
177 // BeatsX:          static const char * device_addr_string = "DC:D3:A2:89:57:FB";
178 // Green mushroom:  static const char * device_addr_string = "41:42:2A:ED:D6:F3";
179 
180 static bd_addr_t device_addr;
181 
182 static uint8_t sdp_a2dp_source_service_buffer[150];
183 static uint8_t sdp_avrcp_target_service_buffer[200];
184 static uint8_t sdp_avrcp_controller_service_buffer[200];
185 
186 static avdtp_media_codec_configuration_sbc_t sbc_configuration;
187 static btstack_sbc_encoder_state_t sbc_encoder_state;
188 
189 static uint8_t media_sbc_codec_configuration[4];
190 static a2dp_media_sending_context_t media_tracker;
191 
192 static stream_data_source_t data_source;
193 
194 static int sine_phase;
195 static int current_sample_rate = 44100;
196 static int new_sample_rate = 44100;
197 
198 static int hxcmod_initialized;
199 static modcontext mod_context;
200 static tracker_buffer_state trkbuf;
201 
202 /* AVRCP Target context START */
203 static const uint8_t subunit_info[] = {
204     0,0,0,0,
205     1,1,1,1,
206     2,2,2,2,
207     3,3,3,3,
208     4,4,4,4,
209     5,5,5,5,
210     6,6,6,6,
211     7,7,7,7
212 };
213 
214 static uint32_t company_id = 0x112233;
215 static uint8_t  companies_num = 1;
216 static uint8_t  companies[] = {
217     0x00, 0x19, 0x58 //BT SIG registered CompanyID
218 };
219 
220 static uint8_t events_num = 6;
221 static uint8_t events[] = {
222     AVRCP_NOTIFICATION_EVENT_PLAYBACK_STATUS_CHANGED,
223     AVRCP_NOTIFICATION_EVENT_TRACK_CHANGED,
224     AVRCP_NOTIFICATION_EVENT_PLAYER_APPLICATION_SETTING_CHANGED,
225     AVRCP_NOTIFICATION_EVENT_NOW_PLAYING_CONTENT_CHANGED,
226     AVRCP_NOTIFICATION_EVENT_AVAILABLE_PLAYERS_CHANGED,
227     AVRCP_NOTIFICATION_EVENT_ADDRESSED_PLAYER_CHANGED
228 };
229 
230 typedef struct {
231     uint8_t track_id[8];
232     uint32_t song_length_ms;
233     avrcp_playback_status_t status;
234     uint32_t song_position_ms; // 0xFFFFFFFF if not supported
235 } avrcp_play_status_info_t;
236 
237 // python -c "print('a'*512)"
238 static const char title[] = "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa";
239 
240 avrcp_track_t tracks[] = {
241     {{0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01}, 1, "Sine", "Generated", "A2DP Source Demo", "monotone", 12345},
242     {{0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02}, 2, "Nao-deceased", "Decease", "A2DP Source Demo", "vivid", 12345},
243     {{0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x03}, 3, (char *)title, "Decease", "A2DP Source Demo", "vivid", 12345},
244 };
245 int current_track_index;
246 avrcp_play_status_info_t play_info;
247 
248 /* AVRCP Target context END */
249 
250 /* @section Main Application Setup
251  *
252  * @text The Listing MainConfiguration shows how to setup AD2P Source and AVRCP services.
253  * Besides calling init() method for each service, you'll also need to register several packet handlers:
254  * - hci_packet_handler - handles legacy pairing, here by using fixed '0000' pin code.
255  * - a2dp_source_packet_handler - handles events on stream connection status (established, released), the media codec configuration, and, the commands on stream itself (open, pause, stopp).
256  * - avrcp_packet_handler - receives connect/disconnect event.
257  * - avrcp_controller_packet_handler - receives answers for sent AVRCP commands.
258  * - avrcp_target_packet_handler - receives AVRCP commands, and registered notifications.
259  * - stdin_process - used to trigger AVRCP commands to the A2DP Source device, such are get now playing info, start, stop, volume control. Requires HAVE_BTSTACK_STDIN.
260  *
261  * @text To announce A2DP Source and AVRCP services, you need to create corresponding
262  * SDP records and register them with the SDP service.
263  */
264 
265 /* LISTING_START(MainConfiguration): Setup Audio Source and AVRCP Target services */
266 static void hci_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size);
267 static void a2dp_source_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t * event, uint16_t event_size);
268 static void avrcp_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size);
269 static void avrcp_target_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size);
270 static void avrcp_controller_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size);
271 #ifdef HAVE_BTSTACK_STDIN
272 static void stdin_process(char cmd);
273 #endif
274 
275 static void a2dp_demo_hexcmod_configure_sample_rate(int sample_rate);
276 
277 static int a2dp_source_and_avrcp_services_init(void){
278     // request role change on reconnecting headset to always use them in slave mode
279     hci_set_master_slave_policy(0);
280 
281     l2cap_init();
282     // Initialize  A2DP Source.
283     a2dp_source_init();
284     a2dp_source_register_packet_handler(&a2dp_source_packet_handler);
285 
286     // Create stream endpoint.
287     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));
288     if (!local_stream_endpoint){
289         printf("A2DP Source: not enough memory to create local stream endpoint\n");
290         return 1;
291     }
292     media_tracker.local_seid = avdtp_local_seid(local_stream_endpoint);
293     avdtp_source_register_delay_reporting_category(media_tracker.local_seid);
294 
295     // Initialize AVRCP Service.
296     avrcp_init();
297     avrcp_register_packet_handler(&avrcp_packet_handler);
298     // Initialize AVRCP Target.
299     avrcp_target_init();
300     avrcp_target_register_packet_handler(&avrcp_target_packet_handler);
301     // Initialize AVRCP Controller
302     avrcp_controller_init();
303     avrcp_controller_register_packet_handler(&avrcp_controller_packet_handler);
304 
305     // Initialize SDP,
306     sdp_init();
307 
308     // Create  A2DP Source service record and register it with SDP.
309     memset(sdp_a2dp_source_service_buffer, 0, sizeof(sdp_a2dp_source_service_buffer));
310     a2dp_source_create_sdp_record(sdp_a2dp_source_service_buffer, 0x10001, AVDTP_SOURCE_FEATURE_MASK_PLAYER, NULL, NULL);
311     sdp_register_service(sdp_a2dp_source_service_buffer);
312 
313     // Create AVRCP target service record and register it with SDP.
314     memset(sdp_avrcp_target_service_buffer, 0, sizeof(sdp_avrcp_target_service_buffer));
315     uint16_t supported_features = AVRCP_FEATURE_MASK_CATEGORY_PLAYER_OR_RECORDER;
316 #ifdef AVRCP_BROWSING_ENABLED
317     supported_features |= AVRCP_FEATURE_MASK_BROWSING;
318 #endif
319     avrcp_target_create_sdp_record(sdp_avrcp_target_service_buffer, 0x10002, supported_features, NULL, NULL);
320     sdp_register_service(sdp_avrcp_target_service_buffer);
321 
322     // setup AVRCP Controller
323     memset(sdp_avrcp_controller_service_buffer, 0, sizeof(sdp_avrcp_controller_service_buffer));
324     uint16_t controller_supported_features = AVRCP_FEATURE_MASK_CATEGORY_PLAYER_OR_RECORDER;
325     avrcp_controller_create_sdp_record(sdp_avrcp_controller_service_buffer, 0x10003, controller_supported_features, NULL, NULL);
326     sdp_register_service(sdp_avrcp_controller_service_buffer);
327 
328     // Set local name with a template Bluetooth address, that will be automatically
329     // replaced with a actual address once it is available, i.e. when BTstack boots
330     // up and starts talking to a Bluetooth module.
331     gap_set_local_name("A2DP Source 00:00:00:00:00:00");
332     gap_discoverable_control(1);
333     gap_set_class_of_device(0x200408);
334 
335     // Register for HCI events.
336     hci_event_callback_registration.callback = &hci_packet_handler;
337     hci_add_event_handler(&hci_event_callback_registration);
338 
339     a2dp_demo_hexcmod_configure_sample_rate(current_sample_rate);
340 
341 #ifdef HAVE_BTSTACK_STDIN
342     // Parse human readable Bluetooth address.
343     sscanf_bd_addr(device_addr_string, device_addr);
344     btstack_stdin_setup(stdin_process);
345 #endif
346     return 0;
347 }
348 /* LISTING_END */
349 
350 static void a2dp_demo_hexcmod_configure_sample_rate(int sample_rate){
351     if (!hxcmod_initialized){
352         hxcmod_initialized = hxcmod_init(&mod_context);
353         if (!hxcmod_initialized) {
354             printf("could not initialize hxcmod\n");
355             return;
356         }
357     }
358     current_sample_rate = sample_rate;
359     media_tracker.sbc_storage_count = 0;
360     media_tracker.samples_ready = 0;
361     hxcmod_unload(&mod_context);
362     hxcmod_setcfg(&mod_context, current_sample_rate, 16, 1, 1, 1);
363     hxcmod_load(&mod_context, (void *) &mod_data, mod_len);
364 }
365 
366 static void a2dp_demo_send_media_packet(void){
367     int num_bytes_in_frame = btstack_sbc_encoder_sbc_buffer_length();
368     int bytes_in_storage = media_tracker.sbc_storage_count;
369     uint8_t num_frames = bytes_in_storage / num_bytes_in_frame;
370     a2dp_source_stream_send_media_payload(media_tracker.a2dp_cid, media_tracker.local_seid, media_tracker.sbc_storage, bytes_in_storage, num_frames, 0);
371     media_tracker.sbc_storage_count = 0;
372     media_tracker.sbc_ready_to_send = 0;
373 }
374 
375 static void produce_sine_audio(int16_t * pcm_buffer, int num_samples_to_write){
376     int count;
377     for (count = 0; count < num_samples_to_write ; count++){
378         switch (current_sample_rate){
379             case 44100:
380                 pcm_buffer[count * 2]     = sine_int16_44100[sine_phase];
381                 pcm_buffer[count * 2 + 1] = sine_int16_44100[sine_phase];
382                 sine_phase++;
383                 if (sine_phase >= num_samples_sine_int16_44100){
384                     sine_phase -= num_samples_sine_int16_44100;
385                 }
386                 break;
387             case 48000:
388                 pcm_buffer[count * 2]     = sine_int16_48000[sine_phase];
389                 pcm_buffer[count * 2 + 1] = sine_int16_48000[sine_phase];
390                 sine_phase++;
391                 if (sine_phase >= num_samples_sine_int16_48000){
392                     sine_phase -= num_samples_sine_int16_48000;
393                 }
394                 break;
395             default:
396                 break;
397         }
398 
399 
400     }
401 }
402 
403 static void produce_mod_audio(int16_t * pcm_buffer, int num_samples_to_write){
404     hxcmod_fillbuffer(&mod_context, (unsigned short *) &pcm_buffer[0], num_samples_to_write, &trkbuf);
405 }
406 
407 static void produce_audio(int16_t * pcm_buffer, int num_samples){
408     switch (data_source){
409         case STREAM_SINE:
410             produce_sine_audio(pcm_buffer, num_samples);
411             break;
412         case STREAM_MOD:
413             produce_mod_audio(pcm_buffer, num_samples);
414             break;
415         default:
416             break;
417     }
418 #ifdef VOLUME_REDUCTION
419     int i;
420     for (i=0;i<num_samples*2;i++){
421         if (pcm_buffer[i] > 0){
422             pcm_buffer[i] =     pcm_buffer[i]  >> VOLUME_REDUCTION;
423         } else {
424             pcm_buffer[i] = -((-pcm_buffer[i]) >> VOLUME_REDUCTION);
425         }
426     }
427 #endif
428 }
429 
430 static int a2dp_demo_fill_sbc_audio_buffer(a2dp_media_sending_context_t * context){
431     // perform sbc encodin
432     int total_num_bytes_read = 0;
433     unsigned int num_audio_samples_per_sbc_buffer = btstack_sbc_encoder_num_audio_frames();
434     while (context->samples_ready >= num_audio_samples_per_sbc_buffer
435         && (context->max_media_payload_size - context->sbc_storage_count) >= btstack_sbc_encoder_sbc_buffer_length()){
436 
437         int16_t pcm_frame[256*NUM_CHANNELS];
438 
439         produce_audio(pcm_frame, num_audio_samples_per_sbc_buffer);
440         btstack_sbc_encoder_process_data(pcm_frame);
441 
442         uint16_t sbc_frame_size = btstack_sbc_encoder_sbc_buffer_length();
443         uint8_t * sbc_frame = btstack_sbc_encoder_sbc_buffer();
444 
445         total_num_bytes_read += num_audio_samples_per_sbc_buffer;
446         memcpy(&context->sbc_storage[context->sbc_storage_count], sbc_frame, sbc_frame_size);
447         context->sbc_storage_count += sbc_frame_size;
448         context->samples_ready -= num_audio_samples_per_sbc_buffer;
449     }
450     return total_num_bytes_read;
451 }
452 
453 static void a2dp_demo_audio_timeout_handler(btstack_timer_source_t * timer){
454     a2dp_media_sending_context_t * context = (a2dp_media_sending_context_t *) btstack_run_loop_get_timer_context(timer);
455     btstack_run_loop_set_timer(&context->audio_timer, AUDIO_TIMEOUT_MS);
456     btstack_run_loop_add_timer(&context->audio_timer);
457     uint32_t now = btstack_run_loop_get_time_ms();
458 
459     uint32_t update_period_ms = AUDIO_TIMEOUT_MS;
460     if (context->time_audio_data_sent > 0){
461         update_period_ms = now - context->time_audio_data_sent;
462     }
463 
464     uint32_t num_samples = (update_period_ms * current_sample_rate) / 1000;
465     context->acc_num_missed_samples += (update_period_ms * current_sample_rate) % 1000;
466 
467     while (context->acc_num_missed_samples >= 1000){
468         num_samples++;
469         context->acc_num_missed_samples -= 1000;
470     }
471     context->time_audio_data_sent = now;
472     context->samples_ready += num_samples;
473 
474     if (context->sbc_ready_to_send) return;
475 
476     a2dp_demo_fill_sbc_audio_buffer(context);
477 
478     if ((context->sbc_storage_count + btstack_sbc_encoder_sbc_buffer_length()) > context->max_media_payload_size){
479         // schedule sending
480         context->sbc_ready_to_send = 1;
481         a2dp_source_stream_endpoint_request_can_send_now(context->a2dp_cid, context->local_seid);
482     }
483 }
484 
485 static void a2dp_demo_timer_start(a2dp_media_sending_context_t * context){
486     context->max_media_payload_size = btstack_min(a2dp_max_media_payload_size(context->a2dp_cid, context->local_seid), SBC_STORAGE_SIZE);
487     context->sbc_storage_count = 0;
488     context->sbc_ready_to_send = 0;
489     context->streaming = 1;
490     btstack_run_loop_remove_timer(&context->audio_timer);
491     btstack_run_loop_set_timer_handler(&context->audio_timer, a2dp_demo_audio_timeout_handler);
492     btstack_run_loop_set_timer_context(&context->audio_timer, context);
493     btstack_run_loop_set_timer(&context->audio_timer, AUDIO_TIMEOUT_MS);
494     btstack_run_loop_add_timer(&context->audio_timer);
495 }
496 
497 static void a2dp_demo_timer_stop(a2dp_media_sending_context_t * context){
498     context->time_audio_data_sent = 0;
499     context->acc_num_missed_samples = 0;
500     context->samples_ready = 0;
501     context->streaming = 1;
502     context->sbc_storage_count = 0;
503     context->sbc_ready_to_send = 0;
504     btstack_run_loop_remove_timer(&context->audio_timer);
505 }
506 
507 static void dump_sbc_configuration(avdtp_media_codec_configuration_sbc_t * configuration){
508     printf("Received media codec configuration:\n");
509     printf("    - num_channels: %d\n", configuration->num_channels);
510     printf("    - sampling_frequency: %d\n", configuration->sampling_frequency);
511     printf("    - channel_mode: %d\n", configuration->channel_mode);
512     printf("    - block_length: %d\n", configuration->block_length);
513     printf("    - subbands: %d\n", configuration->subbands);
514     printf("    - allocation_method: %d\n", configuration->allocation_method);
515     printf("    - bitpool_value [%d, %d] \n", configuration->min_bitpool_value, configuration->max_bitpool_value);
516 }
517 
518 static void hci_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){
519     UNUSED(channel);
520     UNUSED(size);
521     if (packet_type != HCI_EVENT_PACKET) return;
522 
523 #ifndef HAVE_BTSTACK_STDIN
524     if (hci_event_packet_get_type(packet) == BTSTACK_EVENT_STATE){
525         if (btstack_event_state_get_state(packet) != HCI_STATE_WORKING) return;
526         printf("Create A2DP Source connection to addr %s.\n", bd_addr_to_str(device_addr));
527         uint8_t status = a2dp_source_establish_stream(device_addr, media_tracker.local_seid, &media_tracker.a2dp_cid);
528         if (status != ERROR_CODE_SUCCESS){
529             printf("Could not perform command, status 0x%2x\n", status);
530         }
531         return;
532     }
533 #endif
534 
535     if (hci_event_packet_get_type(packet) == HCI_EVENT_PIN_CODE_REQUEST) {
536         bd_addr_t address;
537         printf("Pin code request - using '0000'\n");
538         hci_event_pin_code_request_get_bd_addr(packet, address);
539         gap_pin_code_response(address, "0000");
540     }
541 }
542 
543 static void a2dp_source_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){
544     UNUSED(channel);
545     UNUSED(size);
546     uint8_t status;
547     uint8_t local_seid;
548     bd_addr_t address;
549     uint16_t cid;
550 
551     if (packet_type != HCI_EVENT_PACKET) return;
552     if (hci_event_packet_get_type(packet) != HCI_EVENT_A2DP_META) return;
553 
554     switch (hci_event_a2dp_meta_get_subevent_code(packet)){
555         case A2DP_SUBEVENT_SIGNALING_CONNECTION_ESTABLISHED:
556             a2dp_subevent_signaling_connection_established_get_bd_addr(packet, address);
557             cid = a2dp_subevent_signaling_connection_established_get_a2dp_cid(packet);
558             status = a2dp_subevent_signaling_connection_established_get_status(packet);
559 
560             if (status != ERROR_CODE_SUCCESS){
561                 printf("A2DP Source: Connection failed, status 0x%02x, cid 0x%02x, a2dp_cid 0x%02x \n", status, cid, media_tracker.a2dp_cid);
562                 media_tracker.a2dp_cid = 0;
563                 break;
564             }
565             media_tracker.a2dp_cid = cid;
566             media_tracker.volume = 32;
567 
568             printf("A2DP Source: Connected to address %s, a2dp cid 0x%02x, local seid 0x%02x.\n", bd_addr_to_str(address), media_tracker.a2dp_cid, media_tracker.local_seid);
569             break;
570 
571          case A2DP_SUBEVENT_SIGNALING_MEDIA_CODEC_SBC_CONFIGURATION:{
572             cid  = avdtp_subevent_signaling_media_codec_sbc_configuration_get_avdtp_cid(packet);
573             if (cid != media_tracker.a2dp_cid) return;
574 
575             media_tracker.remote_seid = a2dp_subevent_signaling_media_codec_sbc_configuration_get_acp_seid(packet);
576 
577             sbc_configuration.reconfigure = a2dp_subevent_signaling_media_codec_sbc_configuration_get_reconfigure(packet);
578             sbc_configuration.num_channels = a2dp_subevent_signaling_media_codec_sbc_configuration_get_num_channels(packet);
579             sbc_configuration.sampling_frequency = a2dp_subevent_signaling_media_codec_sbc_configuration_get_sampling_frequency(packet);
580             sbc_configuration.channel_mode = a2dp_subevent_signaling_media_codec_sbc_configuration_get_channel_mode(packet);
581             sbc_configuration.block_length = a2dp_subevent_signaling_media_codec_sbc_configuration_get_block_length(packet);
582             sbc_configuration.subbands = a2dp_subevent_signaling_media_codec_sbc_configuration_get_subbands(packet);
583             sbc_configuration.allocation_method = a2dp_subevent_signaling_media_codec_sbc_configuration_get_allocation_method(packet);
584             sbc_configuration.min_bitpool_value = a2dp_subevent_signaling_media_codec_sbc_configuration_get_min_bitpool_value(packet);
585             sbc_configuration.max_bitpool_value = a2dp_subevent_signaling_media_codec_sbc_configuration_get_max_bitpool_value(packet);
586             sbc_configuration.frames_per_buffer = sbc_configuration.subbands * sbc_configuration.block_length;
587             printf("A2DP Source: Received SBC codec configuration, sampling frequency %u, a2dp_cid 0x%02x, local seid 0x%02x, remote seid 0x%02x.\n",
588                 sbc_configuration.sampling_frequency, cid,
589                 a2dp_subevent_signaling_media_codec_sbc_configuration_get_int_seid(packet),
590                 a2dp_subevent_signaling_media_codec_sbc_configuration_get_acp_seid(packet));
591 
592             // Adapt Bluetooth spec definition to SBC Encoder expected input
593             sbc_configuration.allocation_method -= 1;
594             sbc_configuration.num_channels = 2;
595             switch (sbc_configuration.channel_mode){
596                 case AVDTP_SBC_JOINT_STEREO:
597                     sbc_configuration.channel_mode = 3;
598                     break;
599                 case AVDTP_SBC_STEREO:
600                     sbc_configuration.channel_mode = 2;
601                     break;
602                 case AVDTP_SBC_DUAL_CHANNEL:
603                     sbc_configuration.channel_mode = 1;
604                     break;
605                 case AVDTP_SBC_MONO:
606                     sbc_configuration.channel_mode = 0;
607                     sbc_configuration.num_channels = 1;
608                     break;
609             }
610             dump_sbc_configuration(&sbc_configuration);
611 
612             btstack_sbc_encoder_init(&sbc_encoder_state, SBC_MODE_STANDARD,
613                 sbc_configuration.block_length, sbc_configuration.subbands,
614                 sbc_configuration.allocation_method, sbc_configuration.sampling_frequency,
615                 sbc_configuration.max_bitpool_value,
616                 sbc_configuration.channel_mode);
617             break;
618         }
619 
620         case A2DP_SUBEVENT_SIGNALING_DELAY_REPORTING_CAPABILITY:
621             printf("A2DP Source: remote supports delay report, remote seid %d\n",
622                 avdtp_subevent_signaling_delay_reporting_capability_get_remote_seid(packet));
623             break;
624         case A2DP_SUBEVENT_SIGNALING_CAPABILITIES_DONE:
625             printf("A2DP Source: All capabilities reported, remote seid %d\n",
626                 avdtp_subevent_signaling_capabilities_done_get_remote_seid(packet));
627             break;
628 
629         case A2DP_SUBEVENT_SIGNALING_DELAY_REPORT:
630             printf("A2DP Source: Received delay report of %d.%0d ms, local seid %d\n",
631                 avdtp_subevent_signaling_delay_report_get_delay_100us(packet)/10, avdtp_subevent_signaling_delay_report_get_delay_100us(packet)%10,
632                 avdtp_subevent_signaling_delay_report_get_local_seid(packet));
633             break;
634 
635         case A2DP_SUBEVENT_STREAM_ESTABLISHED:
636             a2dp_subevent_stream_established_get_bd_addr(packet, address);
637             status = a2dp_subevent_stream_established_get_status(packet);
638             if (status){
639                 printf("A2DP Source: Stream failed, status 0x%02x.\n", status);
640                 break;
641             }
642 
643             local_seid = a2dp_subevent_stream_established_get_local_seid(packet);
644             cid = a2dp_subevent_stream_established_get_a2dp_cid(packet);
645 
646             printf("A2DP Source: Stream established a2dp_cid 0x%02x, local_seid 0x%02x, remote_seid 0x%02x\n", cid, local_seid, a2dp_subevent_stream_established_get_remote_seid(packet));
647 
648             a2dp_demo_hexcmod_configure_sample_rate(current_sample_rate);
649             media_tracker.stream_opened = 1;
650             data_source = STREAM_MOD;
651             status = a2dp_source_start_stream(media_tracker.a2dp_cid, media_tracker.local_seid);
652             break;
653 
654         case A2DP_SUBEVENT_STREAM_RECONFIGURED:
655             status = a2dp_subevent_stream_reconfigured_get_status(packet);
656             local_seid = a2dp_subevent_stream_reconfigured_get_local_seid(packet);
657             cid = a2dp_subevent_stream_reconfigured_get_a2dp_cid(packet);
658 
659             if (status != ERROR_CODE_SUCCESS){
660                 printf("A2DP Source: Stream reconfiguration failed with status 0x%02x\n", status);
661                 break;
662             }
663 
664             printf("A2DP Source: Stream reconfigured a2dp_cid 0x%02x, local_seid 0x%02x\n", cid, local_seid);
665             a2dp_demo_hexcmod_configure_sample_rate(new_sample_rate);
666             status = a2dp_source_start_stream(media_tracker.a2dp_cid, media_tracker.local_seid);
667             break;
668 
669         case A2DP_SUBEVENT_STREAM_STARTED:
670             local_seid = a2dp_subevent_stream_started_get_local_seid(packet);
671             cid = a2dp_subevent_stream_started_get_a2dp_cid(packet);
672 
673             play_info.status = AVRCP_PLAYBACK_STATUS_PLAYING;
674             if (media_tracker.avrcp_cid){
675                 avrcp_target_set_now_playing_info(media_tracker.avrcp_cid, &tracks[data_source], sizeof(tracks)/sizeof(avrcp_track_t));
676                 avrcp_target_set_playback_status(media_tracker.avrcp_cid, AVRCP_PLAYBACK_STATUS_PLAYING);
677             }
678             a2dp_demo_timer_start(&media_tracker);
679             printf("A2DP Source: Stream started, a2dp_cid 0x%02x, local_seid 0x%02x\n", cid, local_seid);
680             break;
681 
682         case A2DP_SUBEVENT_STREAMING_CAN_SEND_MEDIA_PACKET_NOW:
683             local_seid = a2dp_subevent_streaming_can_send_media_packet_now_get_local_seid(packet);
684             cid = a2dp_subevent_signaling_media_codec_sbc_configuration_get_a2dp_cid(packet);
685             a2dp_demo_send_media_packet();
686             break;
687 
688         case A2DP_SUBEVENT_STREAM_SUSPENDED:
689             local_seid = a2dp_subevent_stream_suspended_get_local_seid(packet);
690             cid = a2dp_subevent_stream_suspended_get_a2dp_cid(packet);
691 
692             play_info.status = AVRCP_PLAYBACK_STATUS_PAUSED;
693             if (media_tracker.avrcp_cid){
694                 avrcp_target_set_playback_status(media_tracker.avrcp_cid, AVRCP_PLAYBACK_STATUS_PAUSED);
695             }
696             printf("A2DP Source: Stream paused, a2dp_cid 0x%02x, local_seid 0x%02x\n", cid, local_seid);
697 
698             a2dp_demo_timer_stop(&media_tracker);
699             break;
700 
701         case A2DP_SUBEVENT_STREAM_RELEASED:
702             play_info.status = AVRCP_PLAYBACK_STATUS_STOPPED;
703             cid = a2dp_subevent_stream_released_get_a2dp_cid(packet);
704             local_seid = a2dp_subevent_stream_released_get_local_seid(packet);
705 
706             printf("A2DP Source: Stream released, a2dp_cid 0x%02x, local_seid 0x%02x\n", cid, local_seid);
707 
708             if (cid == media_tracker.a2dp_cid) {
709                 media_tracker.stream_opened = 0;
710                 printf("A2DP Source: Stream released.\n");
711             }
712             if (media_tracker.avrcp_cid){
713                 avrcp_target_set_now_playing_info(media_tracker.avrcp_cid, NULL, sizeof(tracks)/sizeof(avrcp_track_t));
714                 avrcp_target_set_playback_status(media_tracker.avrcp_cid, AVRCP_PLAYBACK_STATUS_STOPPED);
715             }
716             a2dp_demo_timer_stop(&media_tracker);
717             break;
718         case A2DP_SUBEVENT_SIGNALING_CONNECTION_RELEASED:
719             cid = a2dp_subevent_signaling_connection_released_get_a2dp_cid(packet);
720             if (cid == media_tracker.a2dp_cid) {
721                 media_tracker.avrcp_cid = 0;
722                 media_tracker.a2dp_cid = 0;
723                 printf("A2DP Source: Signaling released.\n\n");
724             }
725             break;
726         default:
727             break;
728     }
729 }
730 
731 static void avrcp_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){
732     UNUSED(channel);
733     UNUSED(size);
734     bd_addr_t event_addr;
735     uint16_t local_cid;
736     uint8_t  status = ERROR_CODE_SUCCESS;
737 
738     if (packet_type != HCI_EVENT_PACKET) return;
739     if (hci_event_packet_get_type(packet) != HCI_EVENT_AVRCP_META) return;
740 
741     switch (packet[2]){
742         case AVRCP_SUBEVENT_CONNECTION_ESTABLISHED:
743             local_cid = avrcp_subevent_connection_established_get_avrcp_cid(packet);
744             status = avrcp_subevent_connection_established_get_status(packet);
745             if (status != ERROR_CODE_SUCCESS){
746                 printf("AVRCP: Connection failed, local cid 0x%02x, status 0x%02x\n", local_cid, status);
747                 return;
748             }
749             media_tracker.avrcp_cid = local_cid;
750             avrcp_subevent_connection_established_get_bd_addr(packet, event_addr);
751 
752             avrcp_target_set_now_playing_info(media_tracker.avrcp_cid, NULL, sizeof(tracks)/sizeof(avrcp_track_t));
753             avrcp_target_set_unit_info(media_tracker.avrcp_cid, AVRCP_SUBUNIT_TYPE_AUDIO, company_id);
754             avrcp_target_set_subunit_info(media_tracker.avrcp_cid, AVRCP_SUBUNIT_TYPE_AUDIO, (uint8_t *)subunit_info, sizeof(subunit_info));
755 
756             avrcp_controller_get_supported_events(media_tracker.avrcp_cid);
757 
758             printf("AVRCP: Channel successfully opened:  media_tracker.avrcp_cid 0x%02x\n", media_tracker.avrcp_cid);
759             return;
760 
761         case AVRCP_SUBEVENT_CONNECTION_RELEASED:
762             printf("AVRCP Target: Disconnected, avrcp_cid 0x%02x\n", avrcp_subevent_connection_released_get_avrcp_cid(packet));
763             media_tracker.avrcp_cid = 0;
764             return;
765         default:
766             break;
767     }
768 
769     if (status != ERROR_CODE_SUCCESS){
770         printf("Responding to event 0x%02x failed with status 0x%02x\n", packet[2], status);
771     }
772 }
773 
774 static void avrcp_target_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){
775     UNUSED(channel);
776     UNUSED(size);
777     uint8_t  status = ERROR_CODE_SUCCESS;
778 
779     if (packet_type != HCI_EVENT_PACKET) return;
780     if (hci_event_packet_get_type(packet) != HCI_EVENT_AVRCP_META) return;
781 
782     switch (packet[2]){
783         case AVRCP_SUBEVENT_NOTIFICATION_VOLUME_CHANGED:
784             media_tracker.volume = avrcp_subevent_notification_volume_changed_get_absolute_volume(packet);
785             printf("AVRCP Target: Volume set to %d%% (%d)\n", media_tracker.volume * 127/100, media_tracker.volume);
786             break;
787         case AVRCP_SUBEVENT_EVENT_IDS_QUERY:
788             status = avrcp_target_supported_events(media_tracker.avrcp_cid, events_num, events, sizeof(events));
789             break;
790         case AVRCP_SUBEVENT_COMPANY_IDS_QUERY:
791             status = avrcp_target_supported_companies(media_tracker.avrcp_cid, companies_num, companies, sizeof(companies));
792             break;
793         case AVRCP_SUBEVENT_PLAY_STATUS_QUERY:
794             status = avrcp_target_play_status(media_tracker.avrcp_cid, play_info.song_length_ms, play_info.song_position_ms, play_info.status);
795             break;
796         // case AVRCP_SUBEVENT_NOW_PLAYING_INFO_QUERY:
797         //     status = avrcp_target_now_playing_info(avrcp_cid);
798         //     break;
799         case AVRCP_SUBEVENT_OPERATION:{
800             avrcp_operation_id_t operation_id = avrcp_subevent_operation_get_operation_id(packet);
801             switch (operation_id){
802                 case AVRCP_OPERATION_ID_PLAY:
803                     printf("AVRCP Target: PLAY\n");
804                     status = a2dp_source_start_stream(media_tracker.a2dp_cid, media_tracker.local_seid);
805                     break;
806                 case AVRCP_OPERATION_ID_PAUSE:
807                     printf("AVRCP Target: PAUSE\n");
808                     status = a2dp_source_pause_stream(media_tracker.a2dp_cid, media_tracker.local_seid);
809                     break;
810                 case AVRCP_OPERATION_ID_STOP:
811                     printf("AVRCP Target: STOP\n");
812                     status = a2dp_source_disconnect(media_tracker.a2dp_cid);
813                     break;
814                 default:
815                     printf("AVRCP Target: operation 0x%2x is not handled\n", operation_id);
816                     return;
817             }
818             break;
819         }
820 
821         default:
822             break;
823     }
824 
825     if (status != ERROR_CODE_SUCCESS){
826         printf("Responding to event 0x%02x failed with status 0x%02x\n", packet[2], status);
827     }
828 }
829 
830 static void avrcp_controller_packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){
831     UNUSED(channel);
832     UNUSED(size);
833     uint8_t  status = 0xFF;
834 
835     if (packet_type != HCI_EVENT_PACKET) return;
836     if (hci_event_packet_get_type(packet) != HCI_EVENT_AVRCP_META) return;
837 
838     status = packet[5];
839     if (!media_tracker.avrcp_cid) return;
840 
841     // ignore INTERIM status
842     if (status == AVRCP_CTYPE_RESPONSE_INTERIM) return;
843 
844     switch (packet[2]){
845         case AVRCP_SUBEVENT_NOTIFICATION_VOLUME_CHANGED:
846             printf("AVRCP Controller: notification absolute volume changed %d %%\n", avrcp_subevent_notification_volume_changed_get_absolute_volume(packet) * 100 / 127);
847             break;
848         case AVRCP_SUBEVENT_GET_CAPABILITY_EVENT_ID:
849             printf("Remote supports EVENT_ID 0x%02x\n", avrcp_subevent_get_capability_event_id_get_event_id(packet));
850             break;
851         case AVRCP_SUBEVENT_GET_CAPABILITY_EVENT_ID_DONE:
852             printf("automatically enable notifications\n");
853             avrcp_controller_enable_notification(media_tracker.avrcp_cid, AVRCP_NOTIFICATION_EVENT_VOLUME_CHANGED);
854             break;
855         default:
856             break;
857     }
858 }
859 
860 #ifdef HAVE_BTSTACK_STDIN
861 static void show_usage(void){
862     bd_addr_t      iut_address;
863     gap_local_bd_addr(iut_address);
864     printf("\n--- Bluetooth  A2DP Source/AVRCP Demo %s ---\n", bd_addr_to_str(iut_address));
865     printf("b      - A2DP Source create connection to addr %s\n", device_addr_string);
866     printf("B      - A2DP Source disconnect\n");
867     printf("c      - AVRCP create connection to addr %s\n", device_addr_string);
868     printf("C      - AVRCP disconnect\n");
869 
870     printf("x      - start streaming sine\n");
871     if (hxcmod_initialized){
872         printf("z      - start streaming '%s'\n", mod_name);
873     }
874     printf("p      - pause streaming\n");
875     printf("w      - reconfigure stream for 44100 Hz\n");
876     printf("e      - reconfigure stream for 48000 Hz\n");
877     printf("t      - volume up\n");
878     printf("T      - volume down\n");
879     printf("v      - volume up (via set absolute volume)\n");
880     printf("V      - volume down (via set absolute volume)\n");
881 
882     printf("---\n");
883 }
884 
885 static void stdin_process(char cmd){
886     uint8_t status = ERROR_CODE_SUCCESS;
887     switch (cmd){
888         case 'b':
889             status = a2dp_source_establish_stream(device_addr, media_tracker.local_seid, &media_tracker.a2dp_cid);
890             printf("%c - Create A2DP Source connection to addr %s, cid 0x%02x.\n", cmd, bd_addr_to_str(device_addr), media_tracker.a2dp_cid);
891             break;
892         case 'B':
893             printf("%c - A2DP Source Disconnect from cid 0x%2x\n", cmd, media_tracker.a2dp_cid);
894             status = a2dp_source_disconnect(media_tracker.a2dp_cid);
895             break;
896         case 'c':
897             printf("%c - Create AVRCP connection to addr %s.\n", cmd, bd_addr_to_str(device_addr));
898             status = avrcp_connect(device_addr, &media_tracker.avrcp_cid);
899             break;
900         case 'C':
901             printf("%c - AVRCP disconnect\n", cmd);
902             status = avrcp_disconnect(media_tracker.avrcp_cid);
903             break;
904 
905         case '\n':
906         case '\r':
907             break;
908 
909         case 't':
910             printf(" - volume up\n");
911             status = avrcp_controller_volume_up(media_tracker.avrcp_cid);
912             break;
913         case 'T':
914             printf(" - volume down\n");
915             status = avrcp_controller_volume_down(media_tracker.avrcp_cid);
916             break;
917 
918         case 'v':
919             if (media_tracker.volume > 117){
920                 media_tracker.volume = 127;
921             } else {
922                 media_tracker.volume += 10;
923             }
924             printf(" - volume up (via set absolute volume) %d%% (%d)\n",  media_tracker.volume * 127/100,  media_tracker.volume);
925             status = avrcp_controller_set_absolute_volume(media_tracker.avrcp_cid, media_tracker.volume);
926             break;
927         case 'V':
928             if (media_tracker.volume < 10){
929                 media_tracker.volume = 0;
930             } else {
931                 media_tracker.volume -= 10;
932             }
933             printf(" - volume down (via set absolute volume) %d%% (%d)\n",  media_tracker.volume * 127/100,  media_tracker.volume);
934             status = avrcp_controller_set_absolute_volume(media_tracker.avrcp_cid, media_tracker.volume);
935             break;
936 
937         case 'x':
938             if (media_tracker.avrcp_cid){
939                 avrcp_target_set_now_playing_info(media_tracker.avrcp_cid, &tracks[data_source], sizeof(tracks)/sizeof(avrcp_track_t));
940             }
941             printf("%c - Play sine.\n", cmd);
942             data_source = STREAM_SINE;
943             if (!media_tracker.stream_opened) break;
944             status = a2dp_source_start_stream(media_tracker.a2dp_cid, media_tracker.local_seid);
945             break;
946         case 'z':
947             if (media_tracker.avrcp_cid){
948                 avrcp_target_set_now_playing_info(media_tracker.avrcp_cid, &tracks[data_source], sizeof(tracks)/sizeof(avrcp_track_t));
949             }
950             printf("%c - Play mod.\n", cmd);
951             data_source = STREAM_MOD;
952             if (!media_tracker.stream_opened) break;
953             status = a2dp_source_start_stream(media_tracker.a2dp_cid, media_tracker.local_seid);
954             break;
955 
956         case 'p':
957             if (!media_tracker.stream_opened) break;
958             printf("%c - Pause stream.\n", cmd);
959             status = a2dp_source_pause_stream(media_tracker.a2dp_cid, media_tracker.local_seid);
960             break;
961 
962         case 'w':
963             if (!media_tracker.stream_opened) break;
964             if (play_info.status == AVRCP_PLAYBACK_STATUS_PLAYING){
965                 printf("Stream cannot be reconfigured while playing, please pause stream first\n");
966                 break;
967             }
968             new_sample_rate = 44100;
969             if (current_sample_rate == new_sample_rate){
970                 printf("%c - Stream already configured for %d Hz.\n", cmd, new_sample_rate);
971             } else {
972                 printf("%c - Reconfigure for %d Hz.\n", cmd, new_sample_rate);
973                 status = a2dp_source_reconfigure_stream_sampling_frequency(media_tracker.a2dp_cid, new_sample_rate);
974             }
975             break;
976 
977         case 'e':
978             if (!media_tracker.stream_opened) break;
979             if (play_info.status == AVRCP_PLAYBACK_STATUS_PLAYING){
980                 printf("Stream cannot be reconfigured while playing, please pause stream first\n");
981                 break;
982             }
983             new_sample_rate = 48000;
984             if (current_sample_rate == new_sample_rate){
985                 printf("%c - Stream already configured for %d Hz.\n", cmd, new_sample_rate);
986             } else {
987                 printf("%c - Reconfigure for %d Hz.\n", cmd, new_sample_rate);
988                 status = a2dp_source_reconfigure_stream_sampling_frequency(media_tracker.a2dp_cid, new_sample_rate);
989             }
990             break;
991 
992         default:
993             show_usage();
994             return;
995     }
996     if (status != ERROR_CODE_SUCCESS){
997         printf("Could not perform command \'%c\', status 0x%02x\n", cmd, status);
998     }
999 }
1000 #endif
1001 
1002 
1003 int btstack_main(int argc, const char * argv[]);
1004 int btstack_main(int argc, const char * argv[]){
1005     (void)argc;
1006     (void)argv;
1007 
1008     int err = a2dp_source_and_avrcp_services_init();
1009     if (err) return err;
1010     // turn on!
1011     hci_power_control(HCI_POWER_ON);
1012     return 0;
1013 }
1014 /* EXAMPLE_END */
1015