diff -r 839377eedc2b -r befca0ec475f videofeeds/clientapi/src/CIptvClientBase.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/videofeeds/clientapi/src/CIptvClientBase.cpp	Wed Sep 01 12:30:28 2010 +0100
@@ -0,0 +1,265 @@
+/*
+* Copyright (c) 2006 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of the License "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:    Base class for iptv engine client classes.*
+*/
+
+
+
+
+#include "MIptvStreamObject.h"
+#include "IptvDebug.h"
+
+#include "CIptvClientBase.h"
+#include "CIptvMyVideosGlobalFileId.h"
+
+const TInt KTUint16SizeInBytes( 2 );
+
+// ======== MEMBER FUNCTIONS ========
+
+// ---------------------------------------------------------------------------
+// C++ default constructor can NOT contain any code, that
+// might leave.
+// ---------------------------------------------------------------------------
+//
+CIptvClientBase::CIptvClientBase()
+: CActive( EPriorityStandard )
+    {
+    }
+
+// Destructor
+CIptvClientBase::~CIptvClientBase()
+    {
+    IPTVLOGSTRING_LOW_LEVEL("CIptvClientBase::~CIptvClientBase()");
+
+    iSession.Close();
+    Cancel();
+    IPTVLOGSTRING_LOW_LEVEL("CIptvClientBase::~CIptvClientBase() exit");
+    }
+
+// ---------------------------------------------------------------------------
+// CIptvClientBase::RunL
+// Two-phased constructor.
+// ---------------------------------------------------------------------------
+//
+void CIptvClientBase::RunL()
+    {
+    }
+
+// ---------------------------------------------------------------------------
+// CIptvClientBase::DoCancel
+// Two-phased constructor.
+// ---------------------------------------------------------------------------
+//
+void CIptvClientBase::DoCancel()
+    {
+    }
+
+// ---------------------------------------------------------------------------
+// CIptvClientBase::SendRequestL
+// ---------------------------------------------------------------------------
+//
+TInt CIptvClientBase::SendRequestL(
+    TUint16 aMsgId,
+    MIptvStreamObject& aReqStreamObject,
+    MIptvStreamObject& aRespStreamObject,
+    TInt aIpcMsgSize )
+    {
+    IPTVLOGSTRING_LOW_LEVEL("CIptvClientBase::SendRequestL()");
+
+    TInt size;
+    HBufC8* ipcMsgInHeap = NULL;
+    const TInt KMaxInStack = 100;
+    TUint8 ipcMsgInStack[KMaxInStack];
+    TPtr8 ipcMsgPtr((TUint8 *)0, 0, 0);
+
+    if(aIpcMsgSize == 0)
+        {
+        size = aReqStreamObject.CountExternalizeSize();
+        }
+    else
+        {
+        size = aIpcMsgSize;
+        }
+
+    if(size < KMaxInStack)
+        {
+        IPTVLOGSTRING2_LOW_LEVEL(
+            "CIptvClientBase:: size < %d -> using stack object",
+            KMaxInStack);
+        ipcMsgPtr.Set(
+            ipcMsgInStack,
+            0 /* length */,
+            KMaxInStack /* max length */ );
+        }
+    else
+        {
+        IPTVLOGSTRING2_LOW_LEVEL(
+            "CIptvClientBase:: size >= %d -> using heap object",
+            KMaxInStack);
+
+        ipcMsgInHeap = HBufC8::NewL(size);
+        CleanupStack::PushL(ipcMsgInHeap); //1->
+        ipcMsgPtr.Set(ipcMsgInHeap->Des());
+        }
+
+    RDesWriteStream writeStream;
+    CleanupClosePushL( writeStream );
+    //initialize stream object to use ipc msg as a data buffer
+    writeStream.Open(ipcMsgPtr);
+    aReqStreamObject.ExternalizeL(writeStream); //write object to the stream
+    CleanupStack::PopAndDestroy( &writeStream );
+
+    TInt result = iSession.SendRequest(aMsgId, ipcMsgPtr);
+
+    if(result == KErrNone)
+        {
+        RDesReadStream readStream;
+        readStream.Open(ipcMsgPtr);
+        CleanupClosePushL( readStream );
+        aRespStreamObject.InternalizeL(readStream); //read object from stream
+        CleanupStack::PopAndDestroy( &readStream );
+        }
+    else
+        {
+        IPTVLOGSTRING2_LOW_LEVEL(
+            "CIptvClientBase:: error in SendRequest: %d",
+            result);
+        }
+
+    if(ipcMsgInHeap)
+        {
+        CleanupStack::PopAndDestroy(ipcMsgInHeap); //<-1
+        }
+
+    IPTVLOGSTRING_LOW_LEVEL("CIptvClientBase::SendRequestL() exit");
+    return result;
+    }
+
+// ---------------------------------------------------------------------------
+// CIptvClientBase::SendRequestL
+// ---------------------------------------------------------------------------
+//
+TInt CIptvClientBase::SendRequestL(
+    TUint16 aMsgId,
+    MIptvStreamObject& aRespStreamObject,
+    TInt aIpcMsgSize )
+    {
+    TInt result;
+    const TInt KMaxSizeInStack = 100;
+
+    if(aIpcMsgSize < KMaxSizeInStack)
+        {
+        //use ipc msg from stack
+        IPTVLOGSTRING2_LOW_LEVEL(
+            "CIptvClientBase:: size < %d -> using stack object",
+            KMaxSizeInStack);
+        TBuf8<KMaxSizeInStack> ipcMsgInStack;
+
+        result = iSession.SendRequest(aMsgId, ipcMsgInStack);
+
+        if(result == KErrNone)
+            {
+            RDesReadStream readStream;
+            readStream.Open(ipcMsgInStack);
+            CleanupClosePushL( readStream );
+            aRespStreamObject.InternalizeL(readStream); //read object from the stream
+            CleanupStack::PopAndDestroy( &readStream );
+            }
+        }
+    else
+        {
+        //allocate a new IPC message from heap
+        IPTVLOGSTRING2_LOW_LEVEL(
+            "CIptvClientBase:: size >= %d -> using heap object",
+            KMaxSizeInStack );
+
+        HBufC8* ipcMsgInHeap = HBufC8::NewL(aIpcMsgSize);
+        CleanupStack::PushL(ipcMsgInHeap); // 1->
+        TPtr8 ipcMsgPtr(ipcMsgInHeap->Des());
+
+        result = iSession.SendRequest(aMsgId, ipcMsgPtr);
+
+        if(result == KErrNone)
+            {
+            RDesReadStream readStream;
+            readStream.Open(ipcMsgPtr);
+            CleanupClosePushL( readStream );
+            aRespStreamObject.InternalizeL(readStream); //read object from the stream
+            CleanupStack::PopAndDestroy( &readStream );
+            }
+        CleanupStack::PopAndDestroy(ipcMsgInHeap); // <-1
+        }
+
+    return result;
+    }
+
+// ---------------------------------------------------------------------------
+// CIptvClientBase::SendRequestL
+// ---------------------------------------------------------------------------
+//
+TInt CIptvClientBase::SendRequestL(
+    TUint16 aMsgId,
+    MIptvStreamObject& aReqStreamObject )
+    {
+    HBufC8* ipcMsg = HBufC8::NewL( aReqStreamObject.CountExternalizeSize() );
+    CleanupStack::PushL(ipcMsg); // 1->
+
+    TPtr8 ipcMsgPtr(ipcMsg->Des());
+    ipcMsgPtr.Zero();
+
+    RDesWriteStream writeStream;
+    writeStream.Open(ipcMsgPtr);
+    CleanupClosePushL( writeStream );
+    aReqStreamObject.ExternalizeL(writeStream); //write object to the stream
+    CleanupStack::PopAndDestroy( &writeStream );
+
+    TInt err = iSession.SendRequest(aMsgId, ipcMsgPtr);
+    CleanupStack::PopAndDestroy(ipcMsg); // <-1
+    return err;
+    }
+
+// ---------------------------------------------------------------------------
+// CIptvMyVideosClient::SendRequestL
+// ---------------------------------------------------------------------------
+//
+TInt CIptvClientBase::SendRequestL(
+    TInt aMessage,
+    const TDesC& aMsg )
+    {
+    IPTVLOGSTRING_LOW_LEVEL(
+        "My Videos Mgr ## CIptvMyVideosClient::SendRequestL" );
+
+    TUint32 dataSize(
+        KTUint16SizeInBytes + aMsg.Size() );
+
+    HBufC8* ipcMsg = HBufC8::NewL( dataSize );
+    CleanupStack::PushL( ipcMsg ); // 1->
+
+    TPtr8 ipcMsgPtr( ipcMsg->Des() );
+    ipcMsgPtr.Zero();
+
+    RDesWriteStream stream;
+    stream.Open( ipcMsgPtr );
+    CleanupClosePushL( stream );
+    CIptvUtil::WriteDesToStreamL( aMsg, stream );
+    CleanupStack::PopAndDestroy( &stream );
+
+    TRequestStatus status;
+    iSession.SendRequest( aMessage, ipcMsgPtr, status );
+    User::WaitForRequest( status );
+
+    CleanupStack::PopAndDestroy( ipcMsg ); // <-1
+
+    return status.Int();
+    }