| Methods Summary |
|---|
| public void | connect()Connect to the device. It in turn calls openDev to do the
real work.
// Return if it's already connected.
if (isConnected())
return;
if (DSound.isOpen()) {
Log.warning("DSound is already opened for rendering. Will capture at the default format.");
format = null;
}
openDev();
if (pushThread == null) {
if ( /*securityPrivelege && */ (jmfSecurity != null) ) {
String permission = null;
try {
if (jmfSecurity.getName().startsWith("jmf-security")) {
permission = "thread";
jmfSecurity.requestPermission(mSecurity, clSecurity, argsSecurity,
JMFSecurity.THREAD);
mSecurity[0].invoke(clSecurity[0], argsSecurity[0]);
permission = "thread group";
jmfSecurity.requestPermission(mSecurity, clSecurity, argsSecurity,
JMFSecurity.THREAD_GROUP);
mSecurity[0].invoke(clSecurity[0], argsSecurity[0]);
} else if (jmfSecurity.getName().startsWith("internet")) {
PolicyEngine.checkPermission(PermissionID.THREAD);
PolicyEngine.assertPermission(PermissionID.THREAD);
}
} catch (Throwable e) {
if (JMFSecurityManager.DEBUG) {
System.err.println( "Unable to get " + permission +
" privilege " + e);
}
securityPrivelege = false;
// TODO: Do the right thing if permissions cannot
// be obtained.
// User should be notified via an event
}
}
if ( (jmfSecurity != null) && (jmfSecurity.getName().startsWith("jdk12"))) {
try {
Constructor cons = jdk12CreateThreadAction.cons;
pushThread = (PushThread) jdk12.doPrivM.invoke(
jdk12.ac,
new Object[] {
cons.newInstance(
new Object[] {
PushThread.class,
})});
} catch (Exception e) {
// System.out.println("Exception: creating pushThread");
}
} else {
pushThread = new PushThread();
}
pushThread.setSourceStream(this);
}
if (reconnect)
Log.comment("Capture buffer size: " + bufSize);
devFormat = format;
reconnect = false;
|
| public void | disconnect()
if (dSound == null)
return;
/*
dataLine.drain();
*/
dSound.stop();
dSound.close();
dSound = null;
devFormat = null;
if (pushThread != null) {
pushThread.kill();
pushThread = null;
}
|
| public java.lang.Object[] | getControls()
return controls;
|
| public javax.media.Format | getFormat()
return format;
|
| public static javax.media.Format[] | getSupportedFormats()
return supported;
|
| public boolean | isConnected()
return devFormat != null;
|
| void | openDev()Open the capture device.
if (format != null) {
int frameSize = (format.getSampleSizeInBits() * format.getChannels())/8;
if (frameSize == 0)
frameSize = 1;
bufSize = (int)(format.getSampleRate() * frameSize *
bc.getBufferLength() / 1000);
} else {
}
if (!DSound.isFormatSupported(format, bufSize))
throw new IOException("Cannot open audio device for input.");
try {
dSound = new DSoundST(format, bufSize);
dSound.open();
format = dSound.getFormat();
bufSize = dSound.getBufferSize();
} catch (Exception e) {
Log.error("Cannot open audio device for input: " + e);
throw new IOException(e.getMessage());
}
|
| public static javax.media.Format | parseLocator(javax.media.MediaLocator ml)Parse the javasound media locator which specifies the format.
A valid media locator is of the form:
javasound://[rate]/[sizeInBits]/[channels]/[big|little]/[signed|unsigned]
int rate, bits, channels, endian, signed;
String rateStr = null, bitsStr = null, channelsStr = null;
String endianStr = null, signedStr = null;
// Parser the media locator to extract the requested format.
String remainder = ml.getRemainder();
if (remainder != null && remainder.length() > 0) {
while (remainder.length() > 1 && remainder.charAt(0) == '/")
remainder = remainder.substring(1);
// Now see if there's a sample rate specified.
int off = remainder.indexOf('/");
if (off == -1) {
if (!remainder.equals(""))
rateStr = remainder;
} else {
rateStr = remainder.substring(0, off);
remainder = remainder.substring(off + 1);
// Now see if there's a sample size specified
off = remainder.indexOf('/");
if (off == -1) {
if (!remainder.equals(""))
bitsStr = remainder;
} else {
bitsStr = remainder.substring(0, off);
remainder = remainder.substring(off + 1);
// Now see if there's a channels specified
off = remainder.indexOf('/");
if (off == -1) {
if (!remainder.equals(""))
channelsStr = remainder;
} else {
channelsStr = remainder.substring(0, off);
remainder = remainder.substring(off + 1);
// Now see if there's endian specified.
off = remainder.indexOf('/");
if (off == -1) {
if (!remainder.equals(""))
endianStr = remainder;
} else {
endianStr = remainder.substring(0, off);
if (!remainder.equals(""))
signedStr = remainder.substring(off + 1);
}
}
}
}
}
// Sample Rate
rate = DefRate;
if (rateStr != null) {
try {
Integer integer = Integer.valueOf(rateStr);
if (integer != null)
rate = integer.intValue();
} catch (Throwable t) { }
// Range check.
if (rate <= 0 || rate > 96000) {
Log.warning("DSound capture: unsupported sample rate: " + rate);
rate = DefRate;
Log.warning(" defaults to: " + rate);
}
}
// Sample Size
bits = DefBits;
if (bitsStr != null) {
try {
Integer integer = Integer.valueOf(bitsStr);
if (integer != null)
bits = integer.intValue();
} catch (Throwable t) { }
// Range check.
if (bits != 8 && bits != 16) {
Log.warning("DSound capture: unsupported sample size: " + bits);
bits = DefBits;
Log.warning(" defaults to: " + bits);
}
}
// # of channels
channels = DefChannels;
if (channelsStr != null) {
try {
Integer integer = Integer.valueOf(channelsStr);
if (integer != null)
channels = integer.intValue();
} catch (Throwable t) { }
// Range check.
if (channels != 1 && channels != 2) {
Log.warning("DSound capture: unsupported # of channels: " + channels);
channels = DefChannels;
Log.warning(" defaults to: " + channels);
}
}
// Endian
endian = DefEndian;
if (endianStr != null) {
if (endianStr.equalsIgnoreCase("big"))
endian = AudioFormat.BIG_ENDIAN;
else if (endianStr.equalsIgnoreCase("little"))
endian = AudioFormat.LITTLE_ENDIAN;
else {
Log.warning("DSound capture: unsupported endianess: " + endianStr);
Log.warning(" defaults to: big endian");
}
}
// Signed
signed = DefSigned;
if (signedStr != null) {
if (signedStr.equalsIgnoreCase("signed"))
signed = AudioFormat.SIGNED;
else if (signedStr.equalsIgnoreCase("unsigned"))
signed = AudioFormat.UNSIGNED;
else {
Log.warning("DSound capture: unsupported signedness: " + signedStr);
Log.warning(" defaults to: signed");
}
}
AudioFormat fmt;
fmt = new AudioFormat(AudioFormat.LINEAR,
rate, bits, channels, endian, signed);
return fmt;
|
| public void | read(javax.media.Buffer in)
Buffer buffer;
Object data;
synchronized (cb) {
while (!cb.canRead()) {
try {
cb.wait();
} catch (Exception e) {}
}
buffer = cb.read();
}
// Swap data with the input buffer and my own buffer.
data = in.getData();
in.copy(buffer);
buffer.setData(data);
synchronized (cb) {
cb.readReport();
cb.notify();
}
|
| public javax.media.Format | setFormat(javax.media.Format fmt)Set the capture format.
if (started) {
Log.warning("Cannot change audio capture format after started.");
return format;
}
if (fmt == null)
return format;
javax.media.Format f = null;
for (int i = 0; i < supported.length; i++) {
if (fmt.matches(supported[i]) &&
(f = fmt.intersects(supported[i])) != null) {
break;
}
}
if (f == null)
return format;
try {
if (devFormat != null) {
if (!devFormat.matches(f) && !DSound.isOpen()) {
// Can't change format if DirectSound is already opened
// for rendering.
//System.err.println("The capture format has changed.");
format = (AudioFormat)f;
disconnect();
connect();
}
} else {
format = (AudioFormat)f;
connect();
}
} catch (IOException e) {
return null;
}
if (afc != null)
afc.setCurrentFormat(format);
return format;
|
| public void | setTransferHandler(javax.media.protocol.BufferTransferHandler th)
transferHandler = th;
|
| public void | start()Start capturing.
if (dSound == null)
throw new IOException("A DirectSound input channel cannot be opened.");
if (started)
return;
// Check if the GUI control has specified a new format.
if (afc != null) {
Format f;
if ((f = afc.getFormat()) != null && !f.matches(format)) {
if (setFormat(f) == null) {
//System.err.println("The chosen format is not supported.");
}
}
afc.setEnabled(false);
}
// Disconnect the source if the reconnect flag is on.
if (reconnect)
disconnect();
// Connect the source if it's not already connected.
if (!isConnected())
connect();
// Flush the old data.
synchronized (cb) {
while (cb.canRead()) {
cb.read();
cb.readReport();
}
cb.notifyAll();
}
dSound.flush();
dSound.start();
pushThread.start();
started = true;
|
| public void | stop()Stop the capture.
if (!started)
return;
pushThread.pause();
if (dSound != null)
dSound.stop();
started = false;
if (afc != null && !DSound.isOpen())
afc.setEnabled(true);
|
| public boolean | willReadBlock()
return !started;
|
