///////////////////////////////////////////////////////////////////////////////
// MQ4CPP - Message queuing for C++
// Copyright (C) 2004-2007  Riccardo Pompeo (Italy)
//
// This library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
// License as published by the Free Software Foundation; either
// version 2.1 of the License, or (at your option) any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
// Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public
// License along with this library; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
//

#include "Logger.h"
#include "Timer.h"
#include "Compression.h"
#define PCKSIZE 65535
#define CACHE true
#define MASK 0x1F
#define ITERATIONS 1000

int main(int argv,char* argc[])
{
	DISPLAY("MQ4CPP compr.cpp")
	DISPLAY("This example shows how packet compression works")

	_TIMEVAL startTime;	
	_TIMEVAL endTime;	
	PacketCompression compression(CACHE);
	unsigned int bytesCompressed=0;
	unsigned int bytesDecompressed=0;
	startTime=Timer::timeExt();
	
	for(int i=0; i < ITERATIONS; i++)
	{
		string original;
		original.reserve(PCKSIZE);

		for(int cnt=0; cnt < PCKSIZE ; cnt++)
			original += (unsigned char)(rand() & MASK);
		
		try
		{
			string compressed=compression.deflate(original);	
			bytesCompressed+=compressed.size();
			string decompressed=compression.inflate(compressed);
			bytesDecompressed+=decompressed.size();

			if(decompressed.compare(original)!=0)
			{
				DISPLAY("Test NOK " << i << " Size=" << decompressed.size())
				DISPLAY("Original='" << original << "'")
				DISPLAY("Decompre='" << decompressed << "'")
				exit(-1);
			}
		}
		catch(...)
		{
			DISPLAY("Unhandled exception")	
			exit(-1);
		}
	}
	
	endTime=Timer::timeExt();
	long deltaTime=Timer::subtractMillisecs(&startTime,&endTime);
	DISPLAY("Elapsed=" << deltaTime << " ms")
	float comprRatio=(1-(float)bytesCompressed/(float)bytesDecompressed)*100.0;
	DISPLAY("Compression=" << comprRatio << "%")
	float packetspersecond=(float)ITERATIONS/((float)deltaTime/1000.0);
	DISPLAY("Compression+decompression per seconds=" << packetspersecond)
	float duration=(float)deltaTime/(float)ITERATIONS;
	DISPLAY("Compression+decompression duration=" << duration << " ms")
	return 0;
}