/*

* 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 the License "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: Symbian debugging and profiling functions

*

*/

#include "m3g_defs.h"

#include <e32base.h>

#include <f32file.h>

#include <ezlib.h>

#if defined(M3G_SYMBIAN_REMOTE_LOGGING)

#include <EcmtClient.h>

#endif

struct M3GLogger

{

    M3Gint refCount;

#   if defined(M3G_SYMBIAN_REMOTE_LOGGING)

    REcmt iEcmt;

#   endif

#   if defined(M3G_ENABLE_PROFILING)

    M3Guint tickCount[M3G_STAT_MAX];

    M3Guint lastOutputTickCount;

#   endif

};

/*----------------------------------------------------------------------

 * Internal functions

 *--------------------------------------------------------------------*/

/*!

 * \brief Symbian implementation of the block inflation function for

 * the Loader class

 */

extern "C" M3Gsizei m3gSymbianInflateBlock(M3Gsizei srcLength,

                                           const M3Gubyte *src,

                                           M3Gsizei dstLength,

                                           M3Gubyte *dst)

{

    M3G_ASSERT(src);

    M3G_ASSERT(dst);

    M3G_ASSERT(srcLength > 0);

    {

        uLongf len = (uLongf) dstLength;

        if (uncompress((Bytef *) dst, &len,

                       (const Bytef *) src, (uLong) srcLength) != Z_OK) {

            return 0;

        }

        return (M3Gsizei) len;

    }

}

/*!

 * \brief Logging function

 *

 * \note This currently creates a session to the file server for each

 * message, so performance will be sub-optimal if logging is frequent

 */

extern "C" void m3gLogMessage(const char *format, ...)

{    

#   if !defined(M3G_SYMBIAN_REMOTE_LOGGING)

    _LIT(KFileName, "c:\\m3g_event.log");

    RFs fileSrv;

    RFile file;

    if (fileSrv.Connect() != KErrNone) {

        return;

    }

    TInt accessMode = EFileWrite|EFileShareExclusive;

    TInt err = file.Open(fileSrv, KFileName, accessMode);

    // If the file exists, seek to the end; if it doesn't, create it

    if (err == KErrNone) {

        TInt pos = 0;

        file.Seek(ESeekEnd, pos);

    }

    else if (err == KErrNotFound) {

        if (file.Create(fileSrv, KFileName, accessMode) != KErrNone) {

            fileSrv.Close();

            return;

        }

    }

#   endif // !M3G_SYMBIAN_REMOTE_LOGGING

    // Format and write the message

    TBuf8<1024> msg;

    TPtrC8 aFormat((const TUint8 *) format);

    VA_LIST aList;

    VA_START(aList, format);

    msg.FormatList(aFormat, aList);

    VA_END(aList);

#   if defined(M3G_SYMBIAN_REMOTE_LOGGING)

    M3GLogger *logger = (M3GLogger*) Dll::Tls();

    if (logger) {

        TBuf16<1024> msg16;

        msg16.Copy(msg);

        logger->iEcmt.Write(msg16);

    }

#   else

    file.Write(msg);

    // Close the file and the server connection

    file.Flush();

    file.Close();

    fileSrv.Close();

#   endif // !M3G_SYMBIAN_REMOTE_LOGGING

}

/*!

 * \brief Create new log file

 */

extern "C" void m3gBeginLog(void)

{

#   if defined(M3G_SYMBIAN_REMOTE_LOGGING)

    M3GLogger *logger = (M3GLogger*) Dll::Tls();

    if (!logger) {

        logger = new M3GLogger();

        logger->refCount = 0;

        logger->lastOutputTickCount = User::TickCount();

        Dll::SetTls(logger);

    }

    if (++logger->refCount == 1) {

        logger->iEcmt.Connect();

    }

#   else

    /* Just delete any existing log file */

    _LIT(KFileName, "c:\\m3g_event.log");

    RFs fileSrv;

    RFile file;

    if (fileSrv.Connect() != KErrNone) {

        return;

    }

    TInt accessMode = EFileWrite|EFileShareExclusive;

    if (file.Replace(fileSrv, KFileName, accessMode) == KErrNone) {

        file.Flush();

        file.Close();

    }

    fileSrv.Close();

#   endif // !M3G_SYMBIAN_REMOTE_LOGGING

    /* Output initial message(s) */

    m3gLogMessage("--- M3G event log ---\n");

}

/*!

 * \brief End logging

 */

extern "C" void m3gEndLog(void)

{

#   if defined(M3G_SYMBIAN_REMOTE_LOGGING)

    M3GLogger *logger = (M3GLogger*) Dll::Tls();

    if (logger) {

        if (--logger->refCount == 0) {

            logger->iEcmt.Close();

            Dll::FreeTls();

            delete logger;

        }

    }

#   endif

    m3gLogMessage("--- end of log ---\n");

}

/*!

 * \brief Assertion handler

 */

extern "C" void m3gAssertFailed(const char *filename, int line)

{

    M3G_LOG2(M3G_LOG_ALL, "Assertion failed: %s, line %d\n", filename, line);

    User::Panic(_L("M3G-ASSERT"), line);

}

#if defined(M3G_BUILD_DLL)

/*!

 * \brief DLL load check

 */

#ifndef EKA2

GLDEF_C TInt E32Dll( TDllReason /* aReason */ )

{

    return KErrNone;

}

#endif

#endif /* M3G_BUILD_DLL */

/*----------------------------------------------------------------------

 * Profiling

 *--------------------------------------------------------------------*/

#if defined(M3G_ENABLE_PROFILING)

extern "C" void m3gCleanupProfile(void)

{

    ;

}

extern "C" void m3gBeginProfile(int stat)

{

    M3GLogger *logger = (M3GLogger*) Dll::Tls();

    if (logger) {

        logger->tickCount[stat] = User::TickCount();

    }

}

extern "C" int m3gEndProfile(int stat)

{

    M3GLogger *logger = (M3GLogger*) Dll::Tls();

    if (logger) {

        return User::TickCount() - logger->tickCount[stat];

    }

    return 0;

}

extern "C" M3Gint m3gProfileTriggered(void)

{

#   if (M3G_PROFILE_LOG_INTERVAL > 0)

    M3GLogger *logger = (M3GLogger*) Dll::Tls();

    if (logger) {

        M3Guint tickCount = User::TickCount();

        M3Guint delta = tickCount - logger->lastOutputTickCount;

        if (delta >= M3G_PROFILE_LOG_INTERVAL) {

            logger->lastOutputTickCount = tickCount;

            return (M3Gint) delta;

        }

    }

#   endif

    return 0;

}

#endif