--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/plugins/networking/winsockprt/src/wsp_subsession.cpp	Wed Jun 23 15:52:26 2010 +0100
@@ -0,0 +1,78 @@
+// wsp_subsession.cpp
+// 
+// Copyright (c) 2002 - 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 "wsp_subsession.h"
+#include "wsp_session.h"
+#include "wsp_panic.h"
+
+
+//
+// RWin32SubSession.
+//
+
+void RWin32SubSession::Close()
+	{
+	if (iSession->iThread.Handle())
+		{
+		TPckgC<TInt> handlePckg(iHandle);
+		iWin32Message.Set(CWin32Session::ECloseSubSession, handlePckg);
+		iSession->iRequest.MakeRequest(iWin32Message);
+		}
+	}
+
+TInt RWin32SubSession::CreateSubSession(RWin32Session& aSession, TInt aOppCode)
+	{
+	TPckg<TInt> handleBuf(iHandle);
+	iWin32Message.Set(aOppCode, handleBuf);
+	TInt err = aSession.MakeRequest(iWin32Message);
+	if (err == KErrNone)
+		{
+		iSession = &aSession;
+		}
+	return err;
+	}
+
+TInt RWin32SubSession::CreateSubSession(RWin32Session& aSession, TInt aOppCode, const TDesC8& aReadBuf)
+	{
+	TPckg<TInt> handleBuf(iHandle);
+	iWin32Message.Set(aOppCode, aReadBuf, handleBuf);
+	TInt err = aSession.MakeRequest(iWin32Message);
+	if (err == KErrNone)
+		{
+		iSession = &aSession;
+		}
+	return err;
+	}
+
+
+TInt RWin32SubSession::MakeRequest(TWin32Message& aMessage) const
+	{
+	return iSession->iRequest.MakeRequest(aMessage, iHandle);
+	}
+
+
+//
+// CWin32SubSession.
+//
+
+CWin32SubSession::CWin32SubSession(CWin32Scheduler& aScheduler)
+	: CWin32ActiveObject(aScheduler)
+	{
+	}
+
+void CWin32SubSession::Complete(TWin32Message*& aMessage, TInt aReason) const
+	{
+	__ASSERT_DEBUG(aMessage, Panic(EWinSockPrtSubSessionInvalidMessage));
+	aMessage->Complete(aReason);
+	aMessage = NULL;
+	}