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
 
 The SystemC processing element.
 
 History:
 26/02/2011  Initial version. <wsong83@gmail.com>
 31/05/2011  Clean up for opensource. <wsong83@gmail.com>
 
*/
 
#ifndef PROCELEM_H_
#define PROCELEM_H_
 
#include "define.h"
#include <systemc.h>
 
 
// a function to generate random numbers comply with an exponential distribution with expection exp
double rand_exponential(double exp) {
  unsigned int rint = rand() % (unsigned int)(1e6);
  double rdat = rint * 1.0 / 1e6;
  return (-1.0 * exp * log(rdat));
}
 
class ProcElem : public sc_module {
 
public:
  sc_in<bool>  rst_n;		// active low reset
  sc_port<sc_fifo_out_if<FRAME> > Fout;	// frame output port
  sc_port<sc_fifo_in_if<FRAME> > Fin;	// frame input port
 
  SC_HAS_PROCESS(ProcElem);
 
  unsigned int addrx, addry;	// the local address
 
  ProcElem(sc_module_name nm, unsigned int addrx, unsigned int addry)
  : sc_module(nm), addrx(addrx), addry(addry)
  {
    SC_THREAD(tproc);		// frame transmission thread
    SC_THREAD(rproc);		// frame receiving thread
  }
 
  // the transmission thread
  void tproc() {
    // waiting for reset
    wait(rst_n.posedge_event());
 
    while(1) {
      // wait for a random interval
      if(FFreq != 0) {
	double rnum = rand_exponential(1e6/FFreq);
	wait(rnum, SC_PS);
      }
 
      // generate a frame
      // specify the target address according to random uniform traffic
      unsigned int rint, tarx, tary;
      rint = rand()%(DIMX*DIMY-1);
      if(rint == addrx*DIMY + addry)
	rint = DIMX*DIMY-1;
 
      tarx = rint/DIMY;
      tary = rint%DIMY;
 
      // initialize the frame object
      FRAME tframe(FLEN);
 
      // fill in the fields
      tframe.addrx = tarx;
      tframe.addry = tary;
      for(unsigned int i=0; i<FLEN; i++)
	tframe.push(rand()&0xff);
 
      // specify the unique key of each frame
      // a key is 32 bits log
      // in this test bench, it is the first 4 bytes of the frame payload
      unsigned long key = 0;
      for(unsigned int i=0; (i<FLEN && i<4); i++) {
	key <<= 8;
	key |= tframe[i];
      }
 
      // record the new frame
      ANA->start(key, sc_time_stamp().to_double());
 
      // sen the frame to the router
      Fout->write(tframe);
    }
  }
 
  // the receiving thread
  void rproc() {
    while(1) {
      // initialize a space for the frame
      FRAME rframe;
 
      // read in the frame
      rframe = Fin->read();
      unsigned long key = 0;
 
      // regenerate the unique key
      for(unsigned int i=0; (i<FLEN && i<4); i++) {
	key <<= 8;
	key |= rframe[i];
      }
 
      // check the key in the simulation analysis database and update info.
      if(!ANA->stop(key, sc_time_stamp().to_double(), rframe.psize())) {
        // report error when no match is found
	cout << sc_time_stamp() << " " << name() ;
        cout << "packet did not find!" << endl;
        cout << rframe << endl;
        sc_stop();
      }
    }
  }
 
};
 
#endif