/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include <log4cxx/helpers/cyclicbuffer.h>
#include "../logunit.h"

#include <log4cxx/logmanager.h>
#include <log4cxx/logger.h>
#include <log4cxx/spi/loggingevent.h>
#include <log4cxx/spi/location/locationinfo.h>
#include "../testchar.h"

using namespace log4cxx;
using namespace log4cxx::helpers;
using namespace log4cxx::spi;

#define MAX 1000

LOGUNIT_CLASS(CyclicBufferTestCase)
{
	LOGUNIT_TEST_SUITE(CyclicBufferTestCase);
	LOGUNIT_TEST(test0);
	LOGUNIT_TEST(test1);
	LOGUNIT_TEST(testResize);
	LOGUNIT_TEST_SUITE_END();

	LoggerPtr logger;
	std::vector<LoggingEventPtr> e;

public:
	void setUp()
	{
		e.reserve(1000);
		LoggingEventPtr event;

		for (int i = 0; i < MAX; i++)
		{
			event = new LoggingEvent(LOG4CXX_STR("x"), Level::getDebug(), LOG4CXX_STR("e"),
				log4cxx::spi::LocationInfo::getLocationUnavailable());
			e.push_back(event);
		}
	}

	void tearDown()
	{
		LogManager::shutdown();
	}

	void test0()
	{
		int size = 2;

		CyclicBuffer cb(size);
		LOGUNIT_ASSERT_EQUAL(size, cb.getMaxSize());

		cb.add(e[0]);
		LOGUNIT_ASSERT_EQUAL(1, cb.length());
		LOGUNIT_ASSERT_EQUAL(e[0], cb.get());
		LOGUNIT_ASSERT_EQUAL(0, cb.length());
		LOGUNIT_ASSERT(cb.get() == 0);
		LOGUNIT_ASSERT_EQUAL(0, cb.length());

		CyclicBuffer cb2(size);
		cb2.add(e[0]);
		cb2.add(e[1]);
		LOGUNIT_ASSERT_EQUAL(2, cb2.length());
		LOGUNIT_ASSERT_EQUAL(e[0], cb2.get());
		LOGUNIT_ASSERT_EQUAL(1, cb2.length());
		LOGUNIT_ASSERT_EQUAL(e[1], cb2.get());
		LOGUNIT_ASSERT_EQUAL(0, cb2.length());
		LOGUNIT_ASSERT(cb2.get() == 0);
		LOGUNIT_ASSERT_EQUAL(0, cb2.length());
	}

	void test1()
	{
		for (int bufSize = 1; bufSize <= 128; bufSize *= 2)
		{
			doTest1(bufSize);
		}
	}

	void doTest1(int size)
	{
		//System.out.println("Doing test with size = "+size);
		CyclicBuffer cb(size);

		LOGUNIT_ASSERT_EQUAL(size, cb.getMaxSize());

		int i;

		for (i = -(size + 10); i < (size + 10); i++)
		{
			LOGUNIT_ASSERT(cb.get(i) == 0);
		}

		for (i = 0; i < MAX; i++)
		{
			cb.add(e[i]);

			int limit = (i < (size - 1)) ? i : (size - 1);

			//System.out.println("\nLimit is " + limit + ", i="+i);
			for (int j = limit; j >= 0; j--)
			{
				//System.out.println("i= "+i+", j="+j);
				LOGUNIT_ASSERT_EQUAL(e[i - (limit - j)], cb.get(j));
			}

			LOGUNIT_ASSERT(cb.get(-1) == 0);
			LOGUNIT_ASSERT(cb.get(limit + 1) == 0);
		}
	}

	void testResize()
	{
		for (int isize = 1; isize <= 128; isize *= 2)
		{
			doTestResize(isize, (isize / 2) + 1, (isize / 2) + 1);
			doTestResize(isize, (isize / 2) + 1, isize + 10);
			doTestResize(isize, isize + 10, (isize / 2) + 1);
			doTestResize(isize, isize + 10, isize + 10);
		}

	}

	void doTestResize(int initialSize, int numberOfAdds, int newSize)
	{
		//System.out.println("initialSize = "+initialSize+", numberOfAdds="
		//        +numberOfAdds+", newSize="+newSize);
		CyclicBuffer cb(initialSize);

		for (int i = 0; i < numberOfAdds; i++)
		{
			cb.add(e[i]);
		}

		cb.resize(newSize);

		int offset = numberOfAdds - initialSize;

		if (offset < 0)
		{
			offset = 0;
		}

		int len = (newSize < numberOfAdds) ? newSize : numberOfAdds;
		len = (len < initialSize) ? len : initialSize;

		//System.out.println("Len = "+len+", offset="+offset);
		for (int j = 0; j < len; j++)
		{
			LOGUNIT_ASSERT_EQUAL(e[offset + j], cb.get(j));
		}
	}
};

LOGUNIT_TEST_SUITE_REGISTRATION(CyclicBufferTestCase);