--- a/src/org/sipdroid/media/RtpStreamReceiver.java Sat Jan 23 22:19:43 2010 +0100
+++ b/src/org/sipdroid/media/RtpStreamReceiver.java Sun Jan 24 00:42:29 2010 +0100
@@ -19,20 +19,18 @@
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
-package src.org.sipdroid.media;
+package org.sipdroid.media;
import java.io.IOException;
import java.net.SocketException;
-import org.sipdroid.sipua.UserAgent;
-import org.sipdroid.sipua.ui.Receiver;
-import org.sipdroid.sipua.ui.Sipdroid;
+import com.beem.project.beem.jingle.JingleService;
+import com.beem.project.beem.ui.Call;
+import org.sipdroid.net.RtpPacket;
+import org.sipdroid.net.RtpSocket;
+import org.sipdroid.net.SipdroidSocket;
import org.sipdroid.pjlib.Codec;
-import src.org.sipdroid.net.RtpPacket;
-import src.org.sipdroid.net.RtpSocket;
-import src.org.sipdroid.net.SipdroidSocket;
-
import android.content.ContentResolver;
import android.content.Context;
import android.content.SharedPreferences.Editor;
@@ -41,6 +39,7 @@
import android.media.AudioTrack;
import android.media.ToneGenerator;
import android.os.PowerManager;
+import android.os.RemoteException;
import android.preference.PreferenceManager;
import android.provider.Settings;
@@ -50,442 +49,426 @@
*/
public class RtpStreamReceiver extends Thread {
- /** Whether working in debug mode. */
- public static boolean DEBUG = true;
+ /** Whether working in debug mode. */
+ public static boolean DEBUG = true;
- /** Payload type */
- int p_type;
+ /** Payload type */
+ int p_type;
- /** Size of the read buffer */
- public static final int BUFFER_SIZE = 1024;
+ /** Size of the read buffer */
+ public static final int BUFFER_SIZE = 1024;
- /** Maximum blocking time, spent waiting for reading new bytes [milliseconds] */
- public static final int SO_TIMEOUT = 200;
+ /** Maximum blocking time, spent waiting for reading new bytes [milliseconds] */
+ public static final int SO_TIMEOUT = 200;
- /** The RtpSocket */
- RtpSocket rtp_socket = null;
+ /** The RtpSocket */
+ private RtpSocket rtp_socket = null;
- /** Whether it is running */
- boolean running;
- AudioManager am;
- ContentResolver cr;
- public static int speakermode;
-
- /**
- * Constructs a RtpStreamReceiver.
- *
- * @param output_stream
- * the stream sink
- * @param socket
- * the local receiver SipdroidSocket
- */
- public RtpStreamReceiver(SipdroidSocket socket, int payload_type) {
- init(socket);
- p_type = payload_type;
- }
+ /** Whether it is running */
+ private boolean running;
+ private AudioManager am;
+ private ContentResolver cr;
+ public static int speakermode;
+ private JingleService mJingle;
- /** Inits the RtpStreamReceiver */
- private void init(SipdroidSocket socket) {
- if (socket != null)
- rtp_socket = new RtpSocket(socket);
- }
+ /**
+ * Constructs a RtpStreamReceiver.
+ *
+ * @param output_stream
+ * the stream sink
+ * @param socket
+ * the local receiver SipdroidSocket
+ */
+ public RtpStreamReceiver(SipdroidSocket socket, int payload_type) {
+ init(socket);
+ p_type = payload_type;
+ }
+
+ /** Inits the RtpStreamReceiver */
+ private void init(SipdroidSocket socket) {
+ if (socket != null)
+ rtp_socket = new RtpSocket(socket);
+ }
- /** Whether is running */
- public boolean isRunning() {
- return running;
- }
+ /** Whether is running */
+ public boolean isRunning() {
+ return running;
+ }
+
+ /** Stops running */
+ public void halt() {
+ running = false;
+ }
- /** Stops running */
- public void halt() {
- running = false;
- }
-
- public int speaker(int mode) {
- int old = speakermode;
-
- if (Receiver.headset > 0 && mode == AudioManager.MODE_NORMAL)
- return old;
- saveVolume();
- setMode(speakermode = mode);
- restoreVolume();
- return old;
- }
+ public int speaker(int mode) {
+ int old = speakermode;
+
+ if (Call.headset > 0 && mode == AudioManager.MODE_NORMAL)
+ return old;
+ saveVolume();
+ setMode(speakermode = mode);
+ restoreVolume();
+ return old;
+ }
- double smin = 200,s;
- public static int nearend;
-
- void calc(short[] lin,int off,int len) {
- int i,j;
- double sm = 30000,r;
-
- for (i = 0; i < len; i += 5) {
- j = lin[i+off];
- s = 0.03*Math.abs(j) + 0.97*s;
- if (s < sm) sm = s;
- if (s > smin) nearend = 3000/5;
- else if (nearend > 0) nearend--;
- }
- for (i = 0; i < len; i++) {
- j = lin[i+off];
- if (j > 6550)
- lin[i+off] = 6550*5;
- else if (j < -6550)
- lin[i+off] = -6550*5;
- else
- lin[i+off] = (short)(j*5);
- }
- r = (double)len/100000;
- smin = sm*r + smin*(1-r);
+ double smin = 200,s;
+ public static int nearend;
+
+ void calc(short[] lin,int off,int len) {
+ int i,j;
+ double sm = 30000,r;
+
+ for (i = 0; i < len; i += 5) {
+ j = lin[i+off];
+ s = 0.03*Math.abs(j) + 0.97*s;
+ if (s < sm) sm = s;
+ if (s > smin) nearend = 3000/5;
+ else if (nearend > 0) nearend--;
+ }
+ for (i = 0; i < len; i++) {
+ j = lin[i+off];
+ if (j > 6550)
+ lin[i+off] = 6550*5;
+ else if (j < -6550)
+ lin[i+off] = -6550*5;
+ else
+ lin[i+off] = (short)(j*5);
}
-
- static void setStreamVolume(final int stream,final int vol,final int flags) {
- (new Thread() {
- public void run() {
- AudioManager am = (AudioManager) Receiver.mContext.getSystemService(Context.AUDIO_SERVICE);
- am.setStreamVolume(stream, vol, flags);
- if (stream == AudioManager.STREAM_MUSIC) restored = true;
- }
- }).start();
+ r = (double)len/100000;
+ smin = sm*r + smin*(1-r);
+ }
+
+ static void setStreamVolume(final int stream,final int vol,final int flags) {
+ (new Thread() {
+ public void run() {
+ AudioManager am = (AudioManager) Call.mContext.getSystemService(Context.AUDIO_SERVICE);
+ am.setStreamVolume(stream, vol, flags);
+ if (stream == AudioManager.STREAM_MUSIC) restored = true;
+ }
+ }).start();
+ }
+
+ static boolean restored;
+
+ public static float getEarGain() {
+ try {
+ return Float.valueOf(PreferenceManager.getDefaultSharedPreferences(Call.mContext).getString(Call.headset > 0?"heargain":"eargain", "0.25"));
+ } catch (NumberFormatException i) {
+ return (float)0.25;
+ }
+ }
+
+ void restoreVolume() {
+ switch (am.getMode()) {
+ case AudioManager.MODE_IN_CALL:
+ setStreamVolume(AudioManager.STREAM_RING,(int)(
+ am.getStreamMaxVolume(AudioManager.STREAM_RING)*
+ getEarGain()), 0);
+ track.setStereoVolume(AudioTrack.getMaxVolume()*
+ getEarGain()
+ ,AudioTrack.getMaxVolume()*
+ getEarGain());
+ break;
+ case AudioManager.MODE_NORMAL:
+ track.setStereoVolume(AudioTrack.getMaxVolume(),AudioTrack.getMaxVolume());
+ break;
}
-
- static boolean restored;
-
- void restoreVolume() {
- switch (am.getMode()) {
- case AudioManager.MODE_IN_CALL:
- setStreamVolume(AudioManager.STREAM_RING,(int)(
- am.getStreamMaxVolume(AudioManager.STREAM_RING)*
- org.sipdroid.sipua.ui.Settings.getEarGain()), 0);
- track.setStereoVolume(AudioTrack.getMaxVolume()*
- org.sipdroid.sipua.ui.Settings.getEarGain()
- ,AudioTrack.getMaxVolume()*
- org.sipdroid.sipua.ui.Settings.getEarGain());
- break;
- case AudioManager.MODE_NORMAL:
- track.setStereoVolume(AudioTrack.getMaxVolume(),AudioTrack.getMaxVolume());
- break;
- }
- setStreamVolume(AudioManager.STREAM_MUSIC,
- PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getInt("volume"+speakermode,
- am.getStreamMaxVolume(AudioManager.STREAM_MUSIC)*
- (speakermode == AudioManager.MODE_NORMAL?4:3)/4
- ),0);
- }
-
- void saveVolume() {
- if (restored) {
- Editor edit = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).edit();
- edit.putInt("volume"+speakermode,am.getStreamVolume(AudioManager.STREAM_MUSIC));
- edit.commit();
- }
+ setStreamVolume(AudioManager.STREAM_MUSIC,
+ PreferenceManager.getDefaultSharedPreferences(Call.mContext).getInt("volume"+speakermode,
+ am.getStreamMaxVolume(AudioManager.STREAM_MUSIC)*
+ (speakermode == AudioManager.MODE_NORMAL?4:3)/4
+ ),0);
+ }
+
+ void saveVolume() {
+ if (restored) {
+ Editor edit = PreferenceManager.getDefaultSharedPreferences(Call.mContext).edit();
+ edit.putInt("volume"+speakermode,am.getStreamVolume(AudioManager.STREAM_MUSIC));
+ edit.commit();
}
-
- void saveSettings() {
- if (!PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getBoolean("oldvalid",false)) {
- int oldvibrate = am.getVibrateSetting(AudioManager.VIBRATE_TYPE_RINGER);
- int oldvibrate2 = am.getVibrateSetting(AudioManager.VIBRATE_TYPE_NOTIFICATION);
- if (!PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).contains("oldvibrate2"))
- oldvibrate2 = AudioManager.VIBRATE_SETTING_ON;
- int oldpolicy = android.provider.Settings.System.getInt(cr, android.provider.Settings.System.WIFI_SLEEP_POLICY,
- Settings.System.WIFI_SLEEP_POLICY_DEFAULT);
- Editor edit = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).edit();
- edit.putInt("oldvibrate", oldvibrate);
- edit.putInt("oldvibrate2", oldvibrate2);
- edit.putInt("oldpolicy", oldpolicy);
- edit.putInt("oldring",am.getStreamVolume(AudioManager.STREAM_RING));
- edit.putBoolean("oldvalid", true);
- edit.commit();
- }
+ }
+
+ void saveSettings() {
+ if (!PreferenceManager.getDefaultSharedPreferences(Call.mContext).getBoolean("oldvalid",false)) {
+ int oldvibrate = am.getVibrateSetting(AudioManager.VIBRATE_TYPE_RINGER);
+ int oldvibrate2 = am.getVibrateSetting(AudioManager.VIBRATE_TYPE_NOTIFICATION);
+ if (!PreferenceManager.getDefaultSharedPreferences(Call.mContext).contains("oldvibrate2"))
+ oldvibrate2 = AudioManager.VIBRATE_SETTING_ON;
+ int oldpolicy = android.provider.Settings.System.getInt(cr, android.provider.Settings.System.WIFI_SLEEP_POLICY,
+ Settings.System.WIFI_SLEEP_POLICY_DEFAULT);
+ Editor edit = PreferenceManager.getDefaultSharedPreferences(Call.mContext).edit();
+ edit.putInt("oldvibrate", oldvibrate);
+ edit.putInt("oldvibrate2", oldvibrate2);
+ edit.putInt("oldpolicy", oldpolicy);
+ edit.putInt("oldring",am.getStreamVolume(AudioManager.STREAM_RING));
+ edit.putBoolean("oldvalid", true);
+ edit.commit();
}
-
- public static void setMode(int mode) {
- Editor edit = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).edit();
- edit.putBoolean("setmode", mode != AudioManager.MODE_NORMAL);
- edit.commit();
- AudioManager am = (AudioManager) Receiver.mContext.getSystemService(Context.AUDIO_SERVICE);
- am.setMode(mode);
+ }
+
+ public static void setMode(int mode) {
+ Editor edit = PreferenceManager.getDefaultSharedPreferences(Call.mContext).edit();
+ edit.putBoolean("setmode", mode != AudioManager.MODE_NORMAL);
+ edit.commit();
+ AudioManager am = (AudioManager) Call.mContext.getSystemService(Context.AUDIO_SERVICE);
+ am.setMode(mode);
+ }
+
+ public static void restoreMode() {
+ if (PreferenceManager.getDefaultSharedPreferences(Call.mContext).getBoolean("setmode",true)) {
+ setMode(AudioManager.MODE_NORMAL);
}
-
- public static void restoreMode() {
- if (PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getBoolean("setmode",true)) {
- if (Receiver.pstn_state == null || Receiver.pstn_state.equals("IDLE"))
- setMode(AudioManager.MODE_NORMAL);
- else {
- Editor edit = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).edit();
- edit.putBoolean("setmode", false);
- edit.commit();
- }
- }
+ }
+
+ public static void restoreSettings() {
+ if (PreferenceManager.getDefaultSharedPreferences(Call.mContext).getBoolean("oldvalid",true)) {
+ AudioManager am = (AudioManager) Call.mContext.getSystemService(Context.AUDIO_SERVICE);
+ ContentResolver cr = Call.mContext.getContentResolver();
+ int oldvibrate = PreferenceManager.getDefaultSharedPreferences(Call.mContext).getInt("oldvibrate",0);
+ int oldvibrate2 = PreferenceManager.getDefaultSharedPreferences(Call.mContext).getInt("oldvibrate2",0);
+ int oldpolicy = PreferenceManager.getDefaultSharedPreferences(Call.mContext).getInt("oldpolicy",0);
+ am.setVibrateSetting(AudioManager.VIBRATE_TYPE_RINGER,oldvibrate);
+ am.setVibrateSetting(AudioManager.VIBRATE_TYPE_NOTIFICATION,oldvibrate2);
+ Settings.System.putInt(cr, Settings.System.WIFI_SLEEP_POLICY, oldpolicy);
+ setStreamVolume(AudioManager.STREAM_RING, PreferenceManager.getDefaultSharedPreferences(Call.mContext).getInt("oldring",0), 0);
+ Editor edit = PreferenceManager.getDefaultSharedPreferences(Call.mContext).edit();
+ edit.putBoolean("oldvalid", false);
+ edit.commit();
+ PowerManager pm = (PowerManager) Call.mContext.getSystemService(Context.POWER_SERVICE);
+ PowerManager.WakeLock wl = pm.newWakeLock(PowerManager.SCREEN_BRIGHT_WAKE_LOCK |
+ PowerManager.ACQUIRE_CAUSES_WAKEUP, "Sipdroid.RtpStreamReceiver");
+ wl.acquire(1000);
}
+ restoreMode();
+ }
+
+ public static float good, late, lost, loss;
+ public static int timeout;
- public static void restoreSettings() {
- if (PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getBoolean("oldvalid",true)) {
- AudioManager am = (AudioManager) Receiver.mContext.getSystemService(Context.AUDIO_SERVICE);
- ContentResolver cr = Receiver.mContext.getContentResolver();
- int oldvibrate = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getInt("oldvibrate",0);
- int oldvibrate2 = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getInt("oldvibrate2",0);
- int oldpolicy = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getInt("oldpolicy",0);
- am.setVibrateSetting(AudioManager.VIBRATE_TYPE_RINGER,oldvibrate);
- am.setVibrateSetting(AudioManager.VIBRATE_TYPE_NOTIFICATION,oldvibrate2);
- Settings.System.putInt(cr, Settings.System.WIFI_SLEEP_POLICY, oldpolicy);
- setStreamVolume(AudioManager.STREAM_RING, PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getInt("oldring",0), 0);
- Editor edit = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).edit();
- edit.putBoolean("oldvalid", false);
- edit.commit();
- PowerManager pm = (PowerManager) Receiver.mContext.getSystemService(Context.POWER_SERVICE);
- PowerManager.WakeLock wl = pm.newWakeLock(PowerManager.SCREEN_BRIGHT_WAKE_LOCK |
- PowerManager.ACQUIRE_CAUSES_WAKEUP, "Sipdroid.RtpStreamReceiver");
- wl.acquire(1000);
- }
- restoreMode();
+ void empty() {
+ try {
+ rtp_socket.getDatagramSocket().setSoTimeout(1);
+ for (;;)
+ rtp_socket.receive(rtp_packet);
+ } catch (SocketException e2) {
+ e2.printStackTrace();
+ } catch (IOException e) {
+ }
+ try {
+ rtp_socket.getDatagramSocket().setSoTimeout(1000);
+ } catch (SocketException e2) {
+ e2.printStackTrace();
+ }
+ }
+
+ RtpPacket rtp_packet;
+ AudioTrack track;
+
+ /** Runs it in a new Thread. */
+ public void run() {
+ boolean nodata = PreferenceManager.getDefaultSharedPreferences(Call.mContext).getBoolean("nodata",false);
+
+ if (rtp_socket == null) {
+ if (DEBUG)
+ println("ERROR: RTP socket is null");
+ return;
}
- public static float good, late, lost, loss;
- public static int timeout;
-
- void empty() {
- try {
- rtp_socket.getDatagramSocket().setSoTimeout(1);
- for (;;)
- rtp_socket.receive(rtp_packet);
- } catch (SocketException e2) {
- if (!Sipdroid.release) e2.printStackTrace();
- } catch (IOException e) {
+ byte[] buffer = new byte[BUFFER_SIZE+12];
+ byte[] buffer_gsm = new byte[33+12];
+ int i;
+ rtp_packet = new RtpPacket(buffer, 0);
+
+ if (DEBUG)
+ println("Reading blocks of max " + buffer.length + " bytes");
+
+ running = true;
+ speakermode = Call.docked > 0?AudioManager.MODE_NORMAL:AudioManager.MODE_IN_CALL;
+ restored = false;
+
+ android.os.Process.setThreadPriority(android.os.Process.THREAD_PRIORITY_AUDIO);
+ am = (AudioManager) Call.mContext.getSystemService(Context.AUDIO_SERVICE);
+ cr = Call.mContext.getContentResolver();
+ saveSettings();
+ Settings.System.putInt(cr, Settings.System.WIFI_SLEEP_POLICY,Settings.System.WIFI_SLEEP_POLICY_NEVER);
+ am.setVibrateSetting(AudioManager.VIBRATE_TYPE_RINGER,AudioManager.VIBRATE_SETTING_OFF);
+ am.setVibrateSetting(AudioManager.VIBRATE_TYPE_NOTIFICATION,AudioManager.VIBRATE_SETTING_OFF);
+ int oldvol = am.getStreamVolume(AudioManager.STREAM_MUSIC);
+ track = new AudioTrack(AudioManager.STREAM_MUSIC, 8000, AudioFormat.CHANNEL_CONFIGURATION_MONO, AudioFormat.ENCODING_PCM_16BIT,
+ BUFFER_SIZE*2*2, AudioTrack.MODE_STREAM);
+ short lin[] = new short[BUFFER_SIZE];
+ short lin2[] = new short[BUFFER_SIZE];
+ int user, server, lserver, luser, cnt, todo, headroom, len = 0, seq = 0, cnt2 = 0, m = 1,
+ expseq, getseq, vm = 1, gap, gseq;
+ timeout = 1;
+ boolean islate;
+ user = 0;
+ lserver = 0;
+ luser = -8000;
+ cnt = 0;
+ switch (p_type) {
+ case 3:
+ Codec.init();
+ break;
+ case 0:
+ case 8:
+ G711.init();
+ break;
+ }
+ ToneGenerator tg = new ToneGenerator(AudioManager.STREAM_MUSIC,(int)(ToneGenerator.MAX_VOLUME*2*0.95));
+ track.play();
+ if (Call.headset > 0 && Call.oRingtone != null) {
+ ToneGenerator tg2 = new ToneGenerator(AudioManager.STREAM_RING,(int)(ToneGenerator.MAX_VOLUME*2*0.95));
+ tg2.startTone(ToneGenerator.TONE_SUP_RINGTONE);
+ System.gc();
+ tg2.stopTone();
+ } else
+ System.gc();
+ while (running) {
+ if (Call.call_state == Call.UA_STATE_HOLD) {
+ tg.stopTone();
+ track.pause();
+ while (running && Call.call_state == Call.UA_STATE_HOLD) {
+ try {
+ sleep(1000);
+ } catch (InterruptedException e1) {
+ e1.printStackTrace();
+ }
}
- try {
- rtp_socket.getDatagramSocket().setSoTimeout(1000);
- } catch (SocketException e2) {
- if (!Sipdroid.release) e2.printStackTrace();
+ track.play();
+ System.gc();
+ timeout = 1;
+ seq = 0;
+ }
+ try {
+ rtp_socket.receive(rtp_packet);
+ if (timeout != 0) {
+ tg.stopTone();
+ track.pause();
+ user += track.write(lin2,0,BUFFER_SIZE);
+ user += track.write(lin2,0,BUFFER_SIZE);
+ track.play();
+ cnt += 2*BUFFER_SIZE;
+ empty();
}
- }
-
- RtpPacket rtp_packet;
- AudioTrack track;
-
- /** Runs it in a new Thread. */
- public void run() {
- boolean nodata = PreferenceManager.getDefaultSharedPreferences(Receiver.mContext).getBoolean("nodata",false);
-
- if (rtp_socket == null) {
- if (DEBUG)
- println("ERROR: RTP socket is null");
- return;
+ timeout = 0;
+ } catch (IOException e) {
+ if (timeout == 0 && nodata) {
+ tg.startTone(ToneGenerator.TONE_SUP_RINGTONE);
+ }
+ rtp_socket.getDatagramSocket().disconnect();
+ if (++timeout > 22) {
+ try {
+ mJingle.closeCall();
+ } catch (RemoteException e1) {
+ e1.printStackTrace();
+ }
+ break;
+ }
+ }
+ if (running && timeout == 0) {
+ gseq = rtp_packet.getSequenceNumber();
+ if (seq == gseq) {
+ m++;
+ continue;
}
- byte[] buffer = new byte[BUFFER_SIZE+12];
- byte[] buffer_gsm = new byte[33+12];
- int i;
- rtp_packet = new RtpPacket(buffer, 0);
+ server = track.getPlaybackHeadPosition();
+ headroom = user-server;
- if (DEBUG)
- println("Reading blocks of max " + buffer.length + " bytes");
+ if (headroom > 1500)
+ cnt += len;
+ else
+ cnt = 0;
- running = true;
- speakermode = Receiver.docked > 0?AudioManager.MODE_NORMAL:AudioManager.MODE_IN_CALL;
- restored = false;
+ if (lserver == server)
+ cnt2++;
+ else
+ cnt2 = 0;
- android.os.Process.setThreadPriority(android.os.Process.THREAD_PRIORITY_AUDIO);
- am = (AudioManager) Receiver.mContext.getSystemService(Context.AUDIO_SERVICE);
- cr = Receiver.mContext.getContentResolver();
- saveSettings();
- Settings.System.putInt(cr, Settings.System.WIFI_SLEEP_POLICY,Settings.System.WIFI_SLEEP_POLICY_NEVER);
- am.setVibrateSetting(AudioManager.VIBRATE_TYPE_RINGER,AudioManager.VIBRATE_SETTING_OFF);
- am.setVibrateSetting(AudioManager.VIBRATE_TYPE_NOTIFICATION,AudioManager.VIBRATE_SETTING_OFF);
- int oldvol = am.getStreamVolume(AudioManager.STREAM_MUSIC);
- track = new AudioTrack(AudioManager.STREAM_MUSIC, 8000, AudioFormat.CHANNEL_CONFIGURATION_MONO, AudioFormat.ENCODING_PCM_16BIT,
- BUFFER_SIZE*2*2, AudioTrack.MODE_STREAM);
- short lin[] = new short[BUFFER_SIZE];
- short lin2[] = new short[BUFFER_SIZE];
- int user, server, lserver, luser, cnt, todo, headroom, len = 0, seq = 0, cnt2 = 0, m = 1,
- expseq, getseq, vm = 1, gap, gseq;
- timeout = 1;
- boolean islate;
- user = 0;
- lserver = 0;
- luser = -8000;
- cnt = 0;
- switch (p_type) {
- case 3:
- Codec.init();
- break;
- case 0:
- case 8:
- G711.init();
- break;
+ if (cnt <= 500 || cnt2 >= 2 || headroom - 875 < len) {
+ switch (rtp_packet.getPayloadType()) {
+ case 0:
+ len = rtp_packet.getPayloadLength();
+ G711.ulaw2linear(buffer, lin, len);
+ break;
+ case 8:
+ len = rtp_packet.getPayloadLength();
+ G711.alaw2linear(buffer, lin, len);
+ break;
+ case 3:
+ for (i = 12; i < 45; i++)
+ buffer_gsm[i] = buffer[i];
+ len = Codec.decode(buffer_gsm, lin, 0);
+ break;
+ }
+
+ if (speakermode == AudioManager.MODE_NORMAL)
+ calc(lin,0,len);
}
- ToneGenerator tg = new ToneGenerator(AudioManager.STREAM_MUSIC,(int)(ToneGenerator.MAX_VOLUME*2*org.sipdroid.sipua.ui.Settings.getEarGain()));
- track.play();
- if (Receiver.headset > 0 && Receiver.oRingtone != null) {
- ToneGenerator tg2 = new ToneGenerator(AudioManager.STREAM_RING,(int)(ToneGenerator.MAX_VOLUME*2*org.sipdroid.sipua.ui.Settings.getEarGain()));
- tg2.startTone(ToneGenerator.TONE_SUP_RINGTONE);
- System.gc();
- tg2.stopTone();
+
+ if (headroom < 250) {
+ todo = 875 - headroom;
+ println("insert "+todo);
+ islate = true;
+ user += track.write(lin2,0,todo);
} else
- System.gc();
- while (running) {
- if (Receiver.call_state == UserAgent.UA_STATE_HOLD) {
- tg.stopTone();
- track.pause();
- while (running && Receiver.call_state == UserAgent.UA_STATE_HOLD) {
- try {
- sleep(1000);
- } catch (InterruptedException e1) {
- }
- }
- track.play();
- System.gc();
- timeout = 1;
- seq = 0;
- }
- try {
- rtp_socket.receive(rtp_packet);
- if (timeout != 0) {
- tg.stopTone();
- track.pause();
- user += track.write(lin2,0,BUFFER_SIZE);
- user += track.write(lin2,0,BUFFER_SIZE);
- track.play();
- cnt += 2*BUFFER_SIZE;
- empty();
- }
- timeout = 0;
- } catch (IOException e) {
- if (timeout == 0 && nodata) {
- tg.startTone(ToneGenerator.TONE_SUP_RINGTONE);
- }
- rtp_socket.getDatagramSocket().disconnect();
- if (++timeout > 22) {
- Receiver.engine(Receiver.mContext).rejectcall();
- break;
- }
- }
- if (running && timeout == 0) {
- gseq = rtp_packet.getSequenceNumber();
- if (seq == gseq) {
- m++;
- continue;
- }
-
- server = track.getPlaybackHeadPosition();
- headroom = user-server;
-
- if (headroom > 1500)
- cnt += len;
- else
- cnt = 0;
-
- if (lserver == server)
- cnt2++;
- else
- cnt2 = 0;
+ islate = false;
+
+ if (cnt > 500 && cnt2 < 2) {
+ todo = headroom - 875;
+ println("cut "+todo);
+ if (todo < len)
+ user += track.write(lin,todo,len-todo);
+ } else
+ user += track.write(lin,0,len);
- if (cnt <= 500 || cnt2 >= 2 || headroom - 875 < len) {
- switch (rtp_packet.getPayloadType()) {
- case 0:
- len = rtp_packet.getPayloadLength();
- G711.ulaw2linear(buffer, lin, len);
- break;
- case 8:
- len = rtp_packet.getPayloadLength();
- G711.alaw2linear(buffer, lin, len);
- break;
- case 3:
- for (i = 12; i < 45; i++)
- buffer_gsm[i] = buffer[i];
- len = Codec.decode(buffer_gsm, lin, 0);
- break;
- }
-
- if (speakermode == AudioManager.MODE_NORMAL)
- calc(lin,0,len);
- }
-
- if (headroom < 250) {
- todo = 875 - headroom;
- println("insert "+todo);
- islate = true;
- user += track.write(lin2,0,todo);
- } else
- islate = false;
+ seq = gseq;
- if (cnt > 500 && cnt2 < 2) {
- todo = headroom - 875;
- println("cut "+todo);
- if (todo < len)
- user += track.write(lin,todo,len-todo);
- } else
- user += track.write(lin,0,len);
-
- if (seq != 0) {
- getseq = gseq&0xff;
- expseq = ++seq&0xff;
- if (m == RtpStreamSender.m) vm = m;
- gap = (getseq - expseq) & 0xff;
- if (gap > 0) {
- if (gap > 100) gap = 1;
- loss += gap;
- lost += gap;
- good += gap - 1;
- } else {
- if (m < vm)
- loss++;
- if (islate)
- late++;
- }
- good++;
- if (good > 100) {
- good *= 0.99;
- lost *= 0.99;
- loss *= 0.99;
- late *= 0.99;
- }
- }
- m = 1;
- seq = gseq;
-
- if (user >= luser + 8000 && Receiver.call_state == UserAgent.UA_STATE_INCALL) {
- if (luser == -8000 || am.getMode() != speakermode) {
- saveVolume();
- setMode(speakermode);
- restoreVolume();
- }
- luser = user;
- }
- lserver = server;
- }
+ if (user >= luser + 8000 && Call.call_state == Call.UA_STATE_INCALL) {
+ if (luser == -8000 || am.getMode() != speakermode) {
+ saveVolume();
+ setMode(speakermode);
+ restoreVolume();
+ }
+ luser = user;
}
- track.stop();
- saveVolume();
- setStreamVolume(AudioManager.STREAM_MUSIC,oldvol,0);
- restoreSettings();
- setStreamVolume(AudioManager.STREAM_MUSIC,oldvol,0);
- tg.stopTone();
- tg = new ToneGenerator(AudioManager.STREAM_RING,ToneGenerator.MAX_VOLUME/4*3);
- tg.startTone(ToneGenerator.TONE_PROP_PROMPT);
- try {
- sleep(500);
- } catch (InterruptedException e) {
- }
- tg.stopTone();
-
- rtp_socket.close();
- rtp_socket = null;
+ lserver = server;
+ }
+ }
+ track.stop();
+ saveVolume();
+ setStreamVolume(AudioManager.STREAM_MUSIC,oldvol,0);
+ restoreSettings();
+ setStreamVolume(AudioManager.STREAM_MUSIC,oldvol,0);
+ tg.stopTone();
+ tg = new ToneGenerator(AudioManager.STREAM_RING,ToneGenerator.MAX_VOLUME/4*3);
+ tg.startTone(ToneGenerator.TONE_PROP_PROMPT);
+ try {
+ sleep(500);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ tg.stopTone();
- if (DEBUG)
- println("rtp receiver terminated");
- }
+ rtp_socket.close();
+ rtp_socket = null;
- /** Debug output */
- private static void println(String str) {
- if (!Sipdroid.release) System.out.println("RtpStreamReceiver: " + str);
- }
+ if (DEBUG)
+ println("rtp receiver terminated");
+ }
- public static int byte2int(byte b) { // return (b>=0)? b : -((b^0xFF)+1);
- // return (b>=0)? b : b+0x100;
- return (b + 0x100) % 0x100;
- }
+ /** Debug output */
+ private static void println(String str) {
+ System.out.println("RtpStreamReceiver: " + str);
+ }
- public static int byte2int(byte b1, byte b2) {
- return (((b1 + 0x100) % 0x100) << 8) + (b2 + 0x100) % 0x100;
- }
+ public static int byte2int(byte b) { // return (b>=0)? b : -((b^0xFF)+1);
+ // return (b>=0)? b : b+0x100;
+ return (b + 0x100) % 0x100;
+ }
+
+ public static int byte2int(byte b1, byte b2) {
+ return (((b1 + 0x100) % 0x100) << 8) + (b2 + 0x100) % 0x100;
+ }
}