/*

* 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: 

*

*/

#ifndef __RIPC_SESSION__

#define __RIPC_SESSION__

#include<e32std.h> //RSessionBase

#include<e32def.h> //Varargs

#include<sys/types.h>

#include<sys/sem.h>

struct msqid_ds;

struct shmid_ds;

class TChunk

	{

public:

TChunk(): iRef(0){}

TChunk(TInt aShmID): iShmID(aShmID), iRef(0){}

TInt iShmID;

RChunk iChunk;

TInt iRef;

	};

//-----------------------------------------------------------------------

//Class name: RIpcSession

//Description: It represents the session to Ipc Server. 

//-----------------------------------------------------------------------

class RIpcSession : public RSessionBase

	{

	public:

		RIpcSession():iIsConnected(EFalse)

			{iLock.CreateLocal();}

		//msgqueue functions

		int msgctl(int msqid, int cmd, struct msqid_ds *buf, int &aerrno);

		int msgget(key_t key, int msgflg, int& aerrno);

		ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg, int& aerrno);

		int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg, int& aerrno);

		//msgqueue functions

		int shmctl(int shmid, int cmd, struct shmid_ds *buf, int &aerrno);

		int shmget(key_t key, size_t size, int shmflg, int& aerrno);

		void *shmat(int shmid, const void *shmaddr, int shmflg, int& aerrno);

		int shmdt(const void *shmaddr, int& aerrno);

		//semqueue functions

		int semget(key_t key, int nsems, int semflags, int& aerrno);

		int semctl(int semid, int semnum, int cmd, union semun *arg, int& aerrno);

		int semop(int semid, struct sembuf *sops, size_t nsops, int& aerrno);

		RFastLock iLock;

	private:

		TInt AddToList(const TInt& aKey, const TInt& aErr, TAny*& aRetPtr);

		TInt OnDemandConnection();

		void Lock()

			{

			iLock.Wait();

			}

		void UnLock()

			{

			iLock.Signal();

			}

	private:

	TInt Connect();

	TInt iIsConnected;

	//todo put a lock around this list

	RArray<TChunk> iChunkList;

	};	

#endif //__RIPC_SESSION__