btstack_audio_embedded: implement audio sink interface

This commit is contained in:
Matthias Ringwald 2019-02-22 22:16:46 +01:00
parent 3d3351f352
commit 0402264ca0
2 changed files with 74 additions and 48 deletions

View File

@ -57,10 +57,11 @@
// client // client
static void (*playback_callback)(int16_t * buffer, uint16_t num_samples); static void (*playback_callback)(int16_t * buffer, uint16_t num_samples);
static void (*recording_callback)(const int16_t * buffer, uint16_t num_samples); // static void (*recording_callback)(const int16_t * buffer, uint16_t num_samples);
// timer to fill output ring buffer // timer to fill output ring buffer
static btstack_timer_source_t driver_timer; static btstack_timer_source_t driver_timer_sink;
// static btstack_timer_source_t driver_timer_source;
static volatile unsigned int output_buffer_to_play; static volatile unsigned int output_buffer_to_play;
static unsigned int output_buffer_to_fill; static unsigned int output_buffer_to_fill;
@ -71,15 +72,17 @@ static void btstack_audio_audio_played(uint8_t buffer_index){
output_buffer_to_play = (buffer_index + 1) % output_buffer_count; output_buffer_to_play = (buffer_index + 1) % output_buffer_count;
} }
#if 0
static void btstack_audio_audio_recorded(const int16_t * samples, uint16_t num_samples){ static void btstack_audio_audio_recorded(const int16_t * samples, uint16_t num_samples){
UNUSED(samples); UNUSED(samples);
UNUSED(num_samples); UNUSED(num_samples);
} }
#endif
static void driver_timer_handler(btstack_timer_source_t * ts){ static void driver_timer_handler_sink(btstack_timer_source_t * ts){
// playback buffer ready to fill // playback buffer ready to fill
if (playback_callback && output_buffer_to_play != output_buffer_to_fill){ if (output_buffer_to_play != output_buffer_to_fill){
// fill buffer // fill buffer
int16_t * buffer = hal_audio_get_output_buffer(output_buffer_to_fill); int16_t * buffer = hal_audio_get_output_buffer(output_buffer_to_fill);
(*playback_callback)(buffer, output_buffer_samples); (*playback_callback)(buffer, output_buffer_samples);
@ -88,81 +91,104 @@ static void driver_timer_handler(btstack_timer_source_t * ts){
output_buffer_to_fill = (output_buffer_to_fill + 1 ) % output_buffer_count; output_buffer_to_fill = (output_buffer_to_fill + 1 ) % output_buffer_count;
} }
// recording buffer ready to process
if (recording_callback){
}
// re-set timer // re-set timer
btstack_run_loop_set_timer(ts, DRIVER_POLL_INTERVAL_MS); btstack_run_loop_set_timer(ts, DRIVER_POLL_INTERVAL_MS);
btstack_run_loop_add_timer(ts); btstack_run_loop_add_timer(ts);
} }
static int btstack_audio_embedded_init( #if 0
static void driver_timer_handler_source(btstack_timer_source_t * ts){
// TODO
}
#endif
static int btstack_audio_embedded_sink_init(
uint8_t channels, uint8_t channels,
uint32_t samplerate, uint32_t samplerate,
void (*playback)(int16_t * buffer, uint16_t num_samples), void (*playback)(int16_t * buffer, uint16_t num_samples)
void (*recording)(const int16_t * buffer, uint16_t num_samples)
){ ){
playback_callback = playback; if (!playback){
recording_callback = recording; log_error("No playback callback");
return 1;
}
void (*buffer_played_callback) (uint8_t buffer_index) = NULL; playback_callback = playback;
void (*buffer_recorded_callback)(const int16_t * buffer, uint16_t num_samples) = NULL;
if (playback) { // TODO: split HAL Audio API as well
buffer_played_callback = &btstack_audio_audio_played; hal_audio_init(channels, samplerate, &btstack_audio_audio_played, NULL);
}
if (recording) {
buffer_recorded_callback = &btstack_audio_audio_recorded;
}
hal_audio_init(channels, samplerate, buffer_played_callback, buffer_recorded_callback);
return 0; return 0;
} }
static void btstack_audio_embedded_start_stream(void){ static int btstack_audio_embedded_source_init(
uint8_t channels,
uint32_t samplerate,
void (*recording)(const int16_t * buffer, uint16_t num_samples)
){
if (!recording){
log_error("No recording callback");
return 1;
}
return 0;
}
if (playback_callback){ static void btstack_audio_embedded_sink_start_stream(void){
output_buffer_count = hal_audio_get_num_output_buffers();
output_buffer_samples = hal_audio_get_num_output_buffer_samples();
// pre-fill HAL buffers output_buffer_count = hal_audio_get_num_output_buffers();
uint16_t i; output_buffer_samples = hal_audio_get_num_output_buffer_samples();
for (i=0;i<output_buffer_count;i++){
int16_t * buffer = hal_audio_get_output_buffer(i);
(*playback_callback)(buffer, output_buffer_samples);
}
output_buffer_to_play = 0; // pre-fill HAL buffers
output_buffer_to_fill = 0; uint16_t i;
for (i=0;i<output_buffer_count;i++){
int16_t * buffer = hal_audio_get_output_buffer(i);
(*playback_callback)(buffer, output_buffer_samples);
} }
// TODO: setup input output_buffer_to_play = 0;
output_buffer_to_fill = 0;
// start playback // start playback
hal_audio_start(); hal_audio_start();
// start timer // start timer
btstack_run_loop_set_timer_handler(&driver_timer, &driver_timer_handler); btstack_run_loop_set_timer_handler(&driver_timer_sink, &driver_timer_handler_sink);
btstack_run_loop_set_timer(&driver_timer, DRIVER_POLL_INTERVAL_MS); btstack_run_loop_set_timer(&driver_timer_sink, DRIVER_POLL_INTERVAL_MS);
btstack_run_loop_add_timer(&driver_timer); btstack_run_loop_add_timer(&driver_timer_sink);
} }
static void btstack_audio_embedded_close(void){ static void btstack_audio_embedded_source_start_stream(void){
// TODO
}
static void btstack_audio_embedded_sink_close(void){
// stop timer // stop timer
btstack_run_loop_remove_timer(&driver_timer); btstack_run_loop_remove_timer(&driver_timer_sink);
// close HAL // close HAL
hal_audio_close(); hal_audio_close();
} }
static const btstack_audio_t btstack_audio_embedded = { static void btstack_audio_embedded_source_close(void){
/* int (*init)(..);*/ &btstack_audio_embedded_init, // TODO
/* void (*start_stream(void));*/ &btstack_audio_embedded_start_stream, }
/* void (*close)(void); */ &btstack_audio_embedded_close
static const btstack_audio_sink_t btstack_audio_embedded_sink = {
/* int (*init)(..);*/ &btstack_audio_embedded_sink_init,
/* void (*start_stream(void));*/ &btstack_audio_embedded_sink_start_stream,
/* void (*close)(void); */ &btstack_audio_embedded_sink_close
}; };
const btstack_audio_t * btstack_audio_embedded_get_instance(void){ static const btstack_audio_source_t btstack_audio_embedded_source = {
return &btstack_audio_embedded; /* int (*init)(..);*/ &btstack_audio_embedded_source_init,
/* void (*start_stream(void));*/ &btstack_audio_embedded_source_start_stream,
/* void (*close)(void); */ &btstack_audio_embedded_source_close
};
const btstack_audio_sink_t * btstack_audio_embedded_sink_get_instance(void){
return &btstack_audio_embedded_sink;
}
const btstack_audio_source_t * btstack_audio_embedded_source_get_instance(void){
return &btstack_audio_embedded_source;
} }
#endif #endif

View File

@ -346,7 +346,7 @@ void port_main(void){
#ifdef HAVE_HAL_AUDIO #ifdef HAVE_HAL_AUDIO
// setup audio // setup audio
btstack_audio_set_instance(btstack_audio_embedded_get_instance()); btstack_audio_sink_set_instance(btstack_audio_embedded_sink_get_instance());
#endif #endif
// inform about BTstack state // inform about BTstack state