// Copyright (c) 1996-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of the License "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:

// bootldr\src\ymodemb.cpp

// 

//

#define FILE_ID		0x594D4442

#include "bootldr.h"

#include <d32comm.h>

#include "ymodemu.h"

_LIT(KSerialLddName, "ECOMM");

_LIT(KSerialPddName, "EUART");

#if 0

GLREF_C void RequestSignal(TInt aCount);

GLREF_C void HandleClose(TInt aHandle);

GLREF_C TInt OpenCommPort(TInt aPort, TInt& aHandle);

GLREF_C void WriteToCommPort(TInt aHandle, TRequestStatus& aStatus, const TDesC8& aDes);

GLREF_C void CommReadOneOrMore(TInt aHandle, TRequestStatus& aStatus, TDes8& aDes);

GLREF_C void CommRead(TInt aHandle, TRequestStatus& aStatus, TDes8& aDes);

GLREF_C void CommReadCancel(TInt aHandle);

#endif 

YModemU* TheYModem;

TInt DownloadMode;

YModemU::YModemU(TBool aG)

	: YModem(aG)

	{

	}

YModemU::~YModemU()

	{

	iComm.Close();

	iTimer.Close();

	}

TInt YModemU::Create(TInt aPort)

	{

	TInt r=iComm.Open(aPort);

	if (r!=KErrNone)

		return r;

	TCommConfig cfg;

	TCommConfigV01& c=cfg();

	iComm.Config(cfg);

	c.iRate=SerialBaud;

	c.iDataBits=EData8;

	c.iStopBits=EStop1;

	c.iParity=EParityNone;

//	c.iHandshake=KConfigFreeRTS|KConfigFreeDTR;

	c.iHandshake=0;

	c.iFifo=EFifoEnable;

	c.iTerminatorCount=0;

	r=iComm.SetConfig(cfg);

	if (r!=KErrNone)

		return r;

	r=iComm.SetReceiveBufferLength(8192);

	if (r!=KErrNone)

		return r;

	return iTimer.CreateLocal();

	}

YModemU* YModemU::NewL(TInt aPort, TBool aG)

	{

	YModemU* p=new YModemU(aG);

	TInt r=p->Create(aPort);

	if (r!=KErrNone)

		{

		delete p;

		User::Leave(r);

		}

	return p;

	}

void YModemU::WriteC(TUint aChar)

	{

	TBuf8<1> b;

	b.SetLength(1);

	b[0]=(TUint8)aChar;

	TRequestStatus s;

	iComm.Write(s,b);

	User::WaitForRequest(s);

	}

TInt YModemU::ReadBlock(TDes8& aDest)

	{

	aDest.Zero();

	TRequestStatus s1, s2;

	iTimer.After(s1,iTimeout);

//	test.Printf(_L("@%dms %d\n"),User::FastCounter(),iComm.QueryReceiveBuffer());

	iComm.Read(s2,aDest);

	User::WaitForRequest(s1,s2);

	if (s2!=KRequestPending)

		{

		iTimer.Cancel();

		User::WaitForRequest(s1);

		return s2.Int();

		}

	iComm.ReadCancel();

	User::WaitForRequest(s2);

	return KErrTimedOut;

	}

TInt ReadYModemInputData(TUint8* aDest, TInt& aLength)

	{

	if( TheYModem->IsHeaderStored() )

	    {

	    DEBUG_PRINT((_L(">>ReadYModemInputData(aDest:0x%08x, aLength:%d)\r\n"), aDest, aLength))

	    TInt r = TheYModem->GetHeaderBufferContent(aDest, aLength);

	    DEBUG_PRINT((_L("<<ReadYModemInputData(aDest:0x%08x, aLength:%d):%d\r\n"), aDest, aLength, r))

	    return r;

	    }

    else

        {

        TUint8* pD=aDest;

    	TInt r=TheYModem->ReadPackets(pD,aLength);

    	aLength=pD-aDest;

    	return r;    

        }	    

	}

void CloseYModem()

	{

	DEBUG_PRINT((_L(">>CloseYModem()\r\n")));

	TBuf<256> name;

	TInt size=-1;

	TheYModem->StartDownload(DownloadMode, size, name);

	DEBUG_PRINT((_L("<<CloseYModem()\r\n")));

	}

GLDEF_C TInt InitSerialDownload(TInt aPort)

	{

//	RThread().SetSystem(ETrue);

	TInt r=LoadDriver(KSerialLddName,0);

	if (r!=KErrNone)

		BOOT_FAULT();

	r=LoadDriver(KSerialPddName,1);

	if (r!=KErrNone)

		BOOT_FAULT();

	TInt PortNumber=aPort;

	DownloadMode=KYModemGMode;

	TRAP(r,TheYModem=YModemU::NewL(PortNumber,ETrue));

	if (r!=KErrNone || TheYModem==NULL)

		BOOT_FAULT();

//	r=YModemB::New(TheYModem,PortNumber,DownloadMode);

//	TEST(r==KErrNone && TheYModem!=NULL);

	YModemU* pY=TheYModem;

	TBuf<256> name;

	r=pY->StartDownload(DownloadMode, FileSize, name);

	if (r!=KErrNone)

		return r;

#ifdef __SUPPORT_UNZIP__

	if (name.Length()>=4 && name.Right(4).MatchF(_L(".zip"))==0 && FileSize!=0)

		ImageZip=ETrue;

	else

#endif

		ImageZip=EFalse;

#ifdef __SUPPORT_FLASH_REPRO__

	if (name.Length()>=8 && (name.Left(8).MatchF(_L("FLASHIMG"))==0 || name.Left(8).MatchF(_L("FLASHLDR"))==0) && FileSize!=0)

		{

		LoadToFlash=ETrue;

		if (name.Left(8).MatchF(_L("FLASHLDR"))==0)

			FlashBootLoader=ETrue;

		}

	else

#endif

		LoadToFlash=EFalse;

    if (!ImageZip)

        {

        r = pY->GetInnerCompression(ImageDeflated, RomLoaderHeaderExists);

        if(KErrNone != r)

            {

            PrintToScreen(_L("Unable to determine the compression!\r\n"));

		    BOOT_FAULT();    

            }

        }

	LoadDevice=ELoadSerial;

	InputFunction=ReadYModemInputData;

	CloseInputFunction=CloseYModem;

	FileName=name;

	return KErrNone;

	}