/**

* Copyright (c) 2010 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:

* Header file declaring the RawIP Provisioning structures.

* 

*

*/

/**

 @file

 @internalTechnology

*/

#ifdef SYMBIAN_NETWORKING_CONTENTION_MANAGEMENT

#ifndef PDP_CONTENTION_H

#define PDP_CONTENTION_H

#include <comms-infras/contentionmanager.h>

class CMBMSEngine;

class CContextStatusMonitor;

class CContextTypeChecker;

class MContextEventsObserver

    {

public:

    virtual void PrimaryContextAddedL(const TName* aContextName) = 0;

    virtual void SecondaryContextAdded(const TName* aContextName) = 0;

    virtual void PrimaryContextDeleted(const CContextStatusMonitor* aContextStatusMonitor) = 0;

    virtual void ContextMonitoringError(const CContextStatusMonitor* aContextStatusMonitor, TInt aError) = 0;

    virtual void ContextTypeCheckingError(const TName* aContextName, TInt aError) = 0;

    };

class CContextStatusMonitor : public CActive

    {

public:

    CContextStatusMonitor(RPacketService& aPacketService, MContextEventsObserver& aCallback);

    ~CContextStatusMonitor();

public:

    TBool StartL(const TName& aContextName);

    inline TBool IsPassedThroughActiveState() const;

private:

    void RunL();

    void DoCancel();

    TInt RunError(TInt aError);

private:

    RPacketService& iPacketService;

    RPacketContext iPacketContext;

    RPacketContext::TContextStatus iContextStatus;

    MContextEventsObserver& iCallback;

    TName iContextName;

    TBool iWasActive;

    };

class CPrimaryContextsMonitor : public CActive, MContextEventsObserver

    {

    enum TState {EEnumeratingContexts, EGettingInfo, EListening};

public:

    CPrimaryContextsMonitor(RPacketService& aPacketService, MContentionObserver& aCallback);

    ~CPrimaryContextsMonitor();

public:

    void StartL();

// from MContextEventsObserver

    void PrimaryContextAddedL(const TName* aContextName);

    void SecondaryContextAdded(const TName* aContextName);

    void PrimaryContextDeleted(const CContextStatusMonitor* aContextStatusMonitor);

    void ContextMonitoringError(const CContextStatusMonitor* aContextStatusMonitor, TInt aError);

    void ContextTypeCheckingError(const TName* aContextName, TInt aError);

private:

    void RunL();

    void DoCancel();

    TInt RunError(TInt aError);

    void DeleteContextStatusMonitor(const CContextStatusMonitor* aContextStatusMonitor);

    void SwitchStateL();

    void StartContextStatusMonitoringL(const TName& aContextName);

    void RemoveContextNameAndCheckNext(const TName* aContextName);

    void ProcessError(TInt aError);

private:

    RPointerArray<CContextStatusMonitor> iContextMonitors;

    RPointerArray<TName> iAddedContextsNames;

    CContextTypeChecker* iContextTypeChecker;

    RPacketService& iPacketService;

    TState iState;

    RPacketService::TNifInfoV2 iCurrentNifInfo;

    TInt iInitialNifsCount;

    TInt iCurrentNifIndex;

    TBool iFirstContextAdded;

    MContentionObserver& iCallback;

    };

class CContextTypeChecker : public CActive

    {

public:

    CContextTypeChecker(RPacketService& aPacketService, MContextEventsObserver& aCallback);

    ~CContextTypeChecker();

public:

    void Start(const TName* aContextName);

    void RunL();

    TInt RunError(TInt aError);

    void DoCancel();

private:

    RPacketService& iPacketService;

    const TName* iContextName;

    MContextEventsObserver& iCallback;

    TInt iCountInNif;

    };

class CPdpContentionManager : public CContentionManager

    {

public:

    static CPdpContentionManager* NewL(const ESock::CTierManagerBase& aTierManager, RPacketService& aPacketService);

    ~CPdpContentionManager();

public:

    void StartMonitoringL();

private:

    void ConstructL(RPacketService& aPacketService);

    CPdpContentionManager(const ESock::CTierManagerBase& aTierManager);

private:

    // from CContentionManager

    virtual void ContentionResolved(const TContentionRequestItem& aContentionRequest, TBool aResult);

    virtual void ContentionOccured(ESock::CMetaConnectionProviderBase& aMcpr);

    virtual void ReportContentionAvailabilityStatus(ESock::CMetaConnectionProviderBase& aMcpr, const ESock::TAvailabilityStatus& aStatus) const;

private:

    CPrimaryContextsMonitor* iPrimaryContextsMonitor;

    };

inline TBool CContextStatusMonitor::IsPassedThroughActiveState() const

    {

    return iWasActive;

    }

#endif

#endif