// server.h
// 
// Copyright (c) 2006 - 2010 Accenture. All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the "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:
// Accenture - Initial contribution
//

#ifndef __SERVER_H__
#define __SERVER_H__

#ifdef EKA2
#define RMsg RMessage2
#else
#define RMsg RMessage
#endif

#include <e32base.h>
#include <f32file.h>
#include <e32hashtab.h>
#include "iocli.h"
#include "clientserver.h"
#include "log.h"
#include "config.h"

enum TIoPanicReason
	{
	EPanicBadDescriptor = 0,
	EPanicBadHandle = 1,
	EPanicUnknownOpcode = 2,
	EPanicReadAlreadyPending = 3,
	EPanicReadKeyAlreadyPending = 4,
	EPanicReadWhenNotAttached = 5,
	EPanicWriteAlreadyPending = 6,
	EPanicWriteWhenNotAttached = 7,
	EPanicReadKeyWhenNotAttached = 8,
	EPanicCursorPosWhenNotAttached = 9,
	EPanicSetCursorPosAbsWhenNotAttached = 10,
	EPanicSetCursorPosRelWhenNotAttached = 11,
	EPanicSetCursorHeightWhenNotAttached = 12,
	EPanicSetTitleWhenNotAttached = 13,
	EPanicClearScreenWhenNotAttached = 14,
	EPanicClearToEndOfLineWhenNotAttached = 15,
	EPanicScreenSizeWhenNotAttached = 16,
	EPanicInvalidPipeId = 17,
	EPanicSetConsoleModeWhenNotAttached = 18,
	EPanicNotAnEndPoint = 19,
	EPanicNotAPipe = 20,
	EPanicNotAConsole = 21,
	EPanicNotAReadWriteObject = 22,
	EPanicNotAReadObject = 23,
	EPanicNotAWriteObject = 24,
	EPanicNotAPersistentConsole = 25,
	EPanicNotAValidContainerType = 26,
	EPanicFindNextWithNoFindFirst = 27,
	EPanicOpenFoundWithNoFind = 28,
	EPanicSetTitleAlreadyPending = 29,
	EPanicCursorPosAlreadyPending = 30,
	EPanicSetCursorPosAlreadyPending = 31,
	EPanicSetCursorHeightAlreadyPending = 32,
	EPanicClearScreenAlreadyPending = 33,
	EPanicClearToEndOfLineAlreadyPending = 34, 
	EPanicScreenSizeAlreadyPending = 35,
	EPanicSetReadModeAlreadyPending = 36,
	EPanicCannotReadFromUnderlyingConsole = 37,
	EPanicSetAttributesWhenNotAttached = 38,
	EPanicSetAttributesAlreadyPending = 39,
	EPanicSetModeAlreadyPending = 40
	};

void PanicClient(const RMsg& aMessage, TIoPanicReason aReason);

class CIoObject;
class CIoLog;
class CIoPipe;
class CIoConsole;
class CIoFile;
class CIoNull;
class CIoPersistentConsole;
class CIoReadWriteObject;
class CIoReadObject;
class CIoWriteObject;
class MIoWriteEndPoint;

class CShutdownTimer : public CTimer
	{
	enum {KShutdownDelay = 0x2000000};
public:
	CShutdownTimer();
	void ConstructL();
	void Start();
private:
	void RunL();
	};


#ifdef EKA2
class CIoServer : public CServer2
#else
class CIoServer : public CServer
#endif
	{
public:
#ifdef EKA2
	static CServer2* NewLC();
#else
	static CServer* NewLC();
#endif
	~CIoServer();
	void AddSession();
	void DropSession();
	CIoPipe& CreatePipeLC();
	CIoConsole& CreateConsoleLC(const TDesC& aImplementation, const TDesC& aTitle, TSize aSize, MIoWriteEndPoint* aUnderlyingConsole, TUint aOptions);
	CIoFile& CreateFileLC(const TDesC& aName, RIoFile::TMode aMode);
	CIoNull& CreateNullLC();
	CIoPersistentConsole& CreatePersistentConsoleLC(const TDesC& aName, const TDesC& aTitle, const RMsg& aMessage);
	CIoReadObject& CreateReadObjLC();
	CIoWriteObject& CreateWriteObjLC();
	CIoReadObject* NextReadObj(TThreadId aOwningThread) const;
	CIoWriteObject* NextWriteObj(TThreadId aOwningThread) const;
	CIoReadObject* LastOpenedReadObj(TThreadId aOwningThread) const;
	CIoWriteObject* LastOpenedWriteObj(TThreadId aOwningThread) const;
	CIoPersistentConsole& FindPersistentConsoleL(const TDesC& aName);
	CIoObject* FindObjectByName(RIoHandle::TType aType, TInt& aFindHandle, const TDesC& aMatch, TName& aName) const;
	CIoObject& OpenObjectLC(TInt aFindHandle);
	const TIoConfig& Config();
	void PersistentConsoleAddL(const TDesC16& aName, const CIoPersistentConsole& aCons);
	void PersistentConsoleRemove(const TDesC16& aName, const CIoPersistentConsole& aCons);
private:
	CIoServer();
	void ConstructL();
#ifdef EKA2
	virtual CSession2* NewSessionL(const TVersion& aVersion, const RMessage2& aMessage) const;
#else
	virtual CSharableSession* NewSessionL(const TVersion& aVersion) const;
#endif
	TInt RunError(TInt aError);
	CIoReadWriteObject* DoFindObj(RIoHandle::TType aType, TThreadId aOwningThread, TBool aNext) const;
private:
	RFs iFs;
	TInt iSessionCount;
	CShutdownTimer iShutdownTimer;
	CObjectConIx* iIoObjectContainerIndex; 
	CObjectCon* iIoObjectContainer;
	TUint iNextReadObjId;
	TUint iNextWriteObjId;
	TIoConfig iConfig;
	RPtrHashMap<TDesC16, CIoPersistentConsole> iPersistentConsoleNames;
#ifdef IOSRV_LOGGING
	CIoLog* iLog;
#endif
	};

	
TInt DesLengthL(const RMsg& aMessage, TInt aParam);
TInt MaxDesLengthL(const RMsg& aMessage, TInt aParam);
void MessageReadL(const RMsg& aMessage, TInt aParam, TDes8& aDes);
void MessageReadL(const RMsg& aMessage, TInt aParam, TDes8& aDes, TInt aOffset);
void MessageReadL(const RMsg& aMessage, TInt aParam, TDes16& aDes);
void MessageReadL(const RMsg& aMessage, TInt aParam, TDes16& aDes, TInt aOffset);
void MessageWriteL(const RMsg& aMessage, TInt aParam, const TDesC8& aDes);
void MessageWriteL(const RMsg& aMessage, TInt aParam, const TDesC16& aDes);
TInt MessageWrite(const RMsg& aMessage, TInt aParam, const TDesC8& aDes);
TInt MessageWrite(const RMsg& aMessage, TInt aParam, const TDesC16& aDes);
TBool MessagePending(const RMsg& aMessage);
TThreadId ClientThreadIdL(const RMsg& aMessage);
TFullName ClientNameL(const RMsg& aMessage);
void Complete(const RMsg& aMessage, TInt aError);
void CompleteIfPending(const RMsg& aMessage, TInt aError);

#endif // __SERVER_H__