/** @file

 * Copyright (c) 2005-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:  Defines RUpnpDispatcherSession class

 *

 */

// INCLUDE FILES

#include <e32math.h>

#include "upnpmhcommon.h"

#include "upnpdispatchersession.h"

#ifdef _DEBUG

#define KLogFile _L("UPnPStack.txt")

#endif

#include "upnpcustomlog.h"

// Number of message slots to reserve for this client server session.

#if defined(__HN_31__) || defined(__HN_32__)

const TUid KServerUid3 =

    {0x2000F881};

#else

const TUid KServerUid3 =

    {0x10005BCD};

#endif

#ifdef __WINS__

static const TUint KServerMinHeapSize = 0x100000; //  4K

static const TUint KServerMaxHeapSize = 0x1000000; // 16M

#endif

const TInt KServerMessageSlots = 10; //Number of message slots available per session.

const TInt KServerRetryCount = 2;

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

// RUpnpDispatcherSession::RUpnpDispatcherSession

// C++ default constructor can NOT contain any code, that

// might leave.

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

//

RUpnpDispatcherSession::RUpnpDispatcherSession() :

    RUpnpSessionBase(), iParameter0( NULL, 0, 0 )

    {

    // No implementation required

    }

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

// RUpnpDispatcherSession::Connect

// Establish connection to server.

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

//

TInt RUpnpDispatcherSession::Connect()

    {

    return RUpnpSessionBase::Connect( KMessageHandlerName, TVersion(

        KMessageHandlerMajorVersionNumber, KMessageHandlerMinorVersionNumber,

        KMessageHandlerBuildVersionNumber ), KServerMessageSlots,

        KServerRetryCount, KMessageHandlerFilename, KServerUid3 );

    }

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

// RUpnpDispatcherSession::RequestAddLocalDevice

// Client requests server to add local device.

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

//

void RUpnpDispatcherSession::RequestAddLocalDevice( TRequestStatus& aStatus,

    TUpnpAddLocalDevice& aDevice, TPtr8& aBuffer )

    {

    LOG_FUNC_NAME;

    iParameter0.Set( reinterpret_cast<TUint8*>( &aDevice ), sizeof(aDevice ),

        sizeof(aDevice ) );

    SendReceive( EAddLocalDevice, TIpcArgs( &iParameter0, &aBuffer ), aStatus );

    }

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

// RUpnpDispatcherSession::RequestRemoveLocalDevice

// Client requests server to remove local device.

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

//

void RUpnpDispatcherSession::RequestRemoveLocalDevice(

    TRequestStatus& aStatus, const TDesC8& aUuid )

    {

    LOG_FUNC_NAME;

    iParameter0.Set( (TUint8*)aUuid.Ptr( ), aUuid.Size( ), aUuid.Size( ) );

    SendReceive( ERemoveLocalDevice, TIpcArgs( &iParameter0 ), aStatus );

    }

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

// RUpnpDispatcherSession::RequestRemoveSilentLocalDevice

// Client requests server to remove local device.

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

//

void RUpnpDispatcherSession::RequestRemoveSilentLocalDevice(

    TRequestStatus& aStatus, const TDesC8& aUuid )

    {

    LOG_FUNC_NAME;

    iParameter0.Set( (TUint8*)aUuid.Ptr( ), aUuid.Size( ), aUuid.Size( ) );

    TIpcArgs ipcArgs;

    ipcArgs.Set( 0, &iParameter0 );

    SendReceive( ERemoveSilentLocalDevice, ipcArgs, aStatus );

    LOGS("RUpnpDispatcherSession::RequestRemoveSilentLocalDevice passed");

    }

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

// RUpnpDispatcherSession::RequestAddControlPoint

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

//

void RUpnpDispatcherSession::RequestAddControlPoint( TRequestStatus& aStatus )

    {

    SendReceive( EAddControlPointClient, aStatus );

    }

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

// RUpnpDispatcherSession::RequestRemoveControlPoint

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

//

void RUpnpDispatcherSession::RequestRemoveControlPoint(

    TRequestStatus& aStatus )

    {

    SendReceive( ERemoveControlPointClient, aStatus );

    }

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

// RUpnpDispatcherSession::RequestStopFiltering

//

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

//

void RUpnpDispatcherSession::RequestStopFiltering( const TDesC8& aUuids )

    {

    //  Retruned error is ignored

    SendReceive( EStopFilteringDevice, TIpcArgs( &aUuids ) );

    }

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

// RUpnpDispatcherSession::RequestGetDeviceListSize

// Client requests server to get device list size.

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

//

void RUpnpDispatcherSession::RequestGetDeviceListSize(

    TRequestStatus& aStatus, TUpnpGetDeviceListSize& aSize )

    {

    iParameter0.Set( reinterpret_cast<TUint8*>(&aSize), sizeof(aSize ),

        sizeof(aSize ) );

    aStatus = KRequestPending;

    SendReceive( EGetDeviceListSize, TIpcArgs( &iParameter0 ), aStatus );

    }

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

// RUpnpDispatcherSession::RequestGetDeviceList

// Client requests server to get device list.

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

//

void RUpnpDispatcherSession::RequestGetDeviceList( TRequestStatus& aStatus,

    TPtr8& devPtr, TPtr8& servPtr ) const

    {

    LOG_FUNC_NAME;

    SendReceive( EGetDeviceList, TIpcArgs( &devPtr, &servPtr ), aStatus );

    }

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

// RUpnpDispatcherSession::RequestSsdpSearch

// Client requests server to start SSDP search.

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

//

void RUpnpDispatcherSession::RequestSsdpSearch( TRequestStatus& aStatus,

    TDesC8& aSearch, TDesC8& aMX )

    {

    LOG_FUNC_NAME;

    SendReceive( ESsdpSearch, TIpcArgs( &aSearch, &aMX ), aStatus );

    }

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

// RUpnpDispatcherSession::RequestActiveIap

// Client requests server active IAP.

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

//

void RUpnpDispatcherSession::RequestActiveIap( TRequestStatus& aStatus,

    TInt& aIap )

    {

    LOG_FUNC_NAME;

    iParameter0.Set( reinterpret_cast<TUint8*>( &aIap ), sizeof(TInt),

        sizeof(TInt) );

    SendReceive( EActiveIap, TIpcArgs( &iParameter0 ), aStatus );

    }

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

// RUpnpDispatcherSession::RequestStartSsdp

// Client requests server to start SSDP.

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

//

void RUpnpDispatcherSession::RequestStartSsdpL() const

    {

    LOG_FUNC_NAME;

    User::LeaveIfError( SendReceive( EStartSsdp, TIpcArgs() ) );

    }

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

// RUpnpDispatcherSession::RequestCheckError

// 

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

//

void RUpnpDispatcherSession::RequestCheckError( TInt& aError )

    {

    TPckgBuf<TInt> pckgTInt;

    TIpcArgs ipcArgs;

    pckgTInt = aError;

    ipcArgs.Set( 0, &pckgTInt );

    SendReceive( ECheckError, ipcArgs );

    aError = pckgTInt( );

    }

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

// RUpnpDispatcherSession::RequestStop

// Client requests server to cancel.

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

//

void RUpnpDispatcherSession::RequestStop()

    {

    LOG_FUNC_NAME;

    TInt err = SendReceive( ECancelRequest, TIpcArgs( ) );

    if ( err != KErrNone )

        {

        LOGS("RUpnpDispatcherSession::RequestStop - Request for RMessage Cancel Failed");

        }

    }

//  End of File