--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/libraries/iosrv/server/pipe.cpp	Wed Jun 23 15:52:26 2010 +0100
@@ -0,0 +1,176 @@
+// 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);
+			}
+		}
+	}
+