--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/cbs/CbsServer/ServerSrc/CCbsLivecastHandler.cpp	Tue Feb 02 01:11:09 2010 +0200
@@ -0,0 +1,166 @@
+/*
+* Copyright (c) 2004 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:  
+*
+*/
+
+
+// INCLUDE FILES
+#include "CCbsLivecastHandler.h"
+#include "CCbsRecMessage.h"
+#include "CCbsRecWcdmaMessage.h"
+#include "CCbsRecEtel.h"
+#include "CCbsRecCollector.h"
+#include "CCbsReceiverHelper.h"
+#include "CbsLogger.h"
+
+// ================= MEMBER FUNCTIONS =======================
+
+// -----------------------------------------------------------------------------
+// CCbsLivecastHandler::CCbsLivecastHandler
+// C++ default constructor can NOT contain any code, that
+// might leave.
+// -----------------------------------------------------------------------------
+//
+CCbsLivecastHandler::CCbsLivecastHandler( CCbsRecEtel& aRecEtel )
+: iRecEtel( aRecEtel )
+    {    
+    }
+
+// Destructor    
+CCbsLivecastHandler::~CCbsLivecastHandler()
+    {
+    CBSLOGSTRING("CBSSERVER: >>> ~CCbsLivecastHandler::~CCbsLivecastHandler()");
+    CBSLOGSTRING("CBSSERVER: <<< ~CCbsLivecastHandler::~CCbsLivecastHandler()");
+    }
+
+// -----------------------------------------------------------------------------
+// CCbsLivecastHandler::NewL
+// Two-phased constructor.
+// -----------------------------------------------------------------------------
+//
+CCbsLivecastHandler* CCbsLivecastHandler::NewL( CCbsRecEtel& aRecEtel )
+    {
+    CBSLOGSTRING("CBSSERVER: >>> CCbsLivecastHandler::NewL()");
+
+    CCbsLivecastHandler* self = new ( ELeave ) CCbsLivecastHandler( aRecEtel );
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    CleanupStack::Pop();
+
+    CBSLOGSTRING("CBSSERVER: <<< CCbsLivecastHandler::NewL()");
+    return self;
+    }
+
+// -----------------------------------------------------------------------------
+// CCbsLivecastHandler::ConstructL
+// Symbian 2nd phase constructor can leave.
+// -----------------------------------------------------------------------------
+//
+void CCbsLivecastHandler::ConstructL()
+    {
+    }
+
+// -----------------------------------------------------------------------------
+// CCbsLivecastHandler::HandleLivecastMessageL
+// Processes the message.
+// (other items were commented in a header).
+// -----------------------------------------------------------------------------
+// 
+void CCbsLivecastHandler::HandleLivecastMessageL( 
+    CCbsMessage* aLivecastMessage )
+    {
+	CBSLOGSTRING("CBSSERVER: >>> CCbsLivecastHandler::HandleLivecastMessageL()");
+
+    // Take ownership
+    CleanupStack::PushL( aLivecastMessage );
+
+    // Check if this message must be rejected:
+    // 1. Is message compressed
+    // 2. Is message defined as 'Class 2' or 'Class 3' message
+
+	TInt msgclass ( aLivecastMessage->MessageClass() );
+
+	if ( aLivecastMessage->IsCompressed() ||
+		msgclass == 3 || msgclass == 2 )
+        {		
+        CBSLOGSTRING("CBSSERVER: CCbsLivecastHandler::HandleLivecastMessageL(): Rejected, compressed/msg class.");
+
+        // Reject the message
+        CleanupStack::PopAndDestroy(); // aLivecastMessage
+        }
+    else
+        {
+        // Add network information to message
+        TInt error = iRecEtel.AddNetworkInfo( *aLivecastMessage );
+
+		CBSLOGSTRING2("CBSSERVER: CCbsLivecastHandler::HandleLivecastMessageL(): AddNetworkInfo() error: %d", error );
+
+        // Handle the message
+        // Is message multipaged
+        if ( aLivecastMessage->TotalPages() > 1 )
+            {			
+            CBSLOGSTRING("CBSSERVER: CCbsLivecastHandler::HandleLivecastMessageL(): Message multipaged.");
+
+            // Ensure that the network info is available. 
+            // If not, reject the message, because info is required to collect
+            // pages of a multipaged message.
+            if ( KErrNone != error )
+                {				
+                CBSLOGSTRING("CBSSERVER: CCbsLivecastHandler::HandleLivecastMessageL(): Message rejected, AddNetworkInfo() error.");
+                CleanupStack::PopAndDestroy( aLivecastMessage );
+                }
+            else
+                {				
+                CBSLOGSTRING("CBSSERVER: CCbsLivecastHandler::HandleLivecastMessageL(): Sending msg to Collector...");
+
+                // Ownership of aLivecastMessage transferred to collector with
+                // aLivecastMessage left on the cleanup stack.                
+                CCbsMessage* completedMsg = iRecEtel.Collector().CollectL( aLivecastMessage, ECbsMessageLivecast );
+                
+                CBSLOGSTRING("CBSSERVER: CCbsLivecastHandler::HandleLivecastMessageL(): Collector finished.");
+
+                if ( completedMsg )
+                    {					
+                    CBSLOGSTRING("CBSSERVER: CCbsLivecastHandler::HandleLivecastMessageL(): Msg collected.");
+
+                    // Message pages combined => Handle like a single-paged msg.
+                    // Result code ignored.
+                    CleanupStack::PushL( completedMsg );
+					
+                    CBSLOGSTRING("CBSSERVER: CCbsLivecastHandler::HandleLivecastMessageL(): Routing msg to RecEtel...");
+					iRecEtel.RouteMessageL( *completedMsg );					
+                    CBSLOGSTRING("CBSSERVER: CCbsLivecastHandler::HandleLivecastMessageL(): Routing finished.");
+
+                    CleanupStack::PopAndDestroy( completedMsg );
+                    }
+                }
+            }
+        // Message is single paged
+        else            
+            {			
+            CBSLOGSTRING("CBSSERVER: CCbsLivecastHandler::HandleLivecastMessageL(): Message single paged.");            
+
+            iRecEtel.RouteMessageL( *aLivecastMessage );			
+            CBSLOGSTRING("CBSSERVER: CCbsLivecastHandler::HandleLivecastMessageL(): Single paged RouteMessageL() OK.");
+
+            CleanupStack::PopAndDestroy( aLivecastMessage );
+            }        
+        }
+	CBSLOGSTRING("CBSSERVER: <<< CCbsLivecastHandler::HandleLivecastMessageL()");
+    }
+
+// ========================== OTHER EXPORTED FUNCTIONS =========================
+
+//  End of File