import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
 * Add conversion support for any MpegEncoding source with FrameRate or FrameSize not empty.
 * @param targetFormat
 * @param sourceFormat
 * @return
 */
public boolean isConversionSupported(AudioFormat targetFormat, AudioFormat sourceFormat)
{
	if (TDebug.TraceAudioConverter) 
	{
				TDebug.out(">MpegFormatConversionProvider.isConversionSupported(AudioFormat targetFormat, AudioFormat sourceFormat):");
				TDebug.out("checking if conversion possible");
				TDebug.out("from: " + sourceFormat);
				TDebug.out("to: " + targetFormat);
	}

	boolean conversion = super.isConversionSupported(targetFormat, sourceFormat);
	if (conversion == false)
	{
		AudioFormat.Encoding enc = sourceFormat.getEncoding();
		if (enc instanceof MpegEncoding)
		{
			if ((sourceFormat.getFrameRate() != AudioSystem.NOT_SPECIFIED) || (sourceFormat.getFrameSize() != AudioSystem.NOT_SPECIFIED))
			{
				conversion = true;
			}
		}
	}
	return conversion;
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
 * Extract
 * @param s
 * @param start
 * @param end
 * @return
 */
private String chopSubstring(String s, int start, int end)
{
    String str = null;
    // 11/28/04 - String encoding bug fix.
    try
    {
        str = s.substring(start, end);
        int loc = str.indexOf('\0');
        if (loc != -1) str = str.substring(0, loc);
    }
    catch (StringIndexOutOfBoundsException e)
    {
        // Skip encoding issues.
        if (TDebug.TraceAudioFileReader) TDebug.out("Cannot chopSubString " + e.getMessage());
    }
    return str;
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
 * Parse Text Frames.
 *
 * @param bframes
 * @param offset
 * @param size
 * @param skip
 * @return
 */
protected String parseText(byte[] bframes, int offset, int size, int skip)
{
    String value = null;
    try
    {
        String[] ENC_TYPES = { "ISO-8859-1", "UTF16", "UTF-16BE", "UTF-8" };
        value = new String(bframes, offset + skip, size - skip, ENC_TYPES[bframes[offset]]);
        value = chopSubstring(value, 0, value.length());
    }
    catch (UnsupportedEncodingException e)
    {
        if (TDebug.TraceAudioFileReader) TDebug.out("ID3v2 Encoding error :" + e.getMessage());
    }
    return value;
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
 * Reads from the oggBitStream_ a specified number of Bytes(bufferSize_) worth
 * starting at index and puts them in the specified buffer[].
 *
 * @param buffer
 * @param index
 * @param bufferSize_
 * @return             the number of bytes read or -1 if error.
 */
private int readFromStream(byte[] buffer, int index, int bufferSize_)
{
  int bytes = 0;
  try
  {
    bytes = oggBitStream_.read(buffer, index, bufferSize_);
  }
  catch(Exception e)
  {
    if(TDebug.TraceAudioConverter) TDebug.out("Cannot Read Selected Song");
    bytes = -1;
  }
  currentBytes = currentBytes + bytes;
  return bytes;
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
  * Return the AudioFileFormat from the given file.
  */
 public AudioFileFormat getAudioFileFormat(File file) throws UnsupportedAudioFileException, IOException
 {
if (TDebug.TraceAudioFileReader) TDebug.out("getAudioFileFormat(File file)");
   InputStream inputStream = null;
   try
   {	  
  inputStream = new BufferedInputStream(new FileInputStream(file));	
  inputStream.mark(MARK_LIMIT);	    
  AudioFileFormat aff = getAudioFileFormat(inputStream);
  inputStream.reset();
     // Get Vorbis file info such as length in seconds.
     VorbisFile vf = new VorbisFile(file.getAbsolutePath());      
     return getAudioFileFormat(inputStream,(int) file.length(), (int) Math.round((vf.time_total(-1))*1000));
   }
catch (JOrbisException e)
{
	throw new IOException(e.getMessage());
}
  finally
  {
    if (inputStream != null) inputStream.close();
  }
 }
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
 * Reads from the oggBitStream_ a specified number of Bytes(bufferSize_) worth
 * starting at index and puts them in the specified buffer[].
 *
 * @return the number of bytes read or -1 if error.
 */
private int readFromStream(byte[] buffer, int index, int bufferSize_)
{
  int bytes = 0;
  try
  {
    bytes = oggBitStream_.read(buffer, index, bufferSize_);
  }
  catch (Exception e)
  {
    if (TDebug.TraceAudioFileReader)
    {
      TDebug.out("Cannot Read Selected Song");
    }
    bytes = -1;
  }
  return bytes;
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
public String getEncoderVersion() {
	byte[] string=new byte[300];
	int res=nGetEncoderVersion(string);
	if (res<0) {
		if (res==-1) {
			throw new RuntimeException("Unexpected error in Lame.getEncoderVersion()");
		}
		handleNativeException(res);
	}
	String sRes="";
	if (res>0) {
		try {
			sRes=new String(string, 0, res, "ISO-8859-1");
		} catch (UnsupportedEncodingException uee) {
			if (TDebug.TraceAllExceptions) {
				TDebug.out(uee);
			}
			sRes=new String(string, 0, res);
		}
	}
	return sRes;
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
 * workaround for missing paramtrization possibilities 
 * for FormatConversionProviders
 */
private void readParameters() {
	String v=getStringProperty("quality", quality2string(DEFAULT_QUALITY));
	DEFAULT_QUALITY=string2quality(v.toLowerCase(), DEFAULT_QUALITY);
	DEFAULT_BITRATE=getIntProperty("bitrate", DEFAULT_BITRATE);
	v=getStringProperty("chmode", chmode2string(DEFAULT_CHANNEL_MODE));
	DEFAULT_CHANNEL_MODE=string2chmode(v.toLowerCase(), DEFAULT_CHANNEL_MODE);
	DEFAULT_VBR = getBooleanProperty("vbr", DEFAULT_VBR);
	// set the parameters back so that user program can verify them
	try {
		System.setProperty(PROPERTY_PREFIX + "quality", quality2string(DEFAULT_QUALITY));
		System.setProperty(PROPERTY_PREFIX + "bitrate", String.valueOf(DEFAULT_BITRATE));
		System.setProperty(PROPERTY_PREFIX + "chmode", chmode2string(DEFAULT_CHANNEL_MODE));
		System.setProperty(PROPERTY_PREFIX + "vbr", String.valueOf(DEFAULT_VBR));
	}
	catch (Throwable t)
	{
		if (TDebug.TraceAllExceptions)
		{
			TDebug.out(t);
		}
	}
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
private static int getIntProperty(String strName, int def)	{
	String	strPropertyName = PROPERTY_PREFIX + strName;
	int	value = def;
	try {
		String strValue = System.getProperty(strPropertyName, String.valueOf(def));
		value=new Integer(strValue).intValue();
	}
	catch (Throwable e)
	{
		if (TDebug.TraceAllExceptions)
		{
			TDebug.out(e);
		}
	}
	return value;
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
private void closePhysicalStream()
{
	if (TDebug.TraceAudioConverter) TDebug.out("DecodedJorbisAudioInputStream.closePhysicalStream(): begin");
	m_oggSyncState.clear();
	try
	{
		if (m_oggBitStream != null)
		{
			m_oggBitStream.close();
		}
		getCircularBuffer().close();
	}
	catch (Exception e)
	{
		if (TDebug.TraceAllExceptions) { TDebug.out(e); }
	}
	if (TDebug.TraceAudioConverter) TDebug.out("DecodedJorbisAudioInputStream.closePhysicalStream(): end");
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
 * Returns AudioFileFormat from URL.
 */
       @Override
public AudioFileFormat getAudioFileFormat(URL url) throws UnsupportedAudioFileException, IOException
{		
	if (TDebug.TraceAudioFileReader) {TDebug.out("MpegAudioFileReader.getAudioFileFormat(URL): begin"); }
	long lFileLengthInBytes = AudioSystem.NOT_SPECIFIED;
	URLConnection conn = url.openConnection();
	// Tell shoucast server (if any) that SPI support shoutcast stream.
	conn.setRequestProperty ("Icy-Metadata", "1");		
	InputStream	inputStream = conn.getInputStream();
	AudioFileFormat	audioFileFormat = null;
	try
	{
		audioFileFormat = getAudioFileFormat(inputStream, lFileLengthInBytes);
	}
	finally
	{
		inputStream.close();
	}
	if (TDebug.TraceAudioFileReader) {TDebug.out("MpegAudioFileReader.getAudioFileFormat(URL): end"); }
	return audioFileFormat;
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
 * Returns AudioFileFormat from URL.
 */
public AudioFileFormat getAudioFileFormat(URL url)
		throws UnsupportedAudioFileException, IOException
{
	if (TDebug.TraceAudioFileReader)
	{
		TDebug.out("MpegAudioFileReader.getAudioFileFormat(URL): begin");
	}
	long lFileLengthInBytes = AudioSystem.NOT_SPECIFIED;
	URLConnection conn = url.openConnection();
	// Tell shoucast server (if any) that SPI support shoutcast stream.
	conn.setRequestProperty("Icy-Metadata", "1");
	InputStream inputStream = conn.getInputStream();
	AudioFileFormat audioFileFormat = null;
	try
	{
		audioFileFormat = getAudioFileFormat(inputStream, lFileLengthInBytes);
	}
	finally
	{
		inputStream.close();
	}
	if (TDebug.TraceAudioFileReader)
	{
		TDebug.out("MpegAudioFileReader.getAudioFileFormat(URL): end");
	}
	return audioFileFormat;
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**	
 * Constructor.
 */
public MpegFormatConversionProvider()
{
	super(Arrays.asList(INPUT_FORMATS), Arrays.asList(OUTPUT_FORMATS));
	if (TDebug.TraceAudioConverter) 
	{
		TDebug.out(">MpegFormatConversionProvider()");
	}
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
public AudioInputStream getAudioInputStream(AudioFormat targetFormat, AudioInputStream audioInputStream)
{
	if (TDebug.TraceAudioConverter) 
	{
		TDebug.out(">MpegFormatConversionProvider.getAudioInputStream(AudioFormat targetFormat, AudioInputStream audioInputStream):");
	}
	return new DecodedMpegAudioInputStream(targetFormat, audioInputStream);
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
 * Skip frames.
 * You don't need to call it severals times, it will exactly skip given frames number.
 * @param frames
 * @return bytes length skipped matching to frames skipped.
 */
public long skipFrames(long frames)
{
	if (TDebug.TraceAudioConverter) TDebug.out("skip(long frames) : begin");		
	int framesRead = 0;
	int bytesReads = 0;
	try
	{
		for (int i=0;i<frames;i++)
		{
			Header header = m_bitstream.readFrame();
			if (header != null)
			{
				int fsize = header.calculate_framesize();					
				bytesReads = bytesReads + fsize;
			} 
			m_bitstream.closeFrame();
			framesRead++;
		} 
	}
	catch (BitstreamException e)
	{
		if (TDebug.TraceAudioConverter) TDebug.out(e);
	}
	if (TDebug.TraceAudioConverter) TDebug.out("skip(long frames) : end");
	currentFrame = currentFrame + framesRead;
	return bytesReads;
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
public MpegAudioFileReader()
{
    super(MARK_LIMIT, true);
    if (TDebug.TraceAudioFileReader) TDebug.out(VERSION);
    try
    {
        weak = System.getProperty("mp3spi.weak");
    }
    catch (AccessControlException e)
    {
    }
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
 * Returns AudioFileFormat from URL.
 */
public AudioFileFormat getAudioFileFormat(URL url) throws UnsupportedAudioFileException, IOException
{
    if (TDebug.TraceAudioFileReader)
    {
        TDebug.out("MpegAudioFileReader.getAudioFileFormat(URL): begin");
    }
    long lFileLengthInBytes = AudioSystem.NOT_SPECIFIED;
    URLConnection conn = url.openConnection();
    // Tell shoucast server (if any) that SPI support shoutcast stream.
    conn.setRequestProperty("Icy-Metadata", "1");
    InputStream inputStream = conn.getInputStream();
    AudioFileFormat audioFileFormat = null;
    try
    {
        audioFileFormat = getAudioFileFormat(inputStream, lFileLengthInBytes);
    }
    finally
    {
        inputStream.close();
    }
    if (TDebug.TraceAudioFileReader)
    {
        TDebug.out("MpegAudioFileReader.getAudioFileFormat(URL): end");
    }
    return audioFileFormat;
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
/**
 * Return the AudioInputStream from the given InputStream.
 */
public AudioInputStream getAudioInputStream(InputStream inputStream) throws UnsupportedAudioFileException, IOException
{
    if (TDebug.TraceAudioFileReader) TDebug.out("MpegAudioFileReader.getAudioInputStream(InputStream inputStream)");
    if (!inputStream.markSupported()) inputStream = new BufferedInputStream(inputStream);
    return super.getAudioInputStream(inputStream);
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
private void continueFromBufferFull()
{
  if(getCircularBuffer().availableWrite() < 2 * vorbisInfo.channels * bout)
  {
    if(TDebug.TraceAudioConverter) TDebug.out("Too much data in this data packet, better return, let the channel drain, and try again...");
    // Don't change play state.
    return;
  }
  getCircularBuffer().write(convbuffer, 0, 2 * vorbisInfo.channels * bout);
  // Don't change play state. Let outputSamples change play state, if necessary.
  outputSamples();
}
 

import org.tritonus.share.TDebug; //导入依赖的package包/类
private void dumpInternalState()
{
	TDebug.out("m_lReadPos  = " + m_lReadPos + " ^= "+getReadPos());
	TDebug.out("m_lWritePos = " + m_lWritePos + " ^= "+getWritePos());
	TDebug.out("availableRead()  = " + availableRead());
	TDebug.out("availableWrite() = " + availableWrite());
}