rlm@11
|
1 package com.aurellem.capture.audio;
|
rlm@11
|
2
|
rlm@11
|
3 import java.lang.reflect.Field;
|
rlm@11
|
4 import java.nio.ByteBuffer;
|
rlm@11
|
5 import java.util.HashMap;
|
rlm@11
|
6 import java.util.Vector;
|
rlm@11
|
7 import java.util.concurrent.CountDownLatch;
|
rlm@11
|
8 import java.util.logging.Level;
|
rlm@11
|
9 import java.util.logging.Logger;
|
rlm@11
|
10
|
rlm@29
|
11 import javax.sound.sampled.AudioFormat;
|
rlm@29
|
12
|
rlm@11
|
13 import org.lwjgl.LWJGLException;
|
rlm@11
|
14 import org.lwjgl.openal.AL;
|
rlm@11
|
15 import org.lwjgl.openal.AL10;
|
rlm@11
|
16 import org.lwjgl.openal.ALCdevice;
|
rlm@11
|
17 import org.lwjgl.openal.OpenALException;
|
rlm@11
|
18
|
rlm@11
|
19 import com.aurellem.send.AudioSend;
|
rlm@11
|
20 import com.jme3.audio.Listener;
|
rlm@11
|
21 import com.jme3.audio.lwjgl.LwjglAudioRenderer;
|
rlm@11
|
22 import com.jme3.math.Vector3f;
|
rlm@11
|
23 import com.jme3.util.BufferUtils;
|
rlm@11
|
24
|
rlm@11
|
25 public class AudioSendRenderer
|
rlm@11
|
26
|
rlm@11
|
27 extends LwjglAudioRenderer implements MultiListener {
|
rlm@11
|
28
|
rlm@11
|
29 private AudioSend audioSend;
|
rlm@29
|
30 private static final AudioFormat outFormat = new AudioFormat(44100.0f, 32, 1, true, false);
|
rlm@11
|
31
|
rlm@11
|
32 /**
|
rlm@11
|
33 * Keeps track of all the listeners which have been registered so far.
|
rlm@11
|
34 * The first element is <code>null</code>, which represents the zeroth
|
rlm@11
|
35 * LWJGL listener which is created automatically.
|
rlm@11
|
36 */
|
rlm@11
|
37 public Vector<Listener> listeners = new Vector<Listener>();
|
rlm@11
|
38
|
rlm@11
|
39 public void initialize(){
|
rlm@11
|
40 super.initialize();
|
rlm@11
|
41 listeners.add(null);
|
rlm@11
|
42 }
|
rlm@11
|
43
|
rlm@11
|
44 /**
|
rlm@11
|
45 * This is to call the native methods which require the OpenAL device ID.
|
rlm@11
|
46 * currently it is obtained through reflection.
|
rlm@11
|
47 */
|
rlm@11
|
48 private long deviceID;
|
rlm@11
|
49
|
rlm@11
|
50 /**
|
rlm@11
|
51 * To ensure that <code>deviceID<code> and <code>listeners<code> are
|
rlm@11
|
52 * properly initialized before any additional listeners are added.
|
rlm@11
|
53 */
|
rlm@11
|
54 private CountDownLatch latch = new CountDownLatch(1);
|
rlm@11
|
55
|
rlm@11
|
56 /**
|
rlm@11
|
57 * Each listener (including the main LWJGL listener) can be registered
|
rlm@11
|
58 * with a <code>SoundProcessor</code>, which this Renderer will call whenever
|
rlm@11
|
59 * there is new audio data to be processed.
|
rlm@11
|
60 */
|
rlm@11
|
61 public HashMap<Listener, SoundProcessor> soundProcessorMap =
|
rlm@11
|
62 new HashMap<Listener, SoundProcessor>();
|
rlm@11
|
63
|
rlm@11
|
64
|
rlm@11
|
65 /**
|
rlm@11
|
66 * Create a new slave context on the recorder device which will render all the
|
rlm@11
|
67 * sounds in the main LWJGL context with respect to this listener.
|
rlm@11
|
68 */
|
rlm@11
|
69 public void addListener(Listener l) {
|
rlm@11
|
70 try {this.latch.await();}
|
rlm@11
|
71 catch (InterruptedException e) {e.printStackTrace();}
|
rlm@11
|
72 audioSend.addListener();
|
rlm@11
|
73 this.listeners.add(l);
|
rlm@11
|
74 }
|
rlm@11
|
75
|
rlm@11
|
76 /**
|
rlm@11
|
77 * Whenever new data is rendered in the perspective of this listener,
|
rlm@11
|
78 * this Renderer will send that data to the SoundProcessor of your choosing.
|
rlm@11
|
79 */
|
rlm@11
|
80 public void registerSoundProcessor(Listener l, SoundProcessor sp) {
|
rlm@11
|
81 this.soundProcessorMap.put(l, sp);
|
rlm@11
|
82 }
|
rlm@11
|
83
|
rlm@11
|
84 /**
|
rlm@11
|
85 * Registers a SoundProcessor for the main LWJGL context. IF all you want to
|
rlm@11
|
86 * do is record the sound you would normally hear in your application, then
|
rlm@11
|
87 * this is the only method you have to worry about.
|
rlm@11
|
88 */
|
rlm@11
|
89 public void registerSoundProcessor(SoundProcessor sp){
|
rlm@11
|
90 // register a sound processor for the default listener.
|
rlm@11
|
91 this.soundProcessorMap.put(null, sp);
|
rlm@11
|
92 }
|
rlm@11
|
93
|
rlm@11
|
94 private static final Logger logger =
|
rlm@11
|
95 Logger.getLogger(AudioSendRenderer.class.getName());
|
rlm@11
|
96
|
rlm@11
|
97
|
rlm@11
|
98
|
rlm@11
|
99 /**
|
rlm@11
|
100 * Instead of taking whatever device is available on the system, this call
|
rlm@11
|
101 * creates the "Multiple Audio Send" device, which supports multiple listeners in a limited
|
rlm@11
|
102 * capacity. For each listener, the device renders it not to the sound device, but
|
rlm@11
|
103 * instead to buffers which it makes available via JNI.
|
rlm@11
|
104 */
|
rlm@11
|
105 public void initInThread(){
|
rlm@11
|
106 try{
|
rlm@11
|
107 if (!AL.isCreated()){
|
rlm@29
|
108 AL.create("Multiple Audio Send", (int) outFormat.getSampleRate(), 60, false);
|
rlm@11
|
109 }
|
rlm@11
|
110 }catch (OpenALException ex){
|
rlm@11
|
111 logger.log(Level.SEVERE, "Failed to load audio library", ex);
|
rlm@11
|
112 System.exit(1);
|
rlm@11
|
113 return;
|
rlm@11
|
114 }catch (LWJGLException ex){
|
rlm@11
|
115 logger.log(Level.SEVERE, "Failed to load audio library", ex);
|
rlm@11
|
116 System.exit(1);
|
rlm@11
|
117 return;
|
rlm@11
|
118 }
|
rlm@11
|
119 super.initInThread();
|
rlm@11
|
120
|
rlm@11
|
121 ALCdevice device = AL.getDevice();
|
rlm@11
|
122
|
rlm@11
|
123 // RLM: use reflection to grab the ID of our device for use later.
|
rlm@11
|
124 try {
|
rlm@11
|
125 Field deviceIDField;
|
rlm@11
|
126 deviceIDField = ALCdevice.class.getDeclaredField("device");
|
rlm@11
|
127 deviceIDField.setAccessible(true);
|
rlm@11
|
128 try {deviceID = (Long)deviceIDField.get(device);}
|
rlm@11
|
129 catch (IllegalArgumentException e) {e.printStackTrace();}
|
rlm@11
|
130 catch (IllegalAccessException e) {e.printStackTrace();}
|
rlm@11
|
131 deviceIDField.setAccessible(false);}
|
rlm@11
|
132 catch (SecurityException e) {e.printStackTrace();}
|
rlm@11
|
133 catch (NoSuchFieldException e) {e.printStackTrace();}
|
rlm@11
|
134
|
rlm@11
|
135 this.audioSend = new AudioSend(this.deviceID);
|
rlm@11
|
136
|
rlm@11
|
137 // The LWJGL context must be established as the master context before
|
rlm@11
|
138 // any other listeners can be created on this device.
|
rlm@11
|
139 audioSend.initDevice();
|
rlm@11
|
140 // Now, everything is initialized, and it is safe to add more listeners.
|
rlm@11
|
141 latch.countDown();
|
rlm@11
|
142 }
|
rlm@11
|
143
|
rlm@11
|
144
|
rlm@11
|
145 public void cleanup(){
|
rlm@11
|
146 for(SoundProcessor sp : this.soundProcessorMap.values()){
|
rlm@11
|
147 sp.cleanup();
|
rlm@11
|
148 }
|
rlm@11
|
149 super.cleanup();
|
rlm@11
|
150 }
|
rlm@11
|
151
|
rlm@11
|
152 public void updateAllListeners(){
|
rlm@11
|
153 for (int i = 0; i < this.listeners.size(); i++){
|
rlm@11
|
154 Listener lis = this.listeners.get(i);
|
rlm@11
|
155 if (null != lis){
|
rlm@11
|
156 Vector3f location = lis.getLocation();
|
rlm@11
|
157 Vector3f velocity = lis.getVelocity();
|
rlm@11
|
158 Vector3f orientation = lis.getUp();
|
rlm@11
|
159 float gain = lis.getVolume();
|
rlm@11
|
160 audioSend.setNthListener3f(AL10.AL_POSITION,
|
rlm@11
|
161 location.x, location.y, location.z, i);
|
rlm@11
|
162 audioSend.setNthListener3f(AL10.AL_VELOCITY,
|
rlm@11
|
163 velocity.x, velocity.y, velocity.z, i);
|
rlm@11
|
164 audioSend.setNthListener3f(AL10.AL_ORIENTATION,
|
rlm@11
|
165 orientation.x, orientation.y, orientation.z, i);
|
rlm@11
|
166 audioSend.setNthListenerf(AL10.AL_GAIN, gain, i);
|
rlm@11
|
167 }
|
rlm@11
|
168 }
|
rlm@11
|
169 }
|
rlm@11
|
170
|
rlm@11
|
171
|
rlm@29
|
172 //public final static int BYTES_PER_SAMPLE = 4;
|
rlm@11
|
173 private ByteBuffer buffer = BufferUtils.createByteBuffer(4096);
|
rlm@11
|
174
|
rlm@11
|
175 public void dispatchAudio(float tpf){
|
rlm@29
|
176 int samplesToGet = (int) (tpf * outFormat.getSampleRate());
|
rlm@11
|
177 try {latch.await();}
|
rlm@11
|
178 catch (InterruptedException e) {e.printStackTrace();}
|
rlm@11
|
179 audioSend.step(samplesToGet);
|
rlm@11
|
180 updateAllListeners();
|
rlm@11
|
181
|
rlm@11
|
182 for (int i = 0; i < this.listeners.size(); i++){
|
rlm@11
|
183 buffer.clear();
|
rlm@11
|
184 audioSend.getSamples(buffer, samplesToGet, i);
|
rlm@11
|
185 SoundProcessor sp =
|
rlm@11
|
186 this.soundProcessorMap.get(this.listeners.get(i));
|
rlm@30
|
187 if (null != sp){sp.process(buffer, samplesToGet*outFormat.getFrameSize(), outFormat);}
|
rlm@11
|
188 }
|
rlm@11
|
189
|
rlm@11
|
190 }
|
rlm@11
|
191
|
rlm@11
|
192 public void update(float tpf){
|
rlm@11
|
193 super.update(tpf);
|
rlm@11
|
194 dispatchAudio(tpf);
|
rlm@11
|
195 }
|
rlm@11
|
196
|
rlm@11
|
197 }
|
rlm@11
|
198
|