/*
* Copyright (c) 2002-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:  
*     This class implements notifications from bearers which is needed when
*     transferring data to/from WAP GW.
*
*/



// INCLUDE FILES
#include    <es_sock.h>

#include    "mmsbearerstatus.h"
#include    "mmssession.h"
#include    "mmstransportobserver.h"
#include    "mmsservercommon.h"
#include    "MmsServerDebugLogging.h"

// ================= MEMBER FUNCTIONS =======================

// ---------------------------------------------------------
// C++ constructor
// ---------------------------------------------------------
//
CMmsBearerStatus::CMmsBearerStatus()
    :CActive ( EPriorityStandard),
    iRequester ( NULL ),
    iConnected( EFalse ),
    iSuspended( EFalse )
    {
    iBearerType = EMmsBearerGprs; // default
    }

// ---------------------------------------------------------
// CMmsBearerStatus::ConstructL
// ---------------------------------------------------------
//
void CMmsBearerStatus::ConstructL( RConnection& aRConnection )
    {
    LOG( _L("CMmsBearerStatus::ConstructL") );
    iRConnection = &aRConnection;
    CActiveScheduler::Add( this );
    }

// ---------------------------------------------------------
// Symbian two-phased constructor
// ---------------------------------------------------------
//
CMmsBearerStatus* CMmsBearerStatus::NewL( RConnection& aRConnection )
    {
    CMmsBearerStatus* self = new ( ELeave ) CMmsBearerStatus();
    CleanupStack::PushL( self );
    self->ConstructL( aRConnection );
    CleanupStack::Pop( self );
    return self;
    }
    
// ---------------------------------------------------------
// Destructor
// ---------------------------------------------------------
//
CMmsBearerStatus::~CMmsBearerStatus()
    {
    Cancel();
    }

// ---------------------------------------------------------
// CMmsBearerStatus::IsGprs
// ---------------------------------------------------------
//
TBool CMmsBearerStatus::IsGprs() const
    {
    if( iBearerType == EMmsBearerGprs )
        {
        return ETrue;
        }
    else
        {
        return EFalse;
        }
    }

// ---------------------------------------------------------
// CMmsBearerStatus::IsSuspendedL
// ---------------------------------------------------------
//
TBool CMmsBearerStatus::IsSuspended()
    {
    if( iBearerType != EMmsBearerGprs )
        {
        LOG( _L("CMmsBearerStatus::IsSuspended: Something wrong, no GPRS!") );
        return EFalse;
        }
    TNifProgress nifProgress;
    TInt err = iRConnection->Progress( nifProgress );
    if( err == KErrNone )
        {
        if( nifProgress.iStage == KDataTransferTemporarilyBlocked )
            {
            iSuspended = ETrue;
            return ETrue;
            }
        }
    return EFalse;
    }

// ---------------------------------------------------------
// CMmsBearerStatus::SubscribeNotification
// ---------------------------------------------------------
//
void CMmsBearerStatus::SubscribeNotification( MMmsTransportObserver* aRequester )
    {
    LOG( _L("CMmsBearerStatus::SubscribeNotification") );
    
    iRequester = ( MMmsTransportObserver* ) aRequester;
    // set status to pending to make sure that it is RNif
    // that sets it to complete
    iStatus = KRequestPending;
    iRConnection->ProgressNotification( iProgressBuffer, iStatus );

#ifndef _NO_MMSS_LOGGING_
    if( IsActive() )
        {
        LOG( _L(" - already active") );
        }
#endif  //_NO_MMSS_LOGGING_
    SetActive();
    }

// ---------------------------------------------------------
// CMmsBearerStatus::RunL
// ---------------------------------------------------------
//
void CMmsBearerStatus::RunL()
    {
#ifndef _NO_MMSS_LOGGING_
    if( iStatus.Int() != KErrNone )
        {
        LOG2( _L("ERROR in CMmsBearerStatus::RunL status %d)"), iStatus.Int() );
        }
    LOG2( _L("CMmsBearerStatus::RunL(): progress stage %d"), iProgressBuffer().iStage );
#endif  //_NO_MMSS_LOGGING_


    if( iProgressBuffer().iStage == KLinkLayerClosed && iConnected )
        {
        iConnected = EFalse;
        iRequester->TransferCancelled();
        }
    else if( iProgressBuffer().iStage == KLinkLayerOpen ) 
        {
        iConnected = ETrue;
        if( iSuspended )
            {
            iSuspended = EFalse;
            iRequester->GprsResumed();
            // GprsResumed() puts the observer (this) active if necessary
            }
        else
            {
            SubscribeNotification( iRequester );
            }
        }
    else if( iProgressBuffer().iStage == KDataTransferTemporarilyBlocked )
        {
        iSuspended = ETrue;
        iRequester->GprsSuspended();
        SubscribeNotification( iRequester );
        }
    else
        {
        // Some other state, not really interested about those...
        SubscribeNotification( iRequester );        
        }    
    }

// ---------------------------------------------------------
// CMmsBearerStatus::DoCancel
// ---------------------------------------------------------
//
void CMmsBearerStatus::DoCancel()
    {
    LOG( _L("CMmsBearerStatus::DoCancel") );
    iRConnection->CancelProgressNotification();
    }

// ================= OTHER EXPORTED FUNCTIONS ==============

//  End of File