// Copyright (c) 2002-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:
//

#ifndef __LOGSERVSESSION_H__
#define __LOGSERVSESSION_H__

#include <logcli.h>
#include "LogServDefs.h"
#include "LogServDatabaseChangeObserver.h"

// Classes referenced
class TLogClientServerData;
class MLogServSessionLifetimeObserver;
class MLogServTaskInterface;
class MLogServOperationManager;
class MLogServBackupInterface;
class MLogServDatabaseChangeInterface;
class MLogServDatabaseTransactionInterface;
class CLogServServer;
class CLogNotify;
class CLogServViewBase;

/**
Handles client requests such as "add event", "change event", etc.  
and dispatches them for execution to the hitters.
"Hitter" is an active object which class type is one of (CLogActive derived class): 
 - CLogAddEvent;
 - CLogGetEvent;
 - CLogChangeEvent;
 - CLogDeleteEvent;
 - CLogChangeConfig;
 - CLogMaintenance;
 - CLogServViewWindowFetcher;
  
Every client request is processed asynchronously and consists of two IPC calls:
 - ELogOperationInitiate - the client initiates asynchronous operation that will be executed by 
   one of the hitters;
 - ELogOperationGetResult - after the hitter completes the execution of the requested operation and
   if there is a result for the client, the client can collect the result issuing this IPC request;

The client requests processing is relatively complex and I hope the following "add event" step-by-step
example can clarify how the LogEng server works.
 1. LogEng client issues "add event" request
 2. The request is handled by CLogServSession::ServiceL()
 3. CLogServSession::ServiceL() calls CLogServSession::ServiceOperationFunctionL() where the IPC command 
    is identified as ELogOperationInitiate and a new operation is created by calling
 4. LogServFactory::NewOperationL(). Here the client request type is identified as ELogOperationEventAdd
    and an instance of CLogServOpEventAdd class is created
 5. The CLogServOpEventAdd class derives from CLogServOperationBase. The CLogServOperationBase constructor
    will add the just created operation to a queue of pending operations maintained by an instance of the
    CLogServOperationQueue class, which implements the MLogServOperationManager interface.
    The CLogServOpEventAdd instance is added to the queue by calling 
    MLogServOperationManager::OMOperationQueueAdd().
 6. The CLogServOperationQueue instance is an active object. 
    CLogServOperationQueue::OMOperationQueueAdd() completes itsef and calls SetActive().
    The execution control is returned to the server side session object. Later, when the active scheduler
    takes the execution control the CLogServOperationQueue::RunL() will be called.
 7. CLogServOperationQueue::RunL() will pick up the next pending operation from the queue and calls the
    operation's StartL() method - CLogServOpEventAdd::StartL().
 8. CLogServOpEventAdd::StartL() reads the client "add event" data from the message object and calls
    MLogServTaskInterface::TaskEventAddL() passing the client data as call arguments.
 9. MLogServTaskInterface, as the class name states, is an interface class implemented by the 
    CLogServDatabaseDriver class.
10. CLogServDatabaseDriver::TaskEventAddL() will call the StartL() method of the hitter - 
    CLogAddEvent::StartL().
11. CLogAddEvent::StartL() will complete itself and call SetActive().
12. The next time when the active scheduler takes the execution control, it will call 
    CLogActive::RunL() --> CLogAddEvent::DoRunL(). And the "add event" request will be executed
13. The LogEng client then can complete the "add event" request by calling the server using the 
    ELogOperationGetResult IPC code. CLogServOperationQueue::OMGetResultL() will retrieve the result of the
    operation and destroy the "add event" oeration. 
    
@see LogServFactory    
@see CLogServOpEventAdd
@see MLogServOperationManager
@see CLogServOperationQueue
@see MLogServTaskInterface
@see CLogServDatabaseDriver
@see CLogActive
@see CLogAddEvent

@internalComponent
*/
class CLogServSession : public CSession2, public MLogServDatabaseChangeObserver
	{
public:
	CLogServSession(TLogServSessionId aSessionId, 
                    MLogServSessionLifetimeObserver& aObserver, 
                    MLogServBackupInterface& aBackupInterface, 
                    MLogServTaskInterface& aTaskInterface, 
                    MLogServOperationManager& aOperationManager, 
                    MLogServDatabaseChangeInterface& aChangeInterface, 
                    MLogServDatabaseTransactionInterface& aDatabase);
	~CLogServSession();

    inline TLogServSessionId Id() const;
    CLogServServer& Server() const;
	
private:
	void DCOHandleGlobalChangeEventL(const TLogServDatabaseChangeDefinition& aChange);//FROM MLogServDatabaseChangeObserver
	void CreateL();
	virtual void ServiceL(const RMessage2& aMessage);
	virtual void ServiceError(const RMessage2& aMessage,TInt aError);
	CLogServViewBase& ViewByIdL(TLogViewId aViewId);
	TInt ViewPositionById(TLogViewId aViewId) const;
    void ReadClientServerDataL(TLogClientServerData& aClientServerData, 
    		const RMessage2& aMessage, TInt aMinOperation, TInt aMaxOperation);
	void ServiceViewFunctionL(const RMessage2& aMessage);
	void ServiceOperationFunctionL(const RMessage2& aMessage);
	void ExtendedNotifyCompleteL(TInt aCompletionCode);

private:
	TLogServSessionId iSessionId;
	MLogServSessionLifetimeObserver& iObserver;
	MLogServBackupInterface& iBackupInterface;
	MLogServTaskInterface& iTaskInterface;
	MLogServOperationManager& iOperationManager;
	MLogServDatabaseChangeInterface& iChangeInterface;
	MLogServDatabaseTransactionInterface& iDatabase;
	CLogPackage* iPackage;
	CLogNotify* iNotify;
	RPointerArray<CLogServViewBase> iViewList;
	RMessage2 iExtendedNotificationMessage;
	RArray<TLogServDatabaseChangeDefinition> iPendingGlobalChanges;
	TBool iExtendedNotificationRequested;
#ifdef LOGGING_ENABLED
	TName iClientThreadName;
#endif

	};

inline TLogServSessionId CLogServSession::Id() const
	{
	return iSessionId;
	}

#endif//__LOGSERVSESSION_H__