diff -r 826cea16efd9 -r 13a33d82ad98 dvrengine/CommonRecordingEngineClient/src/RCRService.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/dvrengine/CommonRecordingEngineClient/src/RCRService.cpp	Wed Sep 01 12:20:37 2010 +0100
@@ -0,0 +1,518 @@
+/*
+* 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 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:    Implementation of RC client's Service*
+*/
+
+
+
+
+// INCLUDE FILES
+#include "RCRService.h"
+#include <ipvideo/CRTypeDefs.h>
+#include <e32math.h>
+
+// CONSTANTS
+// None
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// RCRService::RCRService
+//
+// -----------------------------------------------------------------------------
+//
+RCRService::RCRService() : RCRServiceBase()
+    {
+    // None
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::SetIap
+// LiveTV specific.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::SetIap( const TSubConnectionUniqueId& aIapId )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        SCRRtspIapParams msg;
+        RProcess process;
+        TInt handleId( process.Handle() );
+        msg.iQueueName.Format( KCRMsgQueueName, handleId );
+        msg.iQueueName.Trim();
+        msg.iConnectionId = aIapId;
+
+        TPckgBuf<SCRRtspIapParams> pckg( msg );
+        TIpcArgs args( &pckg );
+        return SendReceive( ECRSetIap, args );
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::CancelSetIap
+// LiveTV specific.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::CancelSetIap()
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TIpcArgs args;
+        return SendReceive( ECRCancelSetIap, args );
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::PlayRtspUrl
+// LiveTV specific.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::PlayRtspUrl(
+    TUint& aSessionChk,
+    const SCRRtspParams& aRtspParams )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( 0 );
+        TPckgBuf<SCRRtspParams> pckg1( aRtspParams );
+        TIpcArgs args( &pckg0, &pckg1 );
+        TInt err( SendReceive( ECRPlayRtspUrl, args ) );
+        aSessionChk = pckg0();
+        return err;
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::PlayDvbhStream
+// DVB-H specific.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::PlayDvbhStream(
+    TUint& aSessionChk,
+    const SCRLiveParams& aLiveParams  )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( 0 );
+        TPckgBuf<SCRLiveParams> pckg1( aLiveParams );
+        TIpcArgs args( &pckg0, &pckg1 );
+        TInt err( SendReceive( ECRPlayDvbhLive, args ) );
+        aSessionChk = pckg0();
+        return err;
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::ChangeDvbhService
+// DVB-H specific.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::ChangeDvbhService(
+    TUint& aSessionChk,
+    const SCRLiveParams& aLiveParams  )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( aSessionChk );
+        TPckgBuf<SCRLiveParams> pckg1( aLiveParams );
+        TIpcArgs args( &pckg0, &pckg1 );
+        TInt err( SendReceive( ECRChangeService, args ) );
+        aSessionChk = pckg0();
+        return err;
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::PlayRtpFile
+// DVB-H specific.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::PlayRtpFile(
+    TUint& aSessionChk,
+    const SCRRtpPlayParams& aRtpFile  )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( 0 );
+        TPckgBuf<SCRRtpPlayParams> pckg1( aRtpFile );
+        TIpcArgs args( &pckg0, &pckg1 );
+        TInt err( SendReceive( ECRPlayRtpFile, args ) );
+        aSessionChk = pckg0();
+        return err;
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::PlayRtpFile
+// DVB-H specific.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::PlayRtpFile(
+    TUint& aSessionChk,
+    const RFile& aRtpHandle )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg( 0 );
+        TIpcArgs args( &pckg );
+        aRtpHandle.TransferToServer( args, 1, 2 );
+        TInt err( SendReceive( ECRPlayRtpHandle, args ) );
+        aSessionChk = pckg();
+        return err;
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::RecordCurrentStream
+// UI command.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::RecordCurrentStream(
+    const TUint aSessionChk,
+    const SCRRecordParams& aRecordParams )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( aSessionChk );
+        TPckgBuf<SCRRecordParams> pckg1( aRecordParams );
+        TIpcArgs args( &pckg0, &pckg1 );
+        return SendReceive( ECRRecordCurrentStream, args );
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::RecordRtspStream
+// UI command.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::RecordRtspStream(
+    TUint& aSessionChk,
+    const SCRRtspParams& aRtspUrl,
+    const SCRRecordParams& aRecordParams )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( 0 );
+        TPckgBuf<SCRRtspParams> pckg1( aRtspUrl );
+        TPckgBuf<SCRRecordParams> pckg2( aRecordParams );
+        TIpcArgs args( &pckg0, &pckg1, &pckg2 );
+        TInt err( SendReceive( ECRRecordRtspStream, args ) );
+        aSessionChk = pckg0();
+        return err;
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::RecordDvbhStream
+// UI command.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::RecordDvbhStream(
+    TUint& aSessionChk,
+    const SCRLiveParams& aLiveParams,
+    const SCRRecordParams& aRecordParams )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( 0 );
+        TPckgBuf<SCRLiveParams> pckg1( aLiveParams );
+        TPckgBuf<SCRRecordParams> pckg2( aRecordParams );
+        TIpcArgs args( &pckg0, &pckg1, &pckg2 );
+        TInt err( SendReceive( ECRRecordDvbhStream, args ) );
+        aSessionChk = pckg0();
+        return err;
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::PauseRecordStream
+// UI command.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::PauseRecordStream( const TUint aSessionChk, const TBool& aStart )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( aSessionChk );
+        TPckgBuf<TBool> pckg1( aStart );
+        TIpcArgs args( &pckg0, &pckg1 );
+        return SendReceive( ECRPauseRecordStream, args );
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::StopRecordStream
+// UI command.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::StopRecordStream( const TUint aSessionChk )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( aSessionChk );
+        TIpcArgs args( &pckg0 );
+        return SendReceive( ECRStopRecordStream, args );
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::StartTimeShift
+// UI command.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::StartTimeShift(
+    TUint& aTimeShiftChk,
+    const TUint aCurrentChk )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( 0 );
+        TPckgBuf<TUint> pckg1( aCurrentChk );
+        TIpcArgs args( &pckg0, &pckg1 );
+        TInt err( SendReceive( ECRStartTimeShift, args ) );
+        aTimeShiftChk = pckg0();
+        return err;
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::StopTimeShift
+// UI command.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::StopTimeShift( 
+    const TUint aTimeShiftChk,
+    const TUint aCurrentChk )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( aTimeShiftChk );
+        TPckgBuf<TUint> pckg1( aCurrentChk );
+        TIpcArgs args( &pckg0, &pckg1 );
+        return SendReceive( ECRStopTimeShift, args );
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::PlayCommand
+// Player command.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::PlayCommand(
+    const TUint aSessionChk,
+    const TReal& aStartPos,
+    const TReal& aEndPos )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( aSessionChk );
+        TPckgBuf<TInt64> pckg1( aStartPos );
+        TPckgBuf<TInt64> pckg2( aEndPos );
+        TIpcArgs args( &pckg0, &pckg1, &pckg2 );
+        return SendReceive( ECRPlayCommand, args );
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::PauseCommand
+// Player command.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::PauseCommand( const TUint aSessionChk )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( aSessionChk );
+        TIpcArgs args( &pckg0 );
+        return SendReceive( ECRPauseCommand, args );
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::StopCommand
+// Player command.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::StopCommand( const TUint aSessionChk )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( aSessionChk );
+        TIpcArgs args( &pckg0 );
+        return SendReceive( ECRStopCommand, args );
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::SetPosition
+// Sets position of packet source.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::SetPosition(
+    const TUint aSessionChk,
+    const TInt64 aPosition )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( aSessionChk );
+        TPckgBuf<TInt64> pckg1( aPosition );
+
+        TIpcArgs args( &pckg0, &pckg1 );
+        return SendReceive( ECRSetPosition, args );
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::GetPosition
+// Gets position of packet source.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::GetPosition(
+    const TUint aSessionChk,
+    TInt64& aPosition,
+    TInt64& aDuration )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( aSessionChk );
+        TPckgBuf<TInt64> pckg1( aPosition );
+        TPckgBuf<TInt64> pckg2( 0 );
+
+        TIpcArgs args( &pckg0, &pckg1, &pckg2 );
+        TInt err( SendReceive( ECRGetPosition, args ) );
+        aPosition = pckg1();
+        aDuration = pckg2();
+        return err;
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::CloseSession
+// Player command.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::CloseSession( const TUint aSessionChk )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( aSessionChk );
+        TIpcArgs args( &pckg0 );
+        return SendReceive( ECRCloseSession, args );
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::PlayNullSource
+// Debug purposes.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::PlayNullSource( TUint& aSessionChk )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( 0 );
+        TIpcArgs args( &pckg0 );
+        TInt err( SendReceive( ECRPlayNullSource, args ) );
+        aSessionChk = pckg0();
+        return err;
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRService::PlayRtspUrlToNullSink
+// Debug purposes.
+// -----------------------------------------------------------------------------
+//
+TInt RCRService::PlayRtspUrlToNullSink(
+    TUint& aSessionChk,
+    const SCRRtspParams& aRtspParams  )
+    {
+    __ASSERT_ALWAYS( &( SessionHandle() ), PanicClient( KErrBadHandle ) );
+    if ( SubSessionHandle() )
+        {
+        TPckgBuf<TUint> pckg0( 0 );
+        TPckgBuf<SCRRtspParams> pckg1( aRtspParams );
+        TIpcArgs args( &pckg0, &pckg1 );
+        TInt err( SendReceive( ECRPlayRtspUrlToNullSink, args ) );
+        aSessionChk = pckg0();
+        return err;
+        }
+    
+    return KErrServerTerminated;
+    }
+
+// End of File