--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/upnp/upnpstack/serviceframework/src/upnpdispatchersession.cpp	Tue Feb 02 01:12:20 2010 +0200
@@ -0,0 +1,239 @@
+/** @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