uiplayer.java

java语言开发的P2P流媒体系统

/* Stream-2-Stream - Peer to peer television and radio
 * October 13, 2005 - This file has been modified from the original P2P-Radio source
 * Project homepage: http://s2s.sourceforge.net/
 * Copyright (C) 2005-2006 Jason Hooks
 */

/* 
 * P2P-Radio - Peer to peer streaming system
 * Project homepage: http://p2p-radio.sourceforge.net/
 * Copyright (C) 2003-2004 Michael Kaufmann <[e-mail]>
 * 
 * ---------------------------------------------------------------------------
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 * ---------------------------------------------------------------------------
 */

package p2pradio.players;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;

import p2pradio.Messages;
import p2pradio.event.*;
import p2pradio.gui.*;
import p2pradio.logging.*;
import p2pradio.event.*;

public class UIPlayer extends Player implements MetadataChangedListener, HeaderChangedListener
{	
	private UI ui;
	private FileOutputStream outgoingStreamDump;
	private static final boolean saveMetadataToo = false;
	private boolean headerHasChanged;
	
	public UIPlayer(ListenBuffer buffer, UI ui)
	{
		super(buffer);
		outgoingStreamDump = null;
		this.ui = ui;
		headerHasChanged = false;
	}
	
	public String getMIMEType()
	{
		return "*/*"; //$NON-NLS-1$
	}
	
	public void run()
	{
		buffer.addMetadataChangedListener(this);
		buffer.addHeaderChangedListener(this);
	
		buffer.getReady();
		
		byte data[] = null;
		int offset = 0;
		int length = 0;
		
		if (headerHasChanged && outgoingStreamDump != null)
		{
			// Den Header schreiben
			try {
				buffer.writeHeader(outgoingStreamDump);
			} catch (IOException e) {
			}
			headerHasChanged = false;
		}

		int i =0;
		while(true)
		{
			buffer.nextDataPacket();
			if(outgoingStreamDump != null)
			{
				data = buffer.getData();
				offset = buffer.getDataOffset();
				length = buffer.getDataLength();
				if (headerHasChanged && buffer.getMetadata().getContentType().toLowerCase().equals("application/ogg")) //$NON-NLS-1$
				{
					// Bei Ogg ist das normal. Neuen Header schreiben
					try {
						buffer.writeHeader(outgoingStreamDump);
					} catch (IOException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					headerHasChanged = false;	
				}
				/*
				if (data == null)
					System.out.println("null");
				else
					System.out.println("" + data.length);*/
				
				
				try {
					outgoingStreamDump.write(data, offset, length);
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			ui.updateTime(buffer.getTimeStamp());
		}
	}
	
	public void metadataChanged(MetadataChangedEvent e)
	{
		ui.updateMetadata(buffer.getMetadata());
	}
	public void headerChanged(HeaderChangedEvent e)
	{
		headerHasChanged = true;
	}
	public void recordStream(File file)
	{
		Logger.info("UIPlayer","UIPlayer.RECORD_STREAM", file);
		try {
			outgoingStreamDump = new FileOutputStream(file, true);
		} catch (FileNotFoundException e) {
		}	
	}
	public void stopRecording()
	{
		try {
			outgoingStreamDump.close();
			outgoingStreamDump = null;
			Logger.info("UIPlayer", "UIPlayer.RECORDING_STOPPED");
		} catch (IOException e) {
			Logger.info("UIPlayer", "UIPlayer.RECORDING_COULD_NOT_BE_STOPPED");
		}
		
	}
	//public void timeChanged
}