/*

* 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:  Server side session in HtiBtCommServer.

*

*/

#ifndef CHTIBTCOMMSERVERSESSION_H

#define CHTIBTCOMMSERVERSESSION_H

//  INCLUDES

#include <e32std.h>

#include <e32base.h>

#include "BtSerialClient.h" // MBtSerialClientObserver

// FORWARD DECLARATIONS

class CHtiBtCommServer;

// CLASS DECLARATION

/**

* This class represents a client session in the server.

*

* Server owns one instance of session (meaning only one client session

* is allowed for this server).

* Session allows only one outstanding read request and write request at a time.

* Read request and write request may be outstanding simultaneously.

*/

class CHtiBtCommServerSession :

    public CSession2,

    public MBtSerialClientObserver

    {

public:

   /**

    * Two phase constructor.

    *

    * @param aServer Pointer to the server instance

    */

    static CHtiBtCommServerSession* NewL( CHtiBtCommServer* aServer );

private: // Construction

   /**

    * C++ default constructor.

    *

    * @param aClient

    * @param aServer

    */

    CHtiBtCommServerSession( CHtiBtCommServer* aServer );

    /**

     * Second phase construction.

     */

    void ConstructL();

   /**

    * Destructor.

    */

    ~CHtiBtCommServerSession();

private: // From MBtSerialClientObserver

    void ConnectedToServer(TInt aError);

    void DisconnectedFromServer();

    void DataFromServer(const TDesC8& aData);

    void AllBufferedDataSent();

private:

    /**

    * Handle client request. This is invoced by client server framework.

    * @param aMessage Message object describing client request

    */

    virtual void ServiceL(const RMessage2 &aMessage);

    /**

    * Determine client request type and delegate handling accordingly.

    * @param aMessage Message object describing client request

    */

    void DispatchMessageL(const RMessage2 &aMessage);

    void HandleConnectRequestL(const RMessage2& aMessage);

    /**

    * Handle client's send request.

    * Copies data from client address space to internal send buffer and starts

    * sending it.

    * @param aMessage Message object describing client request

    */

    void HandleSendRequestL(const RMessage2& aMessage);

    /**

    * Handle client's read request.

    * Wait for incoming data. Once received, copy its data to client's

    * address space and complete client's request.

    * @param aMessage Message object describing client request

    */

    void HandleReadRequestL(const RMessage2& aMessage);

    /**

    * Handle client's cancel requests.

    * Cancel either read or write operation depending on client request.

    * @param aMessage Message object describing client request

    */

    void HandleCancelRequestL(const RMessage2& aMessage);

    /**

     * Handle port number request

     * Write the port number of the currently connected service. If not

     * connected writes KErrDisconnected.

     */

    void HandlePortNumberRequestL(const RMessage2& aMessage);

private: // Helpers

    void PanicClient(TInt aPanic) const;

    void ResetAll(TInt aCompletionCode);

    void TryCompleteReadRequest();

private: // Data

    CHtiBtCommServer *iBtCommServer; // referenced

    RMessage2 iReadRequest;

    RMessage2 iWriteRequest;

    RMessage2 iConnectRequest;

    TBool iWriteRequestComplete; // ETrue: no previous pending write request

    TBool iReadRequestComplete; // ETrue: no previous pending read request

    TBool iConnectRequestComplete;

    CBtSerialClient* iBtClient;

    HBufC8* iIncomingDataBuf; // Coming from remote host

    HBufC8* iSendBuffer;      // Sent to remote host

    };

#endif // CHTIBTCOMMSERVERSESSION_H

// End of File