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

#include "serial.h"
#include "TestMgr.h"
//
//	Serial Listener Active Object - receive commands on the serial port
//

CSerialListener::CSerialListener(RComm* aCommPort, CTestMgr* aController)
: CActive(CActive::EPriorityStandard), iCommPort(aCommPort), iController(aController)
{
}

CSerialListener* CSerialListener::NewL(RComm* aCommPort, CTestMgr* aController)
{
	CSerialListener* self = new (ELeave) CSerialListener(aCommPort, aController);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop();	// self
	CActiveScheduler::Add(self);
	return self;
}

void CSerialListener::ConstructL()
{
}

CSerialListener::~CSerialListener()
{
	Cancel();
}

void CSerialListener::Recv()
{
	// read data from Comm port
	iCommPort->Read(iStatus, iDataBuffer);
	SetActive();
}

void CSerialListener::RunL()
{
	iLastBuffer = iDataBuffer;
	// notify controller we have read something
	iController->Notify(CTestMgr::EReadComplete);
	// start the listener again
	Recv();
}

void CSerialListener::DoCancel()
{
	iCommPort->ReadCancel();
}
//
//	Serial Sender Active Object - send commands on the serial port
//

CSerialSender* CSerialSender::NewL(RComm* aCommPort, CTestMgr* aController)
{
	CSerialSender* self = new (ELeave) CSerialSender(aCommPort, aController);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop();	// self
	CActiveScheduler::Add(self);
	return self;
}

void CSerialSender::ConstructL()
{
}

CSerialSender::~CSerialSender()
{
	Cancel();
}

void CSerialSender::Send(TBuffer&  aBuff)
{
	if (!IsActive())
	{
		// take a local copy of data to send
		iDataBuffer = aBuff;
		// send the data
		iCommPort->Write(iStatus, iDataBuffer);
		SetActive();
	}
}

CSerialSender::CSerialSender(RComm* aCommPort, CTestMgr* aController)
: CActive(CActive::EPriorityStandard), iCommPort(aCommPort), iController(aController)
{
}

void CSerialSender::RunL()
{
	// notify controller that send has finished
	iController->Notify(CTestMgr::EWriteComplete);
}

void CSerialSender::DoCancel()
{
	iCommPort->WriteCancel();
}