// 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 "ss_datamon_apiext.h"
#include <comms-infras/datamonmessagesecom.h>
#include <elements/responsemsg.h>


#ifdef _DEBUG
// Panic category for "absolutely impossible!" vanilla ASSERT()-type panics from this module
// (if it could happen through user error then you should give it an explicit, documented, category + code)
_LIT(KSpecAssert_ESockSSocksdtmnp, "ESockSSocksdtmnp");
#endif

using namespace ESock;
using namespace Elements;

EXPORT_C void CDataMonitoringResponder::DataTransferred(CDataMonitoringResponder*& aThis, TUint32 aReceivedBytes, TUint32 aSentBytes)
	{
	if (aThis==NULL)
		return;

	aThis->DoDataTransferred(aReceivedBytes, aSentBytes);
	delete aThis;
	aThis = NULL;
	}
	
EXPORT_C void CDataMonitoringResponder::DataSentNotification(CDataMonitoringResponder*& aThis, TUint32 aSentBytes)
	{
	if (aThis==NULL)
		return;

	aThis->DoDataSentNotification(aSentBytes);
	delete aThis;
	aThis = NULL;
	}
	
EXPORT_C void CDataMonitoringResponder::DataReceivedNotification(CDataMonitoringResponder*& aThis, TUint32 aReceivedBytes)
	{
	if (aThis==NULL)
		return;

	aThis->DoDataReceivedNotification(aReceivedBytes);
	delete aThis;
	aThis = NULL;
	}

EXPORT_C void CDataMonitoringResponder::CancelRequest(CDataMonitoringResponder*& aThis)
	{
	if (aThis==NULL)
		return;

	aThis->DoCancelRequest();
	delete aThis;
	aThis = NULL;
	}

EXPORT_C void CDataMonitoringResponder::Error(CDataMonitoringResponder*& aThis, TInt aError)
	{
	if (aThis==NULL)
		return;

	aThis->DoComplete(aError);
	delete aThis;
	aThis = NULL;
	}

/**
	Completes the client's request for the amount of data transferred.
	
	@param aReceivedBytes The number of bytes received for communication to the client.	
	@param aSentBytes The number of bytes sent for communication to the client.
*/
void CDataMonitoringResponder::DoDataTransferred(TUint32 aReceivedBytes, TUint32 aSentBytes)
	{
	__ASSERT_DEBUG(iMsg == NULL, User::Panic(KSpecAssert_ESockSSocksdtmnp, 1));
	TRAP_IGNORE(iMsg = CDataTransferred::NewL());

	if(iMsg == NULL)
		{
		iResponseMsg.Complete(KErrNoMemory);
		return;
		}

	CDataTransferred& msg = static_cast<CDataTransferred&>(*iMsg);	
	
	msg.SetReceivedBytes(aReceivedBytes);
	msg.SetSentBytes(aSentBytes);

	iResponseMsg.Complete(msg);
	}
	
/**
	Completes the client's notification request for a data sent threshold.
	
	@param aSentBytes The number of bytes sent for communication to the client.
*/
void CDataMonitoringResponder::DoDataSentNotification(TUint32 aSentBytes)
	{	
	__ASSERT_DEBUG(iMsg == NULL, User::Panic(KSpecAssert_ESockSSocksdtmnp, 2));
	TRAP_IGNORE(iMsg = CDataSent::NewL());

	if(iMsg == NULL)
		{
		iResponseMsg.Complete(KErrNoMemory);
		return;
		}

	CDataSent& msg = static_cast<CDataSent&>(*iMsg);
	msg.SetSentBytes(aSentBytes);

	iResponseMsg.Complete(msg);
	}

/**
	Completes the client's notification request for a data received threshold.
	
	@param aReceivedBytes The number of bytes received for communication to the client.
*/
void CDataMonitoringResponder::DoDataReceivedNotification(TUint32 aReceivedBytes)
	{
	__ASSERT_DEBUG(iMsg == NULL, User::Panic(KSpecAssert_ESockSSocksdtmnp, 3));
	TRAP_IGNORE(iMsg = CDataReceived::NewL());

	if(iMsg == NULL)
		{
		iResponseMsg.Complete(KErrNoMemory);
		return;
		}
				
	CDataReceived& msg = static_cast<CDataReceived&>(*iMsg);
	msg.SetReceivedBytes(aReceivedBytes);

	iResponseMsg.Complete(msg);
	}

/**
	Cancels the outstanding response request.
*/
void CDataMonitoringResponder::DoCancelRequest()
	{
	iResponseMsg.Complete(KErrCancel);
	}

EXPORT_C CDataMonitoringResponder* CDataMonitoringResponder::NewL(Elements::RResponseMsg& aResponseMsg)
	{
	return new(ELeave) CDataMonitoringResponder(aResponseMsg);
	}

CDataMonitoringResponder::CDataMonitoringResponder(Elements::RResponseMsg& aResponseMsg)
	: CCommsApiExtIpcResponder(aResponseMsg)
	{
	}

CDataMonitoringResponder::~CDataMonitoringResponder()
	{
	delete iMsg;
	}