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

// IrLAN data send/receive active objects 

// 

//

/**

 @file

*/

#include <nifman.h>

#include <nifvar.h>

#include <nifutl.h>

#include <es_mbuf.h>

#include "PKTDRV.H"

#include "IRLAN.H"

#include "IRLANUTL.H"

#include "IRLANBUF.H"

#include "INTSOCK.H"

//#define __TRACEWIN__

#ifdef __TRACEWIN__

  #include <log.h>

#else

  #define LOG(a)

#endif

//############################ IrLAN Sender ############################

/**

Constructor.

*/

CIrlanSender::CIrlanSender() : CActive(EIrlanSenderPriority)

{

	__DECLARE_NAME(_S("CIrlanSender"));

}

/**

Destructor.

*/

CIrlanSender::~CIrlanSender()

{

#ifdef __TRACEWIN__

	LOG(Log::Printf(_L("IRLAN	~CIrlanSender\r\n")));

#endif

}

/**

Create a new CIrlanSender object.

@param aParent A pointer to CIrlanControlEngine object.

@param aSock A pointer to CInternalSocket object.

@return A pointer to CIrlanSender class.

*/

CIrlanSender* CIrlanSender::NewL(CIrlanControlEngine* aParent,CInternalSocket* aSock)

{

#ifdef __TRACEWIN__

	LOG(Log::Printf(_L("IRLAN	CIrlanSender::NewL\r\n")));

#endif

	CIrlanSender *sd=new (ELeave) CIrlanSender;

	CleanupStack::PushL(sd);

	sd->InitL(aParent,aSock);

	CActiveScheduler::Add(sd);

	CleanupStack::Pop();

	return sd;

}

/**

Add the newly created object to an object container

@param aParent A pointer to CIrlanControlEngine object.

@param aSock A pointer to CInternalSocket object.

*/

void CIrlanSender::InitL(CIrlanControlEngine* aParent,CInternalSocket* aSock)

{

	iParent=aParent;

	iDataSock=aSock;

}

/**

Waits to read the data from the Queue.

@param aPdu A reference to the packet to be sent (really an RMBufPkt)

*/

void CIrlanSender::QueueSend(RMBufChain& aPdu)

{

	if (iDataSock->Write(aPdu,NULL,iStatus,0)!=static_cast<TUint>(KErrNone))

		IrlanUtil::Panic(EIrlanDataWrite);

	SetActive();

}

/**

Initiate sending for tha data.

*/

void CIrlanSender::KickSender()

{

	if (IsActive())

		return;

	else

		SeeIfPacketToSend();

}

/**

Check in Queue whether the packet to send.

*/

void CIrlanSender::SeeIfPacketToSend()

{

	RMBufChain pkt;

	if (iParent->iDataSendQ.Remove(pkt))

		{

		QueueSend(pkt);

		pkt.Free();

		}

}

/**

Handles an active object’s request completion event.

*/

void CIrlanSender::RunL()

{

	TInt ret=iStatus.Int();

	if (ret!=KErrNone)

		{

#ifdef __TRACEWIN__

	LOG(Log::Printf(_L("IRLAN	Data send failed with err=%d\r\n"),ret));

#endif

		iParent->HandleErrorL();

		return;

		}

	SeeIfPacketToSend();

}

/**

cancellation of an outstanding request.

*/

void CIrlanSender::DoCancel()

{

	iDataSock->CancelSend();

}

//############################ IrLAN Receiver ############################

/**

Constructor.

*/

CIrlanReceiver::CIrlanReceiver() : CActive(EIrlanReceiverPriority)

{

	__DECLARE_NAME(_S("CIrlanReceiver"));

}

/**

Destructor.

*/

CIrlanReceiver::~CIrlanReceiver()

{

	DoCancel();

}

/**

Create a new CIrlanReceiver object.

@param aParent A pointer to CIrlanControlEngine object.

@param aSock A pointer to CInternalSocket object.

@return A pointer to CIrlanReceiver class.

*/

CIrlanReceiver* CIrlanReceiver::NewL(CIrlanControlEngine* aParent,CInternalSocket* aSock)

{

#ifdef __TRACEWIN__

	LOG(Log::Printf(_L("IRLAN	CIrlanReceiver::NewL\r\n")));

#endif

	CIrlanReceiver *rv=new (ELeave) CIrlanReceiver;

	CleanupStack::PushL(rv);

	rv->InitL(aParent,aSock);

	CActiveScheduler::Add(rv);

	CleanupStack::Pop();

	return rv;

}

/**

Add the newly created object to an object container

@param aParent A pointer to CIrlanControlEngine object.

@param aSock A pointer to CInternalSocket object.

*/

void CIrlanReceiver::InitL(CIrlanControlEngine* aParent,CInternalSocket* aSock)

{

	iParent=aParent;

	iDataSock=aSock;

}

/**

Waits to read the data from the Queue.

*/

void CIrlanReceiver::QueueRead()

{

#ifdef __TRACEWIN__

	LOG(Log::Printf(_L("IRLAN	QUEUEING WAIT FOR DATA\r\n")));

#endif

	iParent->iRecvBufPtr.SetLength(iParent->iRecvBufLength);

	TInt ret;

	ret = iDataSock->Recv(iParent->iRecvBufPtr,NULL,iStatus,0);

	if (ret!=KErrNone)

		{// what do we do here - panic?

		IrlanUtil::Panic(EIrlanDataRead);

		}

	SetActive();

}

/**

Handles an active object’s request completion event.

*/

void CIrlanReceiver::RunL()

{

	TInt ret=iStatus.Int();

	if (ret!=KErrNone)

		{

#ifdef __TRACEWIN__

	LOG(Log::Printf(_L("IRLAN	Data receive failed with err=%d\r\n"),ret));

#endif

		iParent->HandleErrorL();

		return;

		}

	iParent->ProcessReceivedPacketL();

	QueueRead();

}

/**

cancellation of an outstanding request.

*/

void CIrlanReceiver::DoCancel()

{

	iDataSock->CancelRecv();

}