/*

* Copyright (c) 2009 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:  ECOM plugin to communicate over IP port

*

*/

#ifndef CHTICONNECTIONMANAGER_H

#define CHTICONNECTIONMANAGER_H

// INCLUDES

#include <HtiCommPluginInterface.h> // defined in HtiFramework project

#include <es_sock.h>

#include <in_sock.h>

#include <commdbconnpref.h>

#include "HtiIPCommServerCommon.h"

#include "HtiSocketMonitor.h"

#include "HtiIPCommServer.h"

// FORWARD DECLARATIONS

class CHtiIPCommServer;

class CHtiCfg;

// CLASS DECLARATION

class MHtiTimerObserver

{

public:

    virtual void TimerExpiredL() = 0;

};

class CHtiTimer : public CTimer

{

public:

    static CHtiTimer* NewL( MHtiTimerObserver& aObserver );

    virtual ~CHtiTimer();

protected: // From CActive

    void RunL();

    TInt RunError(TInt aError);

private:

    CHtiTimer( MHtiTimerObserver& aObserver );

    void ConstructL();

private:

    MHtiTimerObserver& iObserver;

};

class CHtiConnectionManager : public CActive,

                              public MHtiSocketObserver,

                              public MHtiTimerObserver

{

public:

    enum TConnectionstate {

        EStartingIAP,

        EWaitingConnection,

        EConnecting,

        EConnected,

        EDisconnecting,

        EDisconnected

    };

    static CHtiConnectionManager* NewL( CHtiIPCommServer* aServer );

    ~CHtiConnectionManager();

    void Receive( const RMessage2& aMessage );

    void Send( const RMessage2& aMessage );

    void CancelReceive();

    void CancelSend();

private:

    CHtiConnectionManager( CHtiIPCommServer* aServer );

    void ConstructL();

    // Config file reading separated to 2 parts because

    // ReadConnectionConfigL might need dns resolver and

    // that should be done after the IAP is started...

    void ReadIAPConfigL();

    void ReadConnectionConfigL();

    void ReadSocket();

    void WriteSocket();

    void StartConnectingL();

    void StartListeningL();

    /*

     *  Cancels all outstanding server session requests

     */

    void CancelAllRequests();

    void ShowErrorNotifierL( const TDesC& aText, TInt aErr = KErrGeneral );

protected: // From CActive

    void RunL();

    void DoCancel();

    TInt RunError(TInt aError);

public: // MHtiTimerObserver

    void TimerExpiredL();

public: // MHtiSocketObserver

    void ReportComplete( MHtiSocketObserver::TRequestType aType, TInt aError );

private:

    CHtiIPCommServer*   iServer;

    CHtiCfg*            iCfg;

    TUint32             iIAPId;

    TInt                iListenPort;

    TInetAddr           iRemoteHost;

    RSocketServ         iSocketServ;

    RConnection         iConnection;

    RSocket             iDataSocket;

    RSocket             iListenSocket;

    TSockXfrLength      iRecvLen;

    TConnectionstate    iState;

    RMessage2           iReceiveRequest;

    RMessage2           iSendRequest;

    TBool               iReceiveRequestComplete;

    TBool               iSendRequestComplete;

    CHtiSocketMonitor*  iSendMonitor;

    CHtiSocketMonitor*  iReceiveMonitor;

    CHtiTimer*          iConnectTimer;

    TInt                iConnectTimeout;

    TBuf8<KIPCommServerReceiveBufferMaxSize> iReceiveBuffer;

    TBuf8<KIPCommServerSendBufferMaxSize>    iSendBuffer;

    TCommDbConnPref     iConnPref;

};

#endif