Ignore:
Timestamp:
Jan 7, 2011, 1:50:18 PM (14 years ago)
Author:
choichil
Message:

Synthetic Initiator with parallel transactions

File:
1 edited

Legend:

Unmodified
Added
Removed

  • trunk/modules/vci_synthetic_initator/caba/sources/src/vci_synthetic_initiator.cpp

    r122 r123  
     1
    12/* -*- c++ -*-
    2  * File         : vci_traffic_generator.cpp
    3  * Date         : 26/08/2010
     3 * File         : vci_synthetic_initiator.cpp
     4 * Date         : 23/12/2010
    45 * Copyright    : UPMC / LIP6
    56 * Authors      : Christophe Choichillon
     7 * Version      : 2.0
    68 *
    79 * SOCLIB_LGPL_HEADER_BEGIN
    … …  
    8284    m_date_fifo("m_date_fifo", depth),
    8385    m_local_seed(m_srcid),
    84     r_vci_fsm("r_vci_fsm")
     86    r_cmd_fsm("r_cmd_fsm")
    8587    {
    8688
     89      r_req_id = new sc_signal<uint64_t>*[tab_size];
     90      for(int i = 0; i < tab_size ; i++){
     91        r_req_id[i] = new sc_signal<uint64_t>[2];
     92      }
    8793
    8894      SC_METHOD(transition);
    … …  
    123129  //////////////////////////////////
    124130  {
    125         const char* state_str[] = { "IDLE",
    126                                      "SINGLE_SEND",
    127                                      "SINGLE_RECEIVE",
    128                                      "BC_SEND",
    129                                      "BC_RECEIVE" };
     131        const char* state_cmd_str[] = { "IDLE",
     132                                        "SINGLE_SEND",
     133                                        "BC_SEND"};
     134
     135        const char* state_bc_rsp_str[] = {"IDLE",
     136                                          "WAIT_RSP"};
    130137
    131138        std::cout << "Vci_Synthetic_Initiator " << name()
    132139                  << " : " << std::dec << m_cpt_cycles << " cycles "
    133                   << " : state = " << state_str[r_vci_fsm]
     140                  << " : state_cmd_fsm = " << state_cmd_str[r_cmd_fsm]
     141                  << " : state_rsp_fsm = " << state_bc_rsp_str[r_bc_rsp_fsm]
    134142                  << " Adresse to send : " << std::hex << m_address_to_send
    135                   << " Number of broadcast to receive : " << std::dec << m_bc_nrsp << std::endl;
     143                  << " Number of broadcast to receive : " << std::dec << r_bc_nrsp.read()
     144                  << " Number of packets sent : " << std::dec << m_npackets << m_id_to_send << std::endl;
     145        for(int i = 0; i < (1<<vci_param::T) ; i++){
     146          std::cout << "ID : " << i << " " << r_req_id[i][0].read() << " " << r_req_id[i][0].read() << std::endl;
     147        }
    136148  }
    137149
    … …  
    158170
    159171      // Initializing FSMs
    160       r_vci_fsm = VCI_IDLE;
     172      r_cmd_fsm = VCI_IDLE;
     173
     174      r_bc_rsp_fsm = BC_RSP_IDLE;
    161175
    162176      // Initializing FIFOs
    … …  
    173187      m_latency_bc              = 0;
    174188      m_nb_bc                   = 0;
     189      m_id_to_send              = -1;
    175190
    176191      r_broadcast_req           = false;
     192
     193      r_broadcast_rsp           = false;
     194
     195      r_bc_nrsp                 = 0;
     196
     197      for(int i = 0; i < tab_size; i++){
     198        r_req_id[i][0] = 0;
     199        r_req_id[i][1] = 0;
     200        //std::cout << name() << " bla bla " << i << std::endl;
     201      }
    177202
    178203      return;
    … …  
    184209
    185210
    186     switch ( r_vci_fsm.read() ) {
    187 
    188         std::cout << m_cpt_cycles << " cycles, " << m_npackets << " packets sent" << std::endl;
    189       //printStats();
     211    // FSM controling effective requests send
     212    switch ( r_cmd_fsm.read() ) {
    190213      //////////////////
    191214      case VCI_IDLE:
    192215        {
    193216          if (m_date_fifo.rok()){
    194             if (r_broadcast_req.read()){
     217            if (r_broadcast_req.read() && !r_broadcast_rsp.read()){
    195218              m_address_to_send = 0x3 | (0x7c1f << vci_param::N-20) ;
    196               r_vci_fsm = VCI_BC_SEND ;
     219              r_cmd_fsm = VCI_BC_SEND ;
    197220            } else {
    198               r_vci_fsm = VCI_SINGLE_SEND ;
     221              for(int i = 0; i < tab_size; i++){
     222                if(r_req_id[i][0] == 0){
     223                  m_id_to_send = i;
     224                  break;
     225                }else{
     226                  m_id_to_send = -1;
     227                }
     228              }
     229              if(m_id_to_send == -1){
     230                r_cmd_fsm = VCI_IDLE ;
     231                break;
     232              } else {
     233                r_cmd_fsm = VCI_SINGLE_SEND ;
     234              }
    199235#ifdef DETERMINISTIC
    200236              m_address_to_send = destAdress(&m_local_seed) << (vci_param::N)-(soclib::common::uint32_log2((uint32_t)m_xmesh)+soclib::common::uint32_log2((uint32_t)m_ymesh));
    … …  
    212248          if (p_vci.cmdack.read()){
    213249            if (m_count == m_length-1) {
    214               m_start_latency1 = m_date_fifo.read();
    215               m_start_latency2 = m_cpt_cycles;
    216               r_vci_fsm = VCI_SINGLE_RECEIVE ;
     250              r_req_id[(int)m_id_to_send][0] = m_date_fifo.read();
     251              r_req_id[m_id_to_send][1] = m_cpt_cycles;
     252              date_fifo_get = true;
     253              r_cmd_fsm = VCI_IDLE ;
    217254            } else {
    218               r_vci_fsm = VCI_SINGLE_SEND ;
     255              r_cmd_fsm = VCI_SINGLE_SEND ;
    219256              m_count++;
    220257            }
    … …  
    222259          break;
    223260        }
    224         //////////////////////
    225       case VCI_SINGLE_RECEIVE:
     261      ///////////////////
     262      case VCI_BC_SEND:
    226263        {
    227264          if (p_vci.rspval.read()) {
    228             m_latency1 = m_latency1 + (m_cpt_cycles - m_start_latency1);
    229             m_latency2 = m_latency2 + (m_cpt_cycles - m_start_latency2);
    230             m_npackets++;
     265            r_bc_nrsp = (m_xmax - m_xmin) * (m_ymax - m_ymin) ;
     266            m_start_latency_bc = m_cpt_cycles;
    231267            date_fifo_get = true;
    232             m_address_to_send = 0;
    233             r_vci_fsm = VCI_IDLE ;
    234           }
    235           break;
    236         }
    237         ///////////////////
    238       case VCI_BC_SEND:
    239         {
    240           if (p_vci.cmdack.read()) {
    241             m_bc_nrsp = (m_xmax - m_xmin) * (m_ymax - m_ymin) ;
    242             m_start_latency_bc = m_cpt_cycles;
    243             r_vci_fsm = VCI_BC_RECEIVE;
     268            r_broadcast_rsp = true;
     269            r_bc_rsp_fsm = VCI_IDLE;
    244270            break;
    245271          }
    246272        }
    247         ////////////////////
    248       case VCI_BC_RECEIVE:
    249         {
    250           if (p_vci.rspval.read()){
    251             if (m_bc_nrsp == 1) {
     273
     274    } // end switch vci_fsm
     275
     276    switch(r_bc_rsp_fsm.read()){
     277      ///////////////////
     278      case BC_RSP_IDLE:
     279        {
     280          if (p_vci.rspval.read() && r_broadcast_rsp.read()) {
     281            r_bc_rsp_fsm = BC_RSP_WAIT_RSP;
     282            break;
     283          }
     284        }
     285      ////////////////////
     286      case BC_RSP_WAIT_RSP:
     287        {
     288          if (p_vci.rspval.read() && (p_vci.rpktid.read() == 1)){
     289            if (r_bc_nrsp == 1) {
    252290              r_broadcast_req = false;
     291              r_broadcast_rsp = false;
    253292              m_address_to_send = 0;
    254               date_fifo_get = true;
    255293              m_latency_bc = m_latency_bc + (m_cpt_cycles - m_start_latency_bc);
    256294              m_nb_bc++;
    257               r_vci_fsm = VCI_IDLE ;
     295              r_bc_rsp_fsm = BC_RSP_IDLE ;
    258296            } else {
    259               m_bc_nrsp--;
    260               r_vci_fsm = VCI_BC_RECEIVE ;
     297              r_bc_nrsp = r_bc_nrsp.read() - 1;;
     298              r_bc_rsp_fsm = BC_RSP_WAIT_RSP ;
    261299            }
    262300          }
    263301          break;
    264         }
    265     } // end switch vci_fsm
    266 
     302        }   
     303    }
     304
     305    if(p_vci.rspval.read()){
     306      if((int)(p_vci.pktid.read()) == 0){
     307        m_latency1 = m_latency1 + (m_cpt_cycles - r_req_id[(int)(p_vci.trdid.read())][0]);
     308        m_latency2 = m_latency2 + (m_cpt_cycles - r_req_id[(int)(p_vci.trdid.read())][1]);
     309        m_npackets++;
     310        r_req_id[(int)(p_vci.trdid.read())][0] = 0;
     311        r_req_id[(int)(p_vci.trdid.read())][1] = 0;
     312      }
     313    }
    267314
    268315    /////////////////// Filling fifo
    … …  
    305352     p_vci.cmd        = vci_param::CMD_WRITE;   
    306353     p_vci.be         = 0xF;                             
     354     p_vci.srcid      = m_srcid;   
    307355     p_vci.pktid      = 0;     
    308      p_vci.srcid      = m_srcid;   
    309356     p_vci.cons       = false;       
    310357     p_vci.wrap       = false;       
    … …  
    312359     p_vci.clen       = 0;         
    313360     p_vci.cfixed     = false;           
    314 
    315 
    316     switch ( r_vci_fsm.read() ) {
     361     p_vci.rspack     = true;
     362
     363
     364    switch ( r_cmd_fsm.read() ) {
    317365
    318366      //////////////////
    … …  
    325373          p_vci.trdid   = 0;                 
    326374          p_vci.eop     = false;                                   
    327           p_vci.rspack  = false;
    328375          break;
    329376        }
    … …  
    335382          p_vci.plen    = m_length*4;                                         
    336383          p_vci.wdata   = 0;                                       
    337           p_vci.trdid   = 0;                 
     384          p_vci.trdid   = m_id_to_send;                 
    338385          if (m_count == m_length - 1 ) {
    339386            p_vci.eop     = true;                                   
    … …  
    341388            p_vci.eop     = false;                                   
    342389          }
    343           p_vci.rspack  = false;
    344           break;
    345         }
    346         //////////////////////
    347       case VCI_SINGLE_RECEIVE:
    348         {
    349           p_vci.cmdval  = false;                 
    350           p_vci.address = 0;
    351           p_vci.plen    = 0;                                         
    352           p_vci.wdata   = 0;                                       
    353           p_vci.trdid   = 0;                 
    354           p_vci.eop     = false;                                   
    355           p_vci.rspack  = true;
    356           break;
     390          break;
    357391        }
    358392        ///////////////////
    … …  
    363397          p_vci.plen    = 4;                                         
    364398          p_vci.wdata   = 0;                                       
     399          p_vci.pktid   = 1;     
    365400          p_vci.trdid   = 0;                 
    366401          p_vci.eop     = true;                                   
    367           p_vci.rspack  = false;
    368           break;
    369         }
    370         ////////////////////
    371       case VCI_BC_RECEIVE:
    372         {
    373           p_vci.cmdval  = false;                 
    374           p_vci.address = 0;
    375           p_vci.plen    = 0;                                         
    376           p_vci.wdata   = 0;                                       
    377           p_vci.trdid   = 0;                 
    378           p_vci.eop     = false;                                   
    379           p_vci.rspack  = true;
    380           break;
    381         }
    382     } // end switch vci_fsm
     402          break;
     403        }
     404    } // end switch vci_cmd_fsm
    383405
    384406  } // end genMoore()
Note: See TracChangeset for help on using the changeset viewer.