/*

* 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:  

*

*/

#ifndef C_CATALOGSHTTPSESSIONMANAGER_H

#define C_CATALOGSHTTPSESSIONMANAGER_H

#include "catalogshttpsessionmanager.h"

#include "catalogshttptypes.h"

#include "catalogsconnectionmethod.h"

#include "catalogsconnection.h"

class CCatalogsNetworkManager;

class CDocumentHandler;

class CCatalogsHttpSessionManager : public CActive,

    public MCatalogsHttpSessionManager,

    public MCatalogsConnectionObserver,

    public MCatalogsConnectionStateObserver

    {

    public:

        /**

         * Maximum number of concurrently running operations.

         *

         */

        static const TInt KMaxConcurrentOperations = 8;

        /**

         * Minimum number of running downloads. In other words, there can

         * be only (KMaxConcurrentOperations - KMinDownloads) number of

         * running transactions

         */

        static const TInt KMinDownloads = 4;

        /** 

         * Minimum number of running transactions. In other words, there can

         * be only (KMaxConcurrentOperations - KMinTransactions) number of

         * running downloads

         */

        static const TInt KMinTransactions = 4;

    public:

        /**

        * NewL

        */

        static CCatalogsHttpSessionManager* NewL( 

            CDocumentHandler& aDocHandler );

        /**  

        * Destructor

        */

        ~CCatalogsHttpSessionManager();

    public: // MCatalogsHttpSessionManager

        void AddRef();

        TInt Release();

        /**

        * @see MCatalogsHttpSessionManager::StartOperation()

        */        

        /**

        * @see MCatalogsHttpSessionManager::PauseOperation()

        */        

        TInt PauseOperation( MCatalogsHttpOperation* aOperation );

        /**

        * @see MCatalogsHttpSessionManager::CompleteOperation()

        */                

        TInt CompleteOperation( MCatalogsHttpOperation* aOperation );

        /**

        * @see MCatalogsHttpSessionManager::OperationPriorityChanged()

        */

        TInt OperationPriorityChanged( MCatalogsHttpOperation* aOperation );

        /**

         * Returns a connection creator

         */

        CCatalogsHttpConnectionCreator& ConnectionCreatorL();

        /**

         */

        void SetResumeMode( TBool aResumeQueued );

        static CCatalogsNetworkManager& NetworkManagerL();

        CDocumentHandler& DocumentHandler();

        TBool DisconnectL();

    public:

        TInt ResumeOperationAction();

    public: // MCatalogsConnectionObserver

        void ConnectionCreatedL( 

            const TCatalogsConnectionMethod& aMethod );

        void ConnectionError( TInt aError );

    public: // MCatalogsConnectionStateObserver

        void ConnectionStateChangedL( TInt aStage );

        void ConnectionStateError( TInt aError );

    protected:        

        void SetConnectionToQueue( 

            const TCatalogsConnectionMethod& aMethod,  

            RCatalogsHttpOperationArray& aArray );

        void ReportConnectionError( 

            const TCatalogsConnectionMethod& aMethod,  

            RCatalogsHttpOperationArray& aArray,

            TInt aError );

        void ReportConnectionError( 

            RCatalogsHttpOperationArray& aArray,

            TInt aError );

    protected: // CActive

        void RunL();

        void DoCancel();

        TInt RunError( TInt aError );

    protected:

        /**

        * Constructor

        */

        CCatalogsHttpSessionManager( CDocumentHandler& aDocHandler );

        void ConstructL();

    private:

        void ResumeOperation();

        TInt AddToQueue( MCatalogsHttpOperation* aOperation );

        TInt RemoveFromQueue( MCatalogsHttpOperation* aOperation );        

        static TInt PrioritizeOperations( 

            const MCatalogsHttpOperation& aFirst, 

            const MCatalogsHttpOperation& aSecond );

        RCatalogsHttpOperationArray& ChooseArray( 

            const MCatalogsHttpOperation& aOperation );

        void UpdateRunningOperations();

        TBool ConnectL( MCatalogsHttpOperation& aOperation );       

        /**

         * @param aStartSwitchTimer If true, timer is started which is used

         * to raise a new AP even if the old one is still up

         */

        TBool StartMonitoringL( TBool aStartSwitchTimer );

    private:

        enum TCatalogsConnectionState 

            {

            ECatalogsConnectionDisconnected,

            ECatalogsConnectionConnecting,

            ECatalogsConnectionConnected,

            ECatalogsConnectionDisconnecting

            };

    private:

        RCatalogsHttpOperationArray iDownloadQueue;

        RCatalogsHttpOperationArray iTransactionQueue;

        RCatalogsHttpOperationArray iGeneralQueue; // Simple queue

        RCatalogsHttpOperationArray iRunningQueue; // All currently executing ops

        // currently executing operations, doesn't include the operation running

        // from general queue

        TInt iRunningOperations;    

        TInt iRunningDownloads;

        // Currently executing transactions        

        TInt iRunningTransactions;        

        TInt iRunningFromGeneral;  

        TInt iRefCount;

        TBool iResumeQueued;

        CCatalogsHttpConnectionCreator* iConnectionCreator; // owned

        CAsyncCallBack* iCallback; // owned

        TInt iResumeCount;

        static CCatalogsNetworkManager* iNetworkManager; // owned

        CCatalogsConnection* iConnection; // owned

        TCatalogsConnectionState iConnectionState;

        MCatalogsHttpOperation* iConnectedOperation; // not owned

        CCatalogsConnectionMonitor* iMonitor; // owned

        RTimer iConnectionTimer; // owned

        // ETrue if iConnectionTimer is being used for switching to another

        // APN

        TBool iSwitchApTimer;

        CDocumentHandler& iDocHandler; // not owned

        TCatalogsConnectionMethod iLatestConnectionMethod;

    };

#endif // C_CATALOGSHTTPSESSIONMANAGER_H