/*
 * Copyright (c) 2007-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:  VoIP Audio Services
 *               Implements base class for uplink and downlink thread objects.
 *
 */

#include "debugtracemacros.h"
#include "VoIPServerThread.h"

// -----------------------------------------------------------------------------
// CVoIPThreadBase::~CVoIPThreadBase
// Destructor
// -----------------------------------------------------------------------------
//
CVoIPThreadBase::~CVoIPThreadBase()
    {
    TRACE_PRN_FN_ENT;

    iChunk.Close();
    delete iMsgQComHandler;
    iMsgQueue.Close();
    iMsgComQueue.Close();
    delete iDevSound;
    delete iActiveScheduler;

    TRACE_PRN_FN_EXT;
    }

// -----------------------------------------------------------------------------
// CVoIPThreadBase::InitThreadL
// Thread initialization
// -----------------------------------------------------------------------------
//
void CVoIPThreadBase::InitThreadL()
    {
    TRACE_PRN_FN_ENT;

    // Create and install active scheduler for this thread
    iActiveScheduler = new (ELeave) CActiveScheduler;
    CActiveScheduler::Install(iActiveScheduler);

    TRACE_PRN_FN_EXT;
    }

// -----------------------------------------------------------------------------
// CVoIPThreadBase::InitMsgQueuesL
//
// -----------------------------------------------------------------------------
//
void CVoIPThreadBase::InitMsgQueuesL(const TDesC& aBufferQ, const TDesC& aComQ)
    {
    TRACE_PRN_FN_ENT;

    // Make sure client thread finished creating message queues
    while (iMsgQueue.OpenGlobal(aBufferQ))
        {
        User::After(KQueueCreateWaitTime);
        }

    // Create message queue for ITC with this thread
    while (iMsgComQueue.OpenGlobal(aComQ))
        {
        User::After(KQueueCreateWaitTime);
        }

    iMsgQComHandler = CQueueHandlerSrv::NewL(this, &iMsgComQueue);

    if (iMsgQComHandler)
        {
        iMsgQComHandler->Start();
        }

    TRACE_PRN_FN_EXT;
    }

// -----------------------------------------------------------------------------
// CVoIPThreadBase::InitDevSoundL
//
// -----------------------------------------------------------------------------
//
void CVoIPThreadBase::InitDevSoundL(const TMMFState aDevSoundState,
        const TInt aPriority, const TInt aPreference)
    {
    TRACE_PRN_FN_ENT;

    iDevSound = CMMFDevSound::NewL();

    if (iDevSound)
        {
        iDevSound->InitializeL(*this, TFourCC(iCodecID), aDevSoundState);
        TMMFPrioritySettings prio;
        prio.iPref = aPreference;
        prio.iPriority = aPriority;
        iDevSound->SetPrioritySettings(prio);
        }
    }

// -----------------------------------------------------------------------------
// CVoIPThreadBase::DetermineMaxBufferLen
//
// -----------------------------------------------------------------------------
//
TInt CVoIPThreadBase::DetermineMaxBufferLen(
        TVoIPCodecSettings::TG711FrameRate aG711FrameRate)
    {
    TRACE_PRN_FN_ENT;

    TInt len = 0;

    switch (iCodecID)
        {
        case KMccFourCCIdG711:
            {
            len = KVoIPG711FrameLen20ms;
            if (aG711FrameRate == TVoIPCodecSettings::E10MS)
                {
                len = KVoIPG711FrameLen10ms;
                }
            break;
            }
        case KMccFourCCIdG729:
            len = KVoIPG729FrameLen;
            break;
        case KMccFourCCIdILBC:
            len = KVoIPILBCFrameLen;
            break;
        case KMccFourCCIdAMRNB:
            len = KVoIPAMRNBFrameLen;
            break;
        case KMMFFourCCCodePCM16:
            len = KVoIPPCM16FrameLen;
            break;
        default:
            break;
        }

    return len;
    }

// -----------------------------------------------------------------------------
// CVoIPThreadBase::DoChunk
// Checks, adjusts and creates global RChunk.
// -----------------------------------------------------------------------------
//
TInt CVoIPThreadBase::DoChunk(const TDesC& aChunkName, const TInt aChunkLen,
        const TInt aChunkMaxLen)
    {
    TInt err = KErrNone;

    if (iChunk.Handle() == 0)
        {
        // NOTE: The fact we closed chunk handle doesn't mean the chunk is
        //       physically removed from the kernel. Most likely it still
        //       exist as long as the owning process is up and running.
        //       Trying to create new global chunk with duplicate name fails
        //       with -11. That's why we need to search first.

        TFindChunk chunk(aChunkName);
        TFullName name;
        if (chunk.Next(name) == KErrNone)
            {
            // Chunk found - open and use it
            iChunk.SetHandle(chunk.Handle());
            err = iChunk.Open(chunk);
            if (err == KErrNone)
                {
                err = iChunk.Adjust(aChunkLen);
                }
            TRACE_PRN_N1(_L("VoIP->THRD: DoChunk->Chunk Opened [%d]"), err);
            }
        else
            {
            err = iChunk.CreateGlobal(aChunkName, aChunkLen, aChunkMaxLen);
            TRACE_PRN_N1(_L("VoIP->THRD: DoChunk->Chunk Created [%d]"), err);
            }
        }
    else
        {
        // Make sure global chunk's current committed size is not
        // smaller than the buffer size requested by the D/S
        if (aChunkLen > iChunk.Size())
            {
            // Re-adjust length of the existing RChunk
            err = iChunk.Adjust(aChunkLen);
            TRACE_PRN_N1(_L("VoIP->THRD: DoChunk->Chunk Adjusted [%d]"), err);
            }
        }

    return err;
    }

// End of file