// 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;

 	}