--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/satengine/SatServer/Engine/src/CSatBIPDataReceiver.cpp	Tue Feb 02 01:11:09 2010 +0200
@@ -0,0 +1,152 @@
+/*
+* Copyright (c) 2002-2007 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:  Receiver class for TCP / UDP sockets
+*
+*/
+
+
+
+// INCLUDE FILES
+#include <es_sock.h>
+#include "CSatBIPDataReceiver.h"
+#include "CSatBIPGPRSDataChannel.h"
+#include "SatLog.h"
+
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// CSatBIPDataReceiver::CSatBIPDataReceiver
+// C++ default constructor can NOT contain any code, that
+// might leave.
+// -----------------------------------------------------------------------------
+//
+CSatBIPDataReceiver::CSatBIPDataReceiver( CSatBIPGPRSDataChannel& aObserver,  
+    RSocket& aSocket,
+    TBool aIsTcpSocket ) : CActive( EPriorityNormal ),
+    iObserver( aObserver ),
+    iSocket( aSocket ),
+    iReceiveDataLen( 0 ),
+    iRecvPckg( iReceiveDataLen )
+    {
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::CSatBIPDataReceiver\
+         calling-exiting" )
+    
+    iIsTcpSocket = aIsTcpSocket;
+    
+    CActiveScheduler::Add( this );
+    }
+    
+// -----------------------------------------------------------------------------
+// CSatBIPDataReceiver::~CSatBIPDataReceiver
+// Destructor
+// -----------------------------------------------------------------------------
+//
+CSatBIPDataReceiver::~CSatBIPDataReceiver()
+    {
+    LOG( SIMPLE, 
+    "SATENGINE: CSatBIPDataReceiver::~CSatBIPDataReceiver calling" )
+    // Don't have our own pointers...
+    LOG( SIMPLE, 
+    "SATENGINE: CSatBIPDataReceiver::~CSatBIPDataReceiver exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatBIPDataReceiver::RunL
+// Two-phased constructor.
+// -----------------------------------------------------------------------------
+//
+void CSatBIPDataReceiver::RunL()
+    {
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::RunL calling" )
+
+    LOG2( NORMAL, "  RunL with error: %i", iStatus.Int() )
+    LOG2( NORMAL, "  RunL Data received <buffer>: %i", iRecvBuffer.Length() )
+
+    // Notify observer
+    if ( KErrNone == iStatus.Int() )
+        {
+        iObserver.DataReceivedNotificationL( iRecvBuffer );
+        }    
+    else
+        {
+        iObserver.DataReceiveError( iStatus.Int() );
+        }
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::RunL exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatBIPDataReceiver::DoCancel
+// Two-phased constructor.
+// -----------------------------------------------------------------------------
+//
+void CSatBIPDataReceiver::DoCancel()
+    {
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::DoCancel calling" )
+    iSocket.CancelRecv();
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::DoCancel exiting" )
+    }
+    
+// -----------------------------------------------------------------------------
+// CSatBIPDataReceiver::ReceiveStoreEmptyNotification
+// -----------------------------------------------------------------------------
+//
+void CSatBIPDataReceiver::ReceiveStoreEmptyNotificationL()
+    {
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::ReceiveStoreEmptyNotification\
+         calling" )
+    // It doesn't matter, if this buffer is empty
+    iObserver.DataReceivedNotificationL( iRecvBuffer );
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::ReceiveStoreEmptyNotification\
+         exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatBIPDataReceiver::StartReceive
+// Starts to receive data
+// -----------------------------------------------------------------------------
+//
+void CSatBIPDataReceiver::StartReceive( TInetAddr& aAddr )
+    {
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::StartReceive calling" )
+
+    // It may already be active
+    if ( !IsActive() )
+        {
+        // This is used only with TCP sockets
+        iReceiveDataLen = 0;
+        // Remove previously received data
+        iRecvBuffer.Zero();
+        // Check the socket type
+        if ( iIsTcpSocket )
+            {
+            LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::StartReceive TCP" )
+            // Only TCP / Stream socket may receive one or more bytes
+            iSocket.RecvOneOrMore( iRecvBuffer, 0, iStatus, iRecvPckg );
+            }
+        else
+            {
+            LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::StartReceive UDP" )
+            // Use different receive method with UPD / Datagram socket
+            // Destination has already been stored in iSocket during 
+            // activation, 
+            // so we don't have to tell it here.        
+            iSocket.RecvFrom( iRecvBuffer, aAddr, 0, iStatus );
+            }
+        SetActive();
+        }
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::StartReceive exiting" )
+    }
+
+// End of file