source: PROJECT_CORE_MPI/CORE_MPI/BRANCHES/v1.00/templates/Mpi_hcl_process_template.vhd @ 76

entity HT_process is
generic (Task_id : natural:=0);
Port ( clk : in  STD_LOGIC;
reset : in  STD_LOGIC;
  en : in std_logic; -- active la tâche
Interf_i : in  core_i; --signaux pour l'interface IO
  Interf_o : out  core_o; --signaux pour l'interface IO
mem_o : out typ_dpram_o; -- signaux pour l'accès à la mémoire
  mem_i : in typ_dpram_i -- signaux pour l'accès à la mémoire
  );
end HT_process;

architecture Behavioral of HT_process is

  type typ_mae is (start,Fillmem,NextFill,InitApp,GetRank,WInCreate,WinPost,WinStart,
  putdata,getdata,WinWait,WinCompleted,MpiSpawn,finalize,st_timeout);
        signal sram : typ_dpram;
        signal MyGroup:mpi_group;
        signal MyWin : mpi_win;
        signal MyRank :std_logic_vector(3 downto 0);
        signal intercomm,array_of_errcodes : natural;
signal Libr : Core_io;  --regroupe tous les signaux IO de la bibliothèque
signal RunState : typ_mae;

begin

--MAE du PE
--=======================================================================
-- Interf<=Libr;


 pPutGet:process(clk,reset,en)
 

variable destrank : natural range 0 to 15;
variable timeout,ct,dlen,dcount : natural range 0 to 255;
variable SrcAdr,DestAdr : std_logic_vector(ADRLEN-1 downto 0);
variable mywin : Mpi_win;
variable command , argv , maxprocs , info , root : natural:=0; --variable pour le spawn 
variable  adresse,adresse_rd :natural range 0 to 65536;

begin
        
if (clk'event and clk='1') and en='1' then 
        
        
if reset='1' then
--set the default signals values
                
                Libr.O.MemBusy<='0';
                Libr.O.Instr_En<='0';
                sram.O.we<='0';
                sram.O.ena<='0';
                sram.O.enb<='0';
                RunState<=start; --jump to the first state of the FSM
else
        --==========================================================
        --affectation des entrées sorties mémoires
        --These signals binding must remain unchanged for proper functionning of the template !
        sram.i.data_out<=mem_I.data_out;
        mem_o.addr_wr<=sram.O.addr_wr;
        mem_o.addr_rd<=sram.O.addr_rd ; 
        mem_o.we<=sram.O.we;
        mem_o.ena<=sram.O.ena;
        mem_o.enb<=sram.O.enb;
        mem_o.data_in<=sram.O.data_in;
        --affectation des entrées sorties MPI_HCL
        Interf_o.Instr_EN<=Libr.O.instr_en;
        Interf_o.Membusy<=Libr.O.MemBusy;
        Interf_o.Instruction<=Libr.O.Instruction;
        Libr.i.Instr_ack<=Interf_i.Instr_ack;
        Libr.i.InitOk<=Interf_i.InitOk;
        Libr.i.Hold_Req<=Interf_i.Hold_req;
        Libr.i.RamSel<=Interf_i.RamSel;
        --============================================================
        
        case  RunState is
        when start =>
                adresse:=10;dcount:=0;
                RunState<=Fillmem;
         when Fillmem => --this state demonstrate a simple example task that writes data in the communication RAM
                        sram.O.we<='1'; --enables writting
                        sram.O.ena<='1'; 
                        sram.O.enb<='0'; --disable reading on port B
                if Libr.I.Ramsel='0' then       --test if the RAM is free
                        sram.O.addr_wr<=std_logic_vector(to_unsigned(adresse,ADRLEN));
                        sram.O.data_in<=std_logic_vector(to_unsigned(dcount,8)); -- x"0f";
                        Libr.O.MemBusy<='1'; --prevent the MPI-HCL to gain control on the RAM
                        dcount:=dcount+1;
                        
                        if dcount=250 then
                                  RunState<=InitApp;
                                Libr.O.MemBusy<='0'; --release the RAM access
                        else
                                adresse:=adresse+1;
                                RunState<=Fillmem;
                        end if;
        else -- attente de la libéraion de la mémoire /waiting for Ram to be free
                        timeout:=timeout+1;
                          if timeout=200 then
                                report "The RAM is been busy for too long!!!";
                                timeout:=0;
                          end if;
                                        
        end if;

when InitApp =>
                dlen:=15;

                pMPI_Init(ct,Libr,Clk,SRam);

                if ct=0 then 
                        RunState<=GetRank;
                end if;

when GetRank =>

        pMPI_Comm_rank(ct,Libr,sram,MPI_COMM_WORLD,MyRank);

        if ct=0 then
                RunState<=WinCreate;

        end if;

when Wincreate => --ici nous personalisons les HT en fonction de leur rang
--we use this state to fix  HT parameters in regard of thier rank
case MyRank is
when x"0"=>
  Mygroup.grp<=x"0000";-- No rank in this group  ==> No Win_Post
  MyGroup.nb<=2;
  destRank:=1;
when x"1" =>
  Mygroup.grp<=x"000A";--  rank 1 and 3 in this group
  destRank:=0;        -- not use by this HT instance 
  DestAdr:=X"043F";
when x"2" =>
  Mygroup.grp<=x"0000";-- no rank in this group
  destRank:=1;
  DestAdr:=X"044F";
when x"3" =>
  Mygroup.grp<=x"0004";-- rank 2 in this group
  destRank:=0;          -- not use by this HT instance 
  DestAdr:=X"045F";
when others =>
  Mygroup.grp<=x"0000";
  destRank:=0;
end case;
                 RunState<=WinPost;
when WinPost =>
        
        pMPI_Win_Post(ct,Libr,sram,MyGroup,0,MyWin);
        if ct=0 then
        RunState<=WinStart;

        end if;
        
when WinStart =>
        pMPI_Win_start(ct,Libr,sram,MyGroup,0,MyWin);

        if ct=0 then
                RunState<=PutData;
        end if;
when putdata => --construire le packet pour le Put

        SrcAdr:=X"000A"; 
        pMPI_put(ct,Libr,Clk,Sram,SrcAdr,Dlen,MPI_int,destrank,DestAdr,Dlen,Mpi_int,Default_win);       
        if ct=0 then
                RunState<=GetData;
        end if;
        
        
when getdata =>                                 
        SrcAdr:=X"006D";
        destrank:=3;
        if unsigned(MyRank) = 2 then 
                pMPI_GET(ct,Libr,Clk,Sram,SrcAdr,Dlen,MPI_int,destrank,DestAdr,Dlen,Mpi_int,Default_win);
        end if;

        if ct=0 then
          
                RunState<=wincompleted;

        end if;

when WinCompleted =>

         pMPI_Win_Complete(ct,Libr,sram,MyWin );                                        
        if ct=0 then
                RunState<=WinWait;      
                
        end if;   
when WinWait =>
        
         pMPI_Win_wait(ct,Libr,sram,MyWin );

        if ct=0 then
                RunState<=Finalize;     
        end if;   

when finalize =>

                if ct=0 then
                        RunState<=start;        
                        
                end if;  
when others =>
        RunState<=start;
end case;

end if;
end if;

  end process pPutGet;  

end Behavioral;