/*

* Copyright (c) 2002 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: Provides methods for client session implementation of calendar server. 

 *

*/

//debug

#include "calendarui_debug.h"

#include "CalSvrClient.h"

#include "CalSvrInitializer.h"

#include "CalSvrDef.h"

#include "CalServerSignaller.h"

#include <e32base.h>

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

// ?classname::?member_function

// ?implementation_description

// (other items were commented in a header).

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

//

static TInt StartCalendarServer()

    {

    TRACE_ENTRY_POINT;

    TRequestStatus started;

    TCalServerStart start( started );

    const TUidType serverUid( KNullUid, KNullUid, KNullUid );

    //

    // EPOC is easy, we just create a new server process. Simultaneous

    // launching of two such processes should be detected when the

    // second one attempts to create the server object, failing with

    // KErrAlreadyExists.

    //

    RProcess server;

    const TInt ret=server.Create( KCalSvrServerExe, start.AsCommand(), serverUid );

    // Did we manage to create the thread/process?

    if(ret != KErrNone)

        {

        TRACE_EXIT_POINT;

        return ret;

        }

    // Wait to see if the thread/process died during construction

    TRequestStatus serverDiedRequestStatus;

    server.Rendezvous(serverDiedRequestStatus);

    // do we have to abort?

    if(serverDiedRequestStatus != KRequestPending)

        {

        server.Kill(0); // abort the sartup here

        }

    else

        {

        server.Resume(); // start server

        }

    User::WaitForRequest(serverDiedRequestStatus);

    // determine the reason for the server exit

    const TInt exitReason =(server.ExitType()==EExitPanic) ? KErrGeneral : serverDiedRequestStatus.Int();

    server.Close();

    TRACE_EXIT_POINT;

    return exitReason;

    }

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

// ?classname::?member_function

// ?implementation_description

// (other items were commented in a header).

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

//

EXPORT_C RCalSvrSession::RCalSvrSession()

:RSessionBase(), iListenerCallback(NULL), iInitializer(NULL)

    {

    TRACE_ENTRY_POINT;

    TRACE_EXIT_POINT;

    }

// open/close

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

// ?classname::?member_function

// ?implementation_description

// (other items were commented in a header).

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

//

EXPORT_C void RCalSvrSession::ConnectL()

    {

    TRACE_ENTRY_POINT;

    // connect to server

    TInt err( KErrNone );

    for( TInt tries(0); tries < 2; tries++ )

        {

        err = CreateSession( KCalendarServerName, TVersion(0,0,0) );

        if( !err )

            {

            // connected to existing server - ok

            break;

            }

        if( err != KErrNotFound && err != KErrServerTerminated )

            {

            // problems other than server not here - propagate error

            break;

            }

        err = StartCalendarServer();

        if( !err || (err==KErrAlreadyExists) )

            {

            // if server launched ok, try again to connect 

            // OR

            // if someone else got there first, try again to connect

            continue;

            }

        break; // server not launched: don't cycle round again

        }

    User::LeaveIfError( err );

    CleanupClosePushL( *this ); // Close if next operation leaves

    iInitializer = new( ELeave )CCalSvrInitializer( *this );

    CleanupStack::Pop( this );

    TRACE_EXIT_POINT;

    }

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

// ?classname::?member_function

// ?implementation_description

// (other items were commented in a header).

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

//

EXPORT_C void RCalSvrSession::Close()

    {

    TRACE_ENTRY_POINT;

    delete iInitializer;

    iInitializer = NULL;

    RSessionBase::Close();

    TRACE_EXIT_POINT;

    }

///////////////////////////////

// These are high-level client interface functions

///////////////////////////////

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

// ?classname::?member_function

// ?implementation_description

// (other items were commented in a header).

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

//

EXPORT_C void RCalSvrSession::Initialize(MCalSvrAgendaUpdateListener& aListener)

    {

    TRACE_ENTRY_POINT;

    //__ASSERT_ALWAYS(!iInitializer->IsActive(), User::Invariant());

    if(!(iInitializer->IsActive()) && (KRequestPending != iInitializer->iStatus.Int()))

        {

        iInitializer->Initialize(&aListener);

        }

    TRACE_EXIT_POINT;

    }

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

// ?classname::?member_function

// ?implementation_description

// (other items were commented in a header).

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

//

EXPORT_C void RCalSvrSession::StopInitialization()

    {

    TRACE_ENTRY_POINT;

    iInitializer->Cancel();

    TRACE_EXIT_POINT;

    }

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

// ?classname::?member_function

// ?implementation_description

// (other items were commented in a header).

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

//

EXPORT_C void RCalSvrSession::Uninitialize()

    {

    TRACE_ENTRY_POINT;

    if(iInitializer->IsActive())

        {

        iInitializer->Cancel();

        }

    SendReceive(ECalSvrUninitialize, TIpcArgs());

    TRACE_EXIT_POINT;

    }

///////////////////////////////

// These are low-level functions talking to server

//////////////////////////////

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

// ?classname::?member_function

// ?implementation_description

// (other items were commented in a header).

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

//

void RCalSvrSession::Initialize(TRequestStatus& aStatus)

    {

    TRACE_ENTRY_POINT;

    SendReceive(ECalSvrInitialize, TIpcArgs(), aStatus);

    TRACE_EXIT_POINT;

    }

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

// ?classname::?member_function

// ?implementation_description

// (other items were commented in a header).

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

//

void RCalSvrSession::CancelInitialize()

    {

    TRACE_ENTRY_POINT;

    SendReceive(ECalSvrCancelInitialize, TIpcArgs());

    TRACE_EXIT_POINT;

    }

// End of File