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

//

/**

 @file

 @publishedPartner

 @released since 399

*/

#include <ecom/ecom.h>

#include <es_sock.h>

#include <comms-infras/es_connectionserv.h>

#include "cs_connectionservimpl.h"

#include <comms-infras/es_connectionservermessages.h>

#include <connpref.h>

#include <comms-infras/ss_log.h>

#include <rsshared.h>

#include <es_ver.h>

#ifdef _DEBUG

// Panic category for "absolutely impossible!" vanilla ASSERT()-type panics from this module

// (if it could happen through user error then you should give it an explicit, documented, category + code)

_LIT(KSpecAssert_ESockCSockcscnct, "ESockCSockcscnct");

#endif

using namespace ConnectionServ;

_LIT(KConnectionServerName, "!ConnectionServer");

EXPORT_C RConnectionServ::RConnectionServ() :

	iConnectionServImpl(0)

/**

 Empty ctor

 */

	{

	LOG( ESockLog::Printf(_L8("RConnectionServ %08x:\tRConnectionServ() tid %d"), this, (TUint)RThread().Id()); );

	}

EXPORT_C TInt RConnectionServ::Connect(TUint aTierId)

/** Opens a session to the connection server.

RHandleBase::Close() should be called once the session is no longer required.

All resources which are opened using the session will be automatically closed

when the session terminates.

@return KErrNone if successful, otherwise another of the system-wide error

codes. */

	{

	LOG( ESockLog::Printf(_L8("RConnectionServ %08x:\tConnect() tid %d tier %d"), this, (TUint)RThread().Id(), aTierId ));

#ifndef __ESOCK_SUPPRESS_ESOCK_HANDLE_OVERWRITE_PANICS

	__ASSERT_DEBUG(Handle() == 0, User::Panic(KSpecAssert_ESockCSockcscnct, 1));

	__ASSERT_DEBUG(iConnectionServImpl == 0, User::Panic(KSpecAssert_ESockCSockcscnct, 2));

#endif

	if(Handle())

		{

		return KErrInUse;

		}

	TVersion ver(KES32MajorVersionNumber,KES32MinorVersionNumber,KES32BuildVersionNumber);

	TInt result = CreateSession(KConnectionServerName,ver,8,EIpcSession_Sharable);

	if (result==KErrNotFound)

		{

		result=StartC32Full();

		if (result==KErrNone || result==KErrAlreadyExists)

			{

			const TUint numberOfConcurrentRequests = 8;

			// If this connection attempt also fails then most likely the connection server is

			// not enabled in the current configuration.

			result=CreateSession(KConnectionServerName,ver,numberOfConcurrentRequests,EIpcSession_Sharable);

			}

		}

	if(result != KErrNone)

		{

		this->Close();

		return result;

		}

	__ASSERT_DEBUG(Handle(), User::Panic(KSpecAssert_ESockCSockcscnct, 3));

    result = SendReceive(ECMAttachToTierManager, TIpcArgs(aTierId));

	if(result != KErrNone)

		{

		this->Close();

		return result;

		}

	if( iConnectionServImpl == 0 )

		{

		TRAP(result, iConnectionServImpl = CConnectionServImpl::NewL(*this));

		if (result != KErrNone)

    		{

    		this->Close();

    		}

		}

	return result;

	}

EXPORT_C void RConnectionServ::Close()

/**

 Closes the comms manager sub-session

 Delete owned object and drop to base class

 */

	{

	LOG( ESockLog::Printf(_L8("RConnectionServ%08x:\tClose() tid %d"), this, (TUint)RThread().Id()); );

	delete iConnectionServImpl; // this causes any requests to be cancelled

	iConnectionServImpl = 0;

	RSessionBase::Close();

	// The API uses ECom types.. This is the last time we get to attempt a cleanup.

	// This call does no harm if the types are still in use (e.g. stored by client code).

	REComSession::FinalClose();

	}

// Asynchronous multiple-IPC functions. Proxy them through to the active objects which handle them, via the impl object.

EXPORT_C void RConnectionServ::AccessPointStatusQuery(const CConnectionServParameterBundle& aQuery, CConnectionServParameterBundle& aResult, TRequestStatus& aStatus)

	{

	__ASSERT_ALWAYS(iConnectionServImpl != NULL, User::Panic(KConnectionServerName, KErrBadHandle));

	iConnectionServImpl->AccessPointStatusQuery(aQuery,aResult,aStatus);

	}

EXPORT_C void RConnectionServ::CancelAccessPointStatusQuery()

	{

	__ASSERT_ALWAYS(iConnectionServImpl != NULL, User::Panic(KConnectionServerName, KErrBadHandle));

	iConnectionServImpl->CancelAccessPointStatusQuery();

	}

EXPORT_C void RConnectionServ::AccessPointNotification(const CConnectionServParameterBundle& aQuery, MAccessPointNotificationObserver& aObserver)

	{

	__ASSERT_ALWAYS(iConnectionServImpl != NULL, User::Panic(KConnectionServerName, KErrBadHandle));

	iConnectionServImpl->AccessPointNotification(aQuery,aObserver);

	}

EXPORT_C void RConnectionServ::CancelAccessPointNotification()

	{

	__ASSERT_ALWAYS(iConnectionServImpl != NULL, User::Panic(KConnectionServerName, KErrBadHandle));

	iConnectionServImpl->CancelAccessPointNotification();

	}