www.pudn.com > simplec++codeforp2p.rar > mms.cpp

// ------------------------------------------------
// File : mms.cpp
// Date: 28-may-2003
// Author: giles
//
// (c) 2002-3 peercast.org
// ------------------------------------------------
// 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.
// ------------------------------------------------

#include "channel.h"
#include "mms.h"
#include "asf.h"

// ------------------------------------------
ASFInfo parseASFHeader(Stream &in);

 
// ------------------------------------------ 
void MMSStream::readEnd(Stream &,Channel *) 
{ 
} 

// ------------------------------------------
void MMSStream::readHeader(Stream &,Channel *)
{ 
}
// ------------------------------------------
int MMSStream::readPacket(Stream &in,Channel *ch)
{
	{
		ASFChunk chunk;

		chunk.read(in); 

		switch (chunk.type)
		{
			case 0x4824:		// asf header
			{
				MemoryStream mem(ch->headPack.data,sizeof(ch->headPack.data));

				chunk.write(mem);
 
 


				MemoryStream asfm(chunk.data,chunk.dataLen);
				ASFObject asfHead;
				asfHead.readHead(asfm);

				ASFInfo asf = parseASFHeader(asfm);
				LOG_DEBUG("ASF Info: pnum=%d, psize=%d, br=%d",asf.numPackets,asf.packetSize,asf.bitrate);
				for(int i=0; iid)
						LOG_DEBUG("ASF Stream %d : %s, br=%d",s->id,s->getTypeName(),s->bitrate);
				}

				ch->info.bitrate = asf.bitrate/1000; 
 
				ch->headPack.type = ChanPacket::T_HEAD; 
				ch->headPack.len = mem.pos; 
				ch->headPack.pos = ch->streamPos; 
				ch->newPacket(ch->headPack); 
 
				ch->streamPos += ch->headPack.len; 

				break;
			}
			case 0x4424:		// asf data
			{

				ChanPacket pack; 

				MemoryStream mem(pack.data,sizeof(pack.data));

				chunk.write(mem); 
 
				pack.type = ChanPacket::T_DATA; 
				pack.len = mem.pos; 
				pack.pos = ch->streamPos; 

				ch->newPacket(pack); 
				ch->streamPos += pack.len; 

				break;
			}
			default:
				throw StreamException("Unknown ASF chunk");

		}

	} 
	return 0;
}


// -----------------------------------
ASFInfo parseASFHeader(Stream &in)
{
	ASFInfo asf;

	try
	{
		int numHeaders = in.readLong();

		in.readChar();
		in.readChar();

		LOG_CHANNEL("ASF Headers: %d",numHeaders);
		for(int i=0; i