diff -r 000000000000 -r bde4ae8d615e os/kernelhwsrv/kerneltest/e32test/misc/ymodemu.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/os/kernelhwsrv/kerneltest/e32test/misc/ymodemu.cpp Fri Jun 15 03:10:57 2012 +0200 @@ -0,0 +1,102 @@ +// Copyright (c) 1998-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: +// e32test\misc\ymodemu.cpp +// +// + +#include +#include +#include +#include "ymodemu.h" + +//#include +//GLREF_C RTest test; + +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=EBps115200; + 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::NTickCount(),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; + } +