/*

* 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:    Class that takes packet from buffer and does not put them*

*/

// INCLUDE FILES

#include "CCRNullSink.h"

#include "CCRPacketBuffer.h"

#include "CCRStreamingSession.h"

#include "CCRTimer.h"

#include "MCRConnectionObserver.h"

#include "videoserviceutilsLogger.h"

// CONSTANTS

// None

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

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

// CCRNullSink::NewL

// Two-phased constructor.

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

//  

CCRNullSink* CCRNullSink::NewL(

    CCRStreamingSession::TCRSinkId aSinkId,

    CCRStreamingSession& aOwningSession )

    {

    CCRNullSink* self = new( ELeave ) CCRNullSink( aSinkId, aOwningSession );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

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

// CCRNullSink::CCRNullSink

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

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

//  

CCRNullSink::CCRNullSink(

    CCRStreamingSession::TCRSinkId aSinkId,

    CCRStreamingSession& aOwningSession )

  : CCRPacketSinkBase( aOwningSession, aSinkId )

    {

    // None

    }

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

// CCRNullSink::ConstructL

// 2nd phase. 

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

//  

void CCRNullSink::ConstructL()

    {

    // None

    }

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

// CCRNullSink::~CCRNullSink

// Destructor.

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

//

CCRNullSink::~CCRNullSink()

    {    

    delete iSdp; 

    delete iFlowTimer;

    iBuffer = NULL; // does not delete and it is right thing.   

    }

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

// CCRNullSink::SetSdpL

// as a side-effect causes parsing of the sdp.

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

//  

void CCRNullSink::SetSdpL( const TDesC8& aSdp )

    {

    LOG1( "CCRNullSink::SetSdpL(), aSdp len: %d", aSdp.Length() );

    delete iSdp; iSdp = NULL; 

    iSdp = aSdp.AllocL();

    iOwningSession.PlayCommand( KRealZero, KRealMinusOne );

    }

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

// CCRNullSink::NewPacketAvailable

//

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

//      

void CCRNullSink::NewPacketAvailable()

    {

    if ( iBuffer )

        {

        TPtr8 packet( NULL, 0 );

        MCRPacketSource::TCRPacketStreamId streamId;

        const TInt book( iBuffer->GetStream( iSinkId, streamId ) );

        iBuffer->GetPacket( book, packet ); 

        const TUint8* pointer( &packet[2] );

        TInt seq( BigEndian::Get16( pointer ) );

        LOG2( "CCRNullSink::NewPacketAvailable(), streamId: %u, seq: %u", 

                                                  streamId, seq );

        // Keep buffer size reasonable

        iBuffer->HandleBufferSize();

        // Handle flow control

        if ( !iBuffer->ContinousStream() && !iFlowTimer )

            {

            TRAPD( err, iFlowTimer = CCRTimer::NewL( CActive::EPriorityLow, *this ) );

            if ( !err )

                {

                if ( iBuffer->PacketsCount( iSinkId ) > KErrNotFound )

                    {

                    iFlowTimer->After( 0 );

                    }

                else

                    {

                    iFlowTimer->At( 2e6 );

                    }

                }

            else

                {

                delete iFlowTimer; iFlowTimer = NULL;

                }

            }

        }

    }

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

// CCRNullSink::TimerExpired

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

//

void CCRNullSink::TimerExpired( CCRTimer* /*aTimer*/ )

    {

    if ( iBuffer->PacketsCount( iSinkId ) > KErrNotFound )

        {

        NewPacketAvailable();

        }

    else

        {

        iOwningSession.SourceRestore();

        }

    delete iFlowTimer; iFlowTimer = NULL;

    }

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

// CCRNullSink::RegisterConnectionObs

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

//

void CCRNullSink::RegisterConnectionObs( MCRConnectionObserver* aObserver )

    {

    iObserver = aObserver;

    }

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

// CCRNullSink::StatusChanged

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

//

void CCRNullSink::StatusChanged( MCRPacketSource::TCRPacketSourceState aNewState )

    {

    if( iObserver )

        {

        TCRTestSinkData data = aNewState==MCRPacketSource::ERtpStateIdle ? ECRTestSinkStateIdle :

                               aNewState==MCRPacketSource::ERtpStateSdpAvailable ? ECRTestSinkStateSdpAvailable :

                               aNewState==MCRPacketSource::ERtpStateSeqAndTSAvailable ? ECRTestSinkStateSeqAndTSAvailable :

                               aNewState==MCRPacketSource::ERtpStatePlaying ? ECRTestSinkStatePlaying :

                               /*aNewState==MCRPacketSource::ERtpStateClosing?*/ ECRTestSinkStateClosing;

        LOG3( "CCRNullSink::StatusChanged: newState=%d -> ECRTestSinkData, checksum=%d, data=%d",

              (TInt)aNewState, (TInt)iOwningSession.SourceChecksum(), (TInt)data );

        iObserver->ConnectionStatusChange( iOwningSession.SourceChecksum(),

                                           MCRConnectionObserver::ECRTestSinkData,

                                           (TInt)data );

        }

    }

//  End of File