/*
* Copyright (c) 2007 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:  Client session retry implementation
*
*/

#include "mpxsessionretry.h"


enum { EFunctionType_SendReceive1, EFunctionType_SendReceive2};

// ============================== LOCAL FUNCTIONS =============================

// ----------------------------------------------------------------------------
// Start server process
// ----------------------------------------------------------------------------
//
LOCAL_C TInt StartServer(const TDesC& aImage)
    {
    RProcess server;
    
    TInt r = server.Create(aImage,KNullDesC);
    if (r != KErrNone)
        {
        return r;
        }
    
    TRequestStatus s;
    server.Rendezvous(s);
    if (s != KRequestPending)
        {
        server.Kill(0);
        }
    else
        {
        server.Resume();
        }
    
    User::WaitForRequest(s);    
    
    r = (server.ExitType()==EExitPanic) ? KErrGeneral : s.Int();
    server.Close();
    
    return r;
    }

// ============================== MEMBER FUNCTIONS ============================

// ----------------------------------------------------------------------------
// Return the version info
// ----------------------------------------------------------------------------
//
TVersion RMPXSessionRetry::Version() const
    { 
    return iVersion;
    }

// ----------------------------------------------------------------------------
// Connect to server
// ----------------------------------------------------------------------------
//
TInt RMPXSessionRetry::Connect(const TDesC& aServer, 
                               const TDesC& aImage, 
                               const TVersion& aVersion)
    {
    iVersion = aVersion;
    iServer = aServer;
    iImage = aImage;
        
    TInt r = RSessionBase::CreateSession(iServer, iVersion, 2);
    
    if (r == KErrNotFound || r == KErrServerTerminated)
        {
        r = Reconnect();
        }

    return r;
    }

// ----------------------------------------------------------------------------
// Reconnect to server
// ----------------------------------------------------------------------------
//
TInt RMPXSessionRetry::Reconnect()
    {
    // make sure the current session is closed; it does no harm to close
    // a session that is already closed
    Close();
    
    TInt r = StartServer(iImage);
        
    if (r == KErrNone || r == KErrAlreadyExists)
        {
        r = RSessionBase::CreateSession(iServer, iVersion, 2);
        }
    
    return r;
    }

// -----------------------------------------------------------------------------
// Send a message
// -----------------------------------------------------------------------------
//
TInt RMPXSessionRetry::SendReceiveL(TInt aFunction)
    {
    TInt retVal = RSessionBase::SendReceive(aFunction);
    
    if (KErrServerTerminated == retVal) 
        {        
        Reconnect(); // try again in case IAD took down the server to replace it
        retVal = RSessionBase::SendReceive(aFunction);
        }
    
    return User::LeaveIfError(retVal);
    }

// -----------------------------------------------------------------------------
// Send a message
// -----------------------------------------------------------------------------
//
TInt RMPXSessionRetry::SendReceiveL(TInt aFunction, const TIpcArgs& aArgs)
    {
    TInt retVal = RSessionBase::SendReceive(aFunction,aArgs);
    
    if (KErrServerTerminated == retVal) 
        {
        Reconnect(); // try again in case IAD took down the server to replace it
        retVal = RSessionBase::SendReceive(aFunction,aArgs);
        }    
    
    return User::LeaveIfError(retVal);
    }

// -----------------------------------------------------------------------------
// Send a message
// -----------------------------------------------------------------------------
//
void RMPXSessionRetry::SendReceive(TInt aFunction, 
                                   TRequestStatus& aStatus)
    {
    RSessionBase::SendReceive(aFunction, aStatus);
    }

// -----------------------------------------------------------------------------
// Send a message
// -----------------------------------------------------------------------------
//
void RMPXSessionRetry::SendReceive(TInt aFunction, 
                                   const TIpcArgs& aArgs,
                                   TRequestStatus& aStatus)
    {
    RSessionBase::SendReceive(aFunction, aArgs, aStatus);
    }