// Copyright (c) 2006-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:

//

/**

 @file

 @internalTechnology

*/

#include "datamonitormessages.h"

#include <comms-infras/ss_datamon_apiext.h> // MDataMonitorProtocolReq

#include <elements/responsemsg.h> 		// CResponseMsg

using namespace ESock;

using namespace Elements;

using namespace NetInterfaces;

enum TMobilityRequestMessages

	{

	EDataMonitoringMsgRequestDataTransferred = 0,

	EDataMonitoringMsgCancelDataTransferredRequest,

	EDataMonitoringMsgRequestDataSentNotification,

	EDataMonitoringMsgCancelDataSentNotificationRequest,

	EDataMonitoringMsgRequestDataReceivedNotification,

	EDataMonitoringMsgCancelDataReceivedNotificationRequest,

	};

/*-------------------------------------------------------

	Client -> Server messages

  -------------------------------------------------------*/

EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TRequestDataTransferred, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgRequestDataTransferred)

END_ATTRIBUTE_TABLE()

EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TCancelDataTransferredRequest, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgCancelDataTransferredRequest)

END_ATTRIBUTE_TABLE()

EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TRequestDataSentNotification, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgRequestDataSentNotification)

	REGISTER_ATTRIBUTE(TRequestDataSentNotification, iDelta, TMeta<TUint>)

	REGISTER_ATTRIBUTE(TRequestDataSentNotification, iSentBytes, TMeta<TUint>)

END_ATTRIBUTE_TABLE()

EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TCancelDataSentNotificationRequest, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgCancelDataSentNotificationRequest)

END_ATTRIBUTE_TABLE()

EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TRequestDataReceivedNotification, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgRequestDataReceivedNotification)

	REGISTER_ATTRIBUTE(TRequestDataReceivedNotification, iDelta, TMeta<TUint>)

	REGISTER_ATTRIBUTE(TRequestDataReceivedNotification, iReceivedBytes, TMeta<TUint>)

END_ATTRIBUTE_TABLE()

EXPORT_START_ATTRIBUTE_TABLE_AND_FN(TCancelDataReceivedNotificationRequest, KDataMonitoringRequestMessagesImplementationUid, EDataMonitoringMsgCancelDataReceivedNotificationRequest)

END_ATTRIBUTE_TABLE()

EXPORT_C void TRequestDataTransferred::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)

	{

	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));

	CDataMonitoringResponder* responder = CDataMonitoringResponder::NewL(aResponseMsg);

	i->RequestDataTransferred(responder, aSubSessionUniqueId);

	}

EXPORT_C void TCancelDataTransferredRequest::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)

	{

	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));

	i->CancelDataTransferredRequest(aSubSessionUniqueId);

	aResponseMsg.Complete(KErrNone);

	}

EXPORT_C void TRequestDataReceivedNotification::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)

	{

	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));

	CDataMonitoringResponder* responder = CDataMonitoringResponder::NewL(aResponseMsg);

	i->RequestDataReceivedNotification(responder, iDelta, iReceivedBytes, aSubSessionUniqueId);

	}

EXPORT_C void TCancelDataReceivedNotificationRequest::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)

	{

	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));

	i->CancelDataReceivedNotificationRequest(aSubSessionUniqueId);

	aResponseMsg.Complete(KErrNone);

	}

EXPORT_C void TRequestDataSentNotification::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)

	{

	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));

	CDataMonitoringResponder* responder = CDataMonitoringResponder::NewL(aResponseMsg);

	i->RequestDataSentNotification(responder, iDelta, iSentBytes, aSubSessionUniqueId);

	}

EXPORT_C void TCancelDataSentNotificationRequest::DispatchL(NetInterfaces::TInterfaceControl& aIntfCtrl, const TSubSessionUniqueId& aSubSessionUniqueId, Elements::RResponseMsg& aResponseMsg)

	{

	ADataMonitoringProtocolReq* i = reinterpret_cast<ADataMonitoringProtocolReq*>(aIntfCtrl.FetchInterfaceL(EDataMonitoringApiExt));

	i->CancelDataSentNotificationRequest(aSubSessionUniqueId);

	aResponseMsg.Complete(KErrNone);

	}

DEFINE_MVIP_CTR(TRequestDataTransferred);

DEFINE_MVIP_CTR(TCancelDataTransferredRequest);

DEFINE_MVIP_CTR(TRequestDataSentNotification);

DEFINE_MVIP_CTR(TCancelDataSentNotificationRequest);

DEFINE_MVIP_CTR(TRequestDataReceivedNotification);

DEFINE_MVIP_CTR(TCancelDataReceivedNotificationRequest);

const TImplementationProxy DataMonitoringReqMsgImplementationTable[] =

	{

	MVIP_CTR_ENTRY(EDataMonitoringMsgRequestDataTransferred, TRequestDataTransferred),

	MVIP_CTR_ENTRY(EDataMonitoringMsgCancelDataTransferredRequest, TCancelDataTransferredRequest),

	MVIP_CTR_ENTRY(EDataMonitoringMsgRequestDataSentNotification, TRequestDataSentNotification),

	MVIP_CTR_ENTRY(EDataMonitoringMsgCancelDataSentNotificationRequest, TCancelDataSentNotificationRequest),

	MVIP_CTR_ENTRY(EDataMonitoringMsgRequestDataReceivedNotification, TRequestDataReceivedNotification),

	MVIP_CTR_ENTRY(EDataMonitoringMsgCancelDataReceivedNotificationRequest, TCancelDataReceivedNotificationRequest),

	};

EXPORT_C CDataMonitoringMsgPluginInfo* CDataMonitoringMsgPluginInfo::NewL(TAny* /* aParams */)

	{

	return new(ELeave) CDataMonitoringMsgPluginInfo();

	}

EXPORT_C const TImplementationProxy* CDataMonitoringMsgPluginInfo::ImplementationProxy() const

	{

	return DataMonitoringReqMsgImplementationTable;

	}

EXPORT_C TInt CDataMonitoringMsgPluginInfo::ImplementationProxyTableSize() const

	{

	return sizeof(DataMonitoringReqMsgImplementationTable) / sizeof(DataMonitoringReqMsgImplementationTable[0]);

	}