// Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of "Eclipse Public License v1.0"

// which accompanies this distribution, and is available

// at the URL "http://www.eclipse.org/legal/epl-v10.html".

//

// Initial Contributors:

// Nokia Corporation - initial contribution.

//

// Contributors:

//

// Description:

// RTCPFlowFactory Implementation

// 

//

/**

 @file

 @internalComponent

*/

#include <ss_glob.h>

#include <rtp_proto_id.h>

#include "rtpflowfactory.h"

#include "rtpflow.h"

#include "rtcpflow.h"

#include "rtppint.h"

#include "rtp_cfmessages.h"

#include "rtpflowfactory.h"

using namespace ESock;

CRtpFlowFactory* CRtpFlowFactory::NewL(TAny* aConstructionParameters)

	{

	CRtpFlowFactory* ptr = new (ELeave) CRtpFlowFactory(TUid::Uid(KRtpFlowImplementationUid), *(reinterpret_cast<CSubConnectionFlowFactoryContainer*>(aConstructionParameters)));

	CleanupStack::PushL(ptr);

	CleanupStack::Pop();

	return ptr;

	}

CRtpFlowFactory::CRtpFlowFactory(TUid aFactoryId, CSubConnectionFlowFactoryContainer& aParentContainer)

	: CSubConnectionFlowFactoryBase(aFactoryId, aParentContainer)

	{

	}

CProtocolIntfFactoryBase* CRtpFlowFactory::CreateProtocolIntfFactoryL(ESock::CProtocolIntfFactoryContainer& aParentContainer)

    {

    CProtocolIntfFactoryBase* factory = CRtpProtocolIntfFactory::NewL(Uid(), aParentContainer);

    return factory;

    }

ACommsFactoryNodeId* CRtpFlowFactory::DoFindOrCreateObjectL(TFactoryQueryBase& aQuery)

/** Default implementation to create a factory object. This may be overridden by a derived class

*/

	{

	ACommsFactoryNodeId *factoryObject = 0;

	factoryObject = CreateObjectL(aQuery);

	return factoryObject;		

	}

/* Check the MessageID and Create the appropriate Flow */

CSubConnectionFlowBase* CRtpFlowFactory::DoCreateFlowL(CProtocolIntfBase* aProtocolIntf, TFactoryQueryBase& aQuery)

	{

	CSubConnectionFlowBase* flow = 0;

	const TDefaultFlowFactoryQuery& query  = static_cast < const TDefaultFlowFactoryQuery& > (aQuery);

	TInt protocolID = (TInt)query.iProtocolType;

	if(KProtocolRtp == protocolID)

		{

		flow = CRtpFlow::NewL(*this, query.iSCprId, aProtocolIntf);

		}

	else if(KProtocolRtcp == protocolID)

		{

		flow = CRtcpFlow::NewL(*this, query.iSCprId, aProtocolIntf);

		}

	return flow;

	}

TServerProtocolDesc* CRtpFlowFactory::DoCreateFlowDescriptionL(TInt aProtocol)

	{

 	TServerProtocolDesc* protocolDescription = NULL;

     switch(aProtocol)

     	{

        case KProtocolRtp:

             protocolDescription = new(ELeave) TServerProtocolDesc();

             protocolDescription->iName        = KProtocolNameRtp;

             protocolDescription->iAddrFamily  = KAfInet;

             protocolDescription->iSockType    = KSockDatagram;

             protocolDescription->iProtocol    = KProtocolRtp;

             protocolDescription->iVersion     = TVersion(2,0,1);

             protocolDescription->iByteOrder   = EBigEndian;

             protocolDescription->iServiceInfo     = KSIConnectionLess | KSIDatagram |

                                     KSIGracefulClose | KSIPeekData |

                                     KSIRequiresOwnerInfo;

             protocolDescription->iSecurity    = KSocketNoSecurity;

             protocolDescription->iMessageSize     = 65536-128; /*KSocketMessageSizeUndefined;*/

             protocolDescription->iServiceTypeInfo  = ESocketSupport | ETransport |

                                     EPreferMBufChains | ENeedMBufs |

                                     EUseCanSend;

             protocolDescription->iNumSockets      = KUnlimitedSockets;

             break;

        case KProtocolRtcp:

             protocolDescription = new(ELeave) TServerProtocolDesc();

             protocolDescription->iName        = KProtocolNameRtcp;

             protocolDescription->iAddrFamily  = KAfInet;

             protocolDescription->iSockType    = KSockDatagram;

             protocolDescription->iProtocol    = KProtocolRtcp;

             protocolDescription->iVersion     = TVersion(2,0,1);

             protocolDescription->iByteOrder   = EBigEndian;

             protocolDescription->iServiceInfo     = KSIConnectionLess | KSIDatagram |

                                     KSIGracefulClose | KSIPeekData |

                                     KSIRequiresOwnerInfo;

             protocolDescription->iSecurity    = KSocketNoSecurity;

             protocolDescription->iMessageSize     = 65536-128; /*KSocketMessageSizeUndefined;*/

             protocolDescription->iServiceTypeInfo  = ESocketSupport | ETransport |

                                     EPreferMBufChains | ENeedMBufs |

                                     EUseCanSend;

             protocolDescription->iNumSockets      = KUnlimitedSockets;

             break;

		}

	return protocolDescription;

	}