// 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;

	}