diff -r 64a47b97e1e1 -r f27aebe284bb logsui/logsengine/logssymbianos/src/logsworker.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/logsui/logsengine/logssymbianos/src/logsworker.cpp	Wed Aug 18 09:49:12 2010 +0300
@@ -0,0 +1,203 @@
+/*
+* Copyright (c) 2009 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 <exception>
+#include <logview.h>
+#include "logsworker.h"
+#include "logsstatebase.h"
+#include "logslogger.h"
+
+// CONSTANTS
+
+// ----------------------------------------------------------------------------
+// LogsWorker::LogsWorker
+// ----------------------------------------------------------------------------
+//
+LogsWorker::LogsWorker(bool readAllEvents) 
+ : CActive( EPriorityStandard ),
+   mReadAllEvents(readAllEvents),
+   mLogClient(0),
+   mLogViewRecent(0),
+   mLogViewEvent(0),
+   mDuplicatesView(0),
+   mIndex(0),
+   mCurrentStateIndex(0),
+   mCurrentStateMachine(0),
+   mCurrentEventId(-1)
+{
+    LOGS_QDEBUG( "logs [ENG] -> LogsWorker::LogsWorker()" )
+    
+    CActiveScheduler::Add( this ); 
+  
+    LOGS_QDEBUG( "logs [ENG] <- LogsWorker::LogsWorker()" )
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::~LogsWorker
+// ----------------------------------------------------------------------------
+//
+LogsWorker::~LogsWorker()
+{
+    LOGS_QDEBUG( "logs [ENG] -> LogsWorker::~LogsWorker()" )
+    
+    Cancel();
+    
+    LOGS_QDEBUG( "logs [ENG] <- LogsWorker::~LogsWorker()" )
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::RunL
+// ----------------------------------------------------------------------------
+//
+void LogsWorker::RunL()
+{
+    LOGS_QDEBUG_3( "logs [ENG] -> LogsWorker::RunL(), (state, status):", 
+                   mCurrentStateIndex, iStatus.Int() )
+    
+    // Error handling in RunError
+    __ASSERT_ALWAYS( iStatus.Int() == KErrNone, User::Leave( iStatus.Int() ) );
+    
+    if ( currentState().continueL() ){
+        SetActive();
+    }
+    
+    LOGS_QDEBUG( "logs [ENG] <- LogsWorker::RunL()" )
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::RunError
+// ----------------------------------------------------------------------------
+//
+TInt LogsWorker::RunError(TInt error)
+{
+    LOGS_QDEBUG_2( "logs [ENG] <-> LogsWorker::RunError(), err:", error )
+    
+    return KErrNone;
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::DoCancel
+// ----------------------------------------------------------------------------
+//
+void LogsWorker::DoCancel()
+{
+    if ( mLogViewEvent ){
+        mLogViewEvent->Cancel();
+    }
+    if ( mLogViewRecent ){
+        mLogViewRecent->Cancel();
+    }
+    if ( mDuplicatesView ){
+        mDuplicatesView->Cancel();    
+    }
+    if ( mLogClient ){
+        mLogClient->Cancel();
+    }
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::setCurrentState
+// ----------------------------------------------------------------------------
+//
+void LogsWorker::setCurrentState(const LogsStateBase& state)
+{
+    bool found(false);
+    for( int i = 0; i < mCurrentStateMachine->count() && !found; i++ ){
+        if ( mCurrentStateMachine->at(i) == &state ){
+            mCurrentStateIndex = i;
+            found = true;
+            LOGS_QDEBUG_2( "logs [ENG] <-> LogsWorker::setCurrentState, index:", 
+                           mCurrentStateIndex )
+        }
+    }
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::logView
+// ----------------------------------------------------------------------------
+//
+CLogView& LogsWorker::logView()
+{
+    if ( mLogViewRecent ){
+        return *mLogViewRecent;
+    }
+    return *mLogViewEvent;
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::duplicatesView
+// ----------------------------------------------------------------------------
+//
+CLogViewDuplicate& LogsWorker::duplicatesView()
+{
+    return *mDuplicatesView;
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::index
+// ----------------------------------------------------------------------------
+//
+int& LogsWorker::index()
+{
+    return mIndex;
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::reqStatus
+// ----------------------------------------------------------------------------
+//
+TRequestStatus& LogsWorker::reqStatus()
+{
+    return iStatus;
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::currentEventId
+// ----------------------------------------------------------------------------
+//
+int LogsWorker::currentEventId()
+{
+    return mCurrentEventId;
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::logClient
+// ----------------------------------------------------------------------------
+//
+CLogClient& LogsWorker::logClient()
+{
+    return *mLogClient;
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::isRecentView
+// ----------------------------------------------------------------------------
+//
+bool LogsWorker::isRecentView()
+{
+    return ( mLogViewRecent != 0 );
+}
+
+// ----------------------------------------------------------------------------
+// LogsWorker::currentState
+// ----------------------------------------------------------------------------
+//
+LogsStateBase& LogsWorker::currentState()
+{
+    return *(mCurrentStateMachine->at(mCurrentStateIndex));
+}