codec improvement

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@114 d0543943-73ff-0310-b7d9-9358b9ac24b2

src/mod/mod_codec_g729/mod_codec_g729.c

@@ -84,11 +84,26 @@ static switch_status switch_g729_encode(switch_codec *codec,
 	if (!context) {
 		return SWITCH_STATUS_FALSE;
 	}
-
-	g729_coder(&context->encoder_object, (short *) decoded_data,  encoded_data, &cbret);
-	
-	*encoded_data_len = codec->implementation->encoded_bytes_per_frame;
-
+	if (decoded_data_len % 160 == 0) {
+		unsigned int new_len = 0;
+		INT16 *ddp = decoded_data;
+		char *edp = encoded_data;
+		int x;
+		int loops = (int) decoded_data_len / 160;
+		
+		for(x = 0; x < loops && new_len < *encoded_data_len; x++) {
+			g729_coder(&context->encoder_object, ddp, edp, &cbret);
+			edp += 10;
+			ddp += 80;
+			new_len += 10;
+		}
+		if( new_len <= *encoded_data_len ) {
+			*encoded_data_len = new_len;
+		} else {
+			switch_console_printf(SWITCH_CHANNEL_CONSOLE, "buffer overflow!!! %u >= %u\n", new_len, *encoded_data_len);
+			return SWITCH_STATUS_FALSE;			
+		}
+	}
 	return SWITCH_STATUS_SUCCESS;
 }
 
@@ -102,21 +117,35 @@ static switch_status switch_g729_decode(switch_codec *codec,
 								   unsigned int *flag) 
 {
 	struct g729_context *context = codec->private;
-	short *dbuf;
-	unsigned char *ebuf;
-
+	
 	if (!context) {
 		return SWITCH_STATUS_FALSE;
 	}
 
-	if (*flag & SWITCH_CODEC_FLAG_SILENCE) {
-		memset(dbuf, 0, codec->implementation->bytes_per_frame);
-		*decoded_data_len = codec->implementation->bytes_per_frame;
-	} else {
-		g729_decoder(&context->decoder_object, decoded_data, encoded_data, encoded_data_len);
-		*decoded_data_len = codec->implementation->bytes_per_frame;
-	}
 
+	if (encoded_data_len % 10 == 0) {
+		int loops = (int) encoded_data_len / 10;
+		char *edp = encoded_data;
+		short *ddp = decoded_data;
+		int x;
+		unsigned int new_len = 0;
+		for(x = 0; x < loops && new_len < *decoded_data_len; x++) {
+			g729_decoder(&context->decoder_object, ddp, edp, 10);
+			ddp += 80;
+			edp += 10;
+			new_len += 160;
+		}
+		if (new_len <= *decoded_data_len) {
+			*decoded_data_len = new_len;
+		} else {
+			switch_console_printf(SWITCH_CHANNEL_CONSOLE, "buffer overflow!!!\n");
+			return SWITCH_STATUS_FALSE;
+		}
+	} else {
+		switch_console_printf(SWITCH_CHANNEL_CONSOLE, "yo this frame is an odd size [%d]\n", encoded_data_len);
+	}
+	
+	
 	return SWITCH_STATUS_SUCCESS;
 }
 
@@ -130,7 +159,7 @@ static const switch_codec_implementation g729_8k_implementation = {
 	/*.bytes_per_frame*/				320,
 	/*.encoded_bytes_per_frame*/		20,
 	/*.number_of_channels*/				1,
-	/*.pref_frames_per_packet*/			6,
+	/*.pref_frames_per_packet*/			1,
 	/*.max_frames_per_packet*/			24,
 	/*.init*/							switch_g729_init,
 	/*.encode*/							switch_g729_encode,

src/mod/mod_exosip/mod_exosip.c

@@ -225,6 +225,7 @@ static switch_status exosip_on_init(switch_core_session *session)
 	assert(tech_pvt != NULL);
 
 	tech_pvt->read_frame.data = tech_pvt->read_buf;
+	tech_pvt->read_frame.buflen = sizeof(tech_pvt->read_buf);
 
 	switch_console_printf(SWITCH_CHANNEL_CONSOLE, "EXOSIP INIT\n");
 

src/mod/mod_iaxchan/mod_iaxchan.c

@@ -354,7 +354,7 @@ static switch_status channel_on_init(switch_core_session *session)
 	assert(channel != NULL);
 
 	tech_pvt->read_frame.data = tech_pvt->databuf;
-
+	tech_pvt->read_frame.buflen = sizeof(tech_pvt->databuf);
 	iax_set_private(tech_pvt->iax_session, tech_pvt);
 
 	switch_set_flag(tech_pvt, TFLAG_IO);
@@ -631,7 +631,6 @@ static switch_status channel_write_frame(switch_core_session *session, switch_fr
 	if (switch_test_flag(tech_pvt, TFLAG_LINEAR)) {
 		switch_swap_linear(frame->data, (int)frame->datalen / 2);
 	}
-	
 	iax_send_voice(tech_pvt->iax_session, tech_pvt->codec, frame->data, (int)frame->datalen, tech_pvt->write_codec.implementation->samples_per_frame);
 
 	return SWITCH_STATUS_SUCCESS;

src/mod/mod_playback/mod_playback.c

@@ -58,7 +58,7 @@ void playback_function(switch_core_session *session, char *data)
 	switch_channel_answer(channel);
 
 	write_frame.data = buf;
-
+	write_frame.buflen = sizeof(buf);
 
 	if (switch_file_open(&fd, data, SWITCH_FOPEN_READ, SWITCH_FPROT_UREAD, switch_core_session_get_pool(session)) != SWITCH_STATUS_SUCCESS) {
 		switch_console_printf(SWITCH_CHANNEL_CONSOLE, "OPEN FILE FAILED\n");

src/mod/mod_portaudio/mod_portaudio.c

@@ -129,6 +129,7 @@ static switch_status channel_on_init(switch_core_session *session)
 	assert(channel != NULL);
 
 	tech_pvt->read_frame.data = tech_pvt->databuf;
+	tech_pvt->read_frame.buflen = sizeof(tech_pvt->databuf);
 
 	switch_set_flag(tech_pvt, TFLAG_IO);
 	
@@ -361,6 +362,7 @@ static switch_status channel_write_frame(switch_core_session *session, switch_fr
 	}
 */
 	
+
 	WriteAudioStream(tech_pvt->audio_out, (short *)frame->data, (int)(frame->datalen / sizeof(SAMPLE)));
 	//XXX send voice