// Copyright (c) 2000-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:
// server.h
// Transient server example - server classes
// 
//

#ifndef __SENDPROXYSERVER_H__
#define __SENDPROXYSERVER_H__


#include <e32base.h>
#include <e32std.h>

#include "SendProxyClientServer.h"

#include <mclient.h>
	// Required for RMsvServerSession


enum TSendProxyServerPanic
	{
	EPanicBadDescriptor,
	EPanicIllegalFunction,
	EPanicAlreadyReceiving
	};

void PanicClient(const RMessagePtr2& aMessage,TSendProxyServerPanic TSendProxyServerPanic);

class CShutdown : public CTimer
	{
	enum {KSendProxyShutdownDelay=0x200000};	// approx 2s
public:
	inline CShutdown();
	inline void ConstructL();
	inline void Start();
private:
	void RunL();
	};




//
// Used to get acces to send recieve. 
// It is better to encapsulate this than use inheritence into the step.
//

class RMsvServerSessionTest: public RMsvServerSession
{
public :
	TInt SendReceive( TInt aFunction,const TIpcArgs& aArgs ) const;
	TInt SendReceive( TInt aFunction ) const;
		// All we want is to access. Since RSessionBase::SendReceive is protected so is RMsvServerSession::SendReceive
		// So as long as we derive from RSessionBase base we should be get access to SendReceive.
		
	void SendReceive( TInt aFunction,const TIpcArgs& aArgs,TRequestStatus& aRequestStatus ) const;		
	void SendReceive( TInt aFunction,TRequestStatus& aRequestStatus) const;
	
	void SendReceiveAsync( TInt aFunction,const TIpcArgs& aArgs,TRequestStatus& aRequestStatus ) const;		
	void SendReceiveAsync( TInt aFunction,TRequestStatus& aRequestStatus) const;

	TInt CreateSession(const TDesC& aServer,const TVersion& aVersion,TInt aAsyncMessageSlots);

};


class CSendProxyServer : public CServer2
	{
public:
	static CServer2* NewLC();
	void AddSession();
	void DropSession();
	
private:
	CSendProxyServer();
	void ConstructL();
	CSession2* NewSessionL(const TVersion& aVersion, const RMessage2& aMessage) const;
private:
	TInt iSessionCount;
	CShutdown iShutdown;
			
	};



// Just used to get acces to the array .iArgs. 
// This may be an inadequency of the API we can get buffers according to args
// but not the RInts.
// 
class RMessage2Derv : public RMessage2
{
public: 
	IMPORT_C TInt GetiArgs(TInt aPos) const;	
};



class CSendProxyServerSession : public CSession2
	{
public:
	CSendProxyServerSession();
	void CreateL();
	
private:
	~CSendProxyServerSession();
	inline CSendProxyServer& Server();
	void ServiceL(const RMessage2& aMessage);
	void ServiceError(const RMessage2& aMessage,TInt aError);
	inline TBool ReceivePending() const;
	

private :
	void SetupTIpcArgL( const RMessage2Derv& aMessage, TInt aPos, TIpcArgs& atipcArgs);
	void SetupTIpcArgsL( const RMessage2Derv& aMessage, TIpcArgs& atipcArgs);
	
	void SetupReturnTIpcArgL(const RMessage2Derv& aMessage, TInt aPos);
	void SetupReturnTIpcArgsL(const RMessage2Derv& aMessage);
	
	void ReadCapabilities(TInt32& aServerCaps);
	
	void ClearBuffer(TInt aPos);
	void ClearBuffers();
	TInt DoCommandL(const RMessage2Derv& aMessage );						
	
private:
	RMessagePtr2 iReceiveMsg;
	TInt iReceiveLen;
	RMsvServerSessionTest iMsvServerSession;
	TInt iSessionCount;

	TSendProxyMessages iCommand;	// Which type of send we are expected to perform.
	TInt iFlags; // from TIpcArgs, we use these flags to set up buffers if we require.
	RBuf8 iBuffer8[KMaxMessageArguments];
	TPtr8* iTPtr8[KMaxMessageArguments];

	RBuf16 iBuffer16[KMaxMessageArguments];
	TPtr16* iTPtr16[KMaxMessageArguments];
	
	};






//TInt StartMsvServer();


#endif // __SENDPROXYSERVER_H__