Changes between Version 103 and Version 104 of Writing Rules/Tlmt

Timestamp:

Mar 2, 2009, 5:35:03 PM (15 years ago)

Author:

alinevieiramello@…

Comment:

--

Writing Rules/Tlmt

@@ -256 +256 @@
 
 {{{
+#include "my_initiator.h"                       // Our header
+
+my_initiator::my_initiator
+            ( sc_core::sc_module_name name,           // module name
+              const soclib::common::IntTab &index,    // index of mapping table
+              const soclib::common::MappingTable &mt, // mapping table
+              uint32_t time_quantum)                  // time quantum
+            : sc_module(name),                        // init module name
+            m_mt(mt),                                 // mapping table
+            p_vci_initiator("socket")                 // vci initiator socket name
+{ 
+  //register callback function VCI INITIATOR SOCKET
+  p_vci_initiator.register_nb_transport_bw(this, &my_initiator::my_nb_transport_bw);
+ 
+  //initiator identification
+  m_srcid = mt.indexForId(index);
+
+  //Quantum keeper
+  tlm_utils::tlm_quantumkeeper::set_global_quantum(time_quantum * UNIT_TIME);
+  m_QuantumKeeper.reset();
+
+  //initialize the local time
+  m_local_time= 0 * UNIT_TIME;
+  
+  //initialize the activity variable
+  setActivity(true);
+  
+  // register thread process
+  SC_THREAD(behavior);    
+}
+
+/////////////////////////////////////////////////////////////////////////////////////
+// Fuctions
+/////////////////////////////////////////////////////////////////////////////////////
+bool my_initiator::getActivity()
+{
+  return m_activity_status;
+}
+
+void my_initiator::setActivity(bool t)
+{
+  m_activity_status =t;
+}
+
+//send a message to network to inform the current activity status
+void my_initiator::sendActivity()
+{
+  tlm::tlm_generic_payload *payload_ptr = new tlm::tlm_generic_payload();
+  tlm::tlm_phase            phase;
+  sc_core::sc_time          send_time;
+  soclib_payload_extension *extension_ptr = new soclib_payload_extension();
+
+  // set the active or inactive command
+  if(m_activity_status) extension_ptr->set_active();
+  else extension_ptr->set_inactive();
+  // set the extension to tlm payload
+  payload_ptr->set_extension (extension_ptr);
+  //set the tlm phase
+  phase = tlm::BEGIN_REQ;
+  //set the local time to transaction time
+  send_time = m_local_time;
+  //send the message
+  p_vci_initiator->nb_transport_fw(*payload_ptr, phase, send_time);
+  //wait a response
+  wait(m_rspEvent);
+}
+
+sc_core::sc_time my_initiator::getLocalTime()
+{
+  return m_local_time;
+}
+
+void my_initiator::setLocalTime(sc_core::sc_time &t)
+{
+  m_local_time=t;
+}
+
+void my_initiator::addTime(sc_core::sc_time t)
+{
+  m_local_time= m_local_time + t;
+}
+
+//send a null message to network to inform the current local time
+void my_initiator::sendNullMessage()
+{
+  tlm::tlm_generic_payload *payload_ptr = new tlm::tlm_generic_payload();
+  tlm::tlm_phase            phase;
+  sc_core::sc_time          send_time;
+  soclib_payload_extension *extension_ptr = new soclib_payload_extension();
+
+  // set the null message command
+  extension_ptr->set_null_message();
+  // set the extension to tlm payload
+  payload_ptr->set_extension(extension_ptr);
+  //set the tlm phase
+  phase = tlm::BEGIN_REQ;
+  //set the local time to transaction time
+  send_time = m_local_time;
+  //send the null message 
+  p_vci_initiator->nb_transport_fw(*payload_ptr, phase, send_time);
+  //deschedule
+  wait(sc_core::SC_ZERO_TIME);
+}
+// initiator thread 
+void my_initiator::behavior(void)
+{ 
+  tlm::tlm_generic_payload *payload_ptr = new tlm::tlm_generic_payload();
+  tlm::tlm_phase            phase;
+  sc_core::sc_time          send_time;
+  soclib_payload_extension *extension_ptr = new soclib_payload_extension();
+ 
+  uint32_t nwords = 1;
+  uint32_t nbytes= nwords * vci_param::nbytes;
+  unsigned char data[nbytes];
+  unsigned char byte_enable[nbytes];
+  unsigned int byte_enable_enabled = 0xffffffff;
+  unsigned int pktid = 0;
+ 
+  while (true){
+    
+    addTime(1000 * UNIT_TIME);
+    m_QuantumKeeper.inc(1000 * UNIT_TIME);
+    
+    for(unsigned int i=0, j=0; i<nwords; i++, j+=4){
+      utoa(byte_enable_enabled, byte_enable, j);
+      utoa(data_int[i], data, j);
+      data_int[i]++;
+    }
+
+    // set the values in tlm payload
+    payload_ptr->set_command(tlm::TLM_IGNORE_COMMAND);
+    payload_ptr->set_address(address[idx]);
+    payload_ptr->set_byte_enable_ptr(byte_enable);
+    payload_ptr->set_byte_enable_length(nbytes);
+    payload_ptr->set_data_ptr(data);
+    payload_ptr->set_data_length(nbytes);
+    // set the values in payload extension
+    extension_ptr->set_write();
+    extension_ptr->set_src_id(m_srcid);
+    extension_ptr->set_trd_id(0);
+    extension_ptr->set_pkt_id(pktid);
+    // set the extension to tlm payload
+    payload_ptr->set_extension (extension_ptr );
+    // set the tlm phase
+    phase = tlm::BEGIN_REQ;
+    // set the local time to transaction time
+    m_send_time = m_local_time;
+
+#if MY_INITIATOR_DEBUG
+    std::cout << "[INITIATOR " << m_srcid << "] send cmd packet id = " <<  pktid << " time = " << m_local_time.value() << std::endl;
+#endif
+    
+    // send the transaction
+    p_vci_initiator->nb_transport_fw(*payload_ptr, phase, m_send_time);
+    wait(m_rspEvent);
+
+#if MY_INITIATOR_DEBUG
+    payload_ptr->get_extension( extension_ptr );
+    std::cout << "[INITIATOR " << m_srcid << "] receive rsp packet id = " << extension_ptr->get_pkt_id() << " time = " << m_local_time.value() << std::endl;
+#endif
+
+    pktid++;
+
+    addTime(1000 * UNIT_TIME);
+    m_QuantumKeeper.inc(1000 * UNIT_TIME);
+ 
+    // set the values in tlm payload
+    payload_ptr->set_command(tlm::TLM_IGNORE_COMMAND);
+    payload_ptr->set_address(address[idx]);
+    payload_ptr->set_byte_enable_ptr(byte_enable);
+    payload_ptr->set_byte_enable_length(nbytes);
+    payload_ptr->set_data_ptr(data);
+    payload_ptr->set_data_length(nbytes);
+    // set the values in payload extension
+    extension_ptr->set_read();
+    extension_ptr->set_src_id(m_srcid);
+    extension_ptr->set_trd_id(0);
+    extension_ptr->set_pkt_id(pktid);
+    // set the extension to tlm payload
+    payload_ptr->set_extension (extension_ptr );
+    // set the tlm phase
+    phase = tlm::BEGIN_REQ;
+    // set the local time to transaction time
+    m_send_time = m_local_time;
+   
+#if MY_INITIATOR_DEBUG
+    std::cout << "[INITIATOR " << m_srcid << "] send cmd packet id = " <<  pktid << " time = " << m_local_time.value() << std::endl;
+#endif
+
+    p_vci_initiator->nb_transport_fw(*payload_ptr, phase, m_send_time);
+    wait(m_rspEvent);
+
+#if MY_INITIATOR_DEBUG
+    payload_ptr->get_extension( extension_ptr );
+    std::cout << "[INITIATOR " << m_srcid << "] receive rsp packet id = " << extension_ptr->get_pkt_id() << " time = " << m_local_time.value() << std::endl;
+
+    for(unsigned int i=0, j=0; i<nwords; i++, j+=4){
+      std::cout << "[" << std::hex << (payload_ptr->get_address() + j) << "] = " << atou(payload_ptr->get_data_ptr(),j) << std::dec;
+      if(payload_ptr->is_response_error())
+        std::cout << " ERROR";
+      std::cout << std::endl;
+    }
+#endif
+
+    pktid++;
+    idx++;
+    if(idx==6) idx=0;
+    
+    // if initiator needs synchronize then it sends a null message and resets the quantum keeper
+    if (m_QuantumKeeper.need_sync()) {
+      sendNullMessage();
+      m_QuantumKeeper.reset();
+    }
+  
+  } // end while true
+  setActivity(false);
+  sendActivity();
+} // end initiator_thread 
+
+
+/////////////////////////////////////////////////////////////////////////////////////
+// Virtual Fuctions  tlm::tlm_bw_transport_if (VCI SOCKET)
+/////////////////////////////////////////////////////////////////////////////////////
+
+/// receive the response packet from target socket
+tlm::tlm_sync_enum my_initiator::my_nb_transport_bw  // inbound nb_transport_bw
+( tlm::tlm_base_protocol_types::tlm_payload_type &payload, // payload
+  tlm::tlm_base_protocol_types::tlm_phase_type   &phase,   // phase
+  sc_core::sc_time                   &time     // time
+ )
+
+{
+  setLocalTime(time);
+  m_QuantumKeeper.inc(time - m_send_time);
+  m_rspEvent.notify(0 * UNIT_TIME);
+  return tlm::TLM_COMPLETED;
+} // end backward nb transport 
+
 
 }}}