// endpoint.cpp

// 

// Copyright (c) 2006 - 2010 Accenture. All rights reserved.

// This component and the accompanying materials are made available

// under the terms of the "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:

// Accenture - Initial contribution

//

#include "server.h"

#include "endpoint.h"

#include "log.h"

#ifdef IOSRV_LOGGING

#define ENDPOINT_NAME TName endPointName(Name())

#define READER_NAME(x) TName readerName((x).IorName())

#define WRITER_NAME(x) TName writerName((x).IowName())

#else

#define ENDPOINT_NAME

#define READER_NAME(x)

#define WRITER_NAME(x)

#endif

CIoEndPoint::~CIoEndPoint()

	{

	ENDPOINT_NAME;

	LOG(CIoLog::Printf(_L("End point \"%S\" (0x%08x) destroying"), &endPointName, this));

	iAttachedReaders.Close();

	}

TName CIoEndPoint::IoepName() const

	{

	return Name();

	}

TBool CIoEndPoint::IoepIsType(RIoHandle::TType aType) const

	{

	return IsType(aType);

	}

void CIoEndPoint::IorepAttachL(MIoReader& aReader, RIoEndPoint::TReadMode aMode)

	{

	ENDPOINT_NAME;

	READER_NAME(aReader);

	LOG(CIoLog::Printf(_L("Attaching reader \"%S\" (0x%08x) to end point \"%S\" (0x%08x)"), &readerName, &aReader, &endPointName, this));

	User::LeaveIfError(Open());

	CleanupClosePushL(*this);

	if (aMode == RIoEndPoint::EForeground)

		{

		User::LeaveIfError(iAttachedReaders.Insert(&aReader, 0));

		}

	else

		{

		User::LeaveIfError(iAttachedReaders.Append(&aReader));

		}

	TInt err = HandleReaderAttached(aReader);

	if (err!=KErrNone)

		{

		TInt index = FindReader(aReader);

		iAttachedReaders.Remove(index);

		User::Leave(err);

		}

	if (aMode == RIoEndPoint::EForeground)

		{

		HandleForegroundReaderChanged();

		}

	CleanupStack::Pop(this);

	}

void CIoEndPoint::IorepDetach(MIoReader& aReader)

	{

	ENDPOINT_NAME;

	READER_NAME(aReader);

	TInt index = FindReader(aReader);

	if (index >= 0)

		{

		LOG(CIoLog::Printf(_L("Detaching reader \"%S\" (0x%08x) from end point \"%S\" (0x%08x)"), &readerName, &aReader, &endPointName, this));

		iAttachedReaders.Remove(index);

		HandleReaderDetached(aReader);

		if ((index == 0) && (iAttachedReaders.Count() > 0))

			{

			HandleForegroundReaderChanged();

			}

		Close();

		}

	else

		{

		LOG(CIoLog::Printf(_L("Reader \"%S\" (0x%08x) not attached to end point \"%S\" (0x%08x) - detach request ignored"), &readerName, &aReader, &endPointName, this));

		}

	}

void CIoEndPoint::IorepSetForegroundReaderL(MIoReader& aReader)

	{

	TInt index = FindReader(aReader);

	User::LeaveIfError(index);

	if (index > 0)

		{

		iAttachedReaders.Remove(index);

		iAttachedReaders.Insert(&aReader, 0); // Shouldn't fail due to the above removal.

		HandleForegroundReaderChanged();

		}

	}

TBool CIoEndPoint::IorepIsForegroundL(const MIoReader& aReader) const

	{

	TInt index = FindReader(aReader);

	User::LeaveIfError(index);

	return (index == 0);

	}

void CIoEndPoint::IowepAttachL(MIoWriter& aWriter)

	{

	User::LeaveIfError(Open());

	++iAttachedWriterCount;

	ENDPOINT_NAME;

	WRITER_NAME(aWriter);

	LOG(CIoLog::Printf(_L("Attached writer \"%S\" (0x%08x) to end point \"%S\" (0x%08x) (%d writers now attached)"), &writerName, &aWriter, &endPointName, this, iAttachedWriterCount));

	TInt err = HandleWriterAttached(aWriter);

	if (err!=KErrNone)

		{

		--iAttachedWriterCount;

		User::Leave(err);

		}

	}

void CIoEndPoint::IowepDetach(MIoWriter& aWriter)

	{

	--iAttachedWriterCount;

	ENDPOINT_NAME;

	WRITER_NAME(aWriter);

	LOG(CIoLog::Printf(_L("Detached writer \"%S\" (0x%08x) from end point \"%S\" (0x%08x) (%d writers now attached)"), &writerName, &aWriter, &endPointName, this, iAttachedWriterCount));

	HandleWriterDetached(aWriter);

	Close();

	}

TInt CIoEndPoint::HandleReaderAttached(MIoReader&)

	{

	return KErrNone;

	}

void CIoEndPoint::HandleReaderDetached(MIoReader&)

	{

	}

void CIoEndPoint::ForegroundReaderChanged()

	{

	}

TInt CIoEndPoint::HandleWriterAttached(MIoWriter&)

	{

	return KErrNone;

	}

void CIoEndPoint::HandleWriterDetached(MIoWriter&)

	{

	}

void CIoEndPoint::HandleForegroundReaderChanged()

	{

	MIoReader* fg = AttachedReader();

	if (fg)

		{

		fg->IorReaderChange(RIoReadHandle::EGainedForeground);

		}

	ForegroundReaderChanged();

	}

CIoEndPoint::CIoEndPoint()

	{

	}

TInt CIoEndPoint::NumAttachedReaders() const

	{

	return iAttachedReaders.Count();

	}

MIoReader* CIoEndPoint::AttachedReader(TInt aIndex)

	{

	if ((aIndex >= 0) && (aIndex < iAttachedReaders.Count()))

		{

		return iAttachedReaders[aIndex];

		}

	return NULL;

	}

TInt CIoEndPoint::NumAttachedWriters() const

	{

	return iAttachedWriterCount;

	}

TInt CIoEndPoint::FindReader(MIoReader& aReader) const

	{

	const TInt numReaders = iAttachedReaders.Count();

	for (TInt i = 0; i < numReaders; ++i)

		{

		if (iAttachedReaders[i] == &aReader)

			{

			return i;

			}

		}

	return KErrNotFound;

	}

TInt CIoEndPoint::FindReader(const MIoReader& aReader) const

	{

	return FindReader(const_cast<MIoReader&>(aReader));

	}