/*

* 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 FILES

#include "loadgen_phonecall.h"

#include "loadgen_utils.h"

#include "loadgen.hrh"

#include <loadgen.rsg>

#include <e32math.h>

_LIT(KThreadName, "PhoneCall %d");

const TInt KDefaultStart = 50;

const TInt KDefaultPeriod = 5000000;

// ===================================== MEMBER FUNCTIONS =====================================

CPhoneCall* CPhoneCall::NewL(TPhoneCallAttributes& aAttributes, TInt aReferenceNumber)

    {

    CPhoneCall* self = new(ELeave) CPhoneCall(aAttributes, aReferenceNumber);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;    

    }

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

CPhoneCall::~CPhoneCall()

    {

    Close();

    }

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

CPhoneCall::CPhoneCall(TPhoneCallAttributes& aAttributes, TInt aReferenceNumber) : iAttributes(aAttributes)

    {

    iAttributes.iId = aReferenceNumber;

    }

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

void CPhoneCall::ConstructL()

    {

    CLoadBase::ConstructL();

    iType = ELoadGenCmdNewLoadPhoneCall;

    TBuf<64> threadName;

    threadName.Format(KThreadName, iAttributes.iId);

    // create a thread

    User::LeaveIfError(iThread.Create(threadName, ThreadFunction, KDefaultStackSize*2, KMinHeapSize, 1024*KMinHeapSize, (TAny*) &iAttributes ));

    // set priority of the thread

    SetPriority();

    }

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

TInt CPhoneCall::ThreadFunction(TAny* aThreadArg)

    {

    CTrapCleanup* pC = CTrapCleanup::New();

    CActiveScheduler* pS = new CActiveScheduler;

    CActiveScheduler::Install(pS);

    // start generating load, pass pointer to arguments

    GenerateLoad(*((TPhoneCallAttributes*) aThreadArg));

    delete pS;

    delete pC;

    return KErrNone;

    }

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

void CPhoneCall::GenerateLoad(TPhoneCallAttributes& aAttributes)

    {

    CPhoneCallManager* phoneCallManager = NULL;

    TRAPD(err, phoneCallManager = CPhoneCallManager::NewL(aAttributes));

    if (err == KErrNone) CActiveScheduler::Start();

    delete phoneCallManager;

    }

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

void CPhoneCall::Resume()

    {

    CLoadBase::Resume();

    iThread.Resume();

    }

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

void CPhoneCall::Suspend()

    {

    CLoadBase::Suspend();

    iThread.Suspend();

    }

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

void CPhoneCall::SetPriority()

    {

    CLoadBase::SetPriority();

    iThread.SetPriority(CLoadGenUtils::SettingItemToThreadPriority(iAttributes.iPriority));

    }

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

void CPhoneCall::Close()

    {

    CLoadBase::Close();

    if (iThread.ExitReason() == 0) // check if the thread is still alive

        {

        // signal the thread that it needs to close

        iThread.RequestComplete(iAttributes.iDeathStatus, KErrCancel);

        // wait the thread to die

        TRequestStatus waiter;

        iThread.Logon(waiter);

        User::WaitForRequest(waiter);

        iThread.Close();

        }

    }

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

TPtrC CPhoneCall::Description()

    {

    TBuf<256> buf;

    TBuf<16> prioBuf;

    CLoadGenUtils::SettingItemToThreadDescription(iAttributes.iPriority, prioBuf);

    _LIT(KPhoneCallEntry, "[%d] PhoneCall prio=%S dest=%S length=%dms idle=%dms random=%d%%");

    buf.Format(KPhoneCallEntry, iAttributes.iId, &prioBuf, &iAttributes.iDestination, iAttributes.iLength, iAttributes.iIdle, iAttributes.iRandomVariance);

    return TPtrC(buf);

    }               

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

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

CPhoneCallManager* CPhoneCallManager::NewL(TPhoneCallAttributes& aAttributes)

    {

    CPhoneCallManager* self = new(ELeave) CPhoneCallManager(aAttributes);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop();

    return self;

    }

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

CPhoneCallManager::CPhoneCallManager(TPhoneCallAttributes& aAttributes) :

    CActive(EPriorityStandard), iAttributes(aAttributes), iState(EStateIdle)

    {

    }

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

CPhoneCallManager::~CPhoneCallManager()

    {

    Cancel();

    if (iPeriodicTimer)

        {

        iPeriodicTimer->Cancel();

        delete iPeriodicTimer;

        }

    delete iDialer;

    }

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

void CPhoneCallManager::ConstructL()

    {

    CActiveScheduler::Add(this);

    // set the status as pending

    iStatus = KRequestPending;

    SetActive();

    // set the death status pointer point to the request status of this ao

    iAttributes.iDeathStatus = &iStatus;

    // init dialer ao

    iDialer = CDialer::NewL(*this);

    // start timer    

    iPeriodicTimer = CPeriodic::NewL(CActive::EPriorityStandard);

    iPeriodicTimer->Start(KDefaultStart, KDefaultPeriod, TCallBack(PeriodicTimerCallBack, this));

    }

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

void CPhoneCallManager::RunL()

    {

    // request status has completed by the main thread meaning that we need to stop now

    CActiveScheduler::Stop();

    }

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

void CPhoneCallManager::DoCancel()

    {

    }

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

TInt CPhoneCallManager::PeriodicTimerCallBack(TAny* aAny)

    {

    CPhoneCallManager* self = static_cast<CPhoneCallManager*>( aAny );

    self->iPeriodicTimer->Cancel();

    self->HandleCalls();

    return KErrNone;

    }

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

void CPhoneCallManager::HandleCalls()

    {

    if (iState == EStateIdle)

        {

        // make a new call

        iState = EStateCall;

        iDialer->Dial(iAttributes.iDestination);

        }

    else if (iState == EStateCall)

        {

        // hangup existing call

        iState = EStateIdle;

        iDialer->Hangup();

        }

    }

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

void CPhoneCallManager::HandleStatus(TInt /*aErr*/)

    {

    // call timer after wait

    if (iState == EStateCall)

        {

        iPeriodicTimer->Start(CLoadGenUtils::MilliSecondsToMicroSeconds(iAttributes.iLength, iAttributes.iRandomVariance), KDefaultPeriod, TCallBack(PeriodicTimerCallBack, this));

        }

    else if (iState == EStateIdle)

        {

        iPeriodicTimer->Start(CLoadGenUtils::MilliSecondsToMicroSeconds(iAttributes.iIdle, iAttributes.iRandomVariance), KDefaultPeriod, TCallBack(PeriodicTimerCallBack, this));

        }        

    }

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

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

CDialer* CDialer::NewL(CPhoneCallManager& aManager)

    {

    CDialer* self = new(ELeave) CDialer(aManager);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop();

    return self;

    }

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

CDialer::CDialer(CPhoneCallManager& aManager) :

    CActive(EPriorityStandard), iManager(aManager), iCallParamsPckg(iCallParams)

    {

    }

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

CDialer::~CDialer()

    {

    Cancel();

    delete iTelephony;

    }

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

void CDialer::ConstructL()

    {

    CActiveScheduler::Add(this);

    // init telephony object

    iTelephony = CTelephony::NewL();

    }

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

void CDialer::RunL()

    {

    // notify the observer that status has changed

    iManager.HandleStatus(iStatus.Int());

    }

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

void CDialer::DoCancel()

    {

    iTelephony->CancelAsync(CTelephony::EDialNewCallCancel);

    iTelephony->CancelAsync(CTelephony::EHangupCancel);

    }

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

void CDialer::Dial(const TDesC& aDestination)

    {

    CTelephony::TTelNumber telNumber(aDestination);

    iCallParams.iIdRestrict = CTelephony::ESendMyId;

    iTelephony->DialNewCall(iStatus, iCallParamsPckg, telNumber, iCallId);

    SetActive();

    }

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

void CDialer::Hangup()

    {

    iTelephony->Hangup(iStatus, iCallId);

    SetActive();

    }

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

// End of File