Mirrors/overte-lubosz
3
0
Fork 0
mirror of https://github.com/lubosz/overte.git synced 2025-04-27 05:55:31 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

clear agent audio injector after send, don't send if empty

Browse source
This commit is contained in:
Stephen Birarda 2013-10-16 11:50:19 -07:00
parent d3c3e330e0
commit ef655f5e78
3 changed files with 15 additions and 2 deletions
assignment-client/src
Agent.cpp
libraries/audio/src
AudioInjector.cppAudioInjector.h

5
assignment-client/src/Agent.cpp
View file

@ -161,13 +161,16 @@ void Agent::run() {
emit willSendAudioDataCallback();
if (audioMixer) {
if (audioMixer && scriptedAudioInjector.hasSamplesToInject()) {
int usecToSleep = usecTimestamp(&startTime) + (thisFrame++ * INJECT_INTERVAL_USECS) - usecTimestampNow();
if (usecToSleep > 0) {
usleep(usecToSleep);
}
scriptedAudioInjector.injectAudio(NodeList::getInstance()->getNodeSocket(), audioMixer->getPublicSocket());
// clear out the audio injector so that it doesn't re-send what we just sent
scriptedAudioInjector.clear();
}
// allow the scripter's call back to setup visual data

8
libraries/audio/src/AudioInjector.cpp
View file

@ -64,7 +64,7 @@ AudioInjector::~AudioInjector() {
}
void AudioInjector::injectAudio(UDPSocket* injectorSocket, sockaddr* destinationSocket) {
if (_audioSampleArray) {
if (_audioSampleArray && _indexOfNextSlot > 0) {
_isInjectingAudio = true;
timeval startTime;
@ -139,6 +139,11 @@ void AudioInjector::addSamples(int16_t* sampleBuffer, int numSamples) {
}
}
void AudioInjector::clear() {
_indexOfNextSlot = 0;
memset(_audioSampleArray, 0, _numTotalSamples * sizeof(int16_t));
}
int16_t& AudioInjector::sampleAt(const int index) {
assert(index >= 0 && index < _numTotalSamples);
@ -149,4 +154,5 @@ void AudioInjector::insertSample(const int index, int sample) {
assert (index >= 0 && index < _numTotalSamples);
_audioSampleArray[index] = (int16_t) sample;
_indexOfNextSlot = index + 1;
}

4
libraries/audio/src/AudioInjector.h
View file

@ -51,8 +51,12 @@ public:
float getRadius() const { return _radius; }
void setRadius(float radius) { _radius = radius; }
bool hasSamplesToInject() const { return _indexOfNextSlot > 0; }
void addSample(const int16_t sample);
void addSamples(int16_t* sampleBuffer, int numSamples);
void clear();
public slots:
int16_t& sampleAt(const int index);
void insertSample(const int index, int sample);