/*

* 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:  Pmc

 *

*/

#include <sstream>

#include <memory>

#include "javasymbianoslayer.h"

#include "logger.h"

#include "pmc.h"

#include "processmanagementeventsinterface.h"

#include "coreinterface.h"

#include "midpruntimearguments.h"

using namespace java::comms;

namespace java

{

namespace captain

{

Pmc::Pmc():mCore(0), mProcessManagementEventsDispatcher(0)

{

    JELOG4(EJavaCaptain, EInfo);

}

Pmc::~Pmc()

{

    JELOG4(EJavaCaptain, EInfo);

    mCore = 0;

    mProcessManagementEventsDispatcher = 0;

}

bool Pmc::start(CoreInterface* aCore,

                ProcessManagementEventsInterface* aProcessManagementEventsDispatcher)

{

    JELOG4(EJavaCaptain, EInfo);

    mCore = aCore;

    mProcessManagementEventsDispatcher = aProcessManagementEventsDispatcher;

    return true;

}

bool Pmc::stop()

{

    JELOG4(EJavaCaptain, EInfo);

    ScopedLock lock(mProcessesMutex);

    for (processes_t::iterator iter = mProcesses.begin() ; iter != mProcesses.end() ; /*emty*/)

    {

        delete iter->second;

        mProcesses.erase(iter++);

    }

    return true;

}

int Pmc::launch(const cmdLine_t& cmdLine, const int& /*options*/)

{

    JELOG4(EJavaCaptain, EInfo);

    int cmdLineSize = cmdLine.size();

    if (cmdLineSize > 0)

    {

        std::auto_ptr<HBufC> runtimeProcess(stringToDes(cmdLine[0].c_str()));

        std::ostringstream params;

        for (unsigned int i = 1 ; i < cmdLineSize ; i++)

        {

            params << cmdLine[i] << " ";

        }

        std::auto_ptr<HBufC> runtimeArgs(stringToDes(params.str().c_str()));

        ILOG2(EJavaCaptain, "launch command line: %s : %s",

              cmdLine[0].c_str(), params.str().c_str());

        ScopedLock lock(mProcessesMutex);

        processes_t::iterator iter = mProcesses.begin();

        while (iter != mProcesses.end())

        {

            if (iter->second->isExited())

            {

                delete iter->second;

                mProcesses.erase(iter);

                iter = mProcesses.begin();

            }

            else

            {

                ++iter;

            }

        }

        std::auto_ptr<RProcess> rp(new RProcess);

        bool prewarm = false;

        if (std::find(cmdLine.begin(), cmdLine.end(), java::runtime::PREWARM_ARGUMENT) != cmdLine.end())

        {

            prewarm = true;

        }

        JavaOsLayer::startUpTrace("CAPTAIN: Creating process", -1, -1);

        if (KErrNone == rp->Create(TPtr(runtimeProcess->Des()), TPtr(runtimeArgs->Des())))

        {

            int pid = rp->Id();

            mProcesses.insert(std::make_pair(pid, new ProcessActive(rp.release(), this, prewarm)));

            return pid;

        }

    }

    return 0;

}

int Pmc::terminate(const int& pid)

{

    JELOG4(EJavaCaptain, EInfo);

    ScopedLock lock(mProcessesMutex);

    processes_t::iterator iter = mProcesses.find(pid);

    if (iter != mProcesses.end())

    {

        iter->second->Terminate(KErrNone);

    }

    return 0;

}

int Pmc::kill(const int& pid)

{

    JELOG4(EJavaCaptain, EInfo);

    ScopedLock lock(mProcessesMutex);

    processes_t::iterator iter = mProcesses.find(pid);

    if (iter != mProcesses.end())

    {

        iter->second->Kill(KErrNone);

    }

    return 0;

}

void Pmc::handleTerminated(const int& pid, const int& exitCode)

{

    JELOG4(EJavaCaptain, EInfo);

    if (mProcessManagementEventsDispatcher)

        mProcessManagementEventsDispatcher->pmcTerminated(pid, exitCode);

}

} // namespace captain

} // namespace java