/*!
 * \file main.cpp
 * \author S. Eisenhauer
 * \date 31.08.2011
 * \brief Application startup
 */
 
/*!
 *	\mainpage XORAYA Plugin executor
 *	This is the main application running on the XORAYA connect to integrate with CanEasy.
*/
 
#include <errno.h>
#include <sys/mman.h>
#include <string.h>
#include <boost/thread.hpp>
#include <boost/bind.hpp>

#include "CPluginExecutor.h"
#include "global.h"

/*!
* \brief Allocates a safe stack
*/
void prefault_stack()
{
    unsigned char aucDummy[nMAX_SAFE_STACK];

    memset(aucDummy, 0, nMAX_SAFE_STACK);
    return;
}

/*!
* \brief Prevents memory of this process to be swapped to disc
* \warning process needs root privileges for this to work correctly
*/
void lockmem()
{
	int res = 0;
	if( (res = mlockall(MCL_CURRENT|MCL_FUTURE)) != 0)
	{
		ERROR_PRINT("mlockall failed: %d errno: %d",res,errno);
		//exit(-2);
	}
}

/*!
* \brief initialization code
*/
void init()
{
	lockmem();
	prefault_stack();
}

/*!
* \brief application starts here
* \param[in] argc number of arguments passed to process
* \param[in] argv the arguments
* \return exit code, 0 on success
*/
int main(int argc, char* argv[])
{
	int res = 0;
	int schedulerPolicy;
	sched_param sp;

	init();

	static CPluginExecutor xPluginExec;
	boost::thread xExecThread(
			boost::function<void()>(
					boost::bind(&CPluginExecutor::vRun,boost::ref(xPluginExec))
			)
	);

	if( argc == 2)
	{
		if( strcmp(argv[1],"RT") == 0 )
		{
			schedulerPolicy = SCHED_FIFO;
			sp.sched_priority = tenPrio::nenRT ; // rt priority
			if(pthread_setschedparam(xExecThread.native_handle(), schedulerPolicy, &sp))
			{
				ERROR_PRINT("pthread_setschedparam failed. Errno: %d",errno);
			}
		}
	}

	if( (res = pthread_getschedparam(xExecThread.native_handle(),&schedulerPolicy,&sp)) != 0 )
	{
		ERROR_PRINT("pthread_getschedparam failed: %d errno: %d",res,errno);
	}
	else
	{
		DEBUG_PRINT("executor thread prio: %d scheduler: %s"
				,sp.sched_priority
				,(schedulerPolicy==SCHED_OTHER)?"SCHED_OTHER":
						(schedulerPolicy==SCHED_FIFO)?"SCHED_FIFO":
								(schedulerPolicy==SCHED_RR)?"SCHED_RR":"other");
	}

	xExecThread.join();
	DEBUG_PRINT("exiting");
	return 0;
}