// pipe.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 "pipe.h"
#include "log.h"

#ifdef IOSRV_LOGGING
#define PIPE_NAME TName pipeName(Name())
#define READER_NAME(x) TName readerName((x).IorName())
#define WRITER_NAME(x) TName writerName((x).IowName())
#else
#define PIPE_NAME
#define READER_NAME(x)
#define WRITER_NAME(x)
#endif

CIoPipe* CIoPipe::NewLC()
	{
	CIoPipe* self = new(ELeave) CIoPipe();
	LOG(CIoLog::Printf(_L("Pipe 0x%08x created"), self));
	CleanupClosePushL(*self);
	return self;
	}

CIoPipe::~CIoPipe()
	{
	iPendingWriters.Close();
	}

TBool CIoPipe::IsType(RIoHandle::TType aType) const
	{
	return ((aType == RIoHandle::EEndPoint) || (aType == RIoHandle::EPipe));
	}

void CIoPipe::IorepReadL(MIoReader& aReader)
	{
	if (&aReader == AttachedReader())
		{
		CheckReady();
		DoCopy();
		}
	}

void CIoPipe::IowepWriteL(MIoWriter& aWriter)
	{
	User::LeaveIfError(iPendingWriters.Append(&aWriter));
	CheckReady();
	DoCopy();
	}

void CIoPipe::IowepWriteCancel(MIoWriter& aWriter)
	{
	const TInt numPendingWriters = iPendingWriters.Count();
	for (TInt i = 0; i < numPendingWriters; ++i)
		{
		if (&aWriter == iPendingWriters[i])
			{
			iPendingWriters.Remove(i);
			break;
			}
		}
	}

void CIoPipe::ForegroundReaderChanged()
	{
	DoCopy();
	}

void CIoPipe::HandleReaderDetached(MIoReader&)
	{
	CheckReady();
	}

void CIoPipe::HandleWriterDetached(MIoWriter& aWriter)
	{
	const TInt numPendingWriters = iPendingWriters.Count();
	for (TInt i = 0; i < numPendingWriters; ++i)
		{
		if (&aWriter == iPendingWriters[i])
			{
			iPendingWriters.Remove(i);
			break;
			}
		}
	CheckReady();
	}

CIoPipe::CIoPipe()
	{
	}

void CIoPipe::DoCopy()
	{
	if ((AttachedReader() == NULL) || !AttachedReader()->IorReadPending())
		{
		return;
		}

	READER_NAME(*AttachedReader());
	TInt readBufOffset = 0;
	TDes& readBuf = AttachedReader()->IorReadBuf();
	TBool readBuffered(EFalse);

	while (iPendingWriters.Count() > 0)
		{
		MIoWriter& writer = *(iPendingWriters[0]);
		WRITER_NAME(writer);
		const TInt lengthToWrite = writer.IowWriteLength();
		const TInt length = Min(lengthToWrite, readBuf.MaxLength() - readBuf.Length());
		TPtr readPtr(const_cast<TText*>(readBuf.Ptr()) + readBufOffset, 0, length);
		TInt err = writer.IowWrite(readPtr);
		if (err == KErrNone)
			{
			LOG(CIoLog::Printf(_L("Copied %d chars from writer \"%S\" (0x%08x) to reader \"%S\" (0x%08x)"), readPtr.Length(), &writerName, &writer, &readerName, AttachedReader()));
			readBufOffset += readPtr.Length();
			readBuf.SetLength(readBufOffset);
			readBuffered = ETrue;
			if (lengthToWrite == length)
				{
				LOG(CIoLog::Printf(_L("Writer \"%S\" (0x%08x) fully copied"), &writerName, &writer));
				writer.IowComplete(KErrNone);
				iPendingWriters.Remove(0);
				}
			else if (readBuf.MaxLength() == readBuf.Length())
				{
				LOG(CIoLog::Printf(_L("Read buffer full (\"%S\" 0x%08x)"), &readerName, AttachedReader()));
				break;
				}
			}
		else
			{
			LOG(CIoLog::Printf(_L("Failed to copy \"%S\" from writer \"%S\" (0x%08x) to reader \"%S\" (0x%08x): %S(%d)"), &readPtr, &writerName, &writer, &readerName, AttachedReader(), CIoLog::StringifyError(err), err));
			writer.IowComplete(err);
			}
		}

	if (readBuffered)
		{
		AttachedReader()->IorDataBuffered(readBuf.Length());
		}
	}

void CIoPipe::CheckReady()
	{
	if ((NumAttachedWriters() == 0) && AttachedReader() && AttachedReader()->IorReadPending())
		{
		if (AttachedReader()->IorDataIsBuffered())
			{
			AttachedReader()->IorReadComplete(KErrNone);
			}
		else
			{
			AttachedReader()->IorReadComplete(KErrEof);
			}
		}
	else if (AttachedReader() == NULL)
		{
		while (iPendingWriters.Count())
			{
			MIoWriter* writer = iPendingWriters[0];
			iPendingWriters.Remove(0);
			writer->IowComplete(KErrNotReady);
			}
		}
	}