/*
* Copyright (c) 2009 - 2010 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:  Thread dump server of J9 VM in S60,
*
*/


#include <string> // Needed for strcmp

#include "logger.h"
#include "fileutilities.h"
#include "exceptionbase.h"
#include "javacommonutils.h"
#include "javasymbianoslayer.h"

#include "j9threaddumper.h"

using namespace java::util;

// ======== STATIC VARIABLES ========

OS_NONSHARABLE_CLASS(ThreadDumperGlobals)
{
public:
    ThreadDumperGlobals() : mDumper(0)
    {
    }

public:
    J9ThreadDumper*  mDumper;
};


#if defined(__WINSCW__)

#include <pls.h>
ThreadDumperGlobals* getThreadDumperGlobals()
{
    // Access the PLS of this process
    ThreadDumperGlobals* globals  =
        Pls<ThreadDumperGlobals>(TUid::Uid(0x20022E77));
    return globals;
}

#else

static ThreadDumperGlobals* sGlobals = 0;

ThreadDumperGlobals* getThreadDumperGlobals()
{
    if (sGlobals == 0)
    {
        sGlobals = new ThreadDumperGlobals();
    }
    return sGlobals;
}
#endif


// Function prototypes
void JNICALL agentThread(void* args);
jint JNICALL JVM_OnLoad(JavaVM* vm, char* options, void* reserved);



J9ThreadDumper::J9ThreadDumper(JavaVM* vm, DgRasInterface* jvmri) :
        mJavaVM(vm), mJNIEnv(0), mJvmriInterface(jvmri),
        mTask(NO_TASK), mState(CREATED)
{
    JELOG2(EJavaRuntime);
}

J9ThreadDumper::~J9ThreadDumper()
{
    JELOG2(EJavaRuntime);
}


void JNICALL agentThread(void* /*args*/)
{
#ifdef __SYMBIAN32__
    RThread().SetPriority(EPriorityMore);
#endif // __SYMBIAN32__
    JELOG2(EJavaRuntime);
    getThreadDumperGlobals()->mDumper->doRun();
    delete getThreadDumperGlobals()->mDumper;
    getThreadDumperGlobals()->mDumper = 0;
#ifndef __WINSCW__
    delete sGlobals;
    sGlobals = 0;
#endif

}

void J9ThreadDumper::doDump()
{
    JELOG2(EJavaRuntime);
    mTask = DO_DUMP;
    wakeUp();
}

void J9ThreadDumper::close()
{
    JELOG2(EJavaRuntime);
    mTask = CLOSE;
    wakeUp();
    mState = CLOSED;
}



void J9ThreadDumper::moveGeneratedDumpFile()
{
#ifdef __SYMBIAN32__
    JELOG2(EJavaRuntime);
    const wchar_t* const midpPrivateDataCage = L"c:\\private\\102033E6";
    const wchar_t* const destRoot = L"c:\\logs\\java\\";


    // Ensure that the target dir exists.
    std::wstring dest(destRoot);
    std::replace(dest.begin(), dest.end(), '\\', '/');
    java::fileutils::FileUtilities::makeDirAll(dest);

    // Get all the files of the private data cage.
    std::list<std::wstring> dirList = java::fileutils::FileUtilities::getDirContentsList(midpPrivateDataCage);

    // Loop all existing files and try to find generated core dumps.
    std::list<std::wstring>::const_iterator it;
    for (it = dirList.begin(); it != dirList.end(); it++)
    {
        if (it->find(L"javacore.") == 0)
        {
            std::wstring oldName(midpPrivateDataCage);
            oldName += L"\\";
            oldName += *it;
            std::wstring newName(destRoot);
            newName += *it;

            char* oldUtf8Name = JavaCommonUtils::wstringToUtf8(oldName);
            char* newUtf8Name = JavaCommonUtils::wstringToUtf8(newName);

            int error = rename(oldUtf8Name, newUtf8Name);
            delete[] oldUtf8Name;
            delete[] newUtf8Name;
        }
    }
#endif // __SYMBIAN32__
}

void J9ThreadDumper::wakeUp()
{
    JELOG2(EJavaRuntime);
    if (mState == ACTIVE)
    {
        mMonitor->notify();
    }
}

void J9ThreadDumper::doRun()
{
    JELOG2(EJavaRuntime);
    if (mState != CREATED)
    {
        return;
    }

    int status = mJavaVM->AttachCurrentThreadAsDaemon((void**)&mJNIEnv, 0);
    if (status == 0)
    {
        mMonitor.reset(Monitor::createMonitor());
        mState = ACTIVE;
        while (mState == ACTIVE)
        {
            mMonitor->wait();
            switch (mTask)
            {
            case DO_DUMP:
                mJvmriInterface->GenerateJavacore(mJNIEnv);
                moveGeneratedDumpFile();
                break;
            case CLOSE:
                mState = CLOSED;
                break;
            }
            mTask = NO_TASK;
        }
        mJavaVM->DetachCurrentThread();
    }
    else
    {
        ELOG1(EUtils, "Thread dumper failed to attach to VM: %d", status);
    }
}

JNIEXPORT jint JNICALL JVM_OnLoad(JavaVM* vm, char* options, void* /*reserved*/)
{
    JELOG2(EJavaRuntime);
    int     rc = -1;
    JNIEnv* env;

    try
    {
        // Get the JNIEnv for the current thread
        rc = vm->GetEnv((void **)&env, JNI_VERSION_1_2);
        if (rc != JNI_OK)
        {
            // No JNIEnv; fail
            return JNI_ERR;
        }

        // Get the RAS Interface
        DgRasInterface* jvmriInterface;
        rc = vm->GetEnv((void **)&jvmriInterface, JVMRAS_VERSION_1_3);
        if (rc != JNI_OK)
        {
            // No RAS Interface available; fail
            return JNI_ERR;
        }

        getThreadDumperGlobals()->mDumper = new J9ThreadDumper(vm, jvmriInterface);

        if (options != 0)
        {
            LOG1(EUtils, EInfo, "Dump options = %s", options);
        }
        // Request creation of the agent thread
        rc = jvmriInterface->CreateThread(env, agentThread,0 , 0);
    }

    catch (ExceptionBase& ex)
    {
        ELOG1(EJavaRuntime,"ERROR in Thread Dump. ExceptionBase: %s",ex.toString().c_str());
    }
    catch (std::exception& e)
    {

        ELOG1(EJavaRuntime,"ERROR in Thread Dump. std::exception: %s",e.what());
    }
    catch (...)
    {
        ELOG(EJavaRuntime,"ERROR in Thread Dump. Unexpected exception was caught");
    }
    return rc;
}

// Keep this in sync with typedef in threaddumper.h file
void doThreadDump()
{
    JELOG2(EJavaRuntime);
    J9ThreadDumper* instance = getThreadDumperGlobals()->mDumper;
    if (instance)
    {
        instance->doDump();
    }
#ifndef __WINSCW__
    else
    {
        delete sGlobals;
        sGlobals = 0;
    }
#endif
}

// Keep this in sync with typedef in threaddumper.h file
void closeThreadDump()
{
    JELOG2(EJavaRuntime);
    J9ThreadDumper* instance = getThreadDumperGlobals()->mDumper;
    if (instance)
    {
        instance->close();
    }
#ifndef __WINSCW__
    else
    {
        delete sGlobals;
        sGlobals = 0;
    }
#endif
}


#ifdef __SYMBIAN32__
EXPORT_C FuncPtr JNICALL jni_lookup(const char* aName)
{
    JELOG2(EJavaRuntime);
    if (!strcmp(aName, "JVM_OnLoad"))
    {
        return (FuncPtr)JVM_OnLoad;
    }

    else if (!strcmp(aName, "doThreadDump"))
    {
        return (FuncPtr)doThreadDump;
    }

    else if (!strcmp(aName, "closeThreadDump"))
    {
        return (FuncPtr)closeThreadDump;
    }

    return 0;
}
#endif // __SYMBIAN32__