diff -r 000000000000 -r f5a58ecadc66 upnp/upnpstack/serviceframework/src/upnpnonmoderatedeventqueuemanager.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/upnp/upnpstack/serviceframework/src/upnpnonmoderatedeventqueuemanager.cpp	Tue Feb 02 01:12:20 2010 +0200
@@ -0,0 +1,180 @@
+/** @file
+* Copyright (c) 2008-2008 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:  Implements algoritms for nonmodereted events
+*
+*/
+
+
+#include "upnpnonmoderatedeventqueuemanager.h"
+#include "upnpgenamessagefactory.h"
+#include "upnphttpnonmoderatedeventtransaction.h"
+#include "upnpcommonupnplits.h"
+#include "upnpcommonstructs.h"
+
+
+#define KLogFile _L("UPnPStack.txt")
+#include "upnpcustomlog.h"
+
+
+// -----------------------------------------------------------------------------
+// CUpnpNonModeratedEventQueueManager::CUpnpNonModeratedEventQueueManager
+// -----------------------------------------------------------------------------
+//
+CUpnpNonModeratedEventQueueManager::CUpnpNonModeratedEventQueueManager( 
+                                                     CUpnpServiceImplementation& aServiceImpl,
+                                                     CUpnpEventController& aEventController,
+                                                     CUpnpSubscriberLibrary* aSubscriberLibrary
+                                                                       )
+    :CUpnpEventQueueManagerBase( aServiceImpl, aEventController , aSubscriberLibrary )
+    {
+    // No implementation required
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpNonModeratedEventQueueManager::~CUpnpNonModeratedEventQueueManager
+// -----------------------------------------------------------------------------
+//
+CUpnpNonModeratedEventQueueManager::~CUpnpNonModeratedEventQueueManager()
+    {
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpNonModeratedEventQueueManager::NewLC
+// -----------------------------------------------------------------------------
+//
+CUpnpNonModeratedEventQueueManager* CUpnpNonModeratedEventQueueManager::NewLC( 
+                                           CUpnpServiceImplementation& aServiceImpl,
+                                           CUpnpEventController& aEventController,
+                                           CUpnpSubscriberLibrary* aSubscriberLibrary 
+                                                                              )
+    {
+    CUpnpNonModeratedEventQueueManager* self = 
+                 new (ELeave) CUpnpNonModeratedEventQueueManager( aServiceImpl, 
+                                                                  aEventController, 
+                                                                  aSubscriberLibrary );
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    return self;
+    }
+    
+// -----------------------------------------------------------------------------
+// CUpnpNonModeratedEventQueueManager::NewL
+// -----------------------------------------------------------------------------
+//    
+CUpnpNonModeratedEventQueueManager* CUpnpNonModeratedEventQueueManager::NewL( 
+                                            CUpnpServiceImplementation& aServiceImpl,
+                                            CUpnpEventController& aEventController,
+                                            CUpnpSubscriberLibrary* aSubscriberLibrary 
+                                                                            )
+    {
+    CUpnpNonModeratedEventQueueManager* self= CUpnpNonModeratedEventQueueManager::NewLC( 
+                                                            aServiceImpl, 
+                                                            aEventController, 
+                                                            aSubscriberLibrary );
+    CleanupStack::Pop( self );
+    return self;
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpNonModeratedEventQueueManager::ConstructL
+// -----------------------------------------------------------------------------
+//
+void CUpnpNonModeratedEventQueueManager::ConstructL()
+    {
+    BaseConstructL();
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpNonModeratedEventQueueManager::SendEvent
+// -----------------------------------------------------------------------------
+//
+void CUpnpNonModeratedEventQueueManager::SendEvent()
+    {
+    TRAPD( err, SendEventL() );
+    if( err )
+        {
+        SendingCompleted();
+        }
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpNonModeratedEventQueueManager::SendEventL
+// -----------------------------------------------------------------------------
+//   
+void CUpnpNonModeratedEventQueueManager::SendEventL()
+    {
+    if ( ! iSubscriberLibrary->SubscriberLibrary().Count() )
+        {
+        return;
+        }
+     
+    if ( iIsSending ) 
+        {
+        iNewValuesWaitingToBeSend = ETrue;
+        return;
+        }
+    
+    iIsSending = ETrue;
+     
+    iCurrentSubscriberIndex = 0;
+    for ( TInt i = 0; i < iServiceImpl.EventedStateVariables().Count(); i++ )
+        {
+        if ( iServiceImpl.EventedStateVariables()[i]->MaxEventRate() > 0 )
+            {
+            iServiceImpl.EventedStateVariables()[i]->EventTick();
+            }
+        }
+            
+    delete iBody;
+    iBody =NULL;
+         
+    iBody = CreateEventL( iServiceImpl.StateVariableList() );
+        
+    PrepareTransactionAndStartSendingL( KFirstSubscriberInQueue );
+    }
+
+   
+// -----------------------------------------------------------------------------
+// CUpnpNonModeratedEventQueueManager::CreateTranscationL
+// -----------------------------------------------------------------------------
+//
+CUpnpHttpTransaction* CUpnpNonModeratedEventQueueManager::CreateTransactionL( CUpnpHttpMessage* aMessage )
+    {
+    return CUpnpHttpNonModeratedEventTransaction::NewL( aMessage, *this );
+    }
+
+// -----------------------------------------------------------------------------
+// CUpnpNonModeratedEventQueueManager::FillEventBodyL
+// -----------------------------------------------------------------------------
+//
+TInt CUpnpNonModeratedEventQueueManager::FillEventBodyL( TDes8& aEvent, 
+                                                   const RPointerArray<CUpnpStateVariable>& aVariableList 
+                                                       )
+    {
+    TInt eventableVariableCount(0);        
+    for ( TInt i = 0; i < aVariableList.Count(); i++ )
+        {
+        if (   aVariableList[i]->Eventable().CompareF( KYes() ) == 0 
+            && aVariableList[i]->ReadyForEventing() 
+            &&!aVariableList[i]->IsModerated() )
+            {                            
+            AddVariableToEventBody( aEvent , aVariableList[i] );
+                                              
+            iServiceImpl.StateVariableEvented( aVariableList[i]->Name() );        
+            eventableVariableCount++;
+            }  
+        }
+    return eventableVariableCount;
+    }
+//end of file