/*
* 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 the License "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 _DPEP_TRANSCEIVER_H_
#define _DPEP_TRANSCEIVER_H_

#include <klib.h>           // For DBase
#include "internalapi.h"    // For MIAD2ChannelApi
#include "iadtrace.h"		// For ASSERT_RESET_ALWAYS

class MIAD2ChannelApi;
class DRouter;

// TODO: remove virtual from classes that are not ment to be derived.

NONSHARABLE_CLASS(DPepTransceiver) : public DBase
{
public:

    DPepTransceiver( DRouter* aRouter, MIAD2ChannelApi* aUl );
    DPepTransceiver( TUint8 aPipeHandle ); // for derived classes
    virtual ~DPepTransceiver();
    virtual void PepStatusInd( const TDesC8& aInd ){ aInd; ASSERT_RESET_ALWAYS( 0, 0 ); };
    virtual TInt Receive( const TDesC8& aData );
    virtual TInt Send( TDes8& aData );
    virtual void PipeEnabled(){ ASSERT_RESET_ALWAYS( 0, 0 ); };
    virtual void PipeDisabled(){ ASSERT_RESET_ALWAYS( 0, 0 ); };
    virtual void SetFlowCtrl( TIADFlowControlStatus aFlow );
    virtual TInt SendPnsPepConnectResp( const TDesC8& );
    virtual TInt SendResetResp( const TDesC8& );
    virtual TInt SendPnsPepDisconnectResp( const TDesC8& );
    virtual TInt SendEnableResp( const TDesC8& );
    virtual TInt SendDisableResp( const TDesC8& );
    void FillIsiHeader( TDes8& aData );
    virtual void RegisterDataMsgStatusCb( MDataMessageStatus* aCb );
#if (NCP_COMMON_SOS_VERSION_SUPPORT >= SOS_VERSION_95)
    virtual void SetNewChannel( MIAD2ChannelApi* aCh ){ ASSERT_RESET_ALWAYS( 0, 0 ); };
    void SetMyChannel( MIAD2ChannelApi* aCh );
#endif
    TDes8& AllocateDataBlock( TUint16 aSize );
    TInt PepControlReq( const TDesC8& aReq );
    TUint16 ChannelId()
        {
        return iChannelId;
        }

    TUint16 PipeHandle()//NEW
        {
        return iPipeHandle;
        }

protected:

    //R&D helper to check that right thread is used to avoid sync problems
    void CheckDfc();

    TIADFlowControlStatus   iFlowCtrl;
    TUint8                  iPipeHandle;

private:
    TDes8& CreateCommonPepResp(const TDesC8& aReq, TUint16 aLenght, TUint8 aMsgId);

private:

    TUint16             iChannelId;
	DRouter*			iRouter;
    MIAD2ChannelApi*    iRcvChannel;

};

NONSHARABLE_CLASS(DPepTx) : public DPepTransceiver
{
public:

    DPepTx(DPepTransceiver& aSuper, TUint8 aPipeHandle);
    virtual ~DPepTx();
    virtual TInt Send(TDes8& aData) = 0;
    virtual void PepStatusInd(const TDesC8& aInd) = 0;
    virtual void PipeEnabled(){ ASSERT_RESET_ALWAYS( 0, 0 ); };
    virtual void PipeDisabled();
    virtual void SetFlowCtrl( TIADFlowControlStatus aFlow );

protected:

    DPepTransceiver& iSuper;

};

NONSHARABLE_CLASS(DPepRx) : public DPepTransceiver, public MDataMessageStatus
{
public:

    DPepRx(DPepTransceiver& aSuper, TUint8 aPipeHandle);
    virtual ~DPepRx();
    virtual TInt Receive(const TDesC8& aData) = 0;
    virtual void PipeEnabled(){ ASSERT_RESET_ALWAYS( 0, 0 ); };
    virtual void PipeDisabled(){ ASSERT_RESET_ALWAYS( 0, 0 ); };

    // From MDataMessageStatus
    virtual void DataMessageDelivered() = 0;
    virtual void RegisterDataMsgStatusCb( MDataMessageStatus* aCb ){ aCb; ASSERT_RESET_ALWAYS( 0, 0 ); };

#if (NCP_COMMON_SOS_VERSION_SUPPORT >= SOS_VERSION_95)
    void SetNewChannel( MIAD2ChannelApi* aCh );
#endif

protected:

    DPepTransceiver& iSuper;

private:
//TBR    TUint16 iReceiveQueueCount;
};

NONSHARABLE_CLASS(DMultiRx) : public DPepRx
{
public:
    DMultiRx(DPepTransceiver& aSuper, TUint8 aPipeHandle);
    virtual ~DMultiRx();

    virtual TInt Receive(const TDesC8& aData);
    virtual void PipeEnabled();
    virtual void PipeDisabled();
    // From MDataMessageStatus
    void DataMessageDelivered();

private:

    void SendCredits(TUint8 aNum);
    TUint16 iThresholdCount;
#ifdef _DEBUG // TODO: remove debug flag from actual code.
    TUint16 iGrantedCreditCount;
#endif

};

NONSHARABLE_CLASS(DLegacyRx) : public DPepRx
{
public:

    DLegacyRx(DPepTransceiver& aSuper, TUint8 aPipeHandle);
    virtual ~DLegacyRx();
    
    virtual TInt Receive(const TDesC8& aData);
    virtual void PipeEnabled();
    virtual void PipeDisabled();

    // From MDataMessageStatus
    void DataMessageDelivered();

private:

    void SendPnsPepStatusInd( TIADFlowControlStatus aFlowCtrlStatus );
    TUint16 iRxQueueCount;

};

NONSHARABLE_CLASS(DOneRx) : public DPepRx
{
public:
    DOneRx(DPepTransceiver& aSuper, TUint8 aPipeHandle);
    virtual ~DOneRx();
    
    virtual TInt Receive(const TDesC8& aData);
    virtual void PipeEnabled();
    virtual void PipeDisabled();

    // From MDataMessageStatus
    void DataMessageDelivered();

private:
    void SendOneCredit();
};

NONSHARABLE_CLASS( DMultiTx ) : public DPepTx
{
public:

    DMultiTx(DPepTransceiver& aSuper, TUint8 aPipeHandle);
    virtual ~DMultiTx();
    TInt Send(TDes8& aData);
    void PepStatusInd(const TDesC8& aInd);
    void PipeEnabled();
    void PipeDisabled();

private:
    TUint16 iGrantedCredits;
};

NONSHARABLE_CLASS( DLegacyTx ) : public DPepTx
{
public:

    DLegacyTx(DPepTransceiver& aSuper, TUint8 aPipeHandle);
    virtual ~DLegacyTx();
    virtual TInt Send(TDes8& aData);
    virtual void PepStatusInd(const TDesC8& aInd);
    virtual void PipeEnabled();

};

NONSHARABLE_CLASS( DOneTx ) : public DPepTx
{
public:

    DOneTx(DPepTransceiver& aSuper, TUint8 aPipeHandle);
    virtual ~DOneTx();
    virtual TInt Send(TDes8& aData);
    virtual void PepStatusInd(const TDesC8& aInd);
    virtual void PipeEnabled();

};

#endif //_DPEP_TRANSCEIVER_H_