Android/frameworks_base
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

am 2ac479fa: am a83987d2: Merge "RTP: integrate the echo canceller from speex." into gingerbread

Browse Source 
Merge commit '2ac479faeb03daa5083d91726f7b639984617ba2'

* commit '2ac479faeb03daa5083d91726f7b639984617ba2':
  RTP: integrate the echo canceller from speex.
This commit is contained in:
Chia-chi Yeh
2010-08-24 12:58:11 -07:00
committed by Android Git Automerger
parent 12ac100de4 2ac479faeb
commit 527ed66d41
2 changed files with 18 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
voip/jni/rtp/Android.mk
View File

@@ -32,10 +32,11 @@ LOCAL_SHARED_LIBRARIES := \
libutils \
libmedia
LOCAL_STATIC_LIBRARIES :=
LOCAL_STATIC_LIBRARIES := libspeex
LOCAL_C_INCLUDES += \
$(JNI_H_INCLUDE)
$(JNI_H_INCLUDE) \
external/speex/include
LOCAL_CFLAGS += -fvisibility=hidden

19
voip/jni/rtp/AudioGroup.cpp
View File

@@ -40,6 +40,8 @@
#include <media/AudioTrack.h>
#include <media/mediarecorder.h>
#include <speex/speex_echo.h>
#include "jni.h"
#include "JNIHelp.h"
@@ -445,6 +447,8 @@ private:
int mDeviceSocket;
AudioTrack mTrack;
AudioRecord mRecord;
SpeexEchoState *mEchoState;
bool networkLoop();
bool deviceLoop();
@@ -506,6 +510,7 @@ AudioGroup::AudioGroup()
mEventQueue = -1;
mDtmfEvent = -1;
mDeviceSocket = -1;
mEchoState = NULL;
mNetworkThread = new NetworkThread(this);
mDeviceThread = new DeviceThread(this);
}
@@ -518,6 +523,9 @@ AudioGroup::~AudioGroup()
mRecord.stop();
close(mEventQueue);
close(mDeviceSocket);
if (mEchoState) {
speex_echo_state_destroy(mEchoState);
}
while (mChain) {
AudioStream *next = mChain->mNext;
delete mChain;
@@ -566,7 +574,8 @@ bool AudioGroup::set(int sampleRate, int sampleCount)
}
LOGD("latency: output %d, input %d", mTrack.latency(), mRecord.latency());
// TODO: initialize echo canceler here.
// Initialize echo canceller.
mEchoState = speex_echo_state_init(sampleCount, sampleRate);
// Create device socket.
int pair[2];
@@ -633,6 +642,7 @@ bool AudioGroup::setMode(int mode)
if (mode == MUTED) {
mRecord.stop();
} else {
speex_echo_state_reset(mEchoState);
mRecord.start();
}
@@ -793,7 +803,7 @@ bool AudioGroup::deviceLoop()
status_t status = mRecord.obtainBuffer(&buffer, 1);
if (status == NO_ERROR) {
int count = (buffer.frameCount < toRead) ?
int count = ((int)buffer.frameCount < toRead) ?
buffer.frameCount : toRead;
memcpy(&input[mSampleCount - toRead], buffer.i8, count * 2);
toRead -= count;
@@ -817,8 +827,9 @@ bool AudioGroup::deviceLoop()
if (mMode == NORMAL) {
send(mDeviceSocket, input, sizeof(input), MSG_DONTWAIT);
} else {
// TODO: Echo canceller runs here.
send(mDeviceSocket, input, sizeof(input), MSG_DONTWAIT);
int16_t result[mSampleCount];
speex_echo_cancellation(mEchoState, input, output, result);
send(mDeviceSocket, result, sizeof(result), MSG_DONTWAIT);
}
}
return true;