package processorManager;

import java.util.ArrayList;
import java.util.Arrays;


import Interpreter.Interpreter;
import processManagement.lista_procesow;
import processManagement.process_control_block;
import processManagement.ProcessManagment;

public class ProcessorManager {

	private process_control_block processesManagement;

    private Interpreter interpreter;
    private ProcessManagment ProcessManagement1;
    boolean arr[] = new boolean[16];

    public static  process_control_block idleProcess;//proces bezczynnosci;
    lista_procesow listaS;
    public   process_control_block Running;//aktualnie dzialajacy proces
    public process_control_block NextRunningProcess;//kolejny proces do uruchomienia

    public ArrayList<ArrayList<process_control_block>> lista;//stworzenie kolejki priorytetowej




	public ProcessorManager(Interpreter interpreter,ProcessManagment ProcessManagement1)
	{
		this.ProcessManagement1=ProcessManagement1;
		this.listaS=ProcessManagement1.getIstniejaceProcesy();
		this.interpreter=interpreter;
		lista = new ArrayList<ArrayList<process_control_block>>();
		for (int i=0;i<16;i++) {
			lista.add(new ArrayList<process_control_block>());
		}
		idleProcess=listaS.getPCB(0);
		Running=idleProcess;

	}

	public void FindReadyThread()//zrzekanie sie albo uplyniecie kwantu czasu
	{
		CheckBiggest();
		changerunningProcess();
	}

	public void ReadyThread(process_control_block Temp)//decyduje o przysz�osci procesu w momencie zwiekszenia sie jego kwantu czasu
	{
		lista.get(Temp.getPriorytet_dynamiczny()).remove(Temp);
		if(lista.get(Temp.getPriorytet_dynamiczny()).size()==0)
		{
			arr[Temp.getPriorytet_dynamiczny()]=false;
		}
		if(Temp.getPriorytet_dynamiczny()<6)
		{
			Temp.INCPriorytet_Dynamiczny();
		}

		Temp.INCPriorytet_Dynamiczny();

		AddProcess(Temp);

	}

	public void Starving()//zwiekszanie priorytetow w po uplynieciu kwantu czasu
	{

		for(int i=6;i>0;i--)//sprawdzanie tylko dla priorytetow 1-6
		{

			if(lista.get(i).size()>0)
			{

				for(int b=lista.get(i).size()-1;b>=0;b--)
				{

						if(lista.get(i).get(b).getLicznik_wykonanych_rozkazow()>2)//decydowanie co ile rozkazow wykonanych ma zmienic sie priorytet
						{
							lista.get(i).get(b).SetLicznik_wykonanych_rozkazow(0);//resetowanie licznika

							process_control_block temp;//zmienna pomocnicza do przelozenia procesu w liscie na nowe nale�ne jej miejsce
							temp=lista.get(i).get(b);

							ReadyThread(temp);
						}

				}


			}
		}
	}

	public boolean CheckBiggest()//sprawdza czy znajduje sie proces wiekszy od aktualnie wykonywanego, jesli tak ustawia go na jako NextRunningProcess
	{
		if(Running.getStan()==2)
		{
			Running=idleProcess;
		}

		int temp=Running.getPriorytet_dynamiczny();


		if(temp>7)
		{

			for(int i=15;i>7;i--)//sprawdzanie jesli Running jest czasu rzeczywistego
			{
				if(lista.get(i).size()>0)//ZMIANAA NOWE
				{
					NextRunningProcess=lista.get(i).get(0);


					if(lista.get(i).isEmpty()==true)

					{
						arr[i]=false;
					}

					return true;
				}

			}
			NextRunningProcess=idleProcess;
			return false;

		}
		else
		{

			for(int i=15;i>temp;i--)//sprawdzanie czy sa wieksze ktore powinny wywlaszczyc
			{

				if(lista.get(i).size()>0)
				{

					NextRunningProcess=lista.get(i).get(0);//sprawdzanie tylko 1 poniwaz reszta nie ma sensu


					if(lista.get(i).isEmpty()==true)//kontrolowanie arr

					{
						arr[i]=false;
					}

					return true;
				}

			}
			for(int i=6;i>0;i--)//znalezienie innego zamiennika na przyszlosc
			{

				if(lista.get(i).size()>0)
				{

					NextRunningProcess=lista.get(i).get(0);

					return false;
				}

			}

			NextRunningProcess=idleProcess;
			return false;
		}

	}

	public void Clear()
	{

		for(int i=8;i>=0;i--)//sprawdzanie tylko dla priorytetow 1-7
		{

			if(lista.get(i).size()>0)//ZMIANA
			{
				for(int b=lista.get(i).size()-1;b>=0;b--)
				{

						if(lista.get(i).get(b).getStan()==2)
						{

							lista.get(i).remove(b);
							if(lista.get(i).size()==0)
							{
								arr[Running.getPriorytet_dynamiczny()]=false;
							}
						}

				}


			}
		}
	}

	public void IncreaseCounter()
	{

		for(int i=6;i>0;i--)//sprawdzanie tylko dla priorytetow 1-6 ZMIANAA
		{

			if(lista.get(i).size()>0)
			{

				for(int b=0;b<lista.get(i).size();b++)
				{

						lista.get(i).get(b).INCLicznik_wykonanych_rozkazow();


				}


			}
		}
	}

	public void AddProcess(process_control_block Temp)//dodawanie procesu do kolejki priorytetowej
	{
		if(Temp!=Running)
		{
		   	lista.get(Temp.getPriorytet_dynamiczny()).add(Temp);

			if(lista.get(Temp.getPriorytet_dynamiczny()).size()>0)
			{
				arr[Temp.getPriorytet_dynamiczny()]=true;
			}


			if(CheckBiggest()==true)
			{

				changerunningProcess();

			}
		}


	}

	public void GetReady()// dodawanie procesow gotowych do kolejki priorytetowej
	{
		int i=0;
		do
		{
			process_control_block temp1;
			temp1=listaS.getPCB(i);

			if(temp1==Running)
			{
				break;
			}
			if(temp1.getStan()==2)
			{
				break;
			}

			if(arr[temp1.getPriorytet_dynamiczny()]==false)
			{
				if(temp1.getPriorytet_bazowy()==0)
				{
					AddProcess(temp1);
					break;
				}

				AddProcess(temp1);
				i++;
			}
			else
			{
			if(temp1.getPriorytet_bazowy()==0)
			{
				if(lista.get(temp1.getPriorytet_dynamiczny()).contains(temp1)==true)//sprawdzenie czy znajduje sie w liscie oraz dodac i
				{
					break;
				}
				else
				{

					AddProcess(temp1);

				}

				break;
			}

			if(lista.get(temp1.getPriorytet_dynamiczny()).contains(temp1)==true)//sprawdzenie czy znajduje sie w liscie oraz dodac i
			{
				break;
			}
			else
			{

				AddProcess(temp1);
				i++;
			}
			}
		}while(true);
	}

	public void changerunningProcess()//bierze aktualnie dzialajacy proces, umieszcza go na poczatku kolejki oraz zmienia aktualnie wykonywany proces
	{
		if(Running.getStan()==0)
		{
			if(Running.getPriorytet_bazowy()>0) {

				lista.get(Running.getPriorytet_dynamiczny()).add(0,Running);//zmienic arr dodawanie true
				if(lista.get(Running.getPriorytet_dynamiczny()).size()>0)
				{
					arr[Running.getPriorytet_dynamiczny()]=true;
				}

			}
		}

		Running=NextRunningProcess;
		if(lista.get(Running.getPriorytet_dynamiczny()).contains(Running))
		{
			lista.get(Running.getPriorytet_dynamiczny()).remove(Running);
		}



		if(lista.get(Running.getPriorytet_dynamiczny()).size()==0)
		{
			arr[Running.getPriorytet_dynamiczny()]=false;
		}

		NextRunningProcess=idleProcess;
	}

	public void Scheduler()//tu sie wszystko dzieje, z tego miejsca wszystko jest wywo�ywane
	{
		//ProcessManagement1.uporzadkuj_procesy();

		GetReady();

		Starving();

		if(Running.getStan()==1)//sprawdzanie czy aktualnie dzialajacy procesor nie jest w stanie oczekujacym
		{
			FindReadyThread();

			//interpreter.RUN(Running);//odpalanie interpretera
		}
		else
		{


		//	CheckBiggest();

			if(CheckBiggest()) {

				changerunningProcess();
			}


			//interpreter.RUN(Running);//odpalanie interpretera
		}
		 showQueue();
		if(Running.getStan()==2)
		{
			Clear();
			Running=idleProcess;
			NextRunningProcess=idleProcess;
		}


		IncreaseCounter();
		if(Running.getPriorytet_dynamiczny()>Running.getPriorytet_bazowy()) {
			Running.DECPriorytet_Dynamiczny();
		}




	}

	public void showQueue() //metoda pomocnicza do testowania projektu
	{
		System.out.println("\n");
		System.out.println("Running:");
		System.out.println("ID procesu: "+Running.getID());
		System.out.println("Kwant procesu : "+Running.getLicznik_wykonanych_rozkazow());
		System.out.println("Priorytet procesu: "+Running.getPriorytet_dynamiczny());
		for(int i=15;i>=0;i--)
		{

			if(lista.get(i).size()>0)
			{
				for(int b=lista.get(i).size()-1;b>=0;b--)
				{


						System.out.println("\n");
						System.out.println("ID procesu: "+lista.get(i).get(b).getID());
						System.out.println("Kwant procesu : "+lista.get(i).get(b).getLicznik_wykonanych_rozkazow());
						System.out.println("Priorytet procesu: "+lista.get(i).get(b).getPriorytet_dynamiczny());



				}


			}
		}
	}

	public void showRunning() //pokazywanie aktualnie wykonywanego procesu
	{
		if(Running!=idleProcess)
		{
			 System.out.println("\n\nAktualnie jest wykonywany proces, jego informacje to:  \n\n");
	         Running.print();
		}
		else
		{
			System.out.println("\n\nAktualnie nie ma procesu wykonywanego \n\n");
		}
	}

}