--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/satengine/SatServer/Engine/src/CSatBIPDataSender.cpp	Tue Feb 02 01:11:09 2010 +0200
@@ -0,0 +1,150 @@
+/*
+* 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:  Sender class for TCP / UDP sockets
+*
+*/
+
+
+
+// INCLUDE FILES
+#include <es_sock.h>
+#include "CSatBIPDataSender.h"
+#include "MSatSendDataObserver.h"
+#include "SatLog.h"
+#include "MSatBIPUtils.h"
+
+#ifdef ENABLE_SAT_LOGGING
+const TUint8 KIpAddressLogSize( 40 );
+#endif
+ 
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// CSatBIPDataSender::CSatBIPDataSender
+// C++ default constructor can NOT contain any code, that
+// might leave.
+// -----------------------------------------------------------------------------
+//
+CSatBIPDataSender::CSatBIPDataSender( MSatSendDataObserver& aObserver, 
+    RSocket& aSocket,
+    TBool aIsTcpSocket,
+    TInt aBufferSize ) : CActive( EPriorityNormal ),
+    iObserver( aObserver ),
+    iSocket( aSocket )
+    {
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataSender::CSatBIPDataSender\
+         calling-exiting" )
+
+    iIsTcpSocket = aIsTcpSocket;
+    iBufferSize = aBufferSize;
+    CActiveScheduler::Add( this );
+    }
+
+// -----------------------------------------------------------------------------
+// CSatBIPDataSender::~CSatBIPDataSender
+// Destructor
+// -----------------------------------------------------------------------------
+//
+CSatBIPDataSender::~CSatBIPDataSender()
+    {
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataSender::~CSatBIPDataSender calling" )
+    // Don't have our own pointers...
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataSender::~CSatBIPDataSender exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatBIPDataSender::RunL
+// Two-phased constructor.
+// -----------------------------------------------------------------------------
+//
+void CSatBIPDataSender::RunL()
+    {
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataSender::RunL calling" )
+
+    LOG2( NORMAL, "  RunL with error: %i", iStatus.Int() )
+    LOG2( NORMAL, "  RunL <buffer_size>: %i", iBufferSize )
+    TInt errCode( MSatBIPUtils::ESatBIPSuccess );
+
+    if ( KErrNone != iStatus.Int() )
+        {
+        // Error, setting error code
+        errCode = MSatBIPUtils::ESatBIPRemoteDeviceNotReachable;
+        }
+
+    // Notify observer and empty buffer
+    iObserver.DataSentNotification( errCode, iBufferSize );
+    iSendPtr.Zero();
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataSender::RunL exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatBIPDataSender::DoCancel
+// Two-phased constructor.
+// -----------------------------------------------------------------------------
+//
+void CSatBIPDataSender::DoCancel()
+    {
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataSender::DoCancel calling" )
+    iSocket.CancelSend();
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataSender::DoCancel exiting" )
+    }
+
+// -----------------------------------------------------------------------------
+// CSatBIPDataSender::SendData
+// Starts the send process using predefined protocol
+// -----------------------------------------------------------------------------
+//
+void CSatBIPDataSender::SendData( const TDesC8& aData, TInetAddr& aDest )
+    {
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataSender::SendData calling" )
+    // Copy data into local buffer
+    iSendPtr.Copy( aData );
+    
+    #ifdef ENABLE_SAT_LOGGING
+    TBuf<KIpAddressLogSize> addressForLog;
+    #endif
+
+    #ifdef ENABLE_SAT_LOGGING
+    aDest.Output( addressForLog );
+    LOG2( NORMAL, 
+    "SATENGINE: CSatBIPDataSender::SendData Sending to %S", &addressForLog )
+    #endif    
+    
+    LOG2( NORMAL, "  Port number: %i", aDest.Port() )
+    LOG2( NORMAL, "  Sending %i bytes", aData.Length() )
+    if ( !IsActive() )
+        {
+        // Check protocol
+        if ( iIsTcpSocket )
+            {
+            LOG( SIMPLE, "SATENGINE: CSatBIPDataSender::SendData TCP" )
+            // When using TCP, this request completes when the data is actually
+            // sent to remote device. 
+            iSocket.Send( iSendPtr, 0, iStatus );
+            }
+        else
+            {
+            LOG( SIMPLE, "SATENGINE: CSatBIPDataSender::SendData UDP" )
+            // UDP Socket. This request completes almost immediately. 
+            // There is no
+            // way to be sure that the remote device gets the datagram.
+            iSocket.SendTo( iSendPtr, aDest, 0, iStatus );
+            }
+        SetActive();
+        }
+    LOG( SIMPLE, "SATENGINE: CSatBIPDataSender::SendData exiting" )
+    }
+
+// End of file