diff options
Diffstat (limited to 'src/java/demos/devmaster/lesson8')
| -rw-r--r-- | src/java/demos/devmaster/lesson8/OggStreamer.java | 99 |
1 files changed, 80 insertions, 19 deletions
diff --git a/src/java/demos/devmaster/lesson8/OggStreamer.java b/src/java/demos/devmaster/lesson8/OggStreamer.java index 1f52973..a7b9b45 100644 --- a/src/java/demos/devmaster/lesson8/OggStreamer.java +++ b/src/java/demos/devmaster/lesson8/OggStreamer.java @@ -68,13 +68,23 @@ public class OggStreamer { } } + private static boolean debug = false; + private static int totalBytes = 0; + + private static void debugMsg(String str) { + if (debug) System.err.println(str); + } + private OggDecoder oggDecoder; // The size of a chunk from the stream that we want to read for each update. - private static int BUFFER_SIZE = 4096*8; + private static int BUFFER_SIZE = 4096*16; + + // The number of buffers used in the audio pipeline + private static int NUM_BUFFERS = 2; - // Buffers hold sound data. There are two of them (front/back) - private int[] buffers = new int[2]; + // Buffers hold sound data. There are two of them by default (front/back) + private int[] buffers = new int[NUM_BUFFERS]; // Sources are points emitting sound. private int[] source = new int[1]; @@ -89,6 +99,8 @@ public class OggStreamer { private URL url; + private long sleepTime = 0; + /** Creates a new instance of OggStreamer */ public OggStreamer(URL url) { this.url = url; @@ -106,20 +118,35 @@ public class OggStreamer { return false; } - if (oggDecoder.numChannels() == 1) + int numChannels = oggDecoder.numChannels(); + int numBytesPerSample = 2; + + if (numChannels == 1) format = AL.AL_FORMAT_MONO16; else format = AL.AL_FORMAT_STEREO16; rate = oggDecoder.sampleRate(); - System.err.println("format = 0x" + Integer.toString(format, 16)); + // A rough estimation of how much time in milliseconds we can sleep + // before checking to see if the queued buffers have been played + // (so that we dont peg the CPU by doing an active wait). We divide + // by 10 at the end to be safe... + // round it off to the nearest multiple of 10. + sleepTime = (long)(1000.0 * BUFFER_SIZE / + numBytesPerSample / numChannels / rate / 10.0); + sleepTime = (sleepTime + 10)/10 * 10; + + System.err.println("#Buffers: " + NUM_BUFFERS); + System.err.println("Buffer size: " + BUFFER_SIZE); + System.err.println("Format: 0x" + Integer.toString(format, 16)); + System.err.println("Sleep time: " + sleepTime); // TODO: I am not if this is the right way to fix the endian // problems I am having... but this seems to fix it on Linux oggDecoder.setSwap(true); - al.alGenBuffers(2, buffers, 0); check(); + al.alGenBuffers(NUM_BUFFERS, buffers, 0); check(); al.alGenSources(1, source, 0); check(); al.alSourcefv(source[0], AL.AL_POSITION , sourcePos, 0); @@ -142,8 +169,9 @@ public class OggStreamer { al.alSourceStop(source[0]); empty(); - al.alDeleteSources(1, source, 0); check(); - al.alDeleteBuffers(2, buffers, 0); check(); + for (int i = 0; i < NUM_BUFFERS; i++) { + al.alDeleteSources(i, source, 0); check(); + } } /** @@ -153,13 +181,14 @@ public class OggStreamer { if (playing()) return true; - if (!stream(buffers[0])) - return false; - - if(!stream(buffers[1])) - return false; + debugMsg("playback(): stream all buffers"); + for (int i = 0; i < NUM_BUFFERS; i++) { + if (!stream(buffers[i])) + return false; + } - al.alSourceQueueBuffers(source[0], 2, buffers, 0); + debugMsg("playback(): queue all buffers & play source"); + al.alSourceQueueBuffers(source[0], NUM_BUFFERS, buffers, 0); al.alSourcePlay(source[0]); return true; @@ -183,6 +212,7 @@ public class OggStreamer { int[] processed = new int[1]; boolean active = true; + debugMsg("update()"); al.alGetSourcei(source[0], AL.AL_BUFFERS_PROCESSED, processed, 0); while (processed[0] > 0) @@ -190,9 +220,11 @@ public class OggStreamer { int[] buffer = new int[1]; al.alSourceUnqueueBuffers(source[0], 1, buffer, 0); check(); + debugMsg("update(): buffer unqueued => " + buffer[0]); active = stream(buffer[0]); + debugMsg("update(): buffer queued => " + buffer[0]); al.alSourceQueueBuffers(source[0], 1, buffer, 0); check(); processed[0]--; @@ -216,6 +248,9 @@ public class OggStreamer { return false; } + totalBytes += size; + debugMsg("stream(): buffer data => " + buffer + " totalBytes:" + totalBytes); + ByteBuffer data = ByteBuffer.wrap(pcm, 0, size); al.alBufferData(buffer, format, data, size, rate); check(); @@ -265,6 +300,14 @@ public class OggStreamer { return false; while (update()) { + // We will try sleeping for sometime so that we dont + // peg the CPU... + try { + Thread.sleep(sleepTime); + } catch (Exception e) { + e.printStackTrace(); + } + if (playing()) continue; if (!playback()) @@ -284,12 +327,23 @@ public class OggStreamer { URL url; try { - if (args.length == 0) { - url = OggStreamer.class.getClassLoader().getResource("demos/data/broken_glass.ogg"); - (new OggStreamer(url)).playstream(); - } - + boolean played = false; for (int i = 0; i < args.length; i++) { + if ("-bs".equals(args[i])) { + BUFFER_SIZE = Integer.valueOf(args[++i]).intValue(); + continue; + } + + if ("-nb".equals(args[i])) { + NUM_BUFFERS = Integer.valueOf(args[++i]).intValue(); + continue; + } + + if ("-d".equals(args[i])) { + debug = true; + continue; + } + System.err.println("Playing Ogg stream : " + args[i]); url = ((new File(args[i])).exists()) ? @@ -297,8 +351,15 @@ public class OggStreamer { if ((new OggStreamer(url)).playstream()) continue; + played = true; System.err.println("ERROR!!"); } + + if (!played) { + url = OggStreamer.class.getClassLoader().getResource("demos/data/broken_glass.ogg"); + (new OggStreamer(url)).playstream(); + } + } catch (Exception e) { e.printStackTrace(); } |