/**
* Copyright (c) 2004-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:
* Header file for the QoS Mapping Messages
* 
*
*/



/**
 @file qos_msg.h
*/

#ifndef __QOS_MSG_H__
#define __QOS_MSG_H__

#include <e32base.h>
#include <e32std.h>
#include <comms-infras/eintsock.h>
#include <networking/qoslib.h>
#include <elements/nm_messages_base.h>

class CPfqosStream;

class TQoSIpSCprMessages
/**
QoSIpSCpr message realm (messages specific to qosipscpr)
 

@internalComponent
*/
	{
  public:
    enum { ERealmId = 0x10204307 };

  private:
  	enum
  	    {
        EOpenInternalSocket = Messages::KNullMessageId + 1,
		EInternalSocketOpened
	    };

  public:

	typedef Messages::TMessageSigVoid<EOpenInternalSocket, TQoSIpSCprMessages::ERealmId> TOpenInternalSocket;
	typedef Messages::TMessageSigVoid<EInternalSocketOpened, TQoSIpSCprMessages::ERealmId> TInternalSocketOpened;
	};


NONSHARABLE_CLASS(CQoSMsg) : public CBase
/**
Encapsulation of a QoS PRT Message that can be stored in a 
link list of messages.

@internalComponent

@released Since v9.0
*/
	{
public:
	// Construction
	static CQoSMsg* NewL( TPfqosMessages aMsgType );
	~CQoSMsg();

	// Message Content
	inline void AddConnInfo(TUint32 aProtocol, const TUidType& aUid, TUint32 aIapId );
	void AddSrcAddr(const TInetAddr &aAddr);
	void AddDstAddr(const TInetAddr &aAddr);
	inline void AddChannel(TInt aChannelId);
	inline void AddQoSParameters(const TQoSParameters& aParameters);
	void AddExtensionPolicy(TQoSExtensionQueue& aExtensions);

	// Send Message to PRT
	void Send(RInternalSocket &aSocket, TRequestStatus& aStatus);

protected:
	// Construction
	CQoSMsg();
	void ConstructL( TPfqosMessages aMsgType );

public:
	/** QoS PRT formatted Message */
	CPfqosStream* iMsg;

	/** Message Type */
	TPfqosMessages iType;

	/** Link to next item */
	TSglQueLink iLink;
	};


class CIpSubConnectionProvider;

NONSHARABLE_CLASS(CQoSSocketOpener) : public CActive
/**
  Active object for asynchronously opening an Internal Socket

  @internalComponent
  @prototype
*/
	{
public:
	static CQoSSocketOpener* NewL(CIpSubConnectionProvider& aIpScpr, Messages::TNodeCtxId& aOriginator);
	~CQoSSocketOpener();

	void Open();
	
protected:
	CQoSSocketOpener(CIpSubConnectionProvider& aIpScpr, Messages::TNodeCtxId& aOriginator);
	
	// Active Object Implementation
	void RunL();
	void DoCancel();
	
private:
	CIpSubConnectionProvider& iIpScpr;
	Messages::TNodeCtxId iOriginator;
	};

NONSHARABLE_CLASS(CQoSMsgWriter) : public CActive
/**
Active Object that sends messages from IP Connection Provider to the QoS PRT

@internalComponent

@released Since v9.0
*/
	{
public:
	// Construction
	static CQoSMsgWriter* NewL(CIpSubConnectionProvider* aOwner, RInternalSocket& aSocket);
	~CQoSMsgWriter();

	// Send Message over Internal Socket
	void Send(CQoSMsg* aMsg);

protected:
	// Construction
	CQoSMsgWriter(CIpSubConnectionProvider* aOwner, RInternalSocket& aSocket);

	// Active Object Implementation
	void RunL();
	inline void DoCancel();

private:
	/** Message Owner */
	CIpSubConnectionProvider* iOwner;

	/** Reference to an Internal Socket */
	RInternalSocket& iSocket;

	/** Current Message */
	CQoSMsg* iCurrentMsg;

	/** List of Pending Messages */
	TSglQue<CQoSMsg> iPendingMsg;

	/** Flag Set when Active Object is shuttin down */
	TBool iClosing;
	};


NONSHARABLE_CLASS(CQoSMsgReader) : public CActive
/**
Active Object that receives messages from the QoS PRT and forwards them to the
IP Connection Provider

@internalComponent

@released Since v9.0
*/
	{
public:
	// Construction
	static CQoSMsgReader* NewL(CIpSubConnectionProvider *aOwner, RInternalSocket& aSocket);
	~CQoSMsgReader();

protected:
	// Construction
	CQoSMsgReader(CIpSubConnectionProvider* aOwner, RInternalSocket& aSocket);
	void ConstructL();

	// Active Object Implmentation
	void RunL();
	inline void DoCancel();

private:
	/** Message Owner */
	CIpSubConnectionProvider* iOwner;

	/** Reference of Internal Socket */
	RInternalSocket& iSocket;

	/** Pointer to Buffer to receive data from QoS PRT */
	TPtr8 iRecvPtr;

	/** Buffer to receive data from QoS PRT */
	HBufC8* iRecvBuf;

	/** Flag Set when Active Object is shuttin down */
	TBool iClosing;
	};

#include "qos_msg.inl"

#endif // __QOS_MSG_H__