// 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:
// ccomreadwrite.cpp
// 
//

#include "debug.h"

#include "comreadwrite.h"
#include "GLOBAL.H"

#include <e32base.h>
#include <f32file.h>
#include <c32comm.h>
#include <e32cons.h>


CComReadWrite::CComReadWrite(TInt aPriority, MComReadWriteObserver& aObserver)
				: CActive(aPriority), iObserver(aObserver)
	{
	}

CComReadWrite* CComReadWrite::NewL(MComReadWriteObserver& aObserver)
	{
	DEBUG_OPEN();
	COMRWPRINT(_L("CComReadWrite::NewL()\n"));
	
	CComReadWrite* self = new(ELeave) CComReadWrite(EPriorityHigh, aObserver);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop();
	return self;
	}

void CComReadWrite::ConstructL()
	{
	CActiveScheduler::Add(this);

	COMRWPRINT(_L("CComReadWrite::ConstructL()\n"));
	}

void CComReadWrite::Open()
	{
	// Connect to Comserver and Open IrComm port
	COMRWPRINT(_L("CComReadWrite::Open()\n"));
	TInt error;
	error = iServer.Connect();
	error = iServer.LoadCommModule(_L("IrCOMM"));
	error = iCommPort.Open(iServer,_L("IRCOMM::0"), ECommExclusive, ECommRoleDCE);
	Signal(error);
	iState = EOpen;
	}

void CComReadWrite::Close()
	{
	COMRWPRINT(_L("CComReadWrite::Close()\n"));
	Cancel();
	Signal(KErrNone);
	iState = EClose;
	}

void CComReadWrite::Signal(TInt aError)
	{
	TRequestStatus *pS=(&iStatus);
	SetActive();
	User::RequestComplete(pS,aError);
	}

CComReadWrite::~CComReadWrite()
	{
	COMRWPRINT(_L("CComReadWrite:: ~CComReadWrite()\n"));
	}

void CComReadWrite::Send(TDesC8& aBuffer)
	{
	COMRWPRINT(_L("CComReadWrite:: ESend request\n"));
	__ASSERT_DEBUG(aBuffer.Length()<= iTxBuffer.MaxLength(), User::Panic(_L("IrTranP"), KErrTooBig));
	if (!(IsActive()))
		{
		iTxBuffer.Zero();
		iTxBuffer.Copy(aBuffer);
		iCommPort.Write(iStatus, iTxBuffer);
		COMRWPRINT(_L("CComReadWrite:: iCommPort.Write cleared\n"));
		iState = ESend;
		SetActive();

		}
	else
		{
		COMRWPRINT(_L("CComReadWrite: Error\n"));
		iObserver.SendError(KErrWrite);
		}

	}

void CComReadWrite::Receive()
	{
	COMRWPRINT(_L("CComReadWrite: EReceive request\n"));
	
	// Clear the buffer and receive the next lot of data;

	iRxBuffer.Zero();
	iCommPort.ReadOneOrMore(iStatus, iRxBuffer);
	iState = EReceive;
	SetActive();
	}

void CComReadWrite::RunL()
	{
	COMRWPRINT(_L("CComReadWrite: RunL()\n"));
	
	switch (iState)
		{
	case EOpen:
		{
		if (iStatus == KErrNone)
			{
			COMRWPRINT(_L("CComReadWrite: EOpen sucessful\n"));
		  	/*TBuf8<1> buf;
			buf.SetLength(0);
			Send(buf);*/

			Receive();
			}
		else
			{
			iObserver.Error(iStatus.Int());
			}
		}
		break;
	case EStop:
		{
		iCommPort.Close();
		iServer.UnloadCommModule(_L("IrCOMM"));
		iServer.Close();
		iObserver.Error(KErrAbort);
		COMRWPRINT(_L("CComReadWrite: EStop sucessfull\n"));
		}
		break;
	case EClose:
		{
		if (iStatus == KErrNone)
			{
			iCommPort.Close();
			iServer.UnloadCommModule(_L("IrCOMM"));
			iServer.Close();
			COMRWPRINT(_L("CComReadWrite: EClose sucessfull\n"));
			}
		else
			{
			iObserver.Error(iStatus.Int());
			}
		}
		break;
	case ESend: // Send Complete
		if (iStatus == KErrNone)
			{
			COMRWPRINT(_L("CComReadWrite: ESend sucessful\n"));
			iObserver.SendComplete(); // posts read request.
			}
		else
			{
			iObserver.SendError(iStatus.Int());
			}
		break;
	case EReceive:
		{
		if (iStatus == KErrNone)
			{
			COMRWPRINT_2(_L("CComReadWrite: ERecieve sucessful %d\n"),iRxBuffer.Length());
			iObserver.ReceiveComplete(iRxBuffer);
			}
		else
			{
			iObserver.ReceiveError(iStatus.Int());
			}
		}
		break;
	default:
		User::Leave(KErrGeneral);
		break;
		}
	
	}

void CComReadWrite::DoCancel()
	{
	COMRWPRINT(_L("CComReadWrite: DoCancel()\n"));

	iCommPort.WriteCancel();
	iCommPort.ReadCancel();
	iState = EStop;
	}