muxnode.java

FMJ（freedom media for java)是java视频开发的新选择

package net.sf.fmj.filtergraph;

import javax.media.Buffer;
import javax.media.Format;
import javax.media.Multiplexer;
import javax.media.ResourceUnavailableException;

/**
 * 
 * @author Ken Larson
 *
 */
public class MuxNode extends FilterGraphNode
{
	private final Format inputFormat;
	private final Multiplexer mux;

	public MuxNode(Multiplexer mux, Format inputFormat)
	{
		super(mux);
		this.inputFormat = inputFormat;
		this.mux = mux;
	}
	
	public FilterGraphNode duplicate()
	{
		return propagateDuplicate(new MuxNode(getMultiplexer(), getInputFormat()));
		
	}

	public Format getInputFormat()
	{
		return inputFormat;
	}

	public Multiplexer getMultiplexer()
	{
		return mux;
	}
	
	public void open() throws ResourceUnavailableException
	{
		getMultiplexer().open();
	}
	
	public int process(final Buffer input, final int sourceTrackNumber, final int destTrackNumber, final int flags)
	{
		if (input.getFormat() == null)
			input.setFormat(getInputFormat());	// TODO: is this right?  JMF appears to set the format in between demux track read adnd mux process.
		
		final int processResult = getMultiplexer().process(input, destTrackNumber);	// TODO: check return code
		// TODO: set buffer1 format if it is not set?
		if (processResult != Multiplexer.BUFFER_PROCESSED_OK)
		{
			if (processResult == Multiplexer.OUTPUT_BUFFER_NOT_FILLED)
				logger.finer("Multiplexer process result: " + processResult);	// this is common, so don't pollute the log.
			else
				logger.warning("Multiplexer process result: " + processResult);
				
			// TODO: set discard in buffer or any other flags?
			// TODO: check any other buffer flags?
		}
		
		return processResult;

	}
	
	

	public void addDestLink(FilterGraphLink n)
	{
		throw new UnsupportedOperationException();
	}
}