diff -r 000000000000 -r 1bce908db942 multimediacommsengine/mmcefloorctrlplugin/src/fcreceiver.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/multimediacommsengine/mmcefloorctrlplugin/src/fcreceiver.cpp Tue Feb 02 01:04:58 2010 +0200 @@ -0,0 +1,152 @@ +/* +* Copyright (c) 2005-2006 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: fcreceiver.cpp +* +*/ + + + + +#include "fcreceiver.h" + +// ----------------------------------------------------------------------------- +// CFCReceiver::NewL +// ----------------------------------------------------------------------------- +// +CFCReceiver* CFCReceiver::NewL(RSocket& aSocket, MFCNotifier& aMFCNotifier) + { + CFCReceiver* self = NewLC(aSocket, aMFCNotifier); + CleanupStack::Pop(self); + return self; + } + +// ----------------------------------------------------------------------------- +// CFCReceiver::NewLC +// ----------------------------------------------------------------------------- +// +CFCReceiver* CFCReceiver::NewLC(RSocket& aSocket, MFCNotifier& aMFCNotifier) + { + CFCReceiver* self = new(ELeave) CFCReceiver(aSocket, aMFCNotifier); + CleanupStack::PushL(self); + self->ConstructL(); + return self; + } + +// ----------------------------------------------------------------------------- +// CFCReceiver::ConstructL +// ----------------------------------------------------------------------------- +// +void CFCReceiver::ConstructL() + { + iReceivedMsg = HBufC8::NewL(KMaxMessageLength); + CActiveScheduler::Add(this); + } + +// ----------------------------------------------------------------------------- +// CFCReceiver::CFCReceiver +// ----------------------------------------------------------------------------- +// +CFCReceiver::CFCReceiver(RSocket& aSocket, MFCNotifier& aMFCNotifier) +: CActive(EPriorityStandard), +iFCNotifier(aMFCNotifier), +iReceivedMsgPtr(0,0,0), +iSocket(aSocket) + { + } + +// ----------------------------------------------------------------------------- +// CFCReceiver::~CFCReceiver +// ----------------------------------------------------------------------------- +// +CFCReceiver::~CFCReceiver() + { + delete iReceivedMsg; + } + +// ----------------------------------------------------------------------------- +// CFCReceiver::DoCancel +// ----------------------------------------------------------------------------- +// +void CFCReceiver::DoCancel() + { + iSocket.CancelRecv(); + } + +// ----------------------------------------------------------------------------- +// CFCReceiver::Listen +// ----------------------------------------------------------------------------- +// +void CFCReceiver::Listen() + { + if(!IsActive()) + { + iReceivedMsgPtr.Set (iReceivedMsg->Des()); + iSocket.RecvFrom(iReceivedMsgPtr, iAddr, 0, iStatus); + SetActive(); + } + } + +// ----------------------------------------------------------------------------- +// CFCReceiver::RunL +// ----------------------------------------------------------------------------- +// +void CFCReceiver::RunL() + { + switch(iStatus.Int()) + { + case KErrNone: + { + HBufC8* data = HBufC8::NewL(iReceivedMsg->Length()); + TPtr8 cptr = data->Des(); + cptr.Copy(*iReceivedMsg); + ReceivedData(data); + Listen(); + break; + } + case KErrCancel: + break; + case KErrNoMemory: + { + User::Leave(iStatus.Int()); + break; + } + default: + + iFCNotifier.ErrorNotify(iStatus.Int()); + break; + } + } + +// ----------------------------------------------------------------------------- +// CFCReceiver::ReceivedDataL +// ----------------------------------------------------------------------------- +// +void CFCReceiver::ReceivedData(HBufC8* aData) + { + iFCNotifier.ReceivedData(aData) ; + } + +// ----------------------------------------------------------------------------- +// CFCReceiver::RunError +// ----------------------------------------------------------------------------- +// +TInt CFCReceiver::RunError(TInt aError) + { + Listen(); + if (aError != KErrNoMemory) + { + return KErrNone; + } + return aError; + }