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

#include <e32math.h>

#include "btcomm.h"
#include "btcommactive.h"
#include "btcommutil.h"


TInt StartConnector(RSocketServ& aSockServ)
	{
	TInt err = aSockServ.Connect();
	if(err == KErrNone)
		{
		err = aSockServ.ShareAuto();
		if(err != KErrNone)
			{
			aSockServ.Close();
			}
		}
		
	return err;
	}

TInt RunConnectorThread(TAny* aArg)
	{
	// Add the thread id to the end of the the thread name
	// to ensure it is unique.
	TName threadName(KConnectorThreadName);
	RThread thread;
	threadName.AppendNum(static_cast<TUint>(thread.Id()), EHex);

	// We can carry on even if this errors
	User::RenameThread(threadName);
	
	return StartConnector(*reinterpret_cast<RSocketServ*>(aArg));
	}
	
//==============================================================================

CSockServConnector* CSockServConnector::NewL(RSocketServ& aSockServ)
	{
	CSockServConnector* self = new(ELeave) CSockServConnector(aSockServ);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop();
	return self;
	}

void CSockServConnector::ConstructL()
	{
	}

CSockServConnector::~CSockServConnector()
	{
	Cancel();
	}

void CSockServConnector::SockServConnect(TRequestStatus& aStatus)
	{
	TThreadFunction connectorThreadFunction(RunConnectorThread);
	iClientStatus = &aStatus;
	*iClientStatus = KRequestPending;

	// Once we've connected this thread it is renamed to ensure
	// its name is unique.
	TInt err = iConnectorThread.Create(KConnectorThreadName, connectorThreadFunction,KDefaultStackSize,KMinHeapSize,1024*1000, &iSockServ, EOwnerThread);

	if(err != KErrNone)
		{
		User::RequestComplete(iClientStatus, err);
		}
	else
		{
		// Set up the configuration of the thread
		iConnectorThread.SetPriority(RThread().Priority());
		
		// Stick ourselves on the scheduler jit so we're not
		// cluttering up the queue when we don't want to be 
		// run.
		CActiveScheduler::Add(this);
		
		// Set ourselves to be notified on death of connector thread.
		iConnectorThread.Logon(iStatus);
		SetActive();

		// Mark connector thread ready to run
		iConnectorThread.Resume();
		}
	}

void CSockServConnector::RunL()
	{
	// Remove ourselves from the active scheduler so we
	// don't get in the way of other active objects
	Deque();
	
	// if the thread returned something other than
	// KErrNone then the Esock connect & share didn't
	// succeed.  Go to RunError to notify client and
	// tidy up.
	User::LeaveIfError(iStatus.Int());
	
	// The exit reason was zero, but the thread 
	// terminated abnormally.
	if(iConnectorThread.ExitType() != EExitKill)
		{
		User::Leave(KErrGeneral);
		}

	NotifyAndClose(KErrNone);
	}
	
TInt CSockServConnector::RunError(TInt aError)
	{
	// let client know about result, and gulp
	NotifyAndClose(aError);
	return KErrNone;
	}
	
void CSockServConnector::NotifyAndClose(TInt aError)
	{
	// tell client the result
	User::RequestComplete(iClientStatus, aError);
	// close connector thread
	iConnectorThread.Close();	
	}

void CSockServConnector::DoCancel()
	{
	BTCommUtil::Panic(EBTCommESockSessionAttachNotDone);
	}

// We make this ao high priority because we want to get the session connected asap so we can
// make some progress servicing other requests.
CSockServConnector::CSockServConnector(RSocketServ& aSockServ) : CActive (EPriorityHigh), iSockServ(aSockServ)
	{
	}