/*

 * 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: Telephony Multimedia Service

 *

 */

#include <AudioPreference.h>

#include "tmsutility.h"

#include "tmsclientserver.h"

#include "tmsshared.h"

#include "ipcallstream.h"

#include "callipadpt.h"

using namespace TMS;

// -----------------------------------------------------------------------------

// CallIPAdpt::NewL

// Symbian constructor.

// -----------------------------------------------------------------------------

//

CallIPAdpt* CallIPAdpt::NewL()

    {

    CallIPAdpt* self = new (ELeave) CallIPAdpt();

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::ConstructL

// 2-nd phase constructor.

// -----------------------------------------------------------------------------

//

void CallIPAdpt::ConstructL()

    {

    TRACE_PRN_FN_ENT;

    iVoIPUplink = NULL;

    iVoIPDownlink = NULL;

    TRACE_PRN_FN_EXT;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::CallIPAdpt

//

// -----------------------------------------------------------------------------

//

CallIPAdpt::CallIPAdpt()

    {

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::~CallIPAdpt

//

// -----------------------------------------------------------------------------

//

CallIPAdpt::~CallIPAdpt()

    {

    TRACE_PRN_FN_ENT;

    iCodecs.Reset();

    iCodecs.Close();

    iArrBitrates.Reset();

    delete iVoIPUplink;

    delete iVoIPDownlink;

    if (iMsgQueueUp.Handle() > 0)

        {

        iMsgQueueUp.Close();

        }

    if (iMsgQueueDn.Handle() > 0)

        {

        iMsgQueueDn.Close();

        }

    TRACE_PRN_FN_EXT;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::PostConstruct

//

// -----------------------------------------------------------------------------

//

gint CallIPAdpt::PostConstruct()

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    iNextStreamId = 1;

    iUplinkInitialized = FALSE;

    iDnlinkInitialized = FALSE;

    TRACE_PRN_FN_EXT;

    return status;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::CreateStream

//

// -----------------------------------------------------------------------------

//

gint CallIPAdpt::CreateStream(TMSCallType /*callType*/,

        TMSStreamType strmType, gint& outStrmId)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            status = TMS_RESULT_ALREADY_EXIST;

            if (!iUplinkInitialized)

                {

                iUplinkInitialized = TRUE;

                iUplinkStreamId = iNextStreamId;

                outStrmId = iUplinkStreamId;

                iNextStreamId++;

                status = TMS_RESULT_SUCCESS;

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            status = TMS_RESULT_ALREADY_EXIST;

            if (!iDnlinkInitialized)

                {

                iDnlinkInitialized = TRUE;

                iDnlinkStreamId = iNextStreamId;

                outStrmId = iDnlinkStreamId;

                iNextStreamId++;

                status = TMS_RESULT_SUCCESS;

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::InitStream

//

// -----------------------------------------------------------------------------

//

gint CallIPAdpt::InitStreamL(TMSCallType /*callType*/,

        TMSStreamType strmType, gint strmId, TMSFormatType frmtType,

        const RMessage2& aMessage)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    TUint32 fourCC = TOFOURCC(frmtType);

    if (fourCC == NULL)

        {

        return TMS_RESULT_INVALID_ARGUMENT;

        }

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            status = TMS_RESULT_DOES_NOT_EXIST;

            if (strmId == iUplinkStreamId)

                {

                SetFormat(iUplinkStreamId, fourCC);

                status = OpenUplinkL(aMessage);

                NotifyClient(iUplinkStreamId, ECmdUplinkInitComplete, status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            status = TMS_RESULT_DOES_NOT_EXIST;

            if (strmId == iDnlinkStreamId)

                {

                SetFormat(iDnlinkStreamId, fourCC);

                status = OpenDownlinkL(aMessage);

                NotifyClient(iDnlinkStreamId, ECmdDownlinkInitComplete, status);

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_IF_ERR(status);

    TRACE_PRN_FN_EXT;

    return status;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::StartStream

//

// -----------------------------------------------------------------------------

//

gint CallIPAdpt::StartStream(TMSCallType /*callType*/, TMSStreamType strmType,

        gint strmId)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_INVALID_STATE);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            if (strmId == iUplinkStreamId && iVoIPUplink)

                {

                iVoIPUplink->Start();

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iUplinkStreamId, ECmdUplinkStarted, status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if (strmId == iDnlinkStreamId && iVoIPDownlink)

                {

                iVoIPDownlink->Start();

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iDnlinkStreamId, ECmdDownlinkStarted, status);

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::PauseStream

//

// -----------------------------------------------------------------------------

//

gint CallIPAdpt::PauseStream(TMSCallType /*callType*/, TMSStreamType strmType,

        gint strmId)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_INVALID_STATE);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            if (strmId == iUplinkStreamId && iVoIPUplink)

                {

                iVoIPUplink->Stop();

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iUplinkStreamId, ECmdUplinkPaused, status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if (strmId == iDnlinkStreamId && iVoIPDownlink)

                {

                iVoIPDownlink->Stop();

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iDnlinkStreamId, ECmdDownlinkPaused, status);

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::StopStream

//

// -----------------------------------------------------------------------------

//

gint CallIPAdpt::StopStream(TMSCallType /*callType*/, TMSStreamType strmType,

        gint strmId)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_INVALID_STATE);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            if (strmId == iUplinkStreamId && iVoIPUplink)

                {

                iVoIPUplink->Stop();

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iUplinkStreamId, ECmdUplinkInitComplete, status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if (strmId == iDnlinkStreamId && iVoIPDownlink)

                {

                iVoIPDownlink->Stop();

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iDnlinkStreamId, ECmdDownlinkInitComplete, status);

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::DeinitStream

//

// -----------------------------------------------------------------------------

//

gint CallIPAdpt::DeinitStream(TMSCallType /*callType*/, TMSStreamType strmType,

        gint strmId)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_INVALID_STATE);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            if (strmId == iUplinkStreamId && iVoIPUplink)

                {

                iVoIPUplink->Stop();

                //iUplinkStreamId = -1;

                iUplinkInitialized = FALSE;

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iUplinkStreamId, ECmdDownlinkDeInitComplete,

                        status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if (strmId == iDnlinkStreamId && iVoIPDownlink)

                {

                iVoIPDownlink->Stop();

                //iDnlinkStreamId = -1;

                iDnlinkInitialized = FALSE;

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iDnlinkStreamId, ECmdDownlinkDeInitComplete,

                        status);

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::DeleteStream

//

// -----------------------------------------------------------------------------

//

gint CallIPAdpt::DeleteStream(TMSCallType /*callType*/,

        TMSStreamType strmType, gint strmId)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            // This is additional error checking

            if (strmId == iUplinkStreamId)

                {

                iUplinkStreamId = -1;

                iUplinkInitialized = FALSE;

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            // This is additional error checking

            if (strmId == iDnlinkStreamId)

                {

                iDnlinkStreamId = -1;

                iDnlinkInitialized = FALSE;

                }

            break;

            }

        default:

            {

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

            }

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::DataXferBufferEmptied

//

// -----------------------------------------------------------------------------

//

gint CallIPAdpt::DataXferBufferEmptied(TMSCallType /*callType*/,

        TMSStreamType strmType, gint strmId)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    switch (strmType)

        {

        case TMS_STREAM_UPLINK:

            {

            if (strmId == iUplinkStreamId)

                {

                TRAP(status, BufferEmptiedL());

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            status = TMS_RESULT_ILLEGAL_OPERATION;

            break;

        default:

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::DataXferBufferFilled

//

// -----------------------------------------------------------------------------

//

gint CallIPAdpt::DataXferBufferFilled(TMSCallType /*callType*/,

        TMSStreamType strmType, gint strmId, guint datasize)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    switch (strmType)

        {

        case TMS_STREAM_DOWNLINK:

            if (strmId == iDnlinkStreamId)

                {

                TRAP(status, BufferFilledL(datasize));

                }

            break;

        case TMS_STREAM_UPLINK:

            status = TMS_RESULT_ILLEGAL_OPERATION;

            break;

        default:

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::GetDataXferBufferHndl

//

// -----------------------------------------------------------------------------

//

gint CallIPAdpt::GetDataXferBufferHndl(const TMSCallType /*callType*/,

        const TMSStreamType strmType, const gint strmId, const guint32 key,

        RChunk& chunk)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    switch (strmType)

        {

        case TMS_STREAM_DOWNLINK:

            {

            if (strmId == iDnlinkStreamId)

                {

                TRAP(status, GetDataXferChunkHndl(strmType, key, chunk));

                }

            break;

            }

        case TMS_STREAM_UPLINK:

            {

            if (strmId == iUplinkStreamId)

                {

                TRAP(status, GetDataXferChunkHndl(strmType, key, chunk));

                }

            break;

            }

        default:

            status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED;

            break;

        }

    TRACE_PRN_FN_EXT;

    return status;

    }

// -----------------------------------------------------------------------------

// CallIPAdpt::GetMaxVolume

//