FS-6757 FS-6713 #comment please try latest master that has a new patch in it to address this issue

src/include/private/switch_core_pvt.h

@@ -179,6 +179,9 @@ struct switch_core_session {
 
 	switch_media_handle_t *media_handle;
 	uint32_t decoder_errors;
+    switch_time_t last_read_time;
+	switch_time_t last_write_time;
+
 };
 
 struct switch_media_bug {

src/switch_core_io.c

@@ -762,8 +762,23 @@ SWITCH_DECLARE(switch_status_t) switch_core_session_read_frame(switch_core_sessi
 			switch_media_bug_t *bp;
 			switch_bool_t ok = SWITCH_TRUE;
 			int prune = 0;
+			switch_time_t now = switch_micro_time_now();
+			switch_time_t diff = 0;
+			switch_size_t len = session->read_impl.decoded_bytes_per_packet;
+			unsigned char fill_data[SWITCH_RECOMMENDED_BUFFER_SIZE] = {0};
+
 			switch_thread_rwlock_rdlock(session->bug_rwlock);
 
+			if (session->last_read_time && session->last_read_time < now) {
+				diff = ((now - session->last_read_time) + 3000 ) / session->read_impl.microseconds_per_packet;
+				
+				if (diff > 1) {
+					memset(fill_data, 255, len);
+				}
+			}
+			
+			session->last_read_time = switch_micro_time_now();
+
 			for (bp = session->bugs; bp; bp = bp->next) {
 				ok = SWITCH_TRUE;
 				
@@ -786,6 +801,17 @@ SWITCH_DECLARE(switch_status_t) switch_core_session_read_frame(switch_core_sessi
 
 				if (ok && bp->ready && switch_test_flag(bp, SMBF_READ_STREAM)) {
 					switch_mutex_lock(bp->read_mutex);
+
+					if (diff > 1) {
+						switch_time_t tdiff = diff;
+
+						while(tdiff > 1) {
+							switch_buffer_write(bp->raw_read_buffer, fill_data, len);
+							tdiff--;
+						}
+
+					}
+					
 					if (bp->read_demux_frame) {
 						uint8_t data[SWITCH_RECOMMENDED_BUFFER_SIZE];
 						int bytes = read_frame->datalen / 2;
@@ -1341,8 +1367,23 @@ SWITCH_DECLARE(switch_status_t) switch_core_session_write_frame(switch_core_sess
 	if (session->bugs) {
 		switch_media_bug_t *bp;
 		int prune = 0;
+		switch_time_t now = switch_micro_time_now();
+		switch_time_t diff = 0;
+		switch_size_t len = session->read_impl.decoded_bytes_per_packet;
+		unsigned char fill_data[SWITCH_RECOMMENDED_BUFFER_SIZE] = {0};
 		
 		switch_thread_rwlock_rdlock(session->bug_rwlock);
+
+		if (session->last_write_time && session->last_write_time < now) {
+			diff = ((now - session->last_write_time) + 3000 ) / session->read_impl.microseconds_per_packet;
+				
+			if (diff > 1) {
+				memset(fill_data, 255, len);
+			}
+		}
+
+		session->last_write_time = switch_micro_time_now();
+
 		for (bp = session->bugs; bp; bp = bp->next) {
 			switch_bool_t ok = SWITCH_TRUE;
 
@@ -1365,6 +1406,15 @@ SWITCH_DECLARE(switch_status_t) switch_core_session_write_frame(switch_core_sess
 
 			if (switch_test_flag(bp, SMBF_WRITE_STREAM)) {
 				switch_mutex_lock(bp->write_mutex);
+				if (diff > 1) {
+					switch_time_t tdiff = diff;
+					
+					while(tdiff > 1) {
+						switch_buffer_write(bp->raw_read_buffer, fill_data, len);
+						tdiff--;
+					}
+				}
+				
 				switch_buffer_write(bp->raw_write_buffer, write_frame->data, write_frame->datalen);
 				switch_mutex_unlock(bp->write_mutex);
 				

src/switch_ivr_async.c

@@ -1268,7 +1268,7 @@ static switch_bool_t record_callback(switch_media_bug_t *bug, void *user_data, s
 			frame.data = data;
 			frame.buflen = SWITCH_RECOMMENDED_BUFFER_SIZE;
 
-			for (;;) {
+
 			status = switch_core_media_bug_read(bug, &frame, SWITCH_FALSE);
 
 			if (status == SWITCH_STATUS_SUCCESS || status == SWITCH_STATUS_BREAK) {
@@ -1307,9 +1307,6 @@ static switch_bool_t record_callback(switch_media_bug_t *bug, void *user_data, s
 						}
 					}
 				}
-				} else {
-					break;
-				}
 			}
 		}
 		break;