diff -r 6b1d113cdff3 -r 6638e7f4bd8f telephonyprotocols/rawipnif/version1/src/Receiver.cpp --- a/telephonyprotocols/rawipnif/version1/src/Receiver.cpp Mon May 03 13:37:20 2010 +0300 +++ b/telephonyprotocols/rawipnif/version1/src/Receiver.cpp Thu May 06 15:10:38 2010 +0100 @@ -1,106 +1,106 @@ -// Copyright (c) 2002-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: -// Implements the active object that controls the Read() requests. -// -// - -/** - @file -*/ - -#include "Receiver.h" -#include "Constants.h" - - -CReceiver::CReceiver(CBcaIoController& aObserver, CBttLogger* aTheLogger) -/** - * Constructor. Performs standard active object initialisation. - * - * @param aObserver Reference to the observer of this state machine - * @param aTheLogger The logging object - */ - : CActive(EPriorityNormal), - iObserver(aObserver), - iTheLogger(aTheLogger) - { - CActiveScheduler::Add(this); - } - -CReceiver::~CReceiver() -/** - * Destructor. - */ - { - Cancel(); - } - -void CReceiver::RunL() -/** - * Method called when read request completes. This will only be once the BCA has a full IP - * packet in its buffer. - */ - { - _LOG_L1C2(_L8("CReceiver::RunL [iStatus=%d]"), iStatus.Int()); - - if (iStatus!=KErrNone) - { - if(iStatus == KErrNoMemory) - { - _LOG_L2C1( - _L8("WARNING! CReceiver: Read failed with KErrNoMemory")); - // Read operation failed!! Nif will re-issue the read request. - StartListening(); - } - else - { - _LOG_L2C1(_L8("WARNING! CReceiver: Read failed")); - iObserver.Stop(iStatus.Int()); - } - return; - } - - _LOG_L1C1(_L8("CReceiver: Data Packet Received")); - - // Process Ip packet - iObserver.Process(iData); - - // The packet received was processed. NIF can start listening - // for another one. - StartListening(); - - } - -void CReceiver::DoCancel() -/** - * Cancel active request - */ - { - _LOG_L1C1(_L8("CReceiver::DoCancel")); - - (iObserver.Bca())->CancelRead(); - } - -void CReceiver::StartListening() -/** - * This method issues a Read request. This is the API used to receive - * packets from BCA. - */ - { - _LOG_L1C1(_L8("CReceiver::StartListening")); - - // The BCA will complete this read once it has a full IP packet in its buffer. - (iObserver.Bca())->Read(iStatus, iData); - - SetActive(); - } +// Copyright (c) 2002-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: +// Implements the active object that controls the Read() requests. +// +// + +/** + @file +*/ + +#include "Receiver.h" +#include "Constants.h" + + +CReceiver::CReceiver(CBcaIoController& aObserver, CBttLogger* aTheLogger) +/** + * Constructor. Performs standard active object initialisation. + * + * @param aObserver Reference to the observer of this state machine + * @param aTheLogger The logging object + */ + : CActive(EPriorityNormal), + iObserver(aObserver), + iTheLogger(aTheLogger) + { + CActiveScheduler::Add(this); + } + +CReceiver::~CReceiver() +/** + * Destructor. + */ + { + Cancel(); + } + +void CReceiver::RunL() +/** + * Method called when read request completes. This will only be once the BCA has a full IP + * packet in its buffer. + */ + { + _LOG_L1C2(_L8("CReceiver::RunL [iStatus=%d]"), iStatus.Int()); + + if (iStatus!=KErrNone) + { + if(iStatus == KErrNoMemory) + { + _LOG_L2C1( + _L8("WARNING! CReceiver: Read failed with KErrNoMemory")); + // Read operation failed!! Nif will re-issue the read request. + StartListening(); + } + else + { + _LOG_L2C1(_L8("WARNING! CReceiver: Read failed")); + iObserver.Stop(iStatus.Int()); + } + return; + } + + _LOG_L1C1(_L8("CReceiver: Data Packet Received")); + + // Process Ip packet + iObserver.Process(iData); + + // The packet received was processed. NIF can start listening + // for another one. + StartListening(); + + } + +void CReceiver::DoCancel() +/** + * Cancel active request + */ + { + _LOG_L1C1(_L8("CReceiver::DoCancel")); + + (iObserver.Bca())->CancelRead(); + } + +void CReceiver::StartListening() +/** + * This method issues a Read request. This is the API used to receive + * packets from BCA. + */ + { + _LOG_L1C1(_L8("CReceiver::StartListening")); + + // The BCA will complete this read once it has a full IP packet in its buffer. + (iObserver.Bca())->Read(iStatus, iData); + + SetActive(); + }