// Copyright (c) 2006-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:

//

#include <ctsy/tflogger.h>

#include "CMmCustomTsy.h"

#include "CMmPacketTsy.h"

#include "Cmmpacketcontexttsy.h"

#include "Cmmpacketcontextlist.h"

// ======== MEMBER FUNCTIONS ========

CMmPacketTsy::CMmPacketTsy()

    {

    }

void CMmPacketTsy::ConstructL()

    {

#ifdef REQHANDLE_TIMER   

    // Create req handle store

    iTsyReqHandleStore = CMmTsyReqHandleStore::NewL( iMmCustomTsy,

        iMmPhone, EMultimodePacketMaxNumOfRequests, iPacketReqHandles );

#else

    // Create req handle store

    iTsyReqHandleStore = CMmTsyReqHandleStore::NewL( 

        EMultimodePacketMaxNumOfRequests, iPacketReqHandles );

#endif // REQHANDLE_TIMER

    iGprsInformationPckg = NULL;

    }

CMmPacketTsy* CMmPacketTsy::NewL(

    CMmCustomTsy* aMmCustomTsy, 

    CMmPhoneTsy* aMmPhone )

    {

TFLOGSTRING( "CustomTSY: CMmPacketTsy::NewL" );

    CMmPacketTsy* mmPacketTsy = new ( ELeave ) CMmPacketTsy();

    CleanupStack::PushL( mmPacketTsy );

    mmPacketTsy->iMmCustomTsy = aMmCustomTsy;

    mmPacketTsy->iMmPhone = aMmPhone;

    mmPacketTsy->ConstructL();

    CleanupStack::Pop();

    return mmPacketTsy;

    }

CMmPacketTsy::~CMmPacketTsy()

    {

TFLOGSTRING( "CustomTSY: CMmPacketTsy::~CMmPacketTsy" );

    delete iTsyReqHandleStore;

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::Init

// Initialisation method that is called from ETel Server.

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

void CMmPacketTsy::Init()

    {

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::RegisterNotification

// RegisterNotification is called when the ETel Server recognises that this 

// notification is being posted for the first time on this subsession object.

// It enables the TSY to "turn on" any regular notification messages that it 

// may receive from DOS.

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

TInt CMmPacketTsy::RegisterNotification(

    const TInt aIpc )

    {

    TInt ret( KErrNotSupported );

    if ( ECustomNotifyEGprsInfoChange == aIpc )

        {

        ret = KErrNone;

        }

    return ret;

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::DeregisterNotification

// DeregisterNotification is called when the ETel Server recognises that this

// notification will not be posted again because the last client to have

// a handle on this sub-session object has just closed the handle. It

// enables the TSY to "turn off" any regular notification messages that

// it may receive from DOS.

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

TInt CMmPacketTsy::DeregisterNotification( 

    const TInt aIpc )

    {

    TInt ret( KErrNotSupported );

    if ( ECustomNotifyEGprsInfoChange == aIpc )

        {

        ret = KErrNone;

        }

    return ret;

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::SupportingIPC

// Use switch to check if given IPC is supported

// in case IPC supported

//     return ETrue

// in case IPC not supported

//     return EFalse

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

TBool CMmPacketTsy::SupportingIPC( 

    TInt aIpc )

    {

    TBool ret( EFalse );

    switch ( aIpc )

        {

        // from CustomApi

        case ECustomNotifyEGprsInfoChange:

        case ECustomGetEGprsInfo:

        case ECustomSetAlwaysOnMode:

            ret = ETrue;

            break;

        default:

            ret = EFalse;

            break;

        }

    return ret;

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::DoExtFuncL

// Dispatches extension function requests.

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

TInt CMmPacketTsy::DoExtFuncL(

    const TTsyReqHandle aTsyReqHandle, 

    const TInt aIpc, 

    const TDataPackage& aPackage )

    {

TFLOGSTRING3( "CustomTSY: CMmPacketTsy::DoExtFuncL - IPC:%d Handle:%d", aIpc, aTsyReqHandle );

    TInt ret( KErrNotSupported );

    switch ( aIpc )

        {

        case ECustomNotifyEGprsInfoChange:

            ret = NotifyEGprsInfoChange( aTsyReqHandle, aPackage.Des1n() );

            break;

        case ECustomGetEGprsInfo:

            ret = GetEGprsInfo( aTsyReqHandle, aPackage.Des1n() );

            break;

        case ECustomSetAlwaysOnMode:

TFLOGSTRING( "TSY:CMmPacketTsy::DoExtFuncL ECustomSetAlwaysOnMode");

            ret = SetAlwaysOnL( aTsyReqHandle,

               ( REINTERPRET_CAST( RMmCustomAPI::TSetAlwaysOnMode*,

                              					aPackage.Ptr1() ) ) );

        default:

            break;

        }

    return ret;

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::ReqModeL

// Returns request mode for given IPC.

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

CTelObject::TReqMode CMmPacketTsy::ReqModeL( 

    const TInt aIpc )

    {

    CTelObject::TReqMode reqMode( 0 );

    switch ( aIpc )

        {

        // Etel Server takes care of flow control. Several simultaneous

        // requests allowed.

        // All disabled

        // TSYs wishing to implement their own buffering algorithm will place

        // all requests in this category. 

        // Get methods that do not use DOS and return immediately.

        // Flow control not required.

        // Methods that can probably take a long time and cannot therefore be

        // flow controlled. Solution: All these methods must check req handle

        // table before handling the request. If the request table indicates

        // that same method has been called and has not been completed, the

        // method should return KErrServerBusy.

        case ECustomGetEGprsInfo:

        case ECustomSetAlwaysOnMode:

            break;

        // KReqModeMultipleCompletionEnabled | ReqModePostImmediately

        // Requests that notify a client about a change of state.

        // Since these requests do not require the issuing of any modem 

        // commands, they do not have to obey flow control.

        // The TSY never gets more than one of these outstanding.

        case ECustomNotifyEGprsInfoChange:

            reqMode = KReqModeMultipleCompletionEnabled |

                KReqModeRePostImmediately;

            break;

        // KReqModeFlowControlObeyed

        // Commands that change the state of the phone, e.g. clearing the AoC 

        // counter, are commands that the TSY should only deal with one at 

        // a time.

        //Other cases

            //reqMode = KReqModeFlowControlObeyed;

            //break;

        default:

            User::Leave( KErrNotSupported );

            break;

        }

    return reqMode;

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::NumberOfSlotsL

// Returns number of slots to be used for given IPC.

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

TInt CMmPacketTsy::NumberOfSlotsL(

    const TInt aIpc )

    {

    TInt numberOfSlots( KMmCustomDefaultSlots );

    switch ( aIpc )

        {

        // from CustomApi

        case ECustomNotifyEGprsInfoChange: 

        case ECustomGetEGprsInfo:

        case ECustomSetAlwaysOnMode:

            break;

        default:

            // Unknown or invalid IPC

            User::Leave( KErrNotSupported );

            break;

        }

    return numberOfSlots;

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::CancelService

// This function is called to cancel the outstanding request.

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

TInt CMmPacketTsy::CancelService(

    const TInt aIpc, 

    const TTsyReqHandle aTsyReqHandle )

    {

TFLOGSTRING2( "CustomTSY: CMmPacketTsy::CancelService IPC:%d", aIpc );

    TInt ret( KErrNone );

    // Req handle type

    TPacketRequestType reqHandletype( 

        EMultimodePacketContextReqHandleUnknown );

    switch ( aIpc )

        {

        // TSY has started a request and it is not possible to then cancel 

        // this request. The best thing for the TSY to do in this case is to 

        // proceed as though the Cancel never happened. The server's call to

        // the TSY cancel function will return synchronously. The TSY then 

        // continues to wait for the original acknowledgement and when it 

        // receives it, the TSY will complete the original request.

        case ECustomGetEGprsInfo:

            break;

        case ECustomSetAlwaysOnMode:

        	 CancelSetAlwaysOn ( aTsyReqHandle );

            break;

        // Notification Cancels, no special requirements.

        case ECustomNotifyEGprsInfoChange:

            iGprsInformationPckg = NULL;

            reqHandletype = EMultimodePacketContextNotifyEGprsInfoChange;

            break;

        // Cancel methods that are not supported

        // Default case

        default:

            ret = KErrNotSupported;

            break;

        }

    if ( reqHandletype != EMultimodePacketContextReqHandleUnknown )

        {

        // Reset tsy request handle

        iTsyReqHandleStore->ResetTsyReqHandle( reqHandletype );

        // Complete request to client with KErrCancel

        ReqCompleted( aTsyReqHandle, KErrCancel );

        }

    return ret;

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::ReqCompleted

// Overloads CTelObject::ReqCompleted for logging purposes.

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

void CMmPacketTsy::ReqCompleted(

    const TTsyReqHandle aTsyReqHandle, 

    const TInt aError )

    {

TFLOGSTRING3( "CustomTSY: CMmPacketTsy::ReqCompleted Handle:%d Error:%d", aTsyReqHandle, aError );

    iMmCustomTsy->ReqCompleted( aTsyReqHandle, aError );

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::NotifyEGprsInfoChange

// Request notification when EGPRS support changes.

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

TInt CMmPacketTsy::NotifyEGprsInfoChange(

    const TTsyReqHandle aTsyReqHandle, 

    TDes8* aGprsInformation )

    {

TFLOGSTRING( "CustomTSY: CMmPacketTsy::NotifyEGprsInfoChange" );

    RMmCustomAPI::TGprsInformation temp;

	RMmCustomAPI::TGprsInformationPckg tempPckg(temp);

	TInt expectedLength = tempPckg.MaxLength();

	TInt paramLength = aGprsInformation->MaxLength();

	TInt ret = KErrArgument;

	if (expectedLength == paramLength)

		{

	    // Store pointer of Gprs information package

	    iGprsInformationPckg = 

	        ( RMmCustomAPI::TGprsInformationPckg* ) aGprsInformation;

	    // Store request handle

	    iTsyReqHandleStore->SetTsyReqHandle( 

	        EMultimodePacketContextNotifyEGprsInfoChange, aTsyReqHandle );

		ret = KErrNone;

		}

    return ret;

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::GetEGprsInfo

// Informs client about EGPRS information.

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

TInt CMmPacketTsy::GetEGprsInfo(

    const TTsyReqHandle aTsyReqHandle, 

    TDes8* aGprsInformation )

    {

TFLOGSTRING( "CustomTSY: CMmPacketTsy::GetEGprsInfo" );

    RMmCustomAPI::TGprsInformation temp;

	RMmCustomAPI::TGprsInformationPckg tempPckg(temp);

	TInt expectedLength = tempPckg.MaxLength();

	TInt paramLength = aGprsInformation->MaxLength();

	TInt ret = KErrArgument;

	if (expectedLength == paramLength && iMmCustomTsy)

		{			

	    RMmCustomAPI::TGprsInformationPckg* gprsInformationPckg =

	        ( RMmCustomAPI::TGprsInformationPckg* ) aGprsInformation;

	    // Unpack gprsInformationPckg

	    RMmCustomAPI::TGprsInformation& gprsInformation = 

	        ( *gprsInformationPckg )();

	    TBool edgeGprsSupportInCell;

	    if ( !iMmCustomTsy->Phone() 

	    	   || !iMmCustomTsy->Phone()->PacketDataSession() 

	    	   || !iMmCustomTsy->Phone()->PacketDataSession()->

	    		    ActivePacketServiceExtension() )

	        {

	        // returns false if EGPRS support failed

	       	edgeGprsSupportInCell = EFalse;

	        }

	    else

	        {

	        // returns information if EGPRS connection supported

	    	edgeGprsSupportInCell = iMmCustomTsy->Phone()->PacketDataSession()->

	            ActivePacketServiceExtension()->EGprsSupportInCell();

	        }

	    // if gprsSupportInCell is ETrue -> cell is supporting EGPRS connection 

	    if ( edgeGprsSupportInCell )

	        {

	TFLOGSTRING( "CustomTSY: CMmPacketTsy::GetEGprsInfo  RMmCustomAPI::EEdgeGprs" );

	        gprsInformation.iGprsInfo = RMmCustomAPI::EEdgeGprs; 

	        }

	    // else EGPRS connection is not supported

	    else 

	        {

	TFLOGSTRING( "CustomTSY: CMmPacketTsy::GetEGprsInfo  RMmCustomAPI::EGprs" );

	        gprsInformation.iGprsInfo = RMmCustomAPI::EGprs;

	        }

		ret = KErrNone;

	    // Complete the client request

	    ReqCompleted( aTsyReqHandle, ret );

		}

    return ret;

    }

// ---------------------------------------------------------------------------

// CMmPacketTsy::CompleteNotifyEGprsInfoChange

// Completes EGPRS notification request to Client.

// (other items were commented in a header).

// ---------------------------------------------------------------------------

//

void CMmPacketTsy::CompleteNotifyEGprsInfoChange(

    const TBool aGprsSupportInCell )

    {

TFLOGSTRING( "CustomTSY: CMmPacketTsy::CompleteNotifyEGprsInfoChange" );

    TTsyReqHandle reqHandle = iTsyReqHandleStore->ResetTsyReqHandle(

        EMultimodePacketContextNotifyEGprsInfoChange );

    if ( EMultimodePacketContextReqHandleUnknown != reqHandle )

        {

        // Unpack iGprsInformationPckg

        RMmCustomAPI::TGprsInformation& gprsInformation = 

            ( *iGprsInformationPckg )();

        // if aGprsSupportInCell is ETrue -> cell is supporting edge GPRS

        if ( aGprsSupportInCell )

            {

TFLOGSTRING( "CustomTSY: CMmPacketTsy::CompleteNotifyEGprsInfoChange  RMmCustomAPI::EEdgeGprs" );

            gprsInformation.iGprsInfo = RMmCustomAPI::EEdgeGprs;

            }

        // if aGprsSupportInCell is EFalse -> cell is not supporting edge GPRS

        else 

            {

TFLOGSTRING( "CustomTSY: CMmPacketTsy::CompleteNotifyEGprsInfoChange  RMmCustomAPI::EGprs" );

            gprsInformation.iGprsInfo = RMmCustomAPI::EGprs;

            }

        iGprsInformationPckg = NULL;

        // Complete the client request

        ReqCompleted( reqHandle, KErrNone );

        }

    }

//-----------------------------------------------------------------------------

// CMmPacketTsy::SetAlwaysOnL

// Requests Set Always On with mode given as parameter aMode

// (other items were commented in a header).

//-----------------------------------------------------------------------------

//

TInt CMmPacketTsy::SetAlwaysOnL( 

	TTsyReqHandle aTsyReqHandle,

	RMmCustomAPI::TSetAlwaysOnMode* aMode )

    {

TFLOGSTRING2( "CMmPacketTsy::SetAlwaysOn Reg Handle = %d", aTsyReqHandle );

	TInt ret( KErrGeneral );