retronetworking
/
freeswitch
13
0
Fork 0
Code Pull Requests Releases Activity

FS-5011 add sync up flags so neither file writes data until audio is moving both ways

This commit is contained in:
Anthony Minessale 2013-03-28 10:41:28 -05:00
parent 3b6ae8966d
commit e6ef517354
1 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/switch_ivr_async.c
View File

@ -1090,6 +1090,8 @@ struct record_helper {
switch_file_handle_t in_fh;
switch_file_handle_t out_fh;
int native;
int rready;
int wready;
uint32_t packet_len;
int min_sec;
switch_bool_t hangup_on_error;
@ -1115,16 +1117,24 @@ static switch_bool_t record_callback(switch_media_bug_t *bug, void *user_data, s
break;
case SWITCH_ABC_TYPE_TAP_NATIVE_READ:
{
nframe = switch_core_media_bug_get_native_read_frame(bug);
len = nframe->datalen;
switch_core_file_write(&rh->in_fh, nframe->data, &len);
rh->rready = 1;
if (rh->rready && rh->wready) {
nframe = switch_core_media_bug_get_native_read_frame(bug);
len = nframe->datalen;
switch_core_file_write(&rh->in_fh, nframe->data, &len);
}
}
break;
case SWITCH_ABC_TYPE_TAP_NATIVE_WRITE:
{
nframe = switch_core_media_bug_get_native_write_frame(bug);
len = nframe->datalen;
switch_core_file_write(&rh->out_fh, nframe->data, &len);
rh->wready = 1;
if (rh->rready && rh->wready) {
nframe = switch_core_media_bug_get_native_write_frame(bug);
len = nframe->datalen;
switch_core_file_write(&rh->out_fh, nframe->data, &len);
}
}
break;
case SWITCH_ABC_TYPE_CLOSE: