view src/samer/audio/LineSource.java @ 8:5e3cbbf173aa tip

Reorganise some more

/*
 *	LineSource.java
 *
 *	Copyright (c) 2000, Samer Abdallah, King's College London.
 *	All rights reserved.
 *
 *	This software is provided AS iS and WITHOUT ANY WARRANTY;
 *	without even the implied warranty of MERCHANTABILITY or
 *	FITNESS FOR A PARTICULAR PURPOSE.
 */

package samer.audio;
import  samer.core.*;
import  samer.tools.*;
import  java.io.*;
import  javax.sound.sampled.*;

/**
	An AudioSource that reads from the sound card in real time.
	Uses a standard JavaSound TargetDataLine to get data.
	However, an alternative DataLine can be supplied instead.
	Audio format is determined by current environment--see
	VLine.
	<p> Object is a Viewable, and is called "linein". Node is
	created in current context, ie with a parent determined by
	current Environment.
	@see samer.core.AudioSource
*/

public class LineSource extends VLine implements AudioSource
{
	private TargetDataLine	line;
	private AudioFormat	fmt;
	private int          bufsize=0;

	/** Create LineSource reading from given TargetDataLine */
	public LineSource(TargetDataLine l,AudioFormat f) throws Exception {
		super("linein"); line=l; fmt=f;
	}

	public int getChannels() { return fmt.getChannels(); }
	public float getRate() { return fmt.getFrameRate(); }
	public AudioFormat getFormat() { return fmt; }
	public void setBufferSize(int b) { bufsize=b; }

	public DataLine getLine() { return line; }
	public boolean  isOpen() { return line.isOpen(); }

	/** Open using default format */
	public void openImpl() throws Exception {
		if (bufsize==0) line.open(fmt); else line.open(fmt,bufsize);
	}

	public void closeImpl() throws Exception { line.close(); }

	public Task reader(final double dbuf[], final int off, final int len) {
		return new Reader(2*len) {
			public void run() throws Exception {
				super.run();	Util.shortToDouble(buf,dbuf,off,len);
			}
		};
	}

	public Task reader(final float dbuf[], final int off, final int len) {
		return new Reader(2*len) {
			public void run() throws Exception {
				super.run();	Util.shortToFloat(buf,dbuf,off,len);
			}
		};
	}


	protected class Reader implements Task {
		byte buf[];
		int		size;

		public Reader(int bufsize) { size=bufsize; buf=new byte[size]; }

		public void starting() { start(); }
		public void stopping() { stop(); }
		public void dispose() {}
		public void run() throws Exception {
			if (line.read(buf,0,size)<=0) throw new EOFException();
			changed();
		}
	}

	public static DataLine.Info lineInfo(AudioFormat fmt) {
		return new DataLine.Info( TargetDataLine.class, fmt); 
	}

	public static DataLine.Info lineInfo(AudioFormat fmt, int bufsize) {
		return new DataLine.Info( TargetDataLine.class, fmt, bufsize); 
	}
}