// Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of "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:
// Nokia Corporation - initial contribution.
//
// Contributors:
//
// Description:
// @file
// @internalTechnology
// 
//

inline TEIntSockOpMsgWrapper::TEIntSockOpMsgWrapper()
	{
		
	}

template < class T0 >
inline TEIntSockOpMsgWrapper::TEIntSockOpMsgWrapper ( T0 a0 )
	{
	iArgs.Set ( 0, a0 );
	iArgs.Set ( 1, 0 );
	iArgs.Set ( 2, 0 );
	iArgs.Set ( 3, 0 );
	}

template < class T0, class T1 >
inline TEIntSockOpMsgWrapper::TEIntSockOpMsgWrapper ( T0 a0, T1 a1 )
	{
	iArgs.Set ( 0, a0 );
	iArgs.Set ( 1, a1 );
	iArgs.Set ( 2, 0 );
	iArgs.Set ( 3, 0 );
	}

template < class T0, class T1, class T2 >
inline TEIntSockOpMsgWrapper::TEIntSockOpMsgWrapper ( T0 a0, T1 a1, T2 a2 )
	{
	iArgs.Set ( 0, a0 );
	iArgs.Set ( 1, a1 );
	iArgs.Set ( 2, a2 );
	iArgs.Set ( 3, 0 );
	}

template < class T0, class T1, class T2, class T3 >
inline TEIntSockOpMsgWrapper::TEIntSockOpMsgWrapper ( T0 a0, T1 a1, T2 a2, T3 a3 )
	{
	iArgs.Set ( 0, a0 );
	iArgs.Set ( 1, a1 );
	iArgs.Set ( 2, a2 );
	iArgs.Set ( 3, a3 );		
	}


inline TInt TEIntSockOpMsgWrapper::ReadDes(TInt aIndex, TDes8& aDes, TInt aOffset) const
	{
	const TDesC8* desc = ( const TDesC8* ) iArgs.iArgs[ aIndex ];
	aDes.Copy( desc->Mid ( aOffset ) );
	return KErrNone;
	}

inline TInt TEIntSockOpMsgWrapper::ReadBufChain ( TInt aIndex, RMBufChain& aBufChain ) const
	{
	RMBufChain* buf = ( RMBufChain* ) iArgs.iArgs [ aIndex ];	
	aBufChain = buf->First ();
	return KErrNone;
	}

inline TInt TEIntSockOpMsgWrapper::ReadInt(TInt aIndex) const
	{
	return iArgs.iArgs[aIndex];
	}

inline void TEIntSockOpMsgWrapper::InitBufChain(TInt aIndex)
	{
	RMBufChain* buf = ( RMBufChain* ) iArgs.iArgs [ aIndex ];
	buf->Init ();		
	}

inline TInt TEIntSockOpMsgWrapper::WriteBufChain( TInt aIndex, RMBufChain& aBufChain )
	{
	RMBufChain* buf = ( RMBufChain* ) iArgs.iArgs [ aIndex ];
	*buf = aBufChain.First ();	
	return KErrNone;
	}

inline void TEIntSockOpMsgWrapper::WriteInt ( TInt aIndex, TInt aValue )
	{
	iArgs.Set ( aIndex, aValue );
	}

const TDesC& TEIntSockOpMsgWrapper::GetDesc ( TInt aIndex ) const
	{
	return (*(( const TDesC* )iArgs.iArgs [ aIndex ]));		
	}

inline void TEIntSockOpMsgWrapper::SetRequest (TRequestWrapper& aRequest)
	{
	iRequest = aRequest;
	}

inline void TEIntSockOpMsgWrapper::CompleteMessage(TInt aError)
	{
	iRequest.RequestComplete(aError);	
	}

inline TInt TEIntSockOpMsgWrapper::GetDesLength ( TInt aIndex ) const
	{
	const TDesC8* desc = (const TDesC8*)iArgs.iArgs[ aIndex ];
	return desc->Length ();
	}

inline TInt TEIntSockOpMsgWrapper::GetDesMaxLength ( TInt aIndex ) const
	{
	TDes8* des = (TDes8*)iArgs.iArgs[ aIndex ];
	return des->MaxSize ();		
	}


inline TInt TEIntSockOpMsgWrapper::GetMBufChainLength ( TInt aIndex ) const
	{
	RMBufChain* buf = (RMBufChain*)iArgs.iArgs [ aIndex ];
	return buf->Length ();
	}

inline TEIntSockMsg::TEIntSockMsg(TSockMess aOperation, TEIntSockOpMsgWrapper& aOpMsg, CInternalSocketImpl* aImplPtr, TRequestStatus& aStatus)
: Den::TWorkerTransportMsg(KEIntSockTransportPluginImplementationUid, aStatus)
	{
	TEIntSockMsgParams* params = reinterpret_cast<TEIntSockMsgParams*>(TCFMessage::ParamBlock());
	params->iOperation = aOperation;
	params->iOpMsg = aOpMsg;
	params->iImplPtr = aImplPtr;
	}

inline TEIntSockMsg::TEIntSockMsg(TSockMess aOperation, TEIntSockOpMsgWrapper& aOpMsg, CInternalSocketImpl** aImplPtrPtr, TRequestStatus& aStatus) 
: Den::TWorkerTransportMsg(KEIntSockTransportPluginImplementationUid, aStatus)
	{
	TEIntSockMsgParams* params = reinterpret_cast<TEIntSockMsgParams*>(TCFMessage::ParamBlock());
	params->iOperation = aOperation;	
	params->iOpMsg = aOpMsg;
	params->iImplPtrPtr = aImplPtrPtr;
	}

inline TEIntSockMsg::TEIntSockMsg(TSockMess aOperation, TEIntSockOpMsgWrapper& aOpMsg, CInternalSocketImpl* aImplPtr)
: Den::TWorkerTransportMsg(KEIntSockTransportPluginImplementationUid)
	{
	TEIntSockMsgParams* params = reinterpret_cast<TEIntSockMsgParams*>(TCFMessage::ParamBlock());
	params->iOperation = aOperation;
	params->iOpMsg = aOpMsg;
	params->iImplPtr = aImplPtr;
	}

inline TEIntSockMsg::TEIntSockMsg(TSockMess aOperation, TEIntSockOpMsgWrapper& aOpMsg, CInternalSocketImpl** aImplPtrPtr) 
: Den::TWorkerTransportMsg(KEIntSockTransportPluginImplementationUid)
	{
	TEIntSockMsgParams* params = reinterpret_cast<TEIntSockMsgParams*>(TCFMessage::ParamBlock());
	params->iOperation = aOperation;	
	params->iOpMsg = aOpMsg;
	params->iImplPtrPtr = aImplPtrPtr;
	}


inline TSockMess TEIntSockMsg::Operation () const
	{
	const TEIntSockMsgParams* params = reinterpret_cast<const TEIntSockMsgParams*>(TCFMessage::ParamBlock());
	return params->iOperation;
	}

inline TEIntSockOpMsgWrapper TEIntSockMsg::OpMsg () const
	{
	const TEIntSockMsgParams* params = reinterpret_cast<const TEIntSockMsgParams*>(TCFMessage::ParamBlock());
	return params->iOpMsg;
	}

inline CInternalSocketImpl*& TEIntSockMsg::ImplPtrRef() const
	{
	const TEIntSockMsgParams* params = reinterpret_cast<const TEIntSockMsgParams*>(TCFMessage::ParamBlock());
	return *params->iImplPtrPtr;
	}

inline CInternalSocketImpl* TEIntSockMsg::ImplPtr() const
	{
	const TEIntSockMsgParams* params = reinterpret_cast<const TEIntSockMsgParams*>(TCFMessage::ParamBlock());
	return params->iImplPtr;
	}

inline TEIntSockMsgExt::TEIntSockMsgExt(TSockMess aOperation, TEIntSockOpMsgWrapper& aOpMsg, CInternalSocketImpl*& aImplPtr, TRequestStatus& aStatus, CommsFW::MCommsTransportSender* aSender, const Messages::TNodeId& aImplCookie)
: TEIntSockMsg(aOperation, aOpMsg, &aImplPtr, aStatus)
	{
	TParams* params = reinterpret_cast<TParams*>(ParamBlock());
	params->iSender = aSender;
    
	// caution - TRuntimeCtxId assignment operator overloaded - it assumes a properly constructed destination, which it isn't here
	// so we in-place construct it
	new (&params->iImplCookie)Messages::TNodeId();
	params->iImplCookie = aImplCookie;
	}

inline TEIntSockMsgExt::TEIntSockMsgExt(TSockMess aOperation, TEIntSockOpMsgWrapper& aOpMsg, CInternalSocketImpl*& aImplPtr, CommsFW::MCommsTransportSender* aSender, const Messages::TNodeId& aImplCookie)
: TEIntSockMsg(aOperation, aOpMsg, &aImplPtr)
	{
	TParams* params = reinterpret_cast<TParams*>(ParamBlock());
	params->iSender = aSender;
	
	// caution - TRuntimeCtxId assignment operator overloaded - it assumes a properly constructed destination, which it isn't here
	// so we in-place construct it
	new (&params->iImplCookie)Messages::TNodeId();
	params->iImplCookie = aImplCookie;
	}

inline CommsFW::MCommsTransportSender* TEIntSockMsgExt::Sender() const
	{
	const TParams* params = reinterpret_cast<const TParams*>(TCFMessage::ParamBlock());
	return params->iSender;
	}
	
inline const Messages::TNodeId& TEIntSockMsgExt::ImplCookie() const
	{
	const TParams* params = reinterpret_cast<const TParams*>(TCFMessage::ParamBlock());
	return params->iImplCookie;
	}