Subversion Repositories async_sdm_noc

/*
 Asynchronous SDM NoC
 (C)2011 Wei Song
 Advanced Processor Technologies Group
 Computer Science, the Univ. of Manchester, UK
 
 Authors: 
 Wei Song     wsong83@gmail.com
 
 License: LGPL 3.0 or later
 
 A SystemC network adapter/interface for NoC simulation.
 
 History:
 23/12/2008  Initial version. <wsong83@gmail.com>
 30/09/2010  Use template style packet definition. <wsong83@gmail.com>
 16/10/2010  Support SDM. <wsong83@gmail.com>
 05/06/2011  Clean up for opensource. <wsong83@gmail.com>
 
*/
 
#include "ni.h"
 
Network_Adapter::Network_Adapter(
         sc_module_name     name            // module name
        ,unsigned int       x               // location x
        ,unsigned int       y               // location y
    ):
         sc_module(name),
	 frame_in("FrmIn"),
	 frame_out("FrmOut"),
	 IP("IP"),
	 OP("OP"),
         loc_x(x),
         loc_y(y),
	 oflit(1)
{
  sc_spawn_options opt;
 
  for(unsigned int i=0; i<SubChN; i++) {
    token[i] = BufDepth/2;
  }
 
  for(unsigned int i=0; i<SubChN; i++) {
    sc_spawn(sc_bind(&Network_Adapter::ibuffer_thread, this, i), NULL, &opt);
    sc_spawn(sc_bind(&Network_Adapter::obuffer_thread, this, i), NULL, &opt);
    sc_spawn(sc_bind(&Network_Adapter::credit_update, this, i), NULL, &opt);
  }
 
  SC_THREAD(oport);
  SC_THREAD(iport);
 
}
 
Network_Adapter::~Network_Adapter()
{
}
 
// read in the incoming frame
void Network_Adapter::ibuffer_thread(unsigned int ii){
  FRAME mframe; 
  FLIT mflit;
 
  while(1){
    mframe.clear();
 
    while(1) {
      mflit = iflit[ii].read();
      mframe << mflit;
 
      if(mflit.ftype == F_TL)	break;
    }
 
    frame_out->write(mframe);
  }
}
 
// send out a frame
void Network_Adapter::obuffer_thread(unsigned int ii){
 
  FRAME mframe; 
  FLIT mflit;
 
  while(1){
    mframe = frame_in->read();
 
    while(1) {
      mframe >> mflit;
      mflit.vcn = ii;
 
      //fetch a token
      if(token[ii] == 0)
	wait(token_arrive[ii]);
 
      token[ii]--;
 
      oflit.write(mflit);
 
      if(mflit.ftype == F_TL) break;
    }
  }
}
 
 
void Network_Adapter::oport() {
  FLIT mflit;
 
  while(1) {
    mflit = oflit.read();
    OP->write(mflit);
  }
}
 
void Network_Adapter::iport() {
  FLIT mflit;
 
  while(1) {
    mflit = IP->read();
    iflit[mflit.vcn].write(mflit);
  }
}
 
void Network_Adapter::credit_update(unsigned int ii) {
 
  CPa[ii].write(false);
  while(1) {
    if(!CP[ii].read())
      wait(CP[ii].posedge_event());
 
    token[ii]++;
    token_arrive[ii].notify();
    CPa[ii].write(true);
 
    wait(CP[ii].negedge_event());
    CPa[ii].write(false);
  }
}
 
bool Network_Adapter::check_frame(const FRAME& frame)
{
    // TODO: check the integerity, dummy right noe
    return true;
}