Mirror/squeezelite-esp32
1
0
Fork 0
mirror of https://github.com/sle118/squeezelite-esp32.git synced 2026-01-27 12:50:49 +03:00
Code Issues Packages Projects Releases Wiki Activity

Stabilize sync on A2DP

Browse Source
This commit is contained in:
Sebastien Leclerc
2019-06-22 08:54:17 -04:00
parent 7572c06800
commit a55bac4306
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
components/platform_esp32/platform_esp32.c
View File

@@ -295,6 +295,9 @@ static int32_t bt_app_a2d_data_cb(uint8_t *data, int32_t len)
SET_MIN_MAX(len,req); SET_MIN_MAX(len,req);
TIME_MEASUREMENT_START(start_timer); TIME_MEASUREMENT_START(start_timer);
LOCK; LOCK;
output.device_frames = 0; // todo: check if this is the right way do to this.
output.updated = gettime_ms();
output.frames_played_dmp = output.frames_played;
SET_MIN_MAX_SIZED(_buf_used(outputbuf),bt,outputbuf->size); SET_MIN_MAX_SIZED(_buf_used(outputbuf),bt,outputbuf->size);
do { do {
avail_data = _output_frames( wanted_len/BYTES_PER_FRAME )*BYTES_PER_FRAME; // Keep the transfer buffer full avail_data = _output_frames( wanted_len/BYTES_PER_FRAME )*BYTES_PER_FRAME; // Keep the transfer buffer full
@@ -304,9 +307,7 @@ static int32_t bt_app_a2d_data_cb(uint8_t *data, int32_t len)
{ {
SET_MIN_MAX(wanted_len, under); SET_MIN_MAX(wanted_len, under);
} }
output.device_frames = 0; // todo: check if this is the right way do to this.
output.updated = gettime_ms();
output.frames_played_dmp = output.frames_played;
UNLOCK; UNLOCK;
SET_MIN_MAX(TIME_MEASUREMENT_GET(start_timer),lock_out_time); SET_MIN_MAX(TIME_MEASUREMENT_GET(start_timer),lock_out_time);
SET_MIN_MAX((len-wanted_len), rec); SET_MIN_MAX((len-wanted_len), rec);

7
main/output_dac.c
View File

@@ -291,6 +291,9 @@ static void *output_thread_dac() {
continue; continue;
} }
LOG_SDEBUG("Current buffer free: %10d, cont read: %10d",_buf_space(dacbuffer),_buf_cont_read(dacbuffer)); LOG_SDEBUG("Current buffer free: %10d, cont read: %10d",_buf_space(dacbuffer),_buf_cont_read(dacbuffer));
output.device_frames =0;
output.updated = gettime_ms();
output.frames_played_dmp = output.frames_played;
do{ do{
// fill our buffer // fill our buffer
@@ -313,7 +316,6 @@ static void *output_thread_dac() {
SET_MIN_MAX_SIZED(_buf_used(dacbuffer),loci2sbuf,dacbuffer->size); SET_MIN_MAX_SIZED(_buf_used(dacbuffer),loci2sbuf,dacbuffer->size);
bytes_to_send_i2s = _buf_cont_read(dacbuffer); bytes_to_send_i2s = _buf_cont_read(dacbuffer);
SET_MIN_MAX(bytes_to_send_i2s,i2savailable); SET_MIN_MAX(bytes_to_send_i2s,i2savailable);
int pass=0;
i2s_total_bytes_written=0; i2s_total_bytes_written=0;
while (bytes_to_send_i2s>0 ) while (bytes_to_send_i2s>0 )
@@ -353,9 +355,6 @@ static void *output_thread_dac() {
SET_MIN_MAX(bytes_to_send_i2s,i2savailable); SET_MIN_MAX(bytes_to_send_i2s,i2savailable);
} }
output.device_frames =0;
output.updated = gettime_ms();
output.frames_played_dmp = output.frames_played;
/* /*