/*

* 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:  ?Description

*

*/

#include <basched.h>

#include "fs_functor.h"

#include "os_functionserver.h"

#include "javasymbianoslayer.h"

#include "logger.h"

#include "exceptionbase.h"

using namespace java::util;

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

inline OsFunctionServer::CFunctionSession::CFunctionSession()

{

    JELOG2(EUtils);

}

TInt OsFunctionServer::CFunctionSession::doServiceL(TAction action, const TAny* param)

{

    JELOG2(EUtils);

    switch (action)

    {

    case EExecute:

        (*static_cast<const Functor*>(param))(); // It doesn't look like it but this may leave

        return KErrNone;

    case EStop:

        ((OsFunctionServer*)Server())->startShutDown();

        return KErrNone;

    default:

        return KErrNotSupported;

    }

}

void OsFunctionServer::CFunctionSession::ServiceL(const RMessage2& message)

{

    JELOG2(EUtils);

    TRAPD(error, (doServiceL(static_cast<TAction>(message.Function()), message.Ptr0())));

    if (error)

    {

        if (error == KLeaveExit) // This is used to exit the application, we obviously want to let it through

        {

            User::Leave(KLeaveExit);

        }

    }

    message.Complete(error);

}

OsFunctionServer::OsFunctionServer()

        : CServer2(EPriorityStandard, ESharableSessions)

{

    JELOG2(EUtils);

}

OsFunctionServer::~OsFunctionServer()

{

    JELOG2(EUtils);

}

void OsFunctionServer::startShutDown()

{

    JELOG2(EUtils);

    mShutdown.startShutDown();

}

void OsFunctionServer::startOsServer()

{

    JELOG2(EUtils);

    TRAPD(err, StartL(KNullDesC));

    if (err != 0)

    {

        std::string errorStr("FServer creation failed: ");

        errorStr.append(JavaCommonUtils::intToString(err));

        throw java::util::ExceptionBase(errorStr, __FILE__, __FUNCTION__, __LINE__);

    }

}

//

// Virtual methods from CServer2

//

OS_EXPORT TInt OsFunctionServer::RunError(TInt error)

{

    JELOG2(EUtils);

    if (error == KLeaveExit) // This is used to exit the application, we obviously want to let it through

    {

        return error;

    }

    else

    {

        return CServer2::RunError(error);

    }

}

OS_EXPORT CSession2* OsFunctionServer::NewSessionL(const TVersion& /*version*/, const RMessage2& /*message*/) const

{

    JELOG2(EUtils);

    return new(ELeave) CFunctionSession();

}

void OsFunctionServer::stopServerInsideServerThread()

{

    JELOG2(EUtils);

    CActiveScheduler::Stop();

}

ServerShutdown::ServerShutdown()

        : CActive(CActive::EPriorityStandard)

{

}

void ServerShutdown::startShutDown()

{

    CActiveScheduler::Add(this);

    iStatus=KRequestPending;

    TRequestStatus* status = &iStatus;

    User::RequestComplete(status, KErrNone);

    SetActive();

}

void ServerShutdown::RunL()

{

    JELOG2(EUtils);

    CActiveScheduler::Stop();

}

TInt ServerShutdown::RunError(TInt error)

{

    JELOG2(EUtils);

    if (error == KLeaveExit)

    {

        return error;

    }

    return KErrNone;

}

void ServerShutdown::DoCancel()

{

    JELOG2(EUtils);

    // nop

}