packetlist.java

一个不错的多媒体传输程序

/*
 * Movino J2ME Client
 * Copyright (C) 2007  Johannes Berg
 * 
 * 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., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
 */

package org.movino.connection;

import java.io.IOException;
import java.util.Vector;

public class PacketList {

	private ImagePacket lastImagePacket;
	
	private Vector miscPackets;
	
	public PacketList(){
		lastImagePacket=null;
		miscPackets = new Vector();
	}
	
	public void addPacket(MovinoPacket packet){
		if(packet instanceof ImagePacket) lastImagePacket = (ImagePacket)packet;
		else{
			synchronized(miscPackets){
				miscPackets.addElement(packet);
			}
		}
	}

	public void flushPackets(MovinoConnection conn) throws IOException{
		ImagePacket last_img = lastImagePacket;
		if(last_img!=null) conn.writePacket(last_img);
		lastImagePacket=null;
		
		MovinoPacket[] packets;
		synchronized(miscPackets){
			packets = new MovinoPacket[miscPackets.size()];
			for(int i=0;i<packets.length;i++){
				packets[i] = (MovinoPacket)miscPackets.elementAt(i);
			}
			miscPackets.removeAllElements();
		}
		
		for(int i=0;i<packets.length;i++){
			conn.writePacket(packets[i]);
		}
	}

	public boolean hasPackets() {
		if(lastImagePacket!=null) return true;
		return miscPackets.size()>0;
	}
}