/*
 * Copyright (c) 2008, 2013, Oracle and/or its affiliates. All rights reserved.
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
 *
 * This code is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License version 2 only, as
 * published by the Free Software Foundation.  Oracle designates this
 * particular file as subject to the "Classpath" exception as provided
 * by Oracle in the LICENSE file that accompanied this code.
 *
 * This code is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
 * version 2 for more details (a copy is included in the LICENSE file that
 * accompanied this code).
 *
 * You should have received a copy of the GNU General Public License version
 * 2 along with this work; if not, write to the Free Software Foundation,
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
 *
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
 * or visit www.oracle.com if you need additional information or have any
 * questions.
 */

package com.sun.media.sound;

import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;

import javax.sound.sampled.AudioInputStream;
import javax.sound.sampled.AudioSystem;

Main mixer for SoftMixingMixer.
Author:Karl Helgason
/** * Main mixer for SoftMixingMixer. * * @author Karl Helgason */
public final class SoftMixingMainMixer { public static final int CHANNEL_LEFT = 0; public static final int CHANNEL_RIGHT = 1; public static final int CHANNEL_EFFECT1 = 2; public static final int CHANNEL_EFFECT2 = 3; public static final int CHANNEL_EFFECT3 = 4; public static final int CHANNEL_EFFECT4 = 5; public static final int CHANNEL_LEFT_DRY = 10; public static final int CHANNEL_RIGHT_DRY = 11; public static final int CHANNEL_SCRATCH1 = 12; public static final int CHANNEL_SCRATCH2 = 13; public static final int CHANNEL_CHANNELMIXER_LEFT = 14; public static final int CHANNEL_CHANNELMIXER_RIGHT = 15; private final SoftMixingMixer mixer; private final AudioInputStream ais; private final SoftAudioBuffer[] buffers; private final SoftAudioProcessor reverb; private final SoftAudioProcessor chorus; private final SoftAudioProcessor agc; private final int nrofchannels; private final Object control_mutex; private final List<SoftMixingDataLine> openLinesList = new ArrayList<>(); private SoftMixingDataLine[] openLines = new SoftMixingDataLine[0]; public AudioInputStream getInputStream() { return ais; } void processAudioBuffers() { for (int i = 0; i < buffers.length; i++) { buffers[i].clear(); } SoftMixingDataLine[] openLines; synchronized (control_mutex) { openLines = this.openLines; for (int i = 0; i < openLines.length; i++) { openLines[i].processControlLogic(); } chorus.processControlLogic(); reverb.processControlLogic(); agc.processControlLogic(); } for (int i = 0; i < openLines.length; i++) { openLines[i].processAudioLogic(buffers); } chorus.processAudio(); reverb.processAudio(); agc.processAudio(); } public SoftMixingMainMixer(SoftMixingMixer mixer) { this.mixer = mixer; nrofchannels = mixer.getFormat().getChannels(); int buffersize = (int) (mixer.getFormat().getSampleRate() / mixer .getControlRate()); control_mutex = mixer.control_mutex; buffers = new SoftAudioBuffer[16]; for (int i = 0; i < buffers.length; i++) { buffers[i] = new SoftAudioBuffer(buffersize, mixer.getFormat()); } reverb = new SoftReverb(); chorus = new SoftChorus(); agc = new SoftLimiter(); float samplerate = mixer.getFormat().getSampleRate(); float controlrate = mixer.getControlRate(); reverb.init(samplerate, controlrate); chorus.init(samplerate, controlrate); agc.init(samplerate, controlrate); reverb.setMixMode(true); chorus.setMixMode(true); agc.setMixMode(false); chorus.setInput(0, buffers[CHANNEL_EFFECT2]); chorus.setOutput(0, buffers[CHANNEL_LEFT]); if (nrofchannels != 1) chorus.setOutput(1, buffers[CHANNEL_RIGHT]); chorus.setOutput(2, buffers[CHANNEL_EFFECT1]); reverb.setInput(0, buffers[CHANNEL_EFFECT1]); reverb.setOutput(0, buffers[CHANNEL_LEFT]); if (nrofchannels != 1) reverb.setOutput(1, buffers[CHANNEL_RIGHT]); agc.setInput(0, buffers[CHANNEL_LEFT]); if (nrofchannels != 1) agc.setInput(1, buffers[CHANNEL_RIGHT]); agc.setOutput(0, buffers[CHANNEL_LEFT]); if (nrofchannels != 1) agc.setOutput(1, buffers[CHANNEL_RIGHT]); InputStream in = new InputStream() { private final SoftAudioBuffer[] buffers = SoftMixingMainMixer.this.buffers; private final int nrofchannels = SoftMixingMainMixer.this.mixer .getFormat().getChannels(); private final int buffersize = buffers[0].getSize(); private final byte[] bbuffer = new byte[buffersize * (SoftMixingMainMixer.this.mixer.getFormat() .getSampleSizeInBits() / 8) * nrofchannels]; private int bbuffer_pos = 0; private final byte[] single = new byte[1]; public void fillBuffer() { processAudioBuffers(); for (int i = 0; i < nrofchannels; i++) buffers[i].get(bbuffer, i); bbuffer_pos = 0; } @Override public int read(byte[] b, int off, int len) { int bbuffer_len = bbuffer.length; int offlen = off + len; byte[] bbuffer = this.bbuffer; while (off < offlen) if (available() == 0) fillBuffer(); else { int bbuffer_pos = this.bbuffer_pos; while (off < offlen && bbuffer_pos < bbuffer_len) b[off++] = bbuffer[bbuffer_pos++]; this.bbuffer_pos = bbuffer_pos; } return len; } @Override public int read() throws IOException { int ret = read(single); if (ret == -1) return -1; return single[0] & 0xFF; } @Override public int available() { return bbuffer.length - bbuffer_pos; } @Override public void close() { SoftMixingMainMixer.this.mixer.close(); } }; ais = new AudioInputStream(in, mixer.getFormat(), AudioSystem.NOT_SPECIFIED); } public void openLine(SoftMixingDataLine line) { synchronized (control_mutex) { openLinesList.add(line); openLines = openLinesList .toArray(new SoftMixingDataLine[openLinesList.size()]); } } public void closeLine(SoftMixingDataLine line) { synchronized (control_mutex) { openLinesList.remove(line); openLines = openLinesList .toArray(new SoftMixingDataLine[openLinesList.size()]); if (openLines.length == 0) if (mixer.implicitOpen) mixer.close(); } } public SoftMixingDataLine[] getOpenLines() { synchronized (control_mutex) { return openLines; } } public void close() { SoftMixingDataLine[] openLines = this.openLines; for (int i = 0; i < openLines.length; i++) { openLines[i].close(); } } }