diff -r 826cea16efd9 -r 13a33d82ad98 dvrengine/CommonRecordingEngine/src/CCRPunchPacketSender.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/dvrengine/CommonRecordingEngine/src/CCRPunchPacketSender.cpp	Wed Sep 01 12:20:37 2010 +0100
@@ -0,0 +1,212 @@
+/*
+* 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:    Firewall/nat box puncher*
+*/
+
+
+
+
+// INCLUDE FILES
+#include "CCRPunchPacketSender.h"
+#include "CCRRtspPacketSource.h"
+#include "videoserviceutilsLogger.h"
+
+// CONSTANTS
+// None.
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// CCRPunchPacketSender::NewL
+// Two-phased constructor.
+// -----------------------------------------------------------------------------
+//
+CCRPunchPacketSender* CCRPunchPacketSender::NewL(
+    RConnection& aConnection, 
+    RSocketServ& aSockServer,
+    TInetAddr& aFromAddr, 
+    TInetAddr& aRemoteAddr , 
+    TUint32 aMySSRC,
+    CCRRtspPacketSource& aOwner )
+    {
+    CCRPunchPacketSender* self = new( ELeave ) CCRPunchPacketSender(
+        aConnection, aSockServer, aFromAddr, aRemoteAddr, aMySSRC, aOwner );
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    CleanupStack::Pop( self );
+    return self;
+    }
+
+// -----------------------------------------------------------------------------
+// CCRPunchPacketSender::CCRPunchPacketSender
+// C++ default constructor can NOT contain any code, that might leave.
+// -----------------------------------------------------------------------------
+//
+CCRPunchPacketSender::CCRPunchPacketSender( 
+    RConnection& aConnection, 
+    RSocketServ& aSockServer,
+    TInetAddr& aFromAddr, 
+    TInetAddr& aRemoteAddr , 
+    TUint32 aMySSRC,
+    CCRRtspPacketSource& aOwner )
+  : iConnection( aConnection ),
+    iSockServer( aSockServer ),
+    iFromAddr( aFromAddr ),
+    iRemoteAddr( aRemoteAddr ),
+    iMySSRC( aMySSRC ),
+    iOwner( aOwner )
+    {  
+    // None
+    }
+
+// -----------------------------------------------------------------------------
+// CCRPunchPacketSender::ConstructL
+// Symbian 2nd phase constructor can leave.
+// -----------------------------------------------------------------------------
+//
+void CCRPunchPacketSender::ConstructL()
+    {
+    iSock1 = CCRSock::NewL( *this, 1, iConnection, iSockServer, EFalse, EFalse );
+    User::LeaveIfError( iSock1->ConnectSock( iRemoteAddr, iFromAddr.Port() ) );
+    iSock2 = CCRSock::NewL( *this, 2, iConnection, iSockServer, EFalse, EFalse );
+    TInetAddr remoteAddr2 = iRemoteAddr; 
+    remoteAddr2.SetPort ( iRemoteAddr.Port() + 1 ); 
+    User::LeaveIfError( iSock2->ConnectSock( remoteAddr2, iFromAddr.Port() + 1 ) );
+    iCleanUp = new ( ELeave ) CAsyncCallBack( CActive::EPriorityStandard ) ; 
+    }
+
+// -----------------------------------------------------------------------------
+// CCRPunchPacketSender::~CCRPunchPacketSender
+// Destructor.
+// -----------------------------------------------------------------------------
+//
+CCRPunchPacketSender::~CCRPunchPacketSender()
+    {
+    LOG( "CCRPunchPacketSender::~CCRPunchPacketSender" );
+    
+    delete iSock1;
+    delete iSock2; 
+    delete iCleanUp; 
+    }
+
+// -----------------------------------------------------------------------------
+// CCRPunchPacketSender::DataReceived
+//
+// This is called when data is received from socket.
+// -----------------------------------------------------------------------------
+//
+void CCRPunchPacketSender::DataReceived( TInt /*aSockId*/, const TDesC8& /*aData*/ ) 
+    {
+    // None
+    }
+
+// -----------------------------------------------------------------------------
+// CCRPunchPacketSender::SockStatusChange
+//
+// This is called when socket status changes.
+// -----------------------------------------------------------------------------
+//
+void CCRPunchPacketSender::SockStatusChange(
+    TInt aSockId,
+    CCRSock::TCRSockStatus aStatus,
+    TInt aError )  
+    {
+    if ( aStatus == CCRSock::EFailed )
+        {
+        LOG3( "CCRPunchPacketSender::SockStatusChange(), aSockId: id: %d, aStatus: %d, aError: %d",
+            aSockId, ( TInt )aStatus, aError );
+        iOwner.SockStatusChange( aSockId, aStatus, aError );
+        }
+    else if ( aStatus == CCRSock::EIdle )
+        {       
+        if ( iSentViaSock2 && iSentViaSock1 )
+            {
+            
+            if ( !iCleanUp->IsActive() ) 
+                {
+                TCallBack cb( CleanupCallBack, this );
+                iCleanUp->Set( cb );
+                iCleanUp->CallBack();
+                }               
+            }
+        else
+            {
+            // here send
+            TDesC8* packet = NULL;
+            if ( iMySSRC ) 
+                {
+                // construct valid packet only if we have SSRC
+                TBuf8<8> receiverReport; 
+                receiverReport.Zero(); 
+                receiverReport.AppendFill( 0x0, 7 ); 
+                TUint8 *rrPtr = const_cast<TUint8 *>( receiverReport.PtrZ() );
+                rrPtr[0] = 0x80; // version and count
+                rrPtr[1] = 0xC9; // packet type 201 = rr
+                rrPtr[2] = 0x00; // packet len high bits = 0 
+                rrPtr[3] = 0x01; // packet len low bits = 1 e.g. len = 1
+                BigEndian::Put32( ( TUint8* )( &rrPtr[4] ), iMySSRC );
+                packet = &receiverReport;
+                }
+            else
+                {
+                // Atleast construct a kind-of valid packet.
+                TBuf8<12> appPacket; 
+                appPacket.Zero(); 
+                appPacket.AppendFill( 0x0, 11 ); 
+                TUint8 *rrPtr = const_cast<TUint8 *>( appPacket.PtrZ() );
+                rrPtr[0] = 0x80; // version and subtype
+                rrPtr[1] = 0xCC; // packet type 204 = APP
+                rrPtr[2] = 0x00; // packet len high bits = 0 
+                rrPtr[3] = 0x01; // packet len low bits = 1 e.g. len = 1
+                // this is not a valid SSRC
+                BigEndian::Put32( ( TUint8* )( &rrPtr[4] ), iMySSRC );
+                rrPtr[8] = 0x44; // ASCII: D
+                rrPtr[9] = 0x56; // ASCII: V
+                rrPtr[10] = 0x52; // ASCII: R
+                rrPtr[11] = 0x45; // ASCII: E
+                packet = &appPacket;
+                }
+            if ( aSockId == 1 && iSock1 && !iSentViaSock1 )
+                {
+                iSock1->SendData( *packet ); 
+                iSentViaSock1 = ETrue;
+                }
+            else if ( aSockId == 2 && iSock2 && !iSentViaSock2 )
+                {
+                iSock2->SendData( *packet ); 
+                iSentViaSock2 = ETrue;            
+                }
+            else
+                {
+                // None
+                }
+            }
+        }
+    }
+
+//-----------------------------------------------------------------------------
+// CCRPunchPacketSender::CleanupCallBack()
+//-----------------------------------------------------------------------------
+TInt CCRPunchPacketSender::CleanupCallBack( TAny* aSelf ) 
+    {
+    LOG( "CCRPunchPacketSender::CleanupCallBack()" );
+
+    CCRPunchPacketSender* self = static_cast<CCRPunchPacketSender*>( aSelf );  
+    delete self->iSock1; self->iSock1 = NULL; 
+    delete self->iSock2; self->iSock2 = NULL; 
+    self->iOwner.PunchPacketsSent( self );
+    return KErrNone; 
+    }
+
+//  End of File