12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061 |
- #include "AudioFramesMixer.hpp"
- //// Reset mix buffer.
- //Arrays.fill(tempMix, 0);
- //
- //// Sum the buffers.
- //for (final AudioUser user : mix) {
- //for (int i = 0; i < tempMix.length; i++) {
- //tempMix[i] += user.lastFrame[i];
- //}
- //}
- //
- //// Clip buffer for real output.
- //for (int i = 0; i < MumbleProtocol.FRAME_SIZE; i++) {
- //clipOut[i] = (short) (Short.MAX_VALUE * (tempMix[i] < -1.0f ? -1.0f
- //: (tempMix[i] > 1.0f ? 1.0f : tempMix[i])));
- //}
- mixer::AudioFramesMixer::AudioFramesMixer(pj_pool_factory &poolFactory)
- : logger(log4cpp::Category::getInstance("AudioFramesMixer")) {
- pool = pj_pool_create(&poolFactory, "media", 32768, 8192, nullptr);
- if (!pool) {
- throw mixer::Exception("error when creating memory pool");
- }
- // todo calculate sizes
- pj_status_t status = pjmedia_circ_buf_create(pool, 960 * 10, &inputBuff);
- if (status != PJ_SUCCESS) {
- throw mixer::Exception("error when creating circular buffer", status);
- }
- }
- mixer::AudioFramesMixer::~AudioFramesMixer() {
- if (pool != nullptr) {
- pj_pool_release(pool);
- }
- }
- void mixer::AudioFramesMixer::addFrameToBuffer(int sessionId, int sequenceNumber, int16_t *samples, int samplesLength) {
- std::unique_lock<std::mutex> lock(inBuffAccessMutex);
- logger.debug("Pushing %d samples to in-buff.", samplesLength);
- pjmedia_circ_buf_write(inputBuff, samples, samplesLength);
- }
- int mixer::AudioFramesMixer::getMixedSamples(int16_t *mixedSamples, int requestedLength) {
- std::unique_lock<std::mutex> lock(inBuffAccessMutex);
- int availableSamples = pjmedia_circ_buf_get_len(inputBuff);
- const int samplesToRead = std::min(requestedLength, availableSamples);
- logger.debug("Pulling %d samples from in-buff.", samplesToRead);
- pjmedia_circ_buf_read(inputBuff, mixedSamples, samplesToRead);
- return samplesToRead;
- }
- void mixer::AudioFramesMixer::clean() {
- }
|