// Copyright (c) 1997-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:
// Locker.cpp - all the active connector code
// 
//

#include <cs_port.h>
#include "btcomm.h"
#include "btcommactive.h"

CBTPortLocker *CBTPortLocker::NewL(CBTPortProxy *aParent)
/**
	Create new CBTPortLocker.
	This function creates a new CBTPortLocker active object.
**/
	{
	CBTPortLocker *cc;
	cc=new (ELeave) CBTPortLocker();
	CleanupStack::PushL(cc);
	cc->InitL(aParent);
	CleanupStack::Pop();
	CActiveScheduler::Add(cc);
	return cc;
	}

void CBTPortLocker::InitL(CBTPortProxy *aParent)
	{
	iPortProxy=aParent;
	}

CBTPortLocker::~CBTPortLocker()
/**
	CBTPortLocker destructor.	
**/
	{
	Cancel();
	}

void CBTPortLocker::RunL()
/**
	CBTPortLocker RunL.
	Active status cleared.  We can now call the DoLockedAction 
	function on the corresponding port proxy object.
**/
	{
    if(iStatus==KErrNone)
        iPortProxy->DoLockedAction();
	}

void CBTPortLocker::LockSession()
/**
	CBTPortLocker LockSession.
	This function initiates the process of making the session exclusive
	on the socket server.
**/
	{
    if(!IsActive())
        {
		// We need to complete this request either by actually getting a
		// lock on ESock if we've got a handle, or by just completing the 
		// request if we don't.  It's fine to do the DoLockedAction() 
		// without a locker if we don't have an ESock handle, as we can't
		// be making any requests to ESock.
		if(iPortProxy->iSockServ.Handle())
			{
			iPortProxy->iSockServ.SetExclusiveMode(iStatus);
			SetActive();
			}
		else
			{
			SetActive();
			TRequestStatus* status = &iStatus;
			User::RequestComplete(status, KErrNone);
			}
		}
	iLockOn=ETrue;
	}

void CBTPortLocker::UnlockSession()
/**
	CBTPortLocker UnlockSession.
**/
	{
    if(iPortProxy->iSockServ.Handle())
        iPortProxy->iSockServ.ClearExclusiveMode();
	iLockOn=EFalse;
	}

void CBTPortLocker::DoCancel()
/**
	CBTPortLocker DoCancel.
	Nothing to cancel.
**/
	{
	}

CBTPortLocker::CBTPortLocker() 
	: CActive (1020)
/**
	CBTPortLocker private c'tor.
	Note that this active object is set with a priority
	of 1020 which is higher than any other active object 
	running on the c32 active scheduler (note IrCOMM locker
	has a priority of 1000).  This means that this active 
	object will always be first in the scheduler's
	list of completed actions when it is completes.
**/
	{
	}

TBool CBTPortLocker::IsSessionLocked()
	{
	return iLockOn;
	}