// Copyright (c) 2003-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:
// Implements a Symbian OS server that exposes the RCDHCP API
// 
//

/**
 @file
 @internalTechnology
*/

#include <e32svr.h>
#include <e32base.h>
#include <e32std.h>
#include "DHCP_Std.h"
#include "DHCPServer.h"
#include "DHCPSess.h"
#include "DHCPIP4Msg.h"
#ifdef SYMBIAN_NETWORKING_PLATSEC
#include <ecom/ecom.h>
#include "DHCPPolicy.h"
#endif

#ifdef _DEBUG
#include <e32property.h>
#endif

/**
 *  Holds current debug options of the server
 *  @internalComponent
 */
TInt CDHCPServer::iDebugFlags(0);

CDHCPServer::~CDHCPServer()
/**
 *
 * Destructor
 *
 * @internalComponent
 */
	{
	__CFLOG_CLOSE;
	__CFLOG_DELETE;
	iEsock.Close();
	delete iTimer;
	}

#ifdef SYMBIAN_NETWORKING_PLATSEC
CDHCPServer::CDHCPServer(): CPolicyServer(EPriorityStandard,Policy,ESharableSessions)
#elif defined(EKA2)
CDHCPServer::CDHCPServer(): CServer2(EPriorityStandard)
#else
//On  EKA1, session is open in one thread and used in another
CDHCPServer::CDHCPServer(): CServer2(EPriorityStandard, ESharableSessions)
#endif
/**
 * The CDHCPServer::CDHCPServer method
 *
 * Constructor
 *
 * @internalComponent
 */
	{
	}
	
CDHCPServer* CDHCPServer::NewL()
/**
 * Creates and start the CServer2 derived server.
 * Called inside the MainL() function.
 *
 * @return - Instance of the server
 */
	{
	CDHCPServer* server = new (ELeave) CDHCPServer();
	CleanupStack::PushL(server);
	server->ConstructL();
	// CServer2 base class call
	server->StartL(KDHCPServerName);
	CleanupStack::Pop(server);
	__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPServer::NewL")));
	return server;
	}

void CDHCPServer::ConstructL()
/**
  * Second stage construction
  *
  * @internalTechnology
  *
  */
	{
	__CFLOG_CREATEL;
	__CFLOG_OPEN;
	User::LeaveIfError(iEsock.Connect());
#ifdef _DEBUG
	DebugFlags() = 0;
#endif
	__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPServer::ConstructL - connected to ESock")));
	}


CSession2* CDHCPServer::NewSessionL(const TVersion& /*aVersion*/, const RMessage2& /*aMessage*/) const
/**
 *
 * Create a new If on this server
 *
 * @param	&aVersion	Vesion of server
 * @return	A new CDHCP session to be used for the connection
 *
 * @internalTechnology
 */
	{
//	TVersion v(KDHCPSrvMajorVersionNumber,KDHCPSrvMinorVersionNumber,KDHCPSrvBuildVersionNumber);

	__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPServer::NewSessionL - creating new session...")));

	//	if (!User::QueryVersionSupported(v, aVersion))
//		User::Leave(KErrNotSupported);
	CDHCPSession* ses = CDHCPSession::NewL();
	SessionConnected();
	return ses;
	}
	
void CDHCPServer::SessionConnected() const
/**
  * Called by session to alert server
  * that something has connected so
  * cancel the shutdown timer if there
  * is one running
  *
  */
  	{
	if (iTimer)
		{
		iTimer->Cancel();
		}  	
  	}
	
void CDHCPServer::Close(CDHCPSession* /*aDHCPSession*/)
/**
  * Reference counting for the server.
  * When there are no sessions open then
  * we shutdown, unless the only one open
  * is oursleves, then we obviously still shutdown...
  *
  * @internalTechnology
  */
	{
	iSessionIter.SetToFirst();
	
   	TInt count = 0;
   	while (iSessionIter++!=NULL)
   		{
   		count++;
   		}
	__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPServer::Close - Current Session Count: (%d)") ,count));
		         
		         
	// if we have one session then it is the current one
	// and ok to shutdown...as this function is called
	// before the session is destroyed...
	if (count==1)
		{
		if (!iTimer)
			{
			TRAPD(ret, iTimer = CExpireTimer::NewL());
			if (ret!=KErrNone)
				{
				// OOM so why not just shut down to free some
				// seeing as that's the process that's been set
				// in motion anyway...
				TimerExpired();
				return;
				}
			}			
		// wait for 10 seconds before shutting down completely...
		// in case anyone wants to connect			
		iTimer->After(TTimeIntervalSeconds(KOneSecond/*10*/), *this);
		}	
	REComSession::FinalClose();
	}
	
void CDHCPServer::TimerExpired()
/**
  * CExpireTimer interface function to  alert server timer has popped
  *
  */
  	{
  	// just stop the server if we get here....
	CActiveScheduler::Stop();
  	}

TInt& CDHCPServer::DebugFlags()
/**
  * Provides acess to debug flags
  */
	{
	return iDebugFlags;
	}

LOCAL_C void MainL()
/**
 * Do the funky stuff, and use Rendezvous to signal completion...
 */
	{
	// Leave the hooks in for platform security
#if (defined __DATA_CAGING__)
	RProcess().DataCaging(RProcess::EDataCagingOn);
	RProcess().SecureApi(RProcess::ESecureApiOn);
#endif

#if defined(__WINS__) && !defined(EKA2) //WINS emulator
	User::LeaveIfError(RThread().Rename(KDHCPProcessName));
#elif !defined(EKA2)
	User::LeaveIfError(RProcess().Rename(KDHCPProcessName));
#else //WINCW emulator or any target
	User::LeaveIfError(RProcess::RenameMe(KDHCPProcessName));
#endif

#ifdef _DEBUG
	TInt err = RProperty::Define(KMyPropertyCat, KMyPropertyDestPortv4, RProperty::EInt, TSecurityPolicy(TSecurityPolicy::EAlwaysPass),
				TSecurityPolicy(ECapabilityWriteDeviceData));
	if (err == KErrNone)
		{
		// not defined by test code
		RProperty::Define(KMyPropertyCat, KMyPropertyDestPortv6, RProperty::EInt, TSecurityPolicy(TSecurityPolicy::EAlwaysPass),
					TSecurityPolicy(ECapabilityWriteDeviceData));
		RProperty::Set(KMyPropertyCat, KMyPropertyDestPortv4, 67);	// set to default values
		RProperty::Set(KMyPropertyCat, KMyPropertyDestPortv6, 547);	// set to default values
		RProperty::Define(KMyPropertyCat, KMyDefaultLeaseTime, RProperty::EInt, TSecurityPolicy(TSecurityPolicy::EAlwaysPass),
					TSecurityPolicy(ECapabilityWriteDeviceData));
		RProperty::Set(KMyPropertyCat, KMyDefaultLeaseTime, 21600);	// Define and set default values for server lease time
		}
#endif

	CActiveScheduler* pScheduler = new(ELeave)CActiveScheduler;
	CActiveScheduler::Install(pScheduler);
	CleanupStack::PushL(pScheduler);
	CDHCPServer* pServer = CDHCPServer::NewL();
	CleanupStack::PushL(pServer);

	__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("MainL - about to start activescheduler")));
	// Sync with the starter and enter the active scheduler
#if defined(__WINS__) && !defined(EKA2)
	RThread::Rendezvous(KErrNone); //WINS emulator
#else	//WINSCW emulator or any target
	RProcess::Rendezvous(KErrNone);
#endif
	CActiveScheduler::Start();
	__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("MainL - activescheduler has stopped...")));
	CleanupStack::PopAndDestroy(pServer);
	CleanupStack::PopAndDestroy(pScheduler);
	}


EXPORT_C TInt E32Main()
/**
 * The main thread function, the Ordinal 1!
 * @return - Standard Epoc error code on exit
 */
	{	
__UHEAP_MARK;
	CTrapCleanup* cleanup = CTrapCleanup::New();
	if (cleanup == NULL)
		{
		return KErrNoMemory;
		}
	TInt err = KErrNone;
	TRAP(err,MainL());
	delete cleanup;
__UHEAP_MARKEND;
	return err;
    }
    
#if !defined(EKA2)
GLDEF_C TInt E32Dll(enum TDllReason)
	{
	return 0;
	}
#endif