ojluni/src/main/java/com/sun/media/sound/SoftMixingMainMixer.java - platform/libcore - Git at Google

 /*
  * 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
  */
 public final class SoftMixingMainMixer {

     public final static int CHANNEL_LEFT = 0;

     public final static int CHANNEL_RIGHT = 1;

     public final static int CHANNEL_EFFECT1 = 2;

     public final static int CHANNEL_EFFECT2 = 3;

     public final static int CHANNEL_EFFECT3 = 4;

     public final static int CHANNEL_EFFECT4 = 5;

     public final static int CHANNEL_LEFT_DRY = 10;

     public final static int CHANNEL_RIGHT_DRY = 11;

     public final static int CHANNEL_SCRATCH1 = 12;

     public final static int CHANNEL_SCRATCH2 = 13;

     public final static int CHANNEL_CHANNELMIXER_LEFT = 14;

     public final static 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<SoftMixingDataLine>();

     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;
             }

             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;
             }

             public int read() throws IOException {
                 int ret = read(single);
                 if (ret == -1)
                     return -1;
                 return single[0] & 0xFF;
             }

             public int available() {
                 return bbuffer.length - bbuffer_pos;
             }

             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();
         }
     }

 }
	/*
	* 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
	*/
	public final class SoftMixingMainMixer {

	public final static int CHANNEL_LEFT = 0;

	public final static int CHANNEL_RIGHT = 1;

	public final static int CHANNEL_EFFECT1 = 2;

	public final static int CHANNEL_EFFECT2 = 3;

	public final static int CHANNEL_EFFECT3 = 4;

	public final static int CHANNEL_EFFECT4 = 5;

	public final static int CHANNEL_LEFT_DRY = 10;

	public final static int CHANNEL_RIGHT_DRY = 11;

	public final static int CHANNEL_SCRATCH1 = 12;

	public final static int CHANNEL_SCRATCH2 = 13;

	public final static int CHANNEL_CHANNELMIXER_LEFT = 14;

	public final static 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<SoftMixingDataLine>();

	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;
	}

	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;
	}

	public int read() throws IOException {
	int ret = read(single);
	if (ret == -1)
	return -1;
	return single[0] & 0xFF;
	}

	public int available() {
	return bbuffer.length - bbuffer_pos;
	}

	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();
	}
	}

	}