// Copyright (c) 2004-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:

// eintsock.cpp

// Implementation of forwarding methods for internal sockets

// 

//

/**

 @file

 @internalComponent

*/

#include "ss_eintsocklog.h"

#include <comms-infras/eintsock.h>

#include <comms-infras/ss_common.h>

#include <comms-infras/ss_nodemessages.h>

#include <comms-infras/ss_nodemessages_dataclient.h>

#include <comms-infras/ss_thread.h>

#include "ss_eintsockimpl.h"

#include "ss_eintsock_msgs.h"

#include <ss_glob.h>

#include <comms-infras/sockmes.h>

using namespace ESock;

using namespace CommsFW;

using namespace Messages;

EXPORT_C RInternalSocket::RInternalSocket()

: iImplementation(NULL)

	{

    }

EXPORT_C RInternalSocket::~RInternalSocket()

	{

    }

EXPORT_C TInt RInternalSocket::Open()

/**

Special Open() for this class to mimic RSocket, but without the socket server session being required

@see RSocket documentation

*/

	{

	__ASSERT_DEBUG(!iImplementation, InternalSocketPanic(ENotNullSocket));

	LOG(Log::Printf(_L("RIS::Open()")));

	TWorkerId selfWorkerId;

	TInt ret = CWorkerThread::CurrentWorkerId(selfWorkerId);

	if(ret == KErrNone)

		{

		TNodeId serverCookie;

		ret = CWorkerThread::CookieForWorkerId(selfWorkerId, serverCookie);

		if(ret == KErrNone)

			{

			MCommsTransportSender* sender = &static_cast<MCommsTransportSender&>(TlsGlobals::Get().TransportSender());

			TEIntSockOpMsgWrapper opMsg;

			TEIntSockMsgExt openMsg(ESoCreateNull, opMsg, iImplementation, sender, serverCookie);

			ret = CInternalSockSubSession::SendReceiveMsg(openMsg, sender, serverCookie);

			}

		}

	LOG(Log::Printf(_L("RIS::Open() ret=%d impl=%08x"), ret, iImplementation));

	return ret;

	}

EXPORT_C TInt RInternalSocket::Open(const TDesC& aName)

/**

Special Open() for this class to mimic RSocket, but without the socket server session being required

With the asynchronous nature of COMMS FW this API might cause deadlock scenario, hence this API is deprecated 

and asynchrnous version is provided. 

@see RInternalSocket::Open(const TDesC& aName, TRequestStatus& aStatus)

@deprecated from 9.5

@see RSocket documentation

*/

	{

	__ASSERT_DEBUG(!iImplementation, InternalSocketPanic(ENotNullSocket));

	LOG(Log::Printf(_L("RIS::Open(%S)"), &aName));

	TNodeId serverCookie;

	TInt ret = CWorkerThread::CookieForProtocolByName(aName, serverCookie);

	if(ret == KErrNone)

		{

		MCommsTransportSender* sender = &static_cast<MCommsTransportSender&>(TlsGlobals::Get().TransportSender());

		TEIntSockOpMsgWrapper opMsg (&aName);

		TEIntSockMsgExt openMsg((TSockMess)KSoOpenByName, opMsg, iImplementation, sender, serverCookie);

		ret = CInternalSockSubSession::SendReceiveMsgAsync(openMsg, sender, serverCookie);

		}

	LOG(Log::Printf(_L("RIS::Open(%S)=%d impl=%08x"), &aName, ret, iImplementation));

	return ret;

	}

EXPORT_C TInt RInternalSocket::Open(TUint aAddrFamily,TUint aSockType,TUint aProtocol)

/**

Special Open() for this class to mimic RSocket, but without the socket server session being required

With the asynchronous nature of COMMS FW this API might cause deadlock scenario, hence this API is deprecated 

and asynchrnous version is provided. 

@see RInternalSocket::Open(TUint aAddrFamily,TUint aSockType,TUint aProtocol, TRequestStatus& aStatus)

@see RSocket documentation

*/

	{

	__ASSERT_DEBUG(!iImplementation, InternalSocketPanic(ENotNullSocket));

	LOG(Log::Printf(_L("RIS::Open(%d, %d, %d)"), aAddrFamily, aSockType, aProtocol));

	TNodeId serverCookie;

	TInt ret = CWorkerThread::CookieForProtocol(aAddrFamily, aSockType, aProtocol, serverCookie);

	if(ret == KErrNone)

		{

		MCommsTransportSender* sender = &static_cast<MCommsTransportSender&>(TlsGlobals::Get().TransportSender());

		TEIntSockOpMsgWrapper opMsg (aAddrFamily, aSockType, aProtocol);

		TEIntSockMsgExt openMsg(ESoCreate, opMsg, iImplementation, sender, serverCookie);		

		ret = CInternalSockSubSession::SendReceiveMsgAsync(openMsg, sender, serverCookie);

		}

	LOG(Log::Printf(_L("RIS::Open(%d, %d, %d)=%d impl=%08x"), aAddrFamily, aSockType, aProtocol, ret, iImplementation));

	return ret;

	}

EXPORT_C void RInternalSocket::Open( const TDesC& aName, TRequestStatus& aStatus )

	{

	__ASSERT_DEBUG(!iImplementation, InternalSocketPanic(ENotNullSocket));

	LOG(Log::Printf(_L("RIS::Open(%S)"), &aName));

	aStatus = KRequestPending;

	TNodeId serverCookie;

	TInt ret = CWorkerThread::CookieForProtocolByName(aName, serverCookie);

	if(ret == KErrNone)

		{

		MCommsTransportSender* sender = &static_cast<MCommsTransportSender&>(TlsGlobals::Get().TransportSender());

		TEIntSockOpMsgWrapper opMsg (&aName);		

		TEIntSockMsgExt openMsg((TSockMess)KSoOpenByName, opMsg, iImplementation, aStatus, sender, serverCookie);

		CInternalSockSubSession::SendMsg(openMsg, sender, serverCookie);

		}

	else

		{

		TRequestStatus* pStatus = &aStatus;

		User::RequestComplete ( pStatus, ret );			

		}

	}

EXPORT_C void RInternalSocket::Open(TUint aAddrFamily,  TUint aSockType, TUint aProtocol, TRequestStatus& aStatus )

	{

	__ASSERT_DEBUG(!iImplementation, InternalSocketPanic(ENotNullSocket));

	LOG(Log::Printf(_L("RIS::Open(%d, %d, %d, %08x)"), aAddrFamily, aSockType, aProtocol, &aStatus));

	aStatus = KRequestPending;

	TNodeId serverCookie;

	TInt ret = CWorkerThread::CookieForProtocol(aAddrFamily, aSockType, aProtocol, serverCookie);

	if(ret == KErrNone)

		{

		MCommsTransportSender* sender = &static_cast<MCommsTransportSender&>(TlsGlobals::Get().TransportSender());

		TEIntSockOpMsgWrapper opMsg (aAddrFamily, aSockType, aProtocol);

		TEIntSockMsgExt openMsg(ESoCreate, opMsg, iImplementation, aStatus, sender, serverCookie);

		CInternalSockSubSession::SendMsg(openMsg, sender, serverCookie);

		}

	else

		{

		TRequestStatus* pStatus = &aStatus;

		User::RequestComplete ( pStatus, ret );			

		}		

	}

EXPORT_C void RInternalSocket::Send(const TDesC8& aDesc,TUint aFlags,TRequestStatus& aStatus)

/**

@see RSocket documentation

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Send(desc, flags=%d, status=%08x) impl=%08x"), aFlags, &aStatus, iImplementation));

	aStatus = KRequestPending;	

	TEIntSockOpMsgWrapper opMsg( &aFlags, 0, &aDesc, EFalse);	

	TEIntSockMsg msg(ESoSendNoLength, opMsg, iImplementation, aStatus);

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::Send(RMBufChain& aData,TUint aFlags,TRequestStatus& aStatus)

/**

@see RSocket documentation

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Send(mbuf, flags=%d, status=%08x) impl=%08x"), aFlags, &aStatus, iImplementation));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(aFlags, 0, &aData, ETrue);

	TEIntSockMsg msg(ESoSendNoLength, opMsg, iImplementation, aStatus);

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::Send(const TDesC8& aDesc,TUint aFlags,TRequestStatus& aStatus,TSockXfrLength& aLen)

/**

@see RSocket documentation

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Send(desc+xferLen, flags=%d, status=%08x) impl=%08x"), aFlags, &aStatus, iImplementation));

	aStatus = KRequestPending;	

	aLen = aFlags;

	TEIntSockOpMsgWrapper opMsg(&aLen, 0, &aDesc, EFalse);	

	TEIntSockMsg msg(ESoSend, opMsg, iImplementation, aStatus);	

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::Send(RMBufChain& aData,TUint aFlags,TRequestStatus& aStatus,TSockXfrLength& aLen)

/**

@see RSocket documentation

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Send(mbuf+xferLen, flags=%d, status=%08x) impl=%08x"), aFlags, &aStatus, iImplementation));

	aStatus = KRequestPending;

	aLen = aFlags;

	TEIntSockOpMsgWrapper opMsg(&aLen, 0, &aData, ETrue);	

	TEIntSockMsg msg(ESoSend, opMsg, iImplementation, aStatus);	

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::SendTo(const TDesC8& aDesc,TSockAddr& aAddr,TUint aFlags,TRequestStatus& aStatus)

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(aFlags, &aAddr, &aDesc, EFalse);	

	TEIntSockMsg msg(ESoSendToNoLength, opMsg, iImplementation, aStatus);

	iImplementation->SendMsg(msg);	

	}

EXPORT_C void RInternalSocket::SendTo(RMBufChain& aData,TSockAddr& aAddr,TUint aFlags,TRequestStatus& aStatus)

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(aFlags, &aAddr, &aData, ETrue);	

	TEIntSockMsg msg(ESoSendToNoLength, opMsg, iImplementation, aStatus);

	iImplementation->SendMsg(msg);			

	}

EXPORT_C void RInternalSocket::SendTo(const TDesC8& aDesc,TSockAddr& aAddr,TUint aFlags,TRequestStatus& aStatus,TSockXfrLength& aLen)

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	aLen = aFlags;

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(&aLen, &aAddr, &aDesc, EFalse);	

	TEIntSockMsg msg(ESoSendTo, opMsg, iImplementation, aStatus);		

	iImplementation->SendMsg(msg);			

	}

EXPORT_C void RInternalSocket::SendTo(RMBufChain& aData, TSockAddr& aAddr,TUint aFlags,TRequestStatus& aStatus,TSockXfrLength& aLen)

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	aLen = aFlags;

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(&aLen, &aAddr, &aData, ETrue);	

	TEIntSockMsg msg(ESoSendTo, opMsg, iImplementation, aStatus);		

	iImplementation->SendMsg(msg);					

	}

EXPORT_C void RInternalSocket::CancelSend()

/**

@see RSocket documentation

*/

	{

	LOG(Log::Printf(_L("RIS::CancelSend() impl=%08x"), iImplementation));

	if(iImplementation)

		{

		TEIntSockOpMsgWrapper opMsg;

		TEIntSockMsg msg(ESoCancelSend, opMsg, iImplementation);

		iImplementation->SendReceiveMsg(msg);

		}

	}

EXPORT_C void RInternalSocket::Recv(TDes8& aDesc,TUint aFlags,TRequestStatus& aStatus)

/**

@see RSocket documentation

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Recv(desc, flags=%d, status=%08x) impl=%08x"), aFlags, &aStatus, iImplementation));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(aFlags, 0, &aDesc, EFalse);

	TEIntSockMsg msg(ESoRecvNoLength, opMsg, iImplementation, aStatus);

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::Recv(RMBufChain& aData,TUint aFlags,TRequestStatus& aStatus)

/**

@see RSocket documentation

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Recv(mbuf, flags=%d, status=%08x) impl=%08x"), aFlags, &aStatus, iImplementation));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(aFlags, 0, &aData, ETrue);

	TEIntSockMsg msg(ESoRecvNoLength, opMsg, iImplementation, aStatus);

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::Recv(TDes8& aDesc, TUint aFlags, TRequestStatus& aStatus, TSockXfrLength& aLen)

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	aLen = aFlags;

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(&aLen, 0, &aDesc, EFalse);	

	TEIntSockMsg msg(ESoRecv, opMsg, iImplementation, aStatus);	

	iImplementation->SendMsg(msg);	

	}

EXPORT_C void RInternalSocket::Recv(RMBufChain& aData, TUint aFlags, TRequestStatus& aStatus, TSockXfrLength& aLen)

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Recv(mbuf, flags=%d, status=%08x) impl=%08x"), aFlags, &aStatus, iImplementation));

	aLen = aFlags;		

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(&aLen, 0, &aData, ETrue);	

	TEIntSockMsg msg(ESoRecv, opMsg, iImplementation, aStatus);	

	iImplementation->SendMsg(msg);		

	}

/**

@see RSocket documentation.

Note: This API is not having a RMBufChain variant as a RIS::Recv with RMBufChain will give the exact behaviour 

*/

EXPORT_C void RInternalSocket::RecvOneOrMore(TDes8& aDesc, TUint aFlags, TRequestStatus& aStatus, TSockXfrLength& aLen)

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::RecvOneOrMore(flags=%d, status=%08x) impl=%08x"), aFlags, &aStatus, iImplementation));

	aLen = aFlags;

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(&aLen, 0, &aDesc, EFalse);

	TEIntSockMsg msg(ESoRecvOneOrMore, opMsg, iImplementation, aStatus );

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::CancelRecv()

/**

@see RSocket documentation

*/

	{

	LOG(Log::Printf(_L("RIS::CancelRecv() impl=%08x"), iImplementation));

	if(iImplementation)

		{

		TEIntSockOpMsgWrapper opMsg;

		TEIntSockMsg msg (ESoCancelRecv, opMsg, iImplementation);

		iImplementation->SendReceiveMsg(msg);

		}

	}

EXPORT_C void RInternalSocket::RecvFrom(TDes8& aDesc,TSockAddr& aAddr,TUint aFlags,TRequestStatus& aStatus)

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(aFlags, &aAddr, &aDesc, EFalse);	

	TEIntSockMsg msg(ESoRecvFromNoLength, opMsg, iImplementation, aStatus);

	iImplementation->SendMsg(msg);		

	}

EXPORT_C void RInternalSocket::RecvFrom(RMBufChain& aData,TSockAddr& aAddr,TUint aFlags,TRequestStatus& aStatus)

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(aFlags, &aAddr, &aData, ETrue);	

	TEIntSockMsg msg(ESoRecvFromNoLength, opMsg, iImplementation, aStatus);

	iImplementation->SendMsg(msg);		

	}

EXPORT_C void RInternalSocket::RecvFrom(TDes8& aDesc,TSockAddr& aAddr,TUint aFlags,TRequestStatus& aStatus,TSockXfrLength& aLen)

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	aStatus = KRequestPending;

	aLen = aFlags;

	TEIntSockOpMsgWrapper opMsg(&aLen, &aAddr, &aDesc, EFalse);	

	TEIntSockMsg msg(ESoRecvFrom, opMsg, iImplementation, aStatus);	

	iImplementation->SendMsg(msg);				

	}

EXPORT_C void RInternalSocket::RecvFrom(RMBufChain& aData,TSockAddr& aAddr,TUint aFlags,TRequestStatus& aStatus,TSockXfrLength& aLen)

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	aLen = aFlags;

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(&aLen, &aAddr, &aData, ETrue);	

	TEIntSockMsg msg(ESoRecvFrom, opMsg, iImplementation, aStatus);	

	iImplementation->SendMsg(msg);				

	}

EXPORT_C void RInternalSocket::Read(TDes8& aDesc,TRequestStatus& aStatus)

/**

@see RSocket documentation

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Read(desc, status=%08x) impl=%08x"), &aStatus, iImplementation));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(0, 0, &aDesc, EFalse);	

	TEIntSockMsg msg(ESoRead, opMsg, iImplementation, aStatus);	

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::Read(RMBufChain& aData,TRequestStatus& aStatus)

/**

@see RSocket documentation

@note Pass in an empty (ie. no mbufs attached) RMBuf chain here - the mbufs will be attached by the protocol

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Read(mbuf, status=%08x) impl=%08x"), &aStatus, iImplementation));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(0, 0, &aData, ETrue);	

	TEIntSockMsg msg(ESoRead, opMsg, iImplementation, aStatus);	

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::CancelRead()

/**

@see RSocket documentation

*/

	{

	LOG(Log::Printf(_L("RIS::CancelRead() impl=%08x"), iImplementation));

	if(iImplementation)

		{

		TEIntSockOpMsgWrapper opMsg;

		TEIntSockMsg msg (ESoCancelRecv, opMsg, iImplementation);

		iImplementation->SendReceiveMsg(msg);

		}

	}

EXPORT_C void RInternalSocket::Write(const TDesC8& aDesc, TRequestStatus& aStatus)

/**

@see RSocket documentation

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Write(desc, status=%08x) impl=%08x"), &aStatus, iImplementation));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(0, 0, &aDesc, EFalse);		

	TEIntSockMsg msg (ESoWrite, opMsg, iImplementation, aStatus);	

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::Write(RMBufChain& aData, TRequestStatus& aStatus)

/**

@see RSocket documentation

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Write(mbuf, status=%08x) impl=%08x"), &aStatus, iImplementation));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(0, 0, &aData, ETrue);

	TEIntSockMsg msg (ESoWrite, opMsg, iImplementation, aStatus);	

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::CancelWrite()

/**

@see RSocket documentation

*/

	{

	LOG(Log::Printf(_L("RIS::CancelWrite() impl=%08x"), iImplementation));

	if(iImplementation)

		{

		TEIntSockOpMsgWrapper opMsg;

		TEIntSockMsg msg (ESoCancelSend, opMsg, iImplementation);

		iImplementation->SendReceiveMsg(msg);

		}

	}

EXPORT_C void RInternalSocket::Connect(TSockAddr& aAddr,TRequestStatus& aStatus)

/**

@see RSocket documentation

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Connect(status=%08x) impl=%08x"), &aStatus, iImplementation));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(&aAddr, NULL, NULL);

	TEIntSockMsg msg (ESoConnect, opMsg, iImplementation, aStatus);

	iImplementation->SendMsg(msg);

	}

EXPORT_C void RInternalSocket::Connect(TSockAddr& aAddr,const TDesC8& aConnectDataOut,TDes8& aConnectDataIn,TRequestStatus& aStatus)

/**

@see RSocket documentation

*/

	{

	__ASSERT_ALWAYS(iImplementation, InternalSocketPanic(ENullSocket));

	LOG(Log::Printf(_L("RIS::Connect(withdata, status=%08x) impl=%08x"), &aStatus, iImplementation));

	aStatus = KRequestPending;

	TEIntSockOpMsgWrapper opMsg(&aAddr, &aConnectDataOut, &aConnectDataIn);

	TEIntSockMsg msg (ESoConnect, opMsg, iImplementation, aStatus);

	iImplementation->SendMsg(msg);

	}