/*

* Copyright (c) 2010 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:  This application is to monitor Harvester and Search Server

*

*/

#include "CWDmonitor.h"

#include "CWDTimer.h"

#include <HarvesterServerLogger.h>

#include <centralrepository.h>

#include <cpixwatchdogcommon.h>

#include "centrepmonitor.h"

#include "servermonitor.h"

#include "OstTraceDefinitions.h"

#ifdef OST_TRACE_COMPILER_IN_USE

#include "cwdmonitorTraces.h"

#endif

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

// CWDMonitor::NewL

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

//

CWDMonitor* CWDMonitor::NewL(  )

    {

    CWDMonitor* self = CWDMonitor::NewLC( );

    CleanupStack::Pop();

    return self;

    }

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

// CWDMonitor::NewLC

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

//

CWDMonitor* CWDMonitor::NewLC( )

    {

    CWDMonitor* self = new ( ELeave ) CWDMonitor( );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

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

// CWDMonitor::~CWDMonitor()

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

//

CWDMonitor::~CWDMonitor()

    {

    delete iHSName;

    delete iSSName;

    delete iWDTimer;

    delete aHSStatusMonitor;

    delete aSSStatusMonitor;

    delete aHSUidMonitor;

    delete aSSUidMonitor;

    delete aHSNameMonitor;

    delete aSSNameMonitor;

    delete iHarvesterMonitor;

    delete iSearchMonitor;

    }

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

// CWDMonitor::CWDMonitor()

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

//

CWDMonitor::CWDMonitor( )                    

    {    

    }

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

// CWDMonitor::ConstructL()

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

//

void CWDMonitor::ConstructL()

    {    

    CRepository* wdrepo = CRepository::NewL( KWDrepoUidMenu );

    wdrepo->Get( KHarvesterServerKey , iAllowHS );

    wdrepo->Get( KSearchServerKey , iAllowSS );

    //get the UID's of the servers

    TBuf<KCenrepUidLength> temp;

    TInt64 value;

    TLex uidvalue;

    //Read Harvester server UId value

    if ( KErrNone == wdrepo->Get( KHarvesterServerUIDKey, temp ) )

        {

        uidvalue.Assign(temp);        

        if (KErrNone == uidvalue.Val( value,EHex ))

            iHSUid.iUid = value;

        }

    //Read Search server Uid value

    if ( KErrNone == wdrepo->Get( KSearchServerUIDKey, temp ))

        {

        uidvalue.Assign(temp);

        if (KErrNone == uidvalue.Val( value,EHex ))

          iSSUid.iUid = value;

        }

    //Read Harvester server Name

    if ( KErrNone == wdrepo->Get( KHarvesterServerNAMEKey, temp ))

        {

        iHSName = HBufC::NewL( temp.Length() );

        TPtr hsname = iHSName->Des();

        hsname.Copy( temp );

        }

    //Read Search server Name

    if ( KErrNone == wdrepo->Get( KSearchServerNAMEKey, temp ))

        {

        iSSName = HBufC::NewL( temp.Length() );

        TPtr ssname = iSSName->Des(); 

        ssname.Copy( temp );

        }

    delete wdrepo;

    if ( iAllowHS || iAllowSS )

        iWDTimer = CWDTimer::NewL( this );

    aHSStatusMonitor = CentrepMonitor::NewL( this, KHarvesterServerKey);

    aHSStatusMonitor->StartNotifier();

    aSSStatusMonitor = CentrepMonitor::NewL( this, KSearchServerKey);

    aSSStatusMonitor->StartNotifier();

    aHSUidMonitor = CentrepMonitor::NewL( this, KHarvesterServerUIDKey);

    aHSUidMonitor->StartNotifier();

    aSSUidMonitor = CentrepMonitor::NewL( this, KSearchServerUIDKey);

    aSSUidMonitor->StartNotifier();

    aHSNameMonitor = CentrepMonitor::NewL( this, KHarvesterServerNAMEKey);

    aHSNameMonitor->StartNotifier();

    aSSNameMonitor = CentrepMonitor::NewL( this, KSearchServerNAMEKey);

    aSSNameMonitor->StartNotifier();

    }

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

// CWDMonitor::StartMonitor()

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

//

void CWDMonitor::HandleWDTimerL()

    {

    OstTrace0( TRACE_NORMAL, CWDMONITOR_HANDLEWDTIMERL, "CWDMonitor::HandleWDTimerL(): Check the servers" );

    CPIXLOGSTRING("CWDMonitor::HandleWDTimerL(): Check the servers");

    if ( !iHarvesterMonitor )

        {

        if ( iAllowHS )

            iHarvesterMonitor = CServerMonitor::NewL( *iHSName , iHSUid );

        iWDTimer->StartWDTimer();

        return;

        }

    if ( iAllowSS )

        iSearchMonitor = CServerMonitor::NewL( *iSSName , iSSUid );

    return;

    }

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

// CWDMonitor::StartMonitor()

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

//

void CWDMonitor::StartMonitor()

    {

    OstTraceFunctionEntry0( CWDMONITOR_STARTMONITOR_ENTRY );

    CPIXLOGSTRING("CWDMonitor::StartMonitor(): Entered");

    iWDTimer->StartWDTimer();

    OstTraceFunctionExit0( CWDMONITOR_STARTMONITOR_EXIT );

    }

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

// CWDMonitor::HandlecentrepL()

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

//

void CWDMonitor::HandlecentrepL( TUint32 aKey )

    {

    CRepository* wdrepo = CRepository::NewL( KWDrepoUidMenu );        

    if ( KHarvesterServerKey == aKey )

        {

        // get the harvester server status

        wdrepo->Get( KHarvesterServerKey , iAllowHS );

        if ( iAllowHS )

            {

            //start the Harvester server and start monitoring            

            iHarvesterMonitor = CServerMonitor::NewL( *iHSName , iHSUid );

            }

        else{

            // Shutdown the harvester server

            iHarvesterMonitor->Cancel();

            iHarvesterMonitor->ShutdownServer();                        

            delete iHarvesterMonitor;

            iHarvesterMonitor = NULL;

            }

        }

    else if ( KSearchServerKey == aKey )

        {

        // get the Search server status

        wdrepo->Get( KSearchServerKey , iAllowSS );

        if ( iAllowSS )

            {

            //Start the Search server and start monitoring

            iSearchMonitor = CServerMonitor::NewL( *iSSName , iSSUid );

            }

        else

            {

            //Shutdown the searchserver

            iSearchMonitor->Cancel();

            iSearchMonitor->ShutdownServer();                        

            delete iSearchMonitor;

            iSearchMonitor = NULL;

            }

        }

    else if ( (KHarvesterServerUIDKey == aKey)||( KHarvesterServerNAMEKey == aKey ) )

        {

        // Shutdown the existing server

        iHarvesterMonitor->Cancel();

        iHarvesterMonitor->ShutdownServer();                        

        delete iHarvesterMonitor;

        iHarvesterMonitor = NULL;

        //read the new values

        TBuf<KCenrepUidLength> temp;

        TInt64 value;

        TLex uidvalue;

        if ( KHarvesterServerUIDKey == aKey )

            {            

            //Read Harvester server UId value

            if ( KErrNone == wdrepo->Get( KHarvesterServerUIDKey, temp ) )

                {

                uidvalue.Assign(temp);        

                if (KErrNone == uidvalue.Val( value,EHex ))

                    iHSUid.iUid = value;

                }

            }

        else

            {

            //read harvester server name

            delete iHSName;

            if ( KErrNone == wdrepo->Get( KHarvesterServerNAMEKey, temp ))

                {

                iHSName = HBufC::NewL( temp.Length() );

                TPtr hsname = iHSName->Des();

                hsname.Copy( temp );

                }

            }        

        // Start the server with new values

        iHarvesterMonitor = CServerMonitor::NewL( *iHSName , iHSUid );

        }

    else if ( (KSearchServerUIDKey == aKey)||( KSearchServerNAMEKey == aKey ) )

        {

        // Shutdown the existing server

        iSearchMonitor->Cancel();

        iSearchMonitor->ShutdownServer();                        

        delete iSearchMonitor;

        iSearchMonitor = NULL;

        //read the new values

        TBuf<KCenrepUidLength> temp;

        TInt64 value;

        TLex uidvalue;

        if ( KSearchServerUIDKey == aKey )

            {

            //read search server uid

            if ( KErrNone == wdrepo->Get( KSearchServerUIDKey, temp ) )

                {

                uidvalue.Assign(temp);        

                if (KErrNone == uidvalue.Val( value,EHex ))

                    iSSUid.iUid = value;

                }

            }

        else

            {

            //read search server name

            delete iSSName;

            if ( KErrNone == wdrepo->Get( KSearchServerNAMEKey, temp ))

                {

                iSSName = HBufC::NewL( temp.Length() );

                TPtr ssname = iSSName->Des();

                ssname.Copy( temp );

                }

            }        

        // Start the server with new values

        iSearchMonitor = CServerMonitor::NewL( *iSSName , iSSUid );

        }

    delete wdrepo;

    }

//End of file