/*

* Copyright (c) 2006 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:   TNE server

*

*/

#include"HXTneserver.h"

#include"HXTneclientservercommon.h"

#include <flogger.h>

#include <f32file64.h>

#include <e32math.h> // Sqrt

#include <stdlib.h> // abs

static const TInt kDefaultStack = 0x4000;

// PRINT macro

#ifdef _DEBUG

#include <e32svr.h>

#define PRINT(x) RDebug::Print x

#else

#define PRINT(x)

#endif

#ifdef _DEBUG

#define ENABLE_S60_TNE_LOGGING 1

#endif

//implementation

#ifdef ENABLE_S60_TNE_LOGGING

#define FLOG FileLog

inline static void FileLog(TRefByValue<const TDesC16> aFmt,...)

{

    VA_LIST  args;

    VA_START (args, aFmt);

    RFileLogger::WriteFormat(_L("tne"), _L("S60tne.log"), 

                        EFileLoggingModeAppend, aFmt, args);

}

#else // logging is disabled

#define FLOG LogFNull

inline static void LogFNull(TRefByValue<const TDesC16> aFmt,...){}

#endif // enable logging

const TInt KMaxPacketToDecode = 160; // Many clips begin with several seconds of logos / MPAA rating which need to be skipped

//////////////Server///////////////

CTneServer::CTneServer(CActive::TPriority aActiveObjectPriority)

    : CServer2(aActiveObjectPriority)

    {

    }

CSession2* CTneServer::NewSessionL(const TVersion& /* aVersion */,const RMessage2& 

/*aMessage*/) const 

{

	 return new (ELeave) CTneSession;

	}

GLDEF_C  TInt CTneServer::ThreadFunction(TAny*  aName)

{

	HBufC   *pServerName = (HBufC *) aName;

	CTrapCleanup* cleanup = NULL;

	CActiveScheduler *pA = NULL;

	CTneServer *pS = NULL;

	TInt err = KErrNoMemory;

    FLOG(_L("CTneServer::ThreadFunction ServerName=%S"), pServerName); 		

	  // get clean-up stack

	if (pServerName)

	{

    		cleanup =CTrapCleanup::New(); 

    	 	pA = new CActiveScheduler;    

    		pS = new CTneServer(EPriorityHigh);

    	 }

    if (cleanup && pA && pS )

   {

   		// OK

   		CActiveScheduler::Install(pA);      

      	// Start the server

    	err =  pS->Start(*pServerName);

  	}

  	RThread::Rendezvous(err);

    CActiveScheduler::Start();

      // Tidy up...    

    delete pS;

    delete pA;

    delete cleanup; 

    return(err);

}

//global function

TInt  StartThread(RThread& aServerThread,  HBufC *pServerName)

    {

    TInt res=KErrNone;

       res=aServerThread.Create(*pServerName,

            CTneServer::ThreadFunction,

            kDefaultStack, &User::Heap(),            

            (TAny *)pServerName  );

          // The thread has been created OK so get it started - however

          // we need to make sure that it has started before we continue.

        if (res==KErrNone)

            {

            TRequestStatus rendezvousStatus;

            aServerThread.SetPriority(EPriorityNormal);

            aServerThread.Rendezvous(rendezvousStatus);

            aServerThread.Resume();

            User::WaitForRequest(rendezvousStatus);

            res = rendezvousStatus.Int();

             }

          // The thread has not been created - clearly there's been a problem.

        else

            {

            aServerThread.Close();

             }

    return res;

    }

	////////////////////////ServerSession//////////////////////////////

CTneSession::CTneSession():CActive(EPriorityStandard),

        iWidth(0),                 

        iHeight(0) ,                                            

        iDuration(0)  ,                                        

        iFrameCount(0)    ,                                     

        m_LastError(KErrNone),                                          

        m_uPacketsReceived(0)    ,                                   

        m_bDone(EFalse),                                                      

        iFs(NULL),                                                    

        iYUVBuffer(NULL),

        iClientYUVBufferPtrPtr(NULL),                         

        iReOpenFileLPending(EFalse),                          

        iGetThumbPending(EFalse),                        

        iCloseHandle(EFalse),        	                        

        ibOpenFilePending(EFalse),  

        iThumbIndex(0),

        iUtil(NULL),                                                

        m_State( ENotReady),

        m_bMetaDataReady(EFalse),

        iPosition(0)

{

    CActiveScheduler::Add(this);

    FLOG(_L("CTneSession::CTneSession()in this=%x"), this);                      

    FLOG(_L("CTneSession::CTneSession()out this=%x"), this); 

}                           

   CTneSession::~CTneSession() 

{                          

	 FLOG(_L("CTneSession::~CTneSession()in this=%x"), this); 

	 Cancel();

     if(iYUVBuffer)        

     {    	               

        User::Free(iYUVBuffer);

        iYUVBuffer = NULL; 

	 }                     

	 if (iCloseHandle)     

	 {	                   

	    iFileHandle.Close();

	 }                     

	 if (iUtil)            

	 {                     

	    delete iUtil;      

	    iUtil = NULL;      

	 }                     

	 if(iFs)               

    {                      

	    iFs->Close();      

	    delete iFs;

	    iFs = NULL;

    }

	 CompleteRequest(iClientRequest,KErrCancel);

	 CompleteRequest(iMetaDataRequest,KErrCancel); 

	 CompleteRequest(iThumbnailRequest,KErrCancel); 

	 CompleteCancelRequest();	 

	 CActiveScheduler::Stop();

    FLOG(_L("CTneSession::~CTneSession()out this=%x"), this);                	

}

	/**

Services a client request.

*/

void CTneSession::ServiceL(const RMessage2& aMessage)

    {

        DispatchMessageL(aMessage); 

    }

void CTneSession::DispatchMessageL(const RMessage2& aMessage)

    {

   	TBool bCompleteRequest = EFalse;

   	TInt lError = KErrNone;

    RFile* pFileHandle;	

    TFileName *pFileName;

    TInt aPosition;

    TNEThumbRequest *pThumbRequestData;

    RFile64 aFilehandle;

    FLOG(_L("CTneSession::DispatchMessageL in type=%d"), aMessage.Function());

    switch (aMessage.Function())

        {        	        

    case  EOpenFileRFmsg:

        m_State = EStartGettingMetadata;

        bCompleteRequest = EFalse;

        CompleteRequest(iClientRequest,KErrNotReady); // Any previous pending request

        iClientRequest = aMessage;

     	pFileHandle = ( RFile* ) aMessage.Ptr0(); // Handle to read Message data     

     	aPosition  = (TInt  ) aMessage.Ptr1();

     	lError = iFileHandle.Duplicate(*pFileHandle);

     	iPosition = aPosition;

     	if (lError == KErrNone)

     	{

            iCloseHandle = ETrue;

            iStatus = KRequestPending;

            SetActive();

            TRequestStatus* pStatus = &iStatus;

            User::RequestComplete(pStatus, KErrNone);          

        }

        break;

//fix me - Avoid duplicate code -common func (Future Work)

    case  EOpenFIleNamemsg:

        iFs = NULL;

        m_State = EStartGettingMetadata;

        CompleteRequest(iClientRequest,KErrNotReady); // Any previous pending request

        iClientRequest = aMessage;

     	pFileName = (TFileName* ) aMessage.Ptr0();    	      

     	aPosition  = (TInt  ) aMessage.Ptr1();

     	iFs = new RFs;

     	if(iFs == NULL)

     	{

     	    lError = KErrNoMemory;

     	    bCompleteRequest = ETrue;

     	}

     	else if ( (lError  = iFs->Connect())!= KErrNone)

     	{

     	    bCompleteRequest = ETrue;

     	}

     	else if ((lError = aFilehandle.Open(*iFs,*pFileName, EFileShareReadersOnly | EFileStream | EFileRead))!= KErrNone)

     	{

     	    bCompleteRequest = ETrue;

     	}

     	else if ((lError = iFileHandle.Duplicate(aFilehandle))!= KErrNone)

     	{

     	    bCompleteRequest = ETrue;

     	    aFilehandle.Close();

     	}

     	else

     	{

     	    bCompleteRequest = EFalse;

     	    aFilehandle.Close();

     	    iStatus = KRequestPending;

     	    iCloseHandle = ETrue;

     	    SetActive();

     	    TRequestStatus* pStatus = &iStatus;

     	    User::RequestComplete(pStatus, KErrNone);

     	}

        if (lError  !=  KErrNone)

        {

            bCompleteRequest = ETrue;

        }                        

        break;

      case EGetMetaDatamsg:

        CompleteRequest(iMetaDataRequest,KErrNotReady); // Any previous pending request

        iMetaDataRequest = aMessage;

        NotifyIfGetMetaDataPending(m_LastError);       

        break;

      case EGetThumbmsg:

        CompleteRequest(iThumbnailRequest,KErrNotReady); // Any previous pending request

        iThumbnailRequest = aMessage;

        pThumbRequestData  = ( TNEThumbRequest * ) aMessage.Ptr0();

        // store thumb request parameters       	    

        iClientYUVBufferPtrPtr  = &(pThumbRequestData->iYUVBuffer);        

        iThumbIndex = pThumbRequestData->iIndex;

        if (iThumbIndex == KBestThumbIndex || iThumbIndex <= 1)

        {

            m_State = EStartGettingThumbNail;

            DoGetThumb();

        }

        else

        {

            m_State = EStartGettingThumbNailWithIndex;

			if (!ibOpenFilePending)

			{

			    lError = ReOpenFile(iFileHandle);

			    if(lError)

			    {

			        m_LastError = lError;

			        CompleteRequest(iThumbnailRequest,m_LastError);

			    }

			}

			else

			{ // Previous thumbnail generation is in progress so cancel it	

			    if(iUtil)

			    {

			        iUtil->CancelThumb();

			    }

			    // Once control returns and if m_State is EStartGettingThumbNailWithIndex call ReOpenFile

			    iReOpenFileLPending = ETrue;

			}

		}

        break;

    case ECancelThumbmsg:

        FLOG(_L("CTneSession::DispatchMessageL cancellation ++"));

        iGetThumbPending = EFalse;

        iCancelRequest = aMessage;        

        m_State = ECancelling;               

        if(iUtil)

        {

        	iUtil->CancelThumb();

        }

        // cancel any pending getthumb or openfile request.

        lError = KErrCancel;

        CompleteRequest(iClientRequest,lError); 

        CompleteRequest(iThumbnailRequest,lError); 

        if (!ibOpenFilePending)

        {

           CompleteCancelRequest(); 

        }

        FLOG(_L("CTneSession::DispatchMessageL cancellation --"));

        break;    

   default:

      //  PanicClient(aMessage,EBadRequest);

        return;

      }

    // If any error occured during file opening

    if (bCompleteRequest)

    {

        CompleteRequest(iClientRequest,lError);

    }

	FLOG(_L("CTneSession::DispatchMessageL out type=%d"), aMessage.Function());

}

TInt CTneSession::DoOpenFile(RFile &aFileHandle, TUint uStartTime)

{

      FLOG(_L(" CTneSession::DoOpenFile in"));

   MHXThumbnailUtilityImplObserver*	pObserver = 

				(MHXThumbnailUtilityImplObserver *) this;

	ibOpenFilePending = ETrue;	

	TFileName aFilename;

	aFileHandle.FullName(aFilename);	

	 FLOG(_L("aFilename=%S"),&aFilename ); 	

	TRAPD(err, iUtil = CHXThumbnailUtility::NewL(*pObserver));

	   m_bDone = EFalse;

 	   m_uPacketsReceived = 0;

	if (err == KErrNone)

	{

        TRAP(err, iUtil->OpenFileL(aFileHandle, uStartTime));

    }

       FLOG(_L(" CTneSession::DoOpenFile  out err = %d"),err);

    ibOpenFilePending = EFalse;

    return err;

}

TInt CTneSession::ReOpenFile(RFile &aFileHandle)

{

	iGetThumbPending = ETrue; 

	TInt lError = KErrNone;

    TUint uStartingTime = 0;

    lError = GetStartingTime(uStartingTime);

    if (lError == KErrNone)

    {       

    	if (iUtil)

    	{	

    	    iUtil->CancelThumb();

    		delete iUtil;

    		iUtil = NULL;    						    

    	}

    	iPosition = uStartingTime;

    	if(!IsActive())   		   

    	{

            iStatus = KRequestPending;

            SetActive();

            TRequestStatus* pStatus = &iStatus;

            User::RequestComplete(pStatus, KErrNone);

    	}

    }

    return lError; 	

}

void CTneSession::FetchBasicMetaData()

{

    TUint lCount = 0;

    TUint i=0;

    TUint lFrameRateinSec  = 0;

    iUtil->GetMetaDataCount(lCount);

    TBool bGotFrameSize = EFalse, bGotDuration = EFalse, bGotFrameRate = EFalse;

    for (i=0; i<lCount; i++)

    {

        HBufC *pDes = NULL;           

        HXMetaDataKeys::EHXMetaDataId id;        

        iUtil->GetMetaDataAt(i, id, pDes);

        if (id == HXMetaDataKeys::EHXFrameSize && pDes)

        {

            TPtr pFrameSizePtr = pDes->Des();

            _LIT(KChar_x, "x");

            TInt xLoc = pFrameSizePtr.Find(KChar_x);

            if (xLoc != KErrNotFound)

            {            	            

            TLex lexWidth(pFrameSizePtr.Mid(0, xLoc));

            TLex lexHeight(pFrameSizePtr.Mid(xLoc+1));

            lexWidth.Val(iWidth);  // Storing into local iWidth variable

            lexHeight.Val(iHeight);  // Storing into local iHeight variable  

            bGotFrameSize = ETrue;

            FLOG(_L(" iWidth=%d,iHeight=%d"), iWidth,iHeight);

            }

        }

        else if (id == HXMetaDataKeys::EHXDuration && pDes)

        {

            TLex lexDuration(pDes->Des());

            lexDuration.Val(iDuration);

            bGotDuration = ETrue;

        }        

        else if (id == HXMetaDataKeys::EHXFramesPerSecond && pDes)

        {

        	TLex lexFramesPerSecond(pDes->Des());        	

            lexFramesPerSecond.Val(lFrameRateinSec);            

        	bGotFrameRate = ETrue;

        }

        if (bGotDuration && bGotFrameRate && bGotFrameSize)

        {        	

        	break;	

        }

    } // end of for

    if (bGotDuration && bGotFrameRate)

    {

    	// approximate frame count

    	// iDuration is in msec.

    	iFrameCount =   ( (iDuration+500)/1000 ) * lFrameRateinSec;

    }

    else

    {

        iFrameCount =   ( (iDuration+500)/1000 ) * 10;

    }