with Ada.Text_IO;           use Ada.Text_IO;
with Ada.Command_Line;      use Ada.Command_Line;
with Ada.Directories;	     use Ada.Directories;
with Ada.Strings.Fixed;     use Ada.Strings.Fixed;
with Ada.Strings.Unbounded; use Ada.Strings.Unbounded;
with GNAT.Os_Lib;

with Ada.Numerics.Float_Random; use Ada.Numerics.Float_Random;

with Objects;                   use Objects;
with Memories;              use Memories;
use Memories.Memories_Table_Package;
with Memory_set;              use Memory_set;
with Tasks;              use Tasks;
with Task_Set;           use Task_Set;
with Systems;            use Systems;
with Processors;         use Processors;
with Processor_Set;      use Processor_Set;
with Address_Spaces;     use Address_Spaces;
with Address_Space_Set;  use Address_Space_Set;
with Buffers;     use Buffers; 
with Buffer_set;  use Buffer_set;
use Buffers.Buffer_Roles_Package;
with Queueing_Systems; use Queueing_Systems;
with Core_Units;         use Core_Units;
use Core_Units.Core_Units_Table_Package;
with batteries;          use batteries;
with battery_set;        use battery_set;
with Processor_Interface;      use Processor_Interface;
with Scheduler_Interface;      use Scheduler_Interface;

with Random_Tools;             use Random_Tools;
with architecture_factory;     use architecture_factory;
with unbounded_strings;        use unbounded_strings;
with call_framework;           use call_framework;
with feasibility_test.feasibility_interval;
use feasibility_test.feasibility_interval;
with doubles; use doubles;
with priority_assignment.rm;
use priority_assignment.rm;
with Ada.Numerics;
with Ada.Numerics.Float_Random;

with Buffers;                          use Buffers;
with Buffer_Set;                       use Buffer_Set;
with Tasks;				 use Tasks;
with Task_Set;                         use Task_Set;
with Queueing_Systems;                 use Queueing_Systems;
with Buffer_Set;                       use Buffers.Buffer_Roles_Package;
with Dependencies;      use Dependencies;
with task_dependencies; use task_dependencies;

procedure Generate_icq_lib_app is

	sys                  	: System;
	
	a_task			: Generic_task_ptr;
	my_tasks		: Tasks_set;
	my_tasks_iterator	: Tasks_iterator;
	
	a_buffer		: Buffer_ptr;
	my_buffers		: Buffers_set;
	my_buffers_iterator	: Buffers_iterator;
	a_buffer_roles		: Buffer_roles_table;


	dispatchers_period	: Natural		:= 10;
	dispatch_delay		: Natural		:= 1;
	dispatch_priority	: Natural		:= 1;
	
	post_delay		: Natural		:= 10;
		
		
	tasks_set_periodic	: Tasks_set;
	sys_hyperperiod	: Natural		:= 3000;

	Tab : constant Character := Character'Val(9);  -- ASCII code for tabulation
	
	src_file	: Unbounded_String := To_Unbounded_String(Argument(2));
	
	
	function Is_Receiver (
	a_system	: System;
	a_task_name	: String
	)
	return Boolean
	is
	begin
	
		my_buffers := sys.Buffers;
	
		reset_iterator (my_buffers, my_buffers_iterator);
		loop
		current_element (my_buffers, a_buffer, my_buffers_iterator);

			a_buffer_roles := a_buffer.roles;
				
			declare
				
				IndexB  	: Natural := Index(To_String(a_buffer.name), "B");
				sender_name 	:  Unbounded_String;
				receiver_name 	:  Unbounded_String;
			begin
			
				sender_name 	:= To_Unbounded_String(To_String(a_buffer.name)(1 .. IndexB - 1));
				receiver_name 	:= To_Unbounded_String(To_String(a_buffer.name)(IndexB + 1 .. To_String(a_buffer.name)'Last));
				
				

				if receiver_name = a_task_name then
				
					return True;
				end if; 
				
			end;
			

		exit when is_last_element (my_buffers, my_buffers_iterator);
		next_element (my_buffers, my_buffers_iterator);
		end loop;
		
		return False;
		
	end Is_Receiver;

begin

	if Argument_Count < 1 then
		Put ("Usage: " & Command_Name & " ");
		Put_Line ("system_cheddar_file(optionnal)");
		GNAT.OS_Lib.OS_Exit (1);
	end if;

	Call_Framework.initialize (False);

	read_from_xml_file(sys, Argument(1));
	
	if not Exists(Containing_Directory(Argument(1)) & "/GR740") then
		Create_Directory(Containing_Directory(Argument(1)) & "/GR740");
	end if;
	---Begin Generation Main File---
	declare
	
		init_file 	: File_Type;
		
		task_capacity 	: Natural;
	
	begin
	
		Create(init_file, Out_File, Containing_Directory(Argument(1)) & "/GR740/" & To_String(src_file) & ".c");
		
		Put_Line(init_file, "#include ""system.h""");

		Put_Line(init_file, "#include ""icq_spinlock.h""");
		Put_Line(init_file, "#include ""icq_configuration.h""");
		Put_Line(init_file, "#include ""icq_manager.h""");
		Put_Line(init_file, "#include ""icq_task.h""");
		Put_Line(init_file, "#include ""icq_queue.h""");
		Put_Line(init_file, "#include ""icq_spinlock.h""");
		Put_Line(init_file, "#include ""icq_macros.h""");

		Put_Line(init_file, "#include <inttypes.h>");
		Put_Line(init_file, "#include <rtems.h>");
		Put_Line(init_file, "#include <time.h>");
		

		my_tasks := sys.Tasks;

		reset_iterator (my_tasks, my_tasks_iterator);
		loop
		current_element (my_tasks, a_task, my_tasks_iterator);

			if (a_task.task_type = Periodic_Type) then
				add(tasks_set_periodic, a_task);
			end if;

			if To_String(a_task.name)'Length >= 3 then
				if To_String(a_task.name)(1 .. 3) = "ICM" then
				
					dispatchers_period := get(sys.Tasks, a_task.name, period);
					dispatch_priority  := get(sys.Tasks, a_task.name, priority);
					goto Next_Iteration_1;
												
				end if;
				
				
			end if;

			task_capacity := get(sys.Tasks, a_task.name, capacity);

			Put_Line(init_file, "DEFINE_ICQ_PROCESS_BEGINNING(" & To_String(a_task.name) & "_process);");
			Put_Line(init_file, Tab & "icq_task_simulate_execution(" & task_capacity'Image & ");");

			my_buffers := sys.Buffers;
		
			reset_iterator (my_buffers, my_buffers_iterator);
			loop
			current_element (my_buffers, a_buffer, my_buffers_iterator);

				a_buffer_roles := a_buffer.roles;
					
				declare
					
					IndexB  	: Natural := Index(To_String(a_buffer.name), "B");
					sender_name 	:  Unbounded_String;
					receiver_name 	:  Unbounded_String;
				begin
				
					sender_name 	:= To_Unbounded_String(To_String(a_buffer.name)(1 .. IndexB - 1));
					receiver_name 	:= To_Unbounded_String(To_String(a_buffer.name)(IndexB + 1 .. To_String(a_buffer.name)'Last));
					

					if sender_name = a_task.name then
						Put_Line(init_file, Tab & "icq_task_send_message(""" & To_String(receiver_name) & """);");
					end if; 
					
					for i in 0 .. a_buffer_roles.nb_entries loop
					
						if To_String(a_buffer_roles.entries(i).item) = sender_name then
							post_delay := a_buffer_roles.entries(i).data.size;
						else
							dispatch_delay := a_buffer_roles.entries(i).data.size;
						end if;
					
					end loop;
					

				end;
					

			exit when is_last_element (my_buffers, my_buffers_iterator);
			next_element (my_buffers, my_buffers_iterator);
			end loop;


			

			Put_Line(init_file, "DEFINE_ICQ_PROCESS_ENDING(" & To_String(a_task.name) & "_process);");
			Put_Line(init_file,  "");
		
			<<Next_Iteration_1>>
		
		exit when is_last_element (my_tasks, my_tasks_iterator);
		next_element (my_tasks, my_tasks_iterator);
		end loop;

		
		Put_Line(init_file, "void main(void){");
		Put_Line(init_file,  "");

		Put_Line(init_file, Tab & "locked_print_initialize();");
		Put_Line(init_file,  "");

		Put_Line(init_file, Tab & "icq_task_initialize_environment();");
		Put_Line(init_file,  "");
		
		my_tasks := sys.Tasks;
		
		reset_iterator (my_tasks, my_tasks_iterator);
		loop
		current_element (my_tasks, a_task, my_tasks_iterator);

			declare
			
				task_name	: String	:= To_String(a_task.name);
				task_period	: Natural 	:= get(sys.Tasks, a_task.name, period);
				task_priority	: Natural 	:= get(sys.Tasks, a_task.name, priority);
				task_core_name	: String 	:= To_String(get(sys.Tasks, a_task.name, core_name));
				task_core_id	: Natural 	:= Integer'Value(task_core_name(task_core_name'Length .. task_core_name'Length));
			
			begin

				if To_String(a_task.name)'Length >= 3 then
					if To_String(a_task.name)(1 .. 3) = "ICM" then
				
						goto Next_Iteration_2;
												
					end if;
				end if;
			
				
				if Is_Receiver(sys, task_name) then
		               	Put_Line(init_file, Tab & "icq_task_t *" & task_name & " = icq_task_init(""" & task_name & """," & task_period'Image & "," & task_priority'Image & "," & task_core_id'Image & ", 1, " & task_name & "_process);");
		               else
		               	Put_Line(init_file, Tab & "icq_task_t *" & task_name & " = icq_task_init(""" & task_name & """," & task_period'Image & "," & task_priority'Image & "," & task_core_id'Image & ", 0, " & task_name & "_process);");
		               end if;
		               
		               <<Next_Iteration_2>>
			end;

		exit when is_last_element (my_tasks, my_tasks_iterator);
		next_element (my_tasks, my_tasks_iterator);
		end loop;
		
		Put_Line(init_file,  "");
		
		my_buffers := sys.Buffers;
		
		reset_iterator (my_buffers, my_buffers_iterator);
		loop
		current_element (my_buffers, a_buffer, my_buffers_iterator);

			a_buffer_roles := a_buffer.roles;
				
			declare
				
				IndexB  	: Natural := Index(To_String(a_buffer.name), "B");
				sender_name 	:  Unbounded_String;
				receiver_name 	:  Unbounded_String;
			begin
			
				sender_name 	:= To_Unbounded_String(To_String(a_buffer.name)(1 .. IndexB - 1));
				receiver_name 	:= To_Unbounded_String(To_String(a_buffer.name)(IndexB + 1 .. To_String(a_buffer.name)'Last));
				

				Put_Line(init_file, Tab & "icq_task_add_receiver(""" & To_String(sender_name) & """, """ & To_String(receiver_name) & """);"); 
				

			end;
			

		exit when is_last_element (my_buffers, my_buffers_iterator);
		next_element (my_buffers, my_buffers_iterator);
		end loop;
			
		Put_Line(init_file,  "");
			
		Put_Line(init_file, Tab & "icq_task_launch_application();");  
		Put_Line(init_file,  "");

		Put_Line(init_file, Tab & "rtems_task_exit();");
		Put_Line(init_file,  "");
		
		Put_Line(init_file, "}");  
		
		Close(init_file);
		
		Put_Line("./GR740/init.c generated");
	end;
	
	
	
	---Begin Generation ICQ Configuration File---
	declare
	
		icq_configuration_file : File_Type;
	
	begin
	
		sys_hyperperiod := compute_hyperperiod(tasks_set_periodic);
	
		Create(icq_configuration_file, Out_File, Containing_Directory(Argument(1)) & "/GR740/icq_configuration.h");
		
		Put_Line(icq_configuration_file,"#ifndef ICQ_CONFIGURATION_H");
		Put_Line(icq_configuration_file,"#define ICQ_CONFIGURATION_H");
		Put_Line(icq_configuration_file, "");

		Put_Line(icq_configuration_file,"#define CONFIGURE_ICQ_MAXIMUM_INTERCORETASKS 500");

		Put_Line(icq_configuration_file,"#define CONFIGURE_ICQ_INTERCOREMANAGER_PERIOD" & dispatchers_period'Image);
		Put_Line(icq_configuration_file,"#define CONFIGURE_ICQ_INTERCORE_MANAGER_PRIORITY" & dispatch_priority'Image);
		Put_Line(icq_configuration_file, "");
		
		Put_Line(icq_configuration_file,"#define CONFIGURE_ICQ_MAXIMUM_RECEIVERTASKS 100");
		Put_Line(icq_configuration_file, "");
		

		Put_Line(icq_configuration_file,"#define CONFIGURE_ICQ_MESSAGEQUEUE_SIZE 10000");

		Put_Line(icq_configuration_file, "");
		
		Put_Line(icq_configuration_file,"#define CONFIGURE_ICQ_MESSAGE_SIZE 64");
		Put_Line(icq_configuration_file, "");
		
		Put_Line(icq_configuration_file,"#define CONFIGURE_ICQ_POST_DELAY " & post_delay'Image);
		Put_Line(icq_configuration_file, "");

		Put_Line(icq_configuration_file,"#define CONFIGURE_ICQ_DISPATCH_DELAY " & post_delay'Image);

		Put_Line(icq_configuration_file, "");
		
		Put_Line(icq_configuration_file,"/*");
		Put_Line(icq_configuration_file," *  Defines the methods used to implement intercorequeue spinlock");
		Put_Line(icq_configuration_file," *      RTEMS: uses RTEMS semaphore methods");
		Put_Line(icq_configuration_file," *      LEON4: uses CASA SPARV9 instructions ( in progress)");
		Put_Line(icq_configuration_file," */");
		Put_Line(icq_configuration_file,"#define RTEMS");
		Put_Line(icq_configuration_file, "");
		
		Put_Line(icq_configuration_file,"/*");
		Put_Line(icq_configuration_file," *  Defines the methods used for intercommunication");
		Put_Line(icq_configuration_file," *      ICQ_SINGLE_QUEUE: use the solution with only one intercorequeue to manage all the messages");
		Put_Line(icq_configuration_file," *      ICQ_ONE_QUEUE_PER_CORE: use the solution with one intercorequeue for the messages of one core");
		Put_Line(icq_configuration_file," *      ICQ_ONE_QUEUE_PER_SENDER_TASK: use the solution with one intercorequeue for each task of the system");
		Put_Line(icq_configuration_file," */");
		Put_Line(icq_configuration_file,"#define ICQ_ONE_QUEUE_PER_SENDER_TASK");
		Put_Line(icq_configuration_file, "");

		Put_Line(icq_configuration_file,"/*");
		Put_Line(icq_configuration_file," *  If ICQ_LOCKING_CONTROL is define, as soon as a spinlock related to sending or receiving a message is locked, ");
		Put_Line(icq_configuration_file," *  the task is blocked until the user allows it to continue");
		Put_Line(icq_configuration_file," *      ICQ_LOCKING_CONTROL ");
		Put_Line(icq_configuration_file," *      ICQ_NO_LOCKING_CONTROL");
		Put_Line(icq_configuration_file," */");
		Put_Line(icq_configuration_file,"#define ICQ_NO_LOCKING_CONTROL");
		Put_Line(icq_configuration_file, "");
		
		Put_Line(icq_configuration_file,"/*  When unlocking a barrier, it is expected that at least one task will be unlocked.");
		Put_Line(icq_configuration_file," *  If after a certain time no task is unlocked, the program stops trying to unlock a task. ");
		Put_Line(icq_configuration_file," *  This macro defines the maximum waiting time in seconds");
		Put_Line(icq_configuration_file," */");
		Put_Line(icq_configuration_file,"#define ICQ_LOCKING_CONTROL_REALEASE_BARRIER_TIMEOUT_IN_SECONDS 10");
		Put_Line(icq_configuration_file, "");
		
		Put_Line(icq_configuration_file,"#define CONFIGURE_ICQ_EXECUTION_TIME" & Integer(sys_hyperperiod*2)'Image);
		Put_Line(icq_configuration_file, "");
		
		Put_Line(icq_configuration_file,"#define CONFIGURE_ICQ_INTERCOREQUEUE_SIZE 1000");
		Put_Line(icq_configuration_file, "");
		

		Put_Line(icq_configuration_file,"#endif");
		
		Close(icq_configuration_file);
		
		Put_Line("./GR740/icq_configuration.h generated");
	end;
	
	
	---Begin Generation System File---
	declare
	
		system_file : File_Type;
	
	begin
		Create(system_file, Out_File, Containing_Directory(Argument(1)) & "/GR740/system.h");
		
		Put_Line(system_file,"#ifndef SYSTEM_H");
		Put_Line(system_file,"#define SYSTEM_H");
		Put_Line(system_file, "");
		
		Put_Line(system_file,"#include SYSTEM_FILE");
		Put_Line(system_file, "");
		
		Put_Line(system_file,"#include <rtems/bspIo.h>");
		Put_Line(system_file,"#include ""test_support.h""");
		Put_Line(system_file,"#include ""tmacros.h""");
		Put_Line(system_file, "");
		
		Put_Line(system_file,"/* system configuration */");
		Put_Line(system_file,"#define RTEMS");
		Put_Line(system_file, "");
		
		Put_Line(system_file,"#define CONFIGURE_APPLICATION_NEED_CLOCK_DRIVER");
		Put_Line(system_file,"#define CONFIGURE_APPLICATION_NEEDS_CONSOLE_DRIVER");
		Put_Line(system_file, "");
		
		Put_Line(system_file,"#define CONFIGURE_MAXIMUM_PROCESSORS   4");
		Put_Line(system_file, "");
		
		Put_Line(system_file,"#define CONFIGURE_MAXIMUM_TASKS     (70 + CONFIGURE_MAXIMUM_PROCESSORS)");
		Put_Line(system_file,"#define CONFIGURE_MAXIMUM_SEMAPHORES 70");
		Put_Line(system_file,"#define CONFIGURE_MAXIMUM_BARRIER    70");
		Put_Line(system_file,"#define CONFIGURE_MAXIMUM_WAITERS    70");
		Put_Line(system_file, "");
		
		Put_Line(system_file,"#define CONFIGURE_RTEMS_INIT_TASKS_TABLE");
		Put_Line(system_file, "");
		
		Put_Line(system_file,"#include <rtems/confdefs.h>");
		Put_Line(system_file, "");
		
		Put_Line(system_file,"#endif");
		
		Close(system_file);
		
		Put_Line("./GR740/system.h generated");
	end;
	
	---Begin Generation GRMON File---
	declare
	
		grmon_file : File_type;
	
	begin
		Create(grmon_file, Out_File, Containing_Directory(Argument(1)) & "/GR740/grmon.cmd");
		
		Put_Line(grmon_file,"load " & To_String(src_file) & ".exe");
       	Put_Line(grmon_file,"run");
        	Put_Line(grmon_file,"quit");
		
		Close(grmon_file);
		
		Put_Line("./GR740/grmon.cmd generated");
	end;
	
	---Begin Generation Makefile File---
	declare
	
		makefile_file : File_Type;
	
	begin
		Create(makefile_file, Out_File, Containing_Directory(Argument(1)) & "/GR740/Makefile");
		
		Put_Line(makefile_file,"CC    = sparc-gaisler-rtems5-gcc");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"APP_SRC_DIR   = ./");
		Put_Line(makefile_file,"APP_OBJ_DIR   = ./");
		Put_Line(makefile_file,"APP_LIB_DIR   = ./lib");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"CURRENT_DIR = $(shell pwd)");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"CONFIG_FILE ?= $(CURRENT_DIR)/icq_configuration.h");
		Put_Line(makefile_file,"SYSTEM_FILE ?= $(CURRENT_DIR)/system.h");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"ICQFLAGS = CONFIG_FILE=$(CURRENT_DIR)/icq_configuration.h SYSTEM_FILE=$(CURRENT_DIR)/system.h LIB_DIR=$(CURRENT_DIR)/$(APP_LIB_DIR)");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"CFLAGS    = -qbsp=gr740_smp -O2 -g -I$(ICQ_DIR)/include -I/opt/rcc-1.3-rc9-gcc/src/rcc-1.3-rc9/testsuites/support/include");
		Put_Line(makefile_file,"CFLAGS   += -DICQ_CONFIG_FILE=\""$(CONFIG_FILE)\"" -DSYSTEM_FILE=\""$(SYSTEM_FILE)\""");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"LDFLAGS   =  -L$(APP_LIB_DIR) -licq");
		Put_Line(makefile_file,"LD        = $(CC)");
		Put_Line(makefile_file,"CINCLUDE  = ");
		Put_Line(makefile_file,"LIBS      = ");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"COMPILE   = $(CC) $(CFLAGS) $(CINCLUDE) -c");
		Put_Line(makefile_file,".c.o: ");
		Put_Line(makefile_file,Tab & "$(COMPILE)  $< ");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"####################################################");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"ICQ_LIB = $(APP_LIB_DIR)/libicq.a");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"APP_SRC = init.c");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"all: clean $(APP_SRC:.c=.exe)");
		Put_Line(makefile_file, "");

		Put_Line(makefile_file,"$(APP_SRC:.c=.exe): $(APP_SRC:.c=.o) | $(ICQ_LIB) $(CONFIG_FILE) $(SYSTEM_FILE)");
		Put_Line(makefile_file,Tab & "$(CC) $(CFLAGS) $(APP_SRC:.c=.o) $(LIBS) $(LDFLAGS) -o $(APP_SRC:.c=.exe)");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"$(ICQ_LIB) $(CONFIG_FILE) $(SYSTEM_FILE): $(APP_LIB_DIR)");
		Put_Line(makefile_file,Tab & "make -C $(ICQ_DIR) $(ICQFLAGS)");
		Put_Line(makefile_file, "");
		
		Put_Line(makefile_file,"$(APP_LIB_DIR):");
		Put_Line(makefile_file,Tab & "mkdir -p $(APP_LIB_DIR)");
		Put_Line(makefile_file, "");

		Put_Line(makefile_file,"clean:");
		Put_Line(makefile_file,Tab & "rm -f *.a *.o *.bak core *.exe");
		Put_Line(makefile_file,Tab & "rm -rf $(APP_LIB_DIR)");
			
		Close(makefile_file);
		
		Put_Line("./GR740/Makefile generated");
	end;

end Generate_icq_lib_app;