/*
* Copyright (c) 2008 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:  session implementation
 *
*/


#include "tsfswsession.h"

// --------------------------------------------------------------------------
// CTsFswSession::CTsFswSession
// --------------------------------------------------------------------------
//
CTsFswSession::CTsFswSession()
    {
    }

// --------------------------------------------------------------------------
// CTsFswSession::Server
// --------------------------------------------------------------------------
//
CTsFswServer& CTsFswSession::Server()
    {
    return *static_cast<CTsFswServer*>(
        const_cast<CServer2*>( CSession2::Server() ) );
    }

// --------------------------------------------------------------------------
// CTsFswSession::CreateL
// --------------------------------------------------------------------------
//
void CTsFswSession::CreateL() // codescanner::LFunctionCantLeave (virtual)
    {
    Server().AddSession();
    }

// --------------------------------------------------------------------------
// CTsFswSession::~CTsFswSession
// --------------------------------------------------------------------------
//
CTsFswSession::~CTsFswSession()
    {
    CompleteSubscribe( KErrCancel );
    iSubscribeRequests.Close();
    Server().DropSession();
    }

// --------------------------------------------------------------------------
// CTsFswSession::CompleteSubscribe
// --------------------------------------------------------------------------
//
void CTsFswSession::CompleteSubscribe( TInt aError )
    {
    for ( TInt i = 0, ie = iSubscribeRequests.Count(); i != ie; ++i )
        {
        iSubscribeRequests[i].Complete( aError );
        }
    iSubscribeRequests.Reset();
    }

// --------------------------------------------------------------------------
// CTsFswSession::ServiceL
// --------------------------------------------------------------------------
//
void CTsFswSession::ServiceL( const RMessage2& aMessage )
    {
    if ( !aMessage.HasCapability( ECapabilityLocalServices ) )
        {
        aMessage.Panic( KTsFswPanicName, EPanicAccessDenied );
        return;
        }

    switch ( aMessage.Function() )
        {
    case ETsFswSubscribe:
        iSubscribeRequests.AppendL( aMessage );
        break;

    case ETsFswCancel:
        CompleteSubscribe( KErrCancel );
        aMessage.Complete( KErrNone );
        break;

    case ETsFswGetBufferSize:
        Server().SerializeAndGetBufferSizeL( aMessage );
        break;

    case ETsFswGetBuffer:
        Server().GetBufferL( aMessage );
        break;

    case ETsFswCloseApp:
        Server().CloseAppL( aMessage.Int0() );
        aMessage.Complete( KErrNone );
        break;

    case ETsFswSwitchToApp:
        Server().SwitchToAppL( aMessage.Int0() );
        aMessage.Complete( KErrNone );
        break;
        
    case ETsFswForegroundAppUid:
        Server().ForegroundAppUidL( aMessage );
        aMessage.Complete( KErrNone );
        break;

    default:
        aMessage.Panic( KTsFswPanicName, EPanicIllegalFunction );
        break;
        }
    }

// --------------------------------------------------------------------------
// CTsFswSession::ServiceError
// --------------------------------------------------------------------------
//
void CTsFswSession::ServiceError( const RMessage2& aMessage,
        TInt aError )
    {
    if ( aError == KErrBadDescriptor )
        {
        aMessage.Panic( KTsFswPanicName, EPanicBadDescriptor );
        }
    CSession2::ServiceError( aMessage, aError );
    }

// --------------------------------------------------------------------------
// CTsFswSession::FswDataChanged
// called by server when notification is received from engine
// --------------------------------------------------------------------------
//
void CTsFswSession::FswDataChanged()
    {
    CompleteSubscribe( KErrNone );
    }

// --------------------------------------------------------------------------
// CTsFswSession::IsListening
// --------------------------------------------------------------------------
//
TBool CTsFswSession::IsListening()
    {
    return iSubscribeRequests.Count() > 0;
    }


// end of file