// Copyright (c) 2006-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 descriptor transfer server - server implementation

// 

//

#include "fdtransfer_srv.h"

#include "sysif.h"

#include "fdesc.h"

// -------------------------------------------------------------------------------

// CShutdown::ConstructL

// -------------------------------------------------------------------------------

inline void CShutdown::ConstructL()

	{

	CTimer::ConstructL();

	}

// -------------------------------------------------------------------------------

// CShutdown::Start

// Starts the timer for the specified time given

// -------------------------------------------------------------------------------

inline void CShutdown::Start()

	{

	CActiveScheduler::Add(this);

	After(KFDTransferServerShutdownDelay);

	}

// -------------------------------------------------------------------------------

// CShutdown::RunL

// Initiate server exit when timer expires

// -------------------------------------------------------------------------------

inline void CShutdown::RunL()

    {

    CActiveScheduler::Stop();

    }

// -------------------------------------------------------------------------------

// CFileDesTransferSession::CreateL

// 2nd phase construction for sessions. Invoked by the CServer2 framework

// -------------------------------------------------------------------------------

inline void CFileDesTransferSession::CreateL()

    {

    Server().AddSession();

    }

// -------------------------------------------------------------------------------

// CFileDesTransferSession::ServiceL

// Handle a client request. Leaves are handled by the ServiceError method.

// -------------------------------------------------------------------------------

void CFileDesTransferSession::ServiceL(const RMessage2& aMsg)

    {

    switch (aMsg.Function())

        {

    case ETransferFile:

    	{

    	GetfilesFromClient(aMsg);

    	break;

    	}

    case ETransferPipe:

        {

        GetPipesFromClient(aMsg);

    	break;    	

        }

    default:

    	{

    	#ifdef _DEBUG

    	RDebug::Printf("CFileDesTransferSession: Illegal message received");

    	#endif

        break;	//_DEBUG

    	}

        }

    }

// -------------------------------------------------------------------------------

// CFileDesTransferSession::GetPipesFromClient

// Inherits pipes from the client.  

// -------------------------------------------------------------------------------

void CFileDesTransferSession::GetPipesFromClient(const RMessage2& aMsg) const

{

	CFileTable& ftable = const_cast<CFileTable&>(Backend()->FileTable());

	TInt indx = aMsg.Int0();

	RPipe pipe;

	TInt err = pipe.Open(aMsg, 1);

	if (err == KErrNone)

	{

		TUint16 mode = 0;

		if(aMsg.Int2()& O_NONBLOCK)

			mode |= O_NONBLOCK;

		if(indx > (ftable.iFids.Count()-1))

		{

			TRAP(err,ftable.ExpandFTableL(indx+1));

		}

		if(KErrNone == err)

			err = ftable.CreatePipeDesc(indx,pipe,mode);

		if (err != KErrNone)

		{

			pipe.Close();

		}

	}

	aMsg.Complete(KErrNone);

}

// -------------------------------------------------------------------------------

// CFileDesTransferSession::GetfilesFromClient

// Inherits normal files the client.  

// -------------------------------------------------------------------------------

void CFileDesTransferSession::GetfilesFromClient(const RMessage2& aMsg) const

{

	CFileTable& ftable = const_cast<CFileTable&>((Backend()->FileTable()));

	TInt indx = aMsg.Int0();

	CFileDesc* fdesc = (CFileDesc*)ftable.iPrivateHeap->AllocZ(sizeof(CFileDesc));

	if (!fdesc)

	{

	     aMsg.Complete(KErrNone);

	     return;				

	}

	fdesc = new (fdesc) CFileDesc;

#if defined(SYMBIAN_OE_LARGE_FILE_SUPPORT) && !defined(SYMBIAN_OE_NO_LFS)

	//The integer width is bigger for 64 bit sizes

	TBuf<140> params;

#else		

	TBuf<60> params;

#endif /* SYMBIAN_OE_LARGE_FILE_SUPPORT && !SYMBIAN_OE_NO_LFS */

	aMsg.Read(1,params);

	TInt err = (fdesc->FileHandle()).AdoptFromClient(aMsg,2,3);

	if(indx > (ftable.iFids.Count()-1))

	{

		TRAP(err,ftable.ExpandFTableL(indx+1));

	}

	if (err == KErrNone)

	{

		fdesc->SetState(params);

		err = fdesc->CreateLock();

	}

	if(err == KErrNone)

		{

		err = fdesc->Alloc();

		}

	if(err == KErrNone)

	{

	   ftable.Attach(indx, fdesc);

	}

	else

	{

		delete fdesc;

		(fdesc->FileHandle()).Close();

	}

	aMsg.Complete(KErrNone);  

	return ;

}

// -------------------------------------------------------------------------------

// CFileDesTransferSession::ServiceError

// Handle an error from CFileTransferSession::ServiceL().

// -------------------------------------------------------------------------------

void CFileDesTransferSession::ServiceError(const RMessage2& aMsg, TInt aError)

    {

    CSession2::ServiceError(aMsg, aError);

    }

// -------------------------------------------------------------------------------

// CFileDesTransferSession::Server

// Obtain a reference to the server

// -------------------------------------------------------------------------------

inline CFileDesTransferServer& CFileDesTransferSession::Server()

    {

	return *(static_cast<CFileDesTransferServer*>(const_cast<CServer2*>(CSession2::Server())));

    }

// -------------------------------------------------------------------------------

// CFileDesTransferSession::~CFileDesTransferSession

// This session is destroyed. Gone forever.

// -------------------------------------------------------------------------------

CFileDesTransferSession::~CFileDesTransferSession()

    {

    Server().DropSession();

    }

// -------------------------------------------------------------------------------

// CFileDesTransferServer::NewLC

// Server constructor

// -------------------------------------------------------------------------------

CFileDesTransferServer* CFileDesTransferServer::NewLC(RSemaphore& sem)

	{

	CFileDesTransferServer* pServer = new(ELeave) CFileDesTransferServer;

	CleanupStack::PushL(pServer);

	pServer->iSem = sem;

	pServer->ConstructL();

	// Leave pServer on the cleanup stack

	return pServer;

	}

// -------------------------------------------------------------------------------

// CFileDesTransferServer::ConstructL

// Second phase construction. Create the shutdown timer object and the semaphore

// -------------------------------------------------------------------------------

void CFileDesTransferServer::ConstructL()

    {

	CleanupStack::Pop();

    }

// -------------------------------------------------------------------------------

// CFileDesTransferServer::AddToScheduler

// Add both the server and the shutdown timer objects to the active scheduler

// -------------------------------------------------------------------------------

TInt CFileDesTransferServer::AddToScheduler(const TDesC& aName)

	{

	iShutdown->Start();

	return CServer2::Start(aName);

	}

// -------------------------------------------------------------------------------

// CFileDesTransferServer::RemoveFromScheduler

// Remove both the server and the shutdown timer objects from the active scheduler

// -------------------------------------------------------------------------------

void CFileDesTransferServer::RemoveFromScheduler()

	{

	if (iShutdown->IsAdded())

		{

		iShutdown->Deque();

		}

	Deque();

	}

// -------------------------------------------------------------------------------

// CFileDesTransferServer::NewSessionL

// Create a new client session.

// -------------------------------------------------------------------------------

CSession2* CFileDesTransferServer::NewSessionL(const TVersion&, const RMessage2&) const

    {

    return new(ELeave) CFileDesTransferSession;

    }

// -------------------------------------------------------------------------------

// CFileDesTransferServer::AddSession

// A new session is created. Cancel the shutdown timer if it was running.

// -------------------------------------------------------------------------------

inline void CFileDesTransferServer::AddSession()

    {

    iShutdown->Deque();

    ++iSessionCount;

    }

// -------------------------------------------------------------------------------

// CFileDesTransferServer::DropSession

// The session is destroyed. Stop the ActiveScheduler

// -------------------------------------------------------------------------------

inline void CFileDesTransferServer::DropSession()

    {

    if (--iSessionCount==0)

    	{

        CActiveScheduler::Stop();

    	}

    }

// -------------------------------------------------------------------------------

// CFileDesTransferServer::StartServer

// Start serving. Blocks until the active scheduler is stopped from CShutdown::RunL

// -------------------------------------------------------------------------------

void CFileDesTransferServer::StartServer()

	{

    iSem.Signal();

    // Start the scheduler

    CActiveScheduler::Start();

    // Block until 

    }

// -------------------------------------------------------------------------------

// CFileDesTransferServer::~CFileDesTransferServer

// -------------------------------------------------------------------------------

CFileDesTransferServer::~CFileDesTransferServer()

	{

	iSem.Close();

	delete iShutdown;

	}