diff -r 000000000000 -r 1bce908db942 natfw/natfwstunplugin/src/cstunasynccallback.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/natfw/natfwstunplugin/src/cstunasynccallback.cpp Tue Feb 02 01:04:58 2010 +0200 @@ -0,0 +1,246 @@ +/* +* Copyright (c) 2007 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: +* +*/ + + + + +#include "mnatfwpluginobserver.h" +#include "cstunasynccallback.h" + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::NewL +// --------------------------------------------------------------------------- +// +CStunAsyncCallback* CStunAsyncCallback::NewL( + const CNATFWPluginApi& aStunPlugin, + MNATFWPluginObserver& aObserver ) + { + CStunAsyncCallback* self + = new (ELeave) CStunAsyncCallback( aStunPlugin, aObserver ); + CActiveScheduler::Add( self ); + self->WaitForRequestsL(); + return self; + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::CStunAsyncCallback +// --------------------------------------------------------------------------- +// +CStunAsyncCallback::CStunAsyncCallback( + const CNATFWPluginApi& aStunPlugin, + MNATFWPluginObserver& aObserver ) + : + CActive( EPriorityStandard ), + iStunPlugin( aStunPlugin ), + iObserver( aObserver ), + iPendingCallbacks( _FOFF( TStunPluginCallbackInfo, iLink ) ) + { + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::CStunAsyncCallback +// Dummy implementation. Default constructor is declared private and not used. +// --------------------------------------------------------------------------- +// +CStunAsyncCallback::CStunAsyncCallback() : + CActive( EPriorityStandard ), + iStunPlugin( *( CNATFWPluginApi* )0x1 ), + iObserver( *( MNATFWPluginObserver* )0x1 ) + { + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::CStunAsyncCallback +// Dummy implementation, as copy constructor is declared private and not used. +// --------------------------------------------------------------------------- +// +CStunAsyncCallback::CStunAsyncCallback( + const CStunAsyncCallback& aAsyncCallback ) : + CActive( EPriorityStandard ), + iStunPlugin( *( CNATFWPluginApi* )0x1 ), + iObserver( aAsyncCallback.iObserver ) + { + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::~CStunAsyncCallback +// --------------------------------------------------------------------------- +// +CStunAsyncCallback::~CStunAsyncCallback() + { + Cancel(); + + TStunPluginCallbackInfo* callback = iPendingCallbacks.First(); + while ( iPendingCallbacks.IsFirst( callback ) && + !iPendingCallbacks.IsEmpty() ) + { + iPendingCallbacks.Remove( *callback ); + delete callback; + callback = iPendingCallbacks.First(); + } + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::DoCancel +// --------------------------------------------------------------------------- +// +void CStunAsyncCallback::DoCancel() + { + if ( iStatus == KRequestPending ) + { + TRequestStatus* status = &iStatus; + User::RequestComplete( status, KErrCancel ); + } + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::RunL +// --------------------------------------------------------------------------- +// +void CStunAsyncCallback::RunL() + { + WaitForRequestsL(); + ExecuteFirstCallback(); + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::RunError +// Currently RunL cannot leave. +// --------------------------------------------------------------------------- +// +TInt CStunAsyncCallback::RunError( TInt aError ) + { + if ( aError == KErrNoMemory ) + { + return aError; + } + return KErrNone; + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::MakeCallbackL +// --------------------------------------------------------------------------- +// +void CStunAsyncCallback::MakeCallbackL( + TStunPluginCallbackInfo::TFunction aFunction, + TUint aStreamId, + TInt aErrorCode, + TAny* aEventData ) + { + TStunPluginCallbackInfo* callback = + new ( ELeave ) TStunPluginCallbackInfo( iStunPlugin, + iObserver, + aFunction, + aStreamId, + aErrorCode, + aEventData ); + CleanupStack::PushL( callback ); + __ASSERT_ALWAYS( callback->Validate(), User::Leave( KErrArgument ) ); + CleanupStack::Pop( callback ); + + // CActive::iActive won't tell whether User::RequestComplete has already + // been called, so iStatus is inspected to see whether a previous call to + // AddDeleteRequestL has already called User::RequestComplete. + + if ( iStatus == KRequestPending ) + { + Wakeup(); + } + + iPendingCallbacks.AddLast( *callback ); + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::CancelCallback +// --------------------------------------------------------------------------- +// +void CStunAsyncCallback::CancelCallback( TUint aStreamId ) + { + TSglQueIter iter( iPendingCallbacks ); + + for ( TStunPluginCallbackInfo* callback = iter++; + callback; callback = iter++ ) + { + if ( callback->iStreamId == aStreamId ) + { + iPendingCallbacks.Remove( *callback ); + delete callback; + } + } + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::ExecuteFirstCallback +// Handle one callback request and wait for the next one. If there are more +// callbacks, complete the asynchronous request so that RunL will soon be +// called again. Don't call more than one callback, since upper layer +// might've deleted STUN plugin, causing CStunAsyncCallback to be deleted too. +// For the same reason nothing is done after executing the callback. +// --------------------------------------------------------------------------- +// +void CStunAsyncCallback::ExecuteFirstCallback() + { + TStunPluginCallbackInfo* callback = iPendingCallbacks.First(); + if ( iPendingCallbacks.IsFirst( callback ) && + !iPendingCallbacks.IsEmpty() ) + { + iPendingCallbacks.Remove( *callback ); + + if ( !iPendingCallbacks.IsEmpty() ) + { + Wakeup(); + } + + callback->Execute(); + delete callback; + } + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::WaitForRequestsL +// --------------------------------------------------------------------------- +// +void CStunAsyncCallback::WaitForRequestsL() + { + __ASSERT_ALWAYS( !IsActive(), User::Leave( KErrNotReady ) ); + + iStatus = KRequestPending; + SetActive(); + } + + +// --------------------------------------------------------------------------- +// CStunAsyncCallback::Wakeup +// --------------------------------------------------------------------------- +// +void CStunAsyncCallback::Wakeup() + { + TRequestStatus* status = &iStatus; + User::RequestComplete( status, KErrNone ); + }