// wsp_protocol.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 <winsockprt.h>
#include "wsp_protocol.h"
#include "wsp_provider.h"
#include "wsp_factory.h"
#include "wsp_resolver.h"
#include "wsp_panic.h"
#include "wsp_def.h"
#include "wsp_log.h"


CWinSockProtocol::~CWinSockProtocol()
	{
	}

CWinSockProtocol::CWinSockProtocol(TUint aSocketType, RWin32Factory& aWin32Factory)
	: iSocketType(aSocketType), iWin32Factory(aWin32Factory)
	{
	}

CWinSockProtocol* CWinSockProtocol::NewL(TUint aSocketType, RWin32Factory& aWin32Factory)
	{
	CWinSockProtocol* self = new(ELeave) CWinSockProtocol(aSocketType, aWin32Factory);
	return self;
	}

void CWinSockProtocol::ProtocolIdentity(TServerProtocolDesc* aDesc, TUint aSocketType, TUint aProtocol)
	{
	switch (aSocketType)
		{
		case KSockStream:
			{
			aDesc->iName = (aProtocol == KProtocolWinsockTcp) ? _S("winsocktcp") : _S("tcp");
			aDesc->iAddrFamily = KAfInet;
			aDesc->iSockType = KSockStream;
			aDesc->iProtocol = aProtocol;
			aDesc->iVersion = TVersion(KWspMajorVersionNumber, KWspMinorVersionNumber, KWspBuildVersionNumber);
			aDesc->iByteOrder = EBigEndian;
			aDesc->iServiceInfo = KSIStreamBased | KSIInOrder | KSIReliable | KSIGracefulClose;
			aDesc->iNamingServices = KNSNameResolution;
			aDesc->iSecurity = KSocketNoSecurity;
			aDesc->iMessageSize = KSocketMessageSizeIsStream;
			aDesc->iServiceTypeInfo = ESocketSupport | EUseCanSend;
			aDesc->iNumSockets = KUnlimitedSockets;
			return;
			}
		case KSockDatagram:
			{
			if (aProtocol == KProtocolWinsockUdp)
				{
				aDesc->iName =  _S("winsockudp");
				}
			else if (aProtocol == KProtocolInetUdp)
				{
				aDesc->iName = _S("udp");
				}
			else if (aProtocol == KProtocolInetIp)
				{
				aDesc->iName = _S("ip");
				}
			aDesc->iAddrFamily = KAfInet;
			aDesc->iSockType = KSockDatagram;
			aDesc->iProtocol = aProtocol;
			aDesc->iVersion = TVersion(KWspMajorVersionNumber,	KWspMinorVersionNumber, KWspBuildVersionNumber);
			aDesc->iByteOrder = EBigEndian;
			aDesc->iServiceInfo = KSIConnectionLess | KSIDatagram | KSIGracefulClose;
			aDesc->iNamingServices = KNSNameResolution;
			aDesc->iSecurity = KSocketNoSecurity;
			aDesc->iMessageSize = 65536-128; /*KSocketMessageSizeUndefined;*/
			aDesc->iServiceTypeInfo = ESocketSupport | EUseCanSend;
			aDesc->iNumSockets = KUnlimitedSockets;
			return;
			}
		}
	}

CServProviderBase* CWinSockProtocol::NewSAPL(TUint aProtocol)
	{
	WSP_LOG(WspLog::Write(_L("CWinSockProtocol::NewSAPL")));

	CWinSockProviderBase* provider = NULL;

	switch (iSocketType)
		{
		case KSockStream:
			{
			provider = CWinSockTcpProvider::NewL(iWin32Factory);
			break;
			}
		case KSockDatagram:
			{
			provider = CWinSockUdpProvider::NewL(iWin32Factory);
			break;
			}
		default:
			{
			__ASSERT_DEBUG(EFalse, Panic(EWinSockPrtCWinSockProtocolNewSAPLInvalidProtocol));
			}
		}

	iProtocol = aProtocol;
	
	return provider;
	}

void CWinSockProtocol::Identify(TServerProtocolDesc* aDesc) const
	{
	CWinSockProtocol::ProtocolIdentity(aDesc, iSocketType, iProtocol);
	}

void CWinSockProtocol::BindL(CProtocolBase* /*aProtocol*/, TUint /*anId*/)
	{
	__ASSERT_DEBUG(EFalse, Panic(EWinSockPrtUnexpectedBindRequestFromPeer));
	}

void CWinSockProtocol::BindToL(CProtocolBase* /*protocol*/)
	{
	__ASSERT_DEBUG(EFalse, Panic(EWinSockPrtUnexpectedBindToRequestFromSocketServer));
	}

TInt CWinSockProtocol::Send(RMBufChain &,CProtocolBase* /*aSourceProtocol*/)
	{
	__ASSERT_DEBUG(EFalse, Panic(EWinSockPrtUnexpectedSendDownCallFromBindee));
	return 0;
	}

void CWinSockProtocol::Process(RMBufChain &,CProtocolBase* /*aSourceProtocol*/)
	{
	__ASSERT_DEBUG(EFalse, Panic(EWinSockPrtUnexpectedProcessUpCallFromBindee));
	}

TInt CWinSockProtocol::Send(TDes8 &, TSockAddr* /*to*/,TSockAddr* /*from*/,CProtocolBase* /*aSourceProtocol*/)
	{
	__ASSERT_DEBUG(EFalse, Panic(EWinSockPrtUnexpectedSendDownCallFromBindee));
	return KErrNone;
	}

void CWinSockProtocol::Process(TDes8&,TSockAddr* /*from*/,TSockAddr* /*to*/,CProtocolBase* /*aSourceProtocol*/)
	{
	__ASSERT_DEBUG(EFalse, Panic(EWinSockPrtUnexpectedProcessUpCallFromBindee));
	}


TInt CWinSockProtocol::GetOption(TUint aLevel,TUint aName,TDes8& aOption,CProtocolBase*)
	{
	if ((aLevel == KNifOptLevel) && (aName == KNifOptGetNifIfUser))
		{
		static_cast<TNifIfUser&>(aOption) = this;
		return KErrNone;
		}
	return KErrNotSupported;
	}

TInt CWinSockProtocol::SetOption(TUint /*level*/,TUint /*name*/,const TDesC8& /*option*/,CProtocolBase* /*aSourceProtocol*/)
	{
	return KErrNotSupported;
	}

void CWinSockProtocol::Error(TInt /*anError*/,CProtocolBase* /*aSourceProtocol*/)
	{
	__ASSERT_DEBUG(EFalse, Panic(EWinSockPrtUnexpectedErrorUpCallFromBindee));
	}

CHostResolvProvdBase* CWinSockProtocol::NewHostResolverL()
	{
	WSP_LOG(WspLog::Write(_L("CWinSockProtocol::NewHostResolverL")));
	return CWinSockResolver::NewL(iWin32Factory);
	}

CServiceResolvProvdBase* CWinSockProtocol::NewServiceResolverL()
	{
	return NULL;
	}

CNetDBProvdBase* CWinSockProtocol::NewNetDatabaseL()
	{
	return NULL;
	}

void CWinSockProtocol::IfUserBindFailure(TInt, TAny*)
	{
	}

void CWinSockProtocol::IfUserNewInterfaceL(CNifIfBase*, TAny*)
	{
	}

void CWinSockProtocol::IfUserInterfaceDown(TInt, CNifIfBase*)
	{
	}

void CWinSockProtocol::IfUserOpenNetworkLayer()
	{
	Open();
	}

void CWinSockProtocol::IfUserCloseNetworkLayer()
	{
	Close();
	}

CProtocolBase* CWinSockProtocol::IfUserProtocol()
	{
	return this;
	}

TBool CWinSockProtocol::IfUserIsNetworkLayerActive()
	{
	}