/*

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

*

*/

#include <flogger.h>

#include "logger.h"

#include "mjvmnativeportlayer.h"

#include "mjavafile.h"

#include "javafile.h"

#include "jvmnativeportlayer.h"

using namespace javaruntime;

MJvmNativePortLayer* CJvmNativePortLayer::NewL(void)

{

    JELOG2(EJVM);

    CJvmNativePortLayer* portLayer = new(ELeave) CJvmNativePortLayer;

    CleanupStack::PushL(portLayer);

    portLayer->ConstructL();

    CleanupStack::Pop(portLayer);

    return portLayer;

}

CJvmNativePortLayer::CJvmNativePortLayer():iStdOut(0), iStdErr(0)

{

    JELOG2(EJVM);

}

CJvmNativePortLayer::~CJvmNativePortLayer()

{

    JELOG2(EJVM);

    if (iStdOut != 0)

    {

        delete iStdOut;

        iStdOut = 0;

    }

    if (iStdErr != 0)

    {

        delete iStdErr;

        iStdErr = 0;

    }

    iRedirector.close();

}

_LIT(KOutpuDir,"java");

_LIT(KOutpuFullDir,"c:\\logs\\java");

_LIT(KConsole,"vmconsole.txt");

void CJvmNativePortLayer::ConstructL(void)

{

    JELOG2(EJVM);

    _LIT(KStdOut,"stdout_%02i%02i_%02i%02i%02i.txt");

    _LIT(KStdErr,"stderr_%02i%02i_%02i%02i%02i.txt");

    iStdOut = HBufC::NewL(KDesLength);

    iStdErr = HBufC::NewL(KDesLength);

    RFs rfs;

    TUint dummy;

    if (rfs.Connect() != KErrNone)

    {

        iLogging = EFalse;

        return;

    }

    if (rfs.Att(KOutpuFullDir, dummy) != KErrNone)

    {

        iLogging = EFalse;

    }

    else

    {

        iLogging = ETrue;

        TTime time;

        time.HomeTime();

        TDateTime dt = time.DateTime();

        iStdOut->Des().Format(KStdOut, dt.Month()+1, dt.Day()+1,

                              dt.Hour(), dt.Minute(), dt.Second());

        iStdErr->Des().Format(KStdErr, dt.Month()+1, dt.Day()+1,

                              dt.Hour(), dt.Minute(), dt.Second());

    }

    rfs.Close();

    iRedirector.connect();

}

MJavaFile* CJvmNativePortLayer::GetJavaFileL()

{

    JELOG2(EJVM);

    MJavaFile* javaFile = CJavaFile::NewL();

    return javaFile;

}

void CJvmNativePortLayer::WriteToStdoutL(const TDesC8& aData)

{

    if (iLogging)

    {

//              RFileLogger::Write( KOutpuDir, *iStdOut, EFileLoggingModeAppendRaw, aData);

        RFileLogger::Write(KOutpuDir, KConsole, EFileLoggingModeAppendRaw, aData);

    }

    iRedirector.systemOut(aData);

}

void CJvmNativePortLayer::WriteToStderrL(const TDesC8& aData)

{

    if (iLogging)

    {

//              RFileLogger::Write( KOutpuDir, *iStdErr, EFileLoggingModeAppendRaw, aData);

        RFileLogger::Write(KOutpuDir, KConsole, EFileLoggingModeAppendRaw, aData);

    }

    iRedirector.systemErr(aData);

}

//Obsolite method, but keeping to be in sync with legacy

EXPORT_C void CJvmNativePortLayer::SetPointerToCafMethod(TBool(* /*aUseCafForFileOpen*/)(const TDesC&))

{

    JELOG2(EJVM);

}

EXPORT_C MJvmNativePortLayer* GetPortLayerL()

{

    JELOG2(EJVM);

    return CJvmNativePortLayer::NewL();

}

const TThreadPriority priorityMapping[] =

{

    EPriorityMuchLess, //0

    EPriorityMuchLess, //1

    EPriorityMuchLess, //2

    EPriorityMuchLess, //3

    EPriorityMuchLess, //4

    EPriorityLess,     //5

    EPriorityLess,     //6

    EPriorityLess,     //7

    EPriorityLess,     //8

    EPriorityNormal,   //9

    EPriorityNormal,   //10

    EPriorityMore,     //11

};

EXPORT_C TThreadPriority GetSingleThreadPriority(const TInt& aJavaPriority)

{

    JELOG2(EJVM);

    TInt index = Max(Min(aJavaPriority,11),0);

    return priorityMapping[index];

}