/*

 * 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 "tmsipcallstream.h"

#include "tmscallipadpt.h"

using namespace TMS;

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

// TMSCallIPAdpt::NewL

// Symbian constructor.

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

//

TMSCallIPAdpt* TMSCallIPAdpt::NewL()

    {

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

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

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

// TMSCallIPAdpt::ConstructL

// 2-nd phase constructor.

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

//

void TMSCallIPAdpt::ConstructL()

    {

    TRACE_PRN_FN_ENT;

    iIPUplink = NULL;

    iIPDownlink = NULL;

    TRACE_PRN_FN_EXT;

    }

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

// TMSCallIPAdpt::TMSCallIPAdpt

//

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

//

TMSCallIPAdpt::TMSCallIPAdpt()

    {

    }

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

// TMSCallIPAdpt::~TMSCallIPAdpt

//

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

//

TMSCallIPAdpt::~TMSCallIPAdpt()

    {

    TRACE_PRN_FN_ENT;

    iCodecs.Reset();

    iCodecs.Close();

    iArrBitrates.Reset();

    delete iIPUplink;

    delete iIPDownlink;

    if (iMsgQueueUp.Handle() > 0)

        {

        iMsgQueueUp.Close();

        }

    if (iMsgQueueDn.Handle() > 0)

        {

        iMsgQueueDn.Close();

        }

    TRACE_PRN_FN_EXT;

    }

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

// TMSCallIPAdpt::PostConstruct

//

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

//

gint TMSCallIPAdpt::PostConstruct()

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    iNextStreamId = 1;

    iUplinkInitialized = FALSE;

    iDnlinkInitialized = FALSE;

    TRACE_PRN_FN_EXT;

    return status;

    }

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

// TMSCallIPAdpt::CreateStream

//

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

//

gint TMSCallIPAdpt::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;

    }

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

// TMSCallIPAdpt::InitStream

//

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

//

gint TMSCallIPAdpt::InitStream(TMSCallType /*callType*/, TMSStreamType strmType,

        gint strmId, TMSFormatType frmtType, const RMessage2& message)

    {

    TRACE_PRN_FN_ENT;

    gint status(TMS_RESULT_SUCCESS);

    guint32 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(message);

                NotifyClient(iUplinkStreamId, ECmdUplinkInitComplete, status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            status = TMS_RESULT_DOES_NOT_EXIST;

            if (strmId == iDnlinkStreamId)

                {

                SetFormat(iDnlinkStreamId, fourCC);

                status = OpenDownlinkL(message);

                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;

    }

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

// TMSCallIPAdpt::StartStream

//

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

//

gint TMSCallIPAdpt::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 && iIPUplink)

                {

                iIPUplink->Start();

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iUplinkStreamId, ECmdUplinkStarted, status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if (strmId == iDnlinkStreamId && iIPDownlink)

                {

                iIPDownlink->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;

    }

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

// TMSCallIPAdpt::PauseStream

//

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

//

gint TMSCallIPAdpt::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 && iIPUplink)

                {

                iIPUplink->Stop();

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iUplinkStreamId, ECmdUplinkPaused, status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if (strmId == iDnlinkStreamId && iIPDownlink)

                {

                iIPDownlink->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;

    }

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

// TMSCallIPAdpt::StopStream

//

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

//

gint TMSCallIPAdpt::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 && iIPUplink)

                {

                iIPUplink->Stop();

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iUplinkStreamId, ECmdUplinkInitComplete, status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if (strmId == iDnlinkStreamId && iIPDownlink)

                {

                iIPDownlink->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;

    }

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

// TMSCallIPAdpt::DeinitStream

//

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

//

gint TMSCallIPAdpt::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 && iIPUplink)

                {

                iIPUplink->Stop();

                //iUplinkStreamId = -1;

                iUplinkInitialized = FALSE;

                status = TMS_RESULT_SUCCESS;

                NotifyClient(iUplinkStreamId, ECmdDownlinkDeInitComplete,

                        status);

                }

            break;

            }

        case TMS_STREAM_DOWNLINK:

            {

            if (strmId == iDnlinkStreamId && iIPDownlink)

                {

                iIPDownlink->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;

    }

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

// TMSCallIPAdpt::DeleteStream

//

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

//

gint TMSCallIPAdpt::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;

    }

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

// TMSCallIPAdpt::DataXferBufferEmptied

//

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

//

gint TMSCallIPAdpt::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;

    }

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

// TMSCallIPAdpt::DataXferBufferFilled

//

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

//

gint TMSCallIPAdpt::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;

    }

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

// TMSCallIPAdpt::GetDataXferBufferHndl

//

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

//

gint TMSCallIPAdpt::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;

    }

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

// TMSCallIPAdpt::GetMaxVolume

//

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