#ifndef _RPCPENDINGCALLS_H

#define _RPCPENDINGCALLS_H

#include <malloc.h>
#include <OS.h>
#include <sys/socket.h>
#include <netinet/in.h>

struct SemaphorePool
{
	sem_id *fPool;
	int32 fPoolCount;
	int32 fPoolSize;
	sem_id fPoolSem;
};

void SemaphorePoolInit (struct SemaphorePool *pool);
void SemaphorePoolDestroy (struct SemaphorePool *pool);
sem_id SemaphorePoolGet(struct SemaphorePool *pool);
void SemaphorePoolPut (struct SemaphorePool *pool, sem_id sem);

struct PendingCall
{
	struct PendingCall *next;
	
	sem_id sem;
	struct sockaddr_in addr;
	int32 xid;
	uint8 *buffer;	
};

void PendingCallInit (struct PendingCall *call);
void PendingCallDestroy (struct PendingCall *call);

struct RPCPendingCalls
{
	struct PendingCall *fFirst;
	sem_id fSem;		
	struct SemaphorePool fPool;	
};

void RPCPendingCallsInit (struct RPCPendingCalls *calls);
void RPCPendingCallsDestroy (struct RPCPendingCalls *calls);

struct PendingCall *RPCPendingCallsAddPendingCall (struct RPCPendingCalls *calls,
													int32 xid, const struct sockaddr_in *addr);

struct PendingCall *RPCPendingCallsFindAndRemovePendingCall (struct RPCPendingCalls *calls,
													int32 xid, const struct sockaddr_in *addr);

#endif