/*
* Copyright (c) 2006 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 session adapter base class.
 *
*/


//  INCLUDE FILES
#include "ximpsrvsessionadapter.h"
#include "ximpsrv.h"
#include "ximpsrvsession.h"
#include "ximpsrvmessageimp.h"
#include "ximppanics.h"
#include "ximptrace.h"
#include <e32base.h>


// -----------------------------------------------------------------------------
// CXIMPSrvSessionAdapter::CXIMPSrvSessionAdapter()
// -----------------------------------------------------------------------------
//
EXPORT_C CXIMPSrvSessionAdapter::CXIMPSrvSessionAdapter( MXIMPSrv& aServer )
    : iServer( aServer )
    {
    iServer.SessionCreated();
    TRACE_1( _L("CXIMPSrvSessionAdapter[%d]::CXIMPSrvSessionAdapter()"),
                 this );
    }


// -----------------------------------------------------------------------------
// CXIMPSrvSessionAdapter::~CXIMPSrvSessionAdapter()
// -----------------------------------------------------------------------------
//
EXPORT_C CXIMPSrvSessionAdapter::~CXIMPSrvSessionAdapter()
    {
    delete iMessage;
    
    iServer.SessionDied();
    delete iSessionImp;

    TRACE_1( _L("CXIMPSrvSessionAdapter[%d]::~CXIMPSrvSessionAdapter()"),
                 this );
    #if _BullseyeCoverage
    cov_write();
    #endif
    }


// -----------------------------------------------------------------------------
// CXIMPSrvSessionAdapter::ServiceL()
// -----------------------------------------------------------------------------
//
EXPORT_C void CXIMPSrvSessionAdapter::ServiceL( const RMessage2& aMessage )
    {
    __ASSERT_ALWAYS( !iCurrentMsg,
                     User::Panic( NXIMPPrivPanic::KCategory,
                                  NXIMPPrivPanic::ECurrentMsgAlreadyExists ) );

    //Non leaving allocation must be used here to prevent OOM leave
    //to ServiceError() method, without a valid iCurrentMsg
    //==> CurrentMsg absence triggers an assert in ServiceError()
    iCurrentMsg = CXIMPSrvMessageImp::NewOrNull( aMessage,
                                                 ( MXIMPSrvMessage*& )iCurrentMsg, 
                                                 iMessage );
    iMessage = NULL;

    //Handle the message
    MXIMPSrvSession* sessionImp = DoInstantiateSessionL( *iCurrentMsg );
    
    if( sessionImp )
        {
        CleanupDeletePushL( sessionImp );

        __ASSERT_ALWAYS( !iSessionImp,
                         iCurrentMsg->PanicClientAndLeaveL(
                         NXIMPPanic::EOnSrvSessionImpAlreadyExists ) );

        iSessionImp = sessionImp;
        CleanupStack::Pop(); //sessionImp;
        iCurrentMsg->Complete( KErrNone );
        }

    else
        {                
        __ASSERT_ALWAYS( iSessionImp,
                         iCurrentMsg->PanicClientAndLeaveL(
                         NXIMPPanic::EOnSrvSessionImpNotFound ) );


        iSessionImp->TryHandleMessageL( *iCurrentMsg );


        //If current message is still not-completed, inform client
        //that it tried to do something unknown
        __ASSERT_ALWAYS( !IsCurrentMessageValid(),
                         iCurrentMsg->PanicClientAndLeaveL(
                         NXIMPPanic::EOnSrvRequestNotUnderstood) );
        }

    iMessage = iCurrentMsg;
    iCurrentMsg = NULL;
    }
  
// -----------------------------------------------------------------------------
// CXIMPSrvSessionAdapter::ServiceError()
// -----------------------------------------------------------------------------
//
EXPORT_C void CXIMPSrvSessionAdapter::ServiceError( const RMessage2& /*aMessage*/,
                                                    TInt aError )
    {
    //If assert below is triggered, it means that current message ownersip
    //is taken somewhere (to be completed asynchronously), but there has
    //happened a leave after ownership transfer

    //The place taking message ownership has to be fixed in this case
    //not to cause exeptions after ownership transfer
    __ASSERT_ALWAYS( iCurrentMsg,
                     User::Panic( NXIMPPrivPanic::KCategory,
                                  NXIMPPrivPanic::ECurrentMsgNotFoundInServiceError ) );


    //If assert below is triggered, it means that current message is already
    //completed, but there has happened a leave after completion

    //The place completing message has to be fixed in this case
    //not to cause exeptions after message completion
    __ASSERT_ALWAYS( !iCurrentMsg->IsCompleted(),
                     User::Panic( NXIMPPrivPanic::KCategory,
                                  NXIMPPrivPanic::ECurrentMsgNotValidInServiceError ) );


    TRACE_3( _L("CXIMPSrvSessionAdapter[%d]::ServiceError() in op[%d], code[%d]"),
                 this, iCurrentMsg->Function(), aError );


    iCurrentMsg->Complete( aError );
    delete iCurrentMsg;
    iCurrentMsg = NULL;
    }


// -----------------------------------------------------------------------------
// CXIMPSrvSessionAdapter::Server()
// -----------------------------------------------------------------------------
//
EXPORT_C MXIMPSrv& CXIMPSrvSessionAdapter::Server()
    {
    return iServer;
    }

// -----------------------------------------------------------------------------
// CXIMPSrvSessionAdapter::IsCurrentMessageValid()
// -----------------------------------------------------------------------------
//
TBool CXIMPSrvSessionAdapter::IsCurrentMessageValid()
    {
    if( iCurrentMsg && !iCurrentMsg->IsCompleted() )
        {
        return ETrue;
        }

    return EFalse;
    }



// End of file