/*
* Copyright (c) 2010 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:
*
*/

#include "ncmcoexistbearerwatcher.h"
#include "OstTraceDefinitions.h"
#ifdef OST_TRACE_COMPILER_IN_USE
#include "ncmcoexistbearerwatcherTraces.h"
#endif


#ifdef _DEBUG
_LIT(KCoBearerPanic, "CoexistBearerPanic");
#endif

CNcmCoexistBearerWatcher* CNcmCoexistBearerWatcher::NewL()
    {
    CNcmCoexistBearerWatcher* self = new(ELeave) CNcmCoexistBearerWatcher();
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
    }

CNcmCoexistBearerWatcher::CNcmCoexistBearerWatcher() : CActive(CActive::EPriorityStandard)
    {
    CActiveScheduler::Add(this);
    }


CNcmCoexistBearerWatcher::~CNcmCoexistBearerWatcher()
    {
    Cancel();
    iProperty.Close();
    }


void CNcmCoexistBearerWatcher::ConstructL()
    {
    OstTraceFunctionEntry0(CNCMCOEXISTBEARERWATCHER_CONSTRUCTL);

    const TUint KIPBearerCoexistenceProperty = 0x10286a95;

    TInt err = iProperty.Define(KIPBearerCoexistenceProperty, RProperty::EInt, KAllowAllPolicy, KNetworkControlPolicy);
    if ( (err != KErrNone) && (err != KErrAlreadyExists) )
        {
        OstTrace1( TRACE_ERROR, CNCMCOEXISTBEARERWATCHER_CONSTRUCTL_DUP02, "Failed to define the property;err=%d", err );
        User::Leave(err);
        }

    TSecureId thisSID = RProcess().SecureId();
    User::LeaveIfError(iProperty.Attach(thisSID, KIPBearerCoexistenceProperty));
    User::LeaveIfError(iProperty.Get(reinterpret_cast<TInt&>(iBearerState)));

    OstTraceFunctionExit0(CNCMCOEXISTBEARERWATCHER_CONSTRUCTL_DUP01);
    }


TInt CNcmCoexistBearerWatcher::SetIpOverUsbActive(TRequestStatus& aStatus)
    {
    OstTraceFunctionEntry0(CNCMCOEXISTBEARERWATCHER_SETIPOVERUSBACTIVE);

    TInt ret = DoActive();
    OstTrace1(TRACE_NORMAL, CNCMCOEXISTBEARERWATCHER_SETIPOVERUSBACTIVE_DUP01, "DoActive()=%d.", ret);

    if (KErrNone == ret)
        {
        OstTraceFunctionExitExt(CNCMCOEXISTBEARERWATCHER_SETIPOVERUSBACTIVE_DUP02, this, KErrCompletion);
        return KErrCompletion;
        }
    else if (KErrInUse == ret)
        {
        iReportStatus = &aStatus;
        *iReportStatus = KRequestPending;

        iProperty.Subscribe(iStatus);
        SetActive();
        return KErrNone;
        }

    OstTraceFunctionExitExt(CNCMCOEXISTBEARERWATCHER_SETIPOVERUSBACTIVE_DUP03, this, ret);
    return ret;
    }
/**
 * do Set IP Over USB Actived.
 */
TInt CNcmCoexistBearerWatcher::DoActive()
    {
    __ASSERT_DEBUG(iBearerState != EIPBearerIPOverUSB, User::Panic(KCoBearerPanic, __LINE__));

    _LIT(KIPBearerCoexistenceMutex, "IPBearerCoexistenceMutex");
    RMutex gMutex;
    TInt error = gMutex.CreateGlobal(KIPBearerCoexistenceMutex);
    if ( error != KErrNone )
        {
        if( error == KErrAlreadyExists )
            {
            error = gMutex.OpenGlobal(KIPBearerCoexistenceMutex);
            if(error != KErrNone)
                {
                OstTrace1(TRACE_ERROR, CNCMCOEXISTBEARERWATCHER_DOACTIVE, "Failed to open global mutex, error=%d", error);
                return KErrNotReady;
                }
            }
        else
            {
            OstTrace1(TRACE_ERROR, CNCMCOEXISTBEARERWATCHER_DOACTIVE_DUP01,  "Failed to create a global mutex, error=%d", error);
            return KErrNotReady;
            }
        }

    gMutex.Wait();
    error = iProperty.Get(reinterpret_cast<TInt&>(iBearerState));
    if (error != KErrNone)
        {
        OstTrace1(TRACE_ERROR, CNCMCOEXISTBEARERWATCHER_DOACTIVE_DUP02, "Failed to get property value, error=%d", error);
        }
    else
        {
        if (iBearerState == EIPBearerNoneActive)
            {
            error = iProperty.Set(EIPBearerIPOverUSB);
            if (error != KErrNone)
                {
                OstTrace1(TRACE_ERROR, CNCMCOEXISTBEARERWATCHER_DOACTIVE_DUP03, "Failed to set property value, error=%d", error);
                }
            else
                {
                iBearerState = EIPBearerIPOverUSB;
                }
            }
        else
            {
            error = KErrInUse;
            __ASSERT_DEBUG(iBearerState != EIPBearerIPOverUSB, User::Panic(KCoBearerPanic, __LINE__));
            OstTrace1(TRACE_WARNING, CNCMCOEXISTBEARERWATCHER_DOACTIVE_DUP04, "Failed to set CoexistIPBearer to IPOverUsb since iBearerState=%d", iBearerState);
            }
        }

    gMutex.Signal();
    gMutex.Close();

    return error;
    }

TInt CNcmCoexistBearerWatcher::SetIpOverUsbDeactive()
    {
    __ASSERT_DEBUG(iBearerState==EIPBearerIPOverUSB, User::Panic(KCoBearerPanic, __LINE__));

    TInt err = iProperty.Set(EIPBearerNoneActive);
    OstTrace1(TRACE_NORMAL, CNCMCOEXISTBEARERWATCHER_SETIPOVERUSBDEACTIVE, "Stop using Coexistence Bearer, result=%d", err);
    iBearerState = EIPBearerNoneActive;

    return err;
    }

void CNcmCoexistBearerWatcher::RunL()
    {
    OstTrace1(TRACE_NORMAL, CNCMCOEXISTBEARERWATCHER_RUNL, "iStatus.Int()=%d", iStatus.Int());

    if (KErrNone == iStatus.Int())
        {
        TInt ret = DoActive();
        OstTrace1(TRACE_NORMAL, CNCMCOEXISTBEARERWATCHER_RUNL_DUP01, "DoActive()=%d", ret);
        if (KErrNone == ret)
            {
            User::RequestComplete(iReportStatus, KErrNone);
            }
        else if (KErrInUse == ret)
            {
            iProperty.Subscribe(iStatus);
            SetActive();
            }
        else
            {
            User::RequestComplete(iReportStatus, ret);
            }
        }
    else if (KErrCancel != iStatus.Int())
        {
        User::RequestComplete(iReportStatus, iStatus.Int());
        }
    }

void CNcmCoexistBearerWatcher::DoCancel()
    {
    OstTraceFunctionEntry0(CNCMCOEXISTBEARERWATCHER_DOCANCEL);
    iProperty.Cancel();
    User::RequestComplete(iReportStatus, KErrCancel);
    }