/*

* 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:  Event notifiers (active objects).

*

*/

#ifndef __CONNMONNOTI_H

#define __CONNMONNOTI_H

#include <es_sock.h>

#include <in_sock.h>

#include <es_enum.h>

#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS

#include <es_enum_internal.h>

#endif

class CConnMonIAP;

class CConnMonServer;

const TInt KNoFiltering = -1;

const TInt KActivityTimeout = 1800000; // 1,8 sec

// Update ConnMon documentation (attribute KConnectionActive) if changing this

// value (KOneTimeQueryThreshold = 1)

const TUint KOneTimeQueryThreshold = 1;

const TUint KInvalidIapCount = 99999;

// Stop requesting new notifications after this many consecutive errors (CBearerNotifier)

const TInt KConnMonEventErrorThreshold = 20;

/**

*  CConnUpDownNotifier

*  @lib CONNMON.LIB

*  @since

*/

NONSHARABLE_CLASS( CConnUpDownNotifier ) : public CActive

    {

    public: // Constructors and destructor

        CConnUpDownNotifier( CConnMonServer* aServer );

        void Construct();

        virtual ~CConnUpDownNotifier();

    public:  // New methods

        /**

        * Requests a new event (connection up/down) from RConnection.

        * @since

        * @return void

        */

        void Receive();

    private: // Methods from base classes

         /**

        * From CActive Cancels the asyncronous request

        * @since

        * @return void

        */

        void DoCancel();

         /**

        * From CActive Handles the the event that has arrived from RConnection.

        * @since

        * @return void

        */

        void RunL();

    private: // Data

        CConnMonServer*           iServer;

        TEventInfo                iEventInfo;

        TInterfaceNotificationBuf iInfoBuf;

        TInt                      iErrorCounter;

    };

/**

*  CDataNotifier

*  @lib CONNMON.LIB

*  @since

*/

NONSHARABLE_CLASS( CDataNotifier ) : public CActive

    {

    public: // Constructors and destructor

        enum TDataDirection

             {

             EDownlink = 0,

             EUplink

             };

        CDataNotifier(

                CConnMonServer* aServer,

                RConnection* aConnection,

                const TUint& aConnectionId,

                const TUint& aSubConnectionId,

                const TInt& aDirection );

        void Construct();

        virtual ~CDataNotifier();

    public: // New methods

        /**

        * Requests a new event (data transferred) from RConnection.

        * @since

        * @return void

        */

        void Receive();

    private: // Methods from base classes

         /**

        * From CActive Cancels the asyncronous request

        * @since

        * @return void

        */

        void DoCancel();

        /**

        * From CActive Handles the the event that has arrived from RConnection.

        * @since

        * @return void

        */

        void RunL();

    private: // Data

        CConnMonServer* iServer;

        RConnection*    iConnection;

        const TUint     iConnectionId;

        const TUint     iSubConnectionId;

        const TInt      iDirection;

        TUint           iVolume;

        TPckg<TUint>    iPckgVolume;

        TUint           iThreshold;

        TEventInfo      iEventInfo;

        TInt            iErrorCounter;

    };

/**

*  CProgressNotifier

*  @lib CONNMON.LIB

*  @since

*/

NONSHARABLE_CLASS( CProgressNotifier ) : public CActive

    {

    public: // Constructors and destructor

        CProgressNotifier(

                CConnMonServer* aServer,

                RConnection* aConnection,

                const TUint& aConnectionId,

                const TUint& aSubConnectionId );

        void Construct();

        virtual ~CProgressNotifier();

    public: // New methods

        /**

        * Requests a new event (connection status has changed) from RConnection.

        * @since

        * @return void

        */

        void Receive();

        /**

        * Requests a new event (connection status has changed) from RConnection.

        * @since

        * @param aFilter Notifications will be dropped until status reaches aFilter.

        * @return void

        */

        void Receive( const TInt aFilter );

        /**

        * Return ETrue if the progress value returned from RConnection indicates that

        * the user has deactivated the connection by using Connection Monitor or

        * some application has issued RConnection::Stop( RConnection::EStopAuthoritative ).

        * @since

        * @return ETrue if connection has been deactivated in an

        *         authoritative way, otherwise returns EFalse.

        */

        TBool IsAuthDelete();

        /**

        * Return ETrue if the connection might reconnect (e.g. CSD after network is down for a while)

        * @since

        * @return ETrue if the connection might reconnect, otherwise returns EFalse.

        */

        TBool CanReconnect() const;

        /**

        * Send KLinkLayerClosed event to clients

        * @since

        */

        void SendClosedEvent();

    private: // Methods from base classes

         /**

        * From CActive Cancels the asyncronous request

        * @since

        * @return void

        */

        void DoCancel();

        /**

        * From CActive Handles the the event that has arrived from RConnection.

        * @since

        * @return void

        */

        void RunL();

    private: // Data

        CConnMonServer* iServer;

        RConnection*    iConnection;

        const TUint     iConnectionId;

        const TUint     iSubConnectionId;

        TEventInfo      iEventInfo;

        TNifProgressBuf iInfoBuf;

        TInt            iFilter;

    };

/**

*  CNetwStatusNotifier

*  @lib CONNMON.LIB

*  @since

*/

NONSHARABLE_CLASS( CNetwStatusNotifier ) : public CActive

    {

    public: // Constructor and destructor

        static CNetwStatusNotifier* NewL( CConnMonServer* aServer );

        virtual ~CNetwStatusNotifier();

    public: // New methods

        /**

        * Requests a new event (network status changed) from ETel.

        * @since

        * @return void

        */

        void Receive();

    private: // Methods from base classes

         /**

        * From CActive Cancels the asyncronous request

        * @since

        * @return void

        */

        void DoCancel();

        /**

        * From CActive Handles the the event that has arrived from ETel.

        * @since

        * @return void

        */

        void RunL();

    private: // Private constructors

        CNetwStatusNotifier( CConnMonServer* aServer );

        void Construct();

    private: // Data

        CConnMonServer*         iServer;

        RPacketService::TStatus iPacketStatus;

        TEventInfo              iEventInfo;

    };

/**

*  CNetwRegistrationNotifier

*  @lib CONNMON.LIB

*  @since

*/

NONSHARABLE_CLASS( CNetwRegistrationNotifier ) : public CActive

    {

    public: // Constructor and destructor

        static CNetwRegistrationNotifier* NewL(

                CConnMonServer* aServer,

                RMobilePhone& aMobilePhone );

        virtual ~CNetwRegistrationNotifier();

    public: // New methods

        /**

        * Requests a new event (network registration changed) from ETel.

        * @since

        * @return void

        */

        void Receive();

    private: // Methods from base classes

         /**

        * From CActive Cancels the asyncronous request

        * @since

        * @return void

        */

        void DoCancel();

        /**

        * From CActive Handles the the event that has arrived from ETel.

        * @since

        * @return void

        */

        void RunL();

    private: // Private constructors

        CNetwRegistrationNotifier(

                CConnMonServer* aServer,

                RMobilePhone& aMobilePhone );

        void Construct();

    private: // Data

        CConnMonServer*                              iServer;

        RMobilePhone&                                iMobilePhone;

        RMobilePhone::TMobilePhoneRegistrationStatus iRegistration;

        TBool                                        iCSDSupported;

        TBool                                        iPhoneSupportsCSD;

        TEventInfo                                   iEventInfo;

    };

/**

* CBearerNotifier

* @lib CONNMON.LIB

*/

NONSHARABLE_CLASS( CBearerNotifier ) : public CActive

    {

    public: // Constructors and destructor

        CBearerNotifier(

                CConnMonServer* aServer,

                RMobilePhone& aMobilePhone );

        void ConstructL();

        static CBearerNotifier* NewL(

                CConnMonServer* aServer,

                RMobilePhone& aMobilePhone );

        virtual ~CBearerNotifier();

    public: // New methods

        /**

        * Requests a new event (bearer changed) from ETel Custom API.

        * @return void

        */

        void Receive();

    private: // Methods from base classes

        /**

        * From CActive, cancels the asyncronous request.

        * @return void

        */

        void DoCancel();

        /**

        * From CActive Handles the the event that has arrived from ETel Custom API.

        * @return void

        */

        void RunL();

    private: // Data

        CConnMonServer* iServer;

        RMobilePhone& iMobilePhone;

        RMmCustomAPI::TGprsInformation iGprsInfo;

        RMmCustomAPI::TGprsInformationPckg iGprsInfoPckg;

        RMmCustomAPI iCustomApi;

        TEventInfo iEventInfo;

        TInt iErrorCounter;

    };

/**

*  CWcdmaBearerNotifier

*  @lib CONNMON.LIB

*  @since

*/

NONSHARABLE_CLASS( CWcdmaBearerNotifier ) : public CActive

    {

    public: // Constructors and destructor

        CWcdmaBearerNotifier(

                CConnMonServer* aServer,

                RTelServer& aTelServer );

        void ConstructL();

        static CWcdmaBearerNotifier* NewL(

                CConnMonServer* aServer,

                RTelServer& aTelServer );

        virtual ~CWcdmaBearerNotifier();

    public: // New methods

        /**

        * Requests a new event (bearer changed) from ETel Custom API.

        * @since

        * @return void

        */

        void Receive();

    private: // Methods from base classes

        /**

        * From CActive Cancels the asyncronous request

        * @since

        * @return void

        */

        void DoCancel();

        /**

        * From CActive Handles the the event that has arrived from ETel Custom API.

        * @since

        * @return void

        */

        void RunL();

    private: // Data

        CConnMonServer*                             iServer;

        RTelServer&                                 iTelServer;

        RMobilePhone                                iMobilePhone;

        RMobilePhone::TMobilePhoneNetworkInfoV5     iNetInfo;

        RMobilePhone::TMobilePhoneNetworkInfoV5Pckg iNetInfoPckg;

        TConnMonBearerInfo                          iPreviousBearerInfo;

        TEventInfo                                  iEventInfo;

    };

/**

*  CModeNotifier

*  @lib CONNMON.LIB

*  @since

*/

NONSHARABLE_CLASS( CModeNotifier ) : public CActive

    {

    public: // Constructor and destructor

        static CModeNotifier* NewL(

                CConnMonServer* aServer,

                RMobilePhone& aMobilePhone );

        virtual ~CModeNotifier();

    public: // New methods

        /**

        * Requests a new event (mode changed) from ETel.

        * @since

        * @return void

        */

        void Receive();

    private: // Methods from base classes

         /**

        * From CActive Cancels the asyncronous request

        * @since

        * @return void

        */

        void DoCancel();

        /**

        * From CActive Handles the the event that has arrived from ETel.

        * @since

        * @return void

        */

        void RunL();

    private: // Private constructors

        CModeNotifier(

                CConnMonServer* aServer,

                RMobilePhone& aMobilePhone );

        void Construct();

    private: // Data

        CConnMonServer*                       iServer;

        RMobilePhone&                         iMobilePhone;

        RMobilePhone::TMobilePhoneNetworkMode iMode;

        TEventInfo                            iEventInfo;

    };

/**

*  CBearerAvailabilityNotifier

*  @lib CONNMON.LIB

*  @since

*/

NONSHARABLE_CLASS( CBearerAvailabilityNotifier ) : public CActive

    {

    public: // Constructors and destructor

        static CBearerAvailabilityNotifier* NewL( CConnMonServer* aServer );

        virtual ~CBearerAvailabilityNotifier();

    public: // New methods

        /**

        * Requests a new event (bearer (PSD) availability changed) from ETel.

        * @since

        * @param aKickOff If aKickOff is ETrue initial bearer status will be obtained from ETel.

        * @return void

        */

        void Receive( TBool aKickOff=ETrue );

    private: // Methods from base classes

         /**

        * From CActive Cancels the asyncronous request

        * @since

        * @return void

        */

        void DoCancel();

        /**

        * From CActive Handles the the event that has arrived from ETel.

        * @since

        * @return void

        */

        void RunL();

    private: // Private constructors

        CBearerAvailabilityNotifier( CConnMonServer* aServer );

        void Construct();

    private: // Data

        CConnMonServer*                     iServer;

        TBool                               iPSD;

        TBool                               iGPRSSupportedByPhone;

        TBool                               iWCDMASupportedByPhone;

        RPacketService::TRegistrationStatus iRegStatus;

        TEventInfo                          iEventInfo;

    };

/**

*  CGsmSignalNotifier

*  @lib CONNMON.LIB

*  @since

*/

NONSHARABLE_CLASS( CGsmSignalNotifier ) : public CActive

    {

    public: // Constructor and destructor

        static CGsmSignalNotifier* NewL(

                CConnMonServer* aServer,

                RMobilePhone& aMobilePhone );

        virtual ~CGsmSignalNotifier();