/*

* Copyright (c) 2009 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: DiagnosticImpl provides implementation for JavaDiagnostic

*

*/

#include "diagnosticimpl.h"

#include "javaredirectserver.h"

using namespace java::debug;

_LIT(KJavaRedirectThread,"JavaRedirectServerThread");

const int REDIRECT_THREAD_STACK_SIZE = 0x5000;

DiagnosticImpl::DiagnosticImpl() : CActive(EPriorityStandard), mListener(0)

{

}

DiagnosticImpl::~DiagnosticImpl()

{

    stop();

}

TInt DiagnosticImpl::setDiagnosticListener(DiagnosticListener& aListener)

{

    TInt rc = KErrAlreadyExists;

    if (!mListener)

    {

        mListener = &aListener;

        rc = start();

        if (rc != KErrNone)

        {

            mListener = 0;

        }

    }

    return rc;

}

void DiagnosticImpl::removeDiagnosticListener()

{

    stop();

    mListener = 0;

}

TInt DiagnosticImpl::start()

{

    TInt rc = mThread.Create(

                  KJavaRedirectThread,

                  reinterpret_cast<TThreadFunction>(messageLoop),

                  REDIRECT_THREAD_STACK_SIZE,

                  NULL,

                  this);

    if (rc == KErrNone)

    {

        // block until thread has been started ok

        TRequestStatus rendezvousStatus;

        mThread.Rendezvous(rendezvousStatus);

        mThread.Resume();

        User::WaitForRequest(rendezvousStatus);

        rc = rendezvousStatus.Int();

    }

    return rc;

}

void DiagnosticImpl::stop()

{

    if (mListener)

    {

        TRequestStatus status;

        mThread.Logon(status);

        TRequestStatus* istatus = &iStatus;

        mThread.RequestComplete(istatus, KErrNone);

        User::WaitForRequest(status);

        mThread.Close();

    }

}

void DiagnosticImpl::messageLoop(TAny* aArgs)

{

    CTrapCleanup* cleanup = CTrapCleanup::New();

    TInt r = KErrNoMemory;

    if (cleanup)

    {

        DiagnosticImpl* me = reinterpret_cast<DiagnosticImpl*>(aArgs);

        TRAP(r,me->runServerL());

    }

    RThread::Rendezvous(r);

    delete cleanup;

}

void DiagnosticImpl::runServerL()

{

    CActiveScheduler* s = new(ELeave) CActiveScheduler;

    CleanupStack::PushL(s);

    CActiveScheduler::Install(s);

    java::util::CRedirectServer* server = new(ELeave) java::util::CRedirectServer(*this);

    CleanupStack::PushL(server);

    server->StartL();

    CActiveScheduler::Add(this);

    iStatus = KRequestPending;

    SetActive();

    RThread::Rendezvous(KErrNone);

    CActiveScheduler::Start();

    CleanupStack::PopAndDestroy(server);

    CleanupStack::PopAndDestroy(s);

}

void DiagnosticImpl::RunL()

{

    CActiveScheduler::Stop();

}

void DiagnosticImpl::DoCancel()

{

}

TInt DiagnosticImpl::RunError(TInt /*aError*/)

{

    return KErrNone;

}

void DiagnosticImpl::systemOut(const TDesC8& aData)

{

    mListener->systemOut(aData);

}

void DiagnosticImpl::systemErr(const TDesC8& aData)

{

    mListener->systemErr(aData);

}

void DiagnosticImpl::log(const TDesC8& aData)

{

    mListener->log(aData);

}