/*
 *  PSYC Manager Daemon, src/Equeue.cc
 *  Copyright (C) 2001 Mark Ralf Thomson
 *  Supervisor: Peter Zehetmayer
 *  Concept: Mark Ralf Thomson
 */
 #include <string>
 
 class Equeue
{

	public:
	string *Q;
	unsigned int time;
	#define bytes Q->length()
	
	inline Equeue() 
	{
		Q = new string();
	}
	
	inline ~Equeue()
	{
		delete Q;
	}

	inline void add(char *ca,int cs)
	{
		time = ::time(NULL);
		*Q = *Q + ca;
	}
	
	inline int getpacket(char *packet,int proto)
	{
		int k=0;
		string tmp;

		k = (int)Q->find(PT_PACKET_END(proto),0);
		cout<<"Q: K="<<k<<"\n";
		if (k > MaxPacketSize || k < 0)
			return -3;
		tmp = Q->substr(0,k);
		cout<<"Q: tmp="<<tmp<<"\n";
		strcat(packet,tmp.c_str());
		packet[k]='\0';
		
		return k; 
	}
	
	/* cut , cuts the  pos first charakters from the buffer using inline, register 
	   and integercopyng (32bit) for speed up --chronux
	*/	
	inline void cut(unsigned int pos)
	{
		Q->erase(0,pos);
	
		/*
		register  int k=0;
		register int *prt1;
		register  int *prt2; 
		register int si=size/sizeof(size);
		
		prt1 = (int*)Q;
		prt2 = (int*)Q+pos;
		
		for (k=0; k<=si; k++)
		{
			*prt1++ = *prt2++;
		}
		*/

	}
	
	
};