// 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:
// Name          : sipcrworkerao.cpp
// Part of       : SIP / SIP Client Resolver
// Version       : %version: 2.1.1 %
//



#include "sipcrworkerao.h"
#include "CSipCRServerSession.h"
 
// ----------------------------------------------------------------------------
// CSipCrWorkerAo::NewL
// ----------------------------------------------------------------------------
//
CSipCrWorkerAo* CSipCrWorkerAo::NewL(CSIPCRServerSession& aSession)
    {
    CSipCrWorkerAo* self = CSipCrWorkerAo::NewLC(aSession);
    CleanupStack::Pop(self);
    return self;
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::NewLC
// ----------------------------------------------------------------------------
//	        
CSipCrWorkerAo* CSipCrWorkerAo::NewLC(CSIPCRServerSession& aSession)
    {
    CSipCrWorkerAo* self = new(ELeave)CSipCrWorkerAo(aSession);
    CleanupStack::PushL(self);
    self->ConstructL();
    return self;
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::NewL
// ----------------------------------------------------------------------------
//
CSipCrWorkerAo* CSipCrWorkerAo::NewL(
    TUint32 aRequestId,
    CBufBase* aSerializedSipRequest,
    HBufC8* aSipRequestBody,
    const TSipClient& aSipClient,
    const TUid& aResolverUid,
    CSIPCRServerSession& aSession)
    {
    CSipCrWorkerAo* self = 
        CSipCrWorkerAo::NewLC(
            aRequestId,aSerializedSipRequest,aSipRequestBody,
            aSipClient,aResolverUid,aSession);
    CleanupStack::Pop(self);
    return self;    
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::NewLC
// ----------------------------------------------------------------------------
//	        
CSipCrWorkerAo* CSipCrWorkerAo::NewLC(
    TUint32 aRequestId,
    CBufBase* aSerializedSipRequest,
    HBufC8* aSipRequestBody,
    const TSipClient& aSipClient,
    const TUid& aResolverUid,
    CSIPCRServerSession& aSession)
    {
    CSipCrWorkerAo* self = 
        new(ELeave)CSipCrWorkerAo(
            aRequestId,aSipClient,aResolverUid,aSession);
    CleanupStack::PushL(self);
    self->ConstructL(aSerializedSipRequest,aSipRequestBody);
    return self;
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::CSipCrWorkerAo
// ----------------------------------------------------------------------------
//
CSipCrWorkerAo::CSipCrWorkerAo(CSIPCRServerSession& aSession)
 : CActive(EPriorityStandard),
   iSession(aSession),
   iSipClient(TUid::Null(),EFalse,EFalse)
    {
	CActiveScheduler::Add(this);
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::CSipCrWorkerAo
// ----------------------------------------------------------------------------
//
CSipCrWorkerAo::CSipCrWorkerAo(
    TUint32 aRequestId,
    const TSipClient& aSipClient,
    const TUid& aResolverUid,    
    CSIPCRServerSession& aSession)
 : CActive(EPriorityStandard),
   iSession(aSession),
   iRequestId(aRequestId),
   iSipClient(aSipClient),
   iResolverUid(aResolverUid)
    {
	CActiveScheduler::Add(this);
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::ConstructL
// ----------------------------------------------------------------------------
//
void CSipCrWorkerAo::ConstructL()
    {
    iSerializedSipRequest = CBufFlat::NewL(1);
    iSipRequestBody = KNullDesC8().AllocL();
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::ConstructL
// ----------------------------------------------------------------------------
//
void CSipCrWorkerAo::ConstructL(
    CBufBase* aSerializedSipRequest,
    HBufC8* aSipRequestBody)
    {
    __ASSERT_ALWAYS(aSerializedSipRequest != NULL, User::Leave(KErrArgument));
    iSerializedSipRequest = aSerializedSipRequest;
    iSipRequestBody = aSipRequestBody;  
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::~CSipCrWorkerAo
// ----------------------------------------------------------------------------
//
CSipCrWorkerAo::~CSipCrWorkerAo()
    {
	CActive::Cancel();
	iThread.Close();
    delete iSerializedSipRequest;
    delete iSipRequestBody;	
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::StartThreadL
// ----------------------------------------------------------------------------
//
void CSipCrWorkerAo::StartThreadL(RThread& aThread)
    {
    User::LeaveIfError(iThread.Duplicate(aThread));
    aThread.Logon(iStatus);
    aThread.Resume();
    SetActive();
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::Session
// ----------------------------------------------------------------------------
//
CSIPCRServerSession& CSipCrWorkerAo::Session()
    {
    return iSession;
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::SerializedSipRequest
// ----------------------------------------------------------------------------
//
CBufBase& CSipCrWorkerAo::SerializedSipRequest()
    {
    return *iSerializedSipRequest;
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::GetSipRequestBody
// ----------------------------------------------------------------------------
//
HBufC8* CSipCrWorkerAo::GetSipRequestBody()
    {
    HBufC8* tmp = iSipRequestBody;
    iSipRequestBody = NULL;
    return tmp;
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::SipClient
// ----------------------------------------------------------------------------
//
TSipClient& CSipCrWorkerAo::SipClient()
    {
    return iSipClient;
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::ResolverUid
// ----------------------------------------------------------------------------
//
const TUid& CSipCrWorkerAo::ResolverUid() const
    {
    return iResolverUid;
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::RequestId
// ----------------------------------------------------------------------------
//
TUint32 CSipCrWorkerAo::RequestId() const
    {
    return iRequestId;
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::CompletionCode
// ----------------------------------------------------------------------------
//       
TInt CSipCrWorkerAo::CompletionCode() const
    {
    TExitType exitType = iThread.ExitType();
    if (exitType == EExitPanic)
        {
        return KErrGeneral;
        }
    return iStatus.Int();
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::RunL
// ----------------------------------------------------------------------------
//
void CSipCrWorkerAo::RunL()
    {
	iSession.WorkerAoRequestCompleted(this); // Note: deletes this
    }

// ----------------------------------------------------------------------------
// CSipCrWorkerAo::DoCancel
// ----------------------------------------------------------------------------
//	
void CSipCrWorkerAo::DoCancel()
    {
	iThread.LogonCancel(iStatus);
    }