/**********************************************************************    The following code is derived, directly or indirectly, from the SystemC    source code Copyright (c) 1996-2008 by all Contributors.    All Rights reserved.     The contents of this file are subject to the restrictions and limitations    set forth in the SystemC Open Source License Version 3.0 (the "License");    You may not use this file except in compliance with such restrictions and    limitations. You may obtain instructions on how to receive a copy of the    License at http://www.systemc.org/. Software distributed by Contributors    under the License is distributed on an "AS IS" basis, WITHOUT WARRANTY OF    ANY KIND, either express or implied. See the License for the specific    language governing rights and limitations under the License. *********************************************************************///=====================================================================/// @file traffic_generator.cpp// /// @brief traffic generation routines////=====================================================================//  Authors://    Bill Bunton, ESLX//    Jack Donovan, ESLX//    Charles Wilson, ESLX//====================================================================#include "reporting.h"               	        // reporting macros#include "traffic_generator.h"                // traffic generator declarations#ifdef USING_EXTENSION_OPTIONAL#include "extension_initiator_id.h"           // initiator ID extension#endif  /* USING_EXTENSION_OPTIONAL */using namespace std;static const char *filename = "traffic_generator.cpp";  ///< filename for reporting/// ConstructorSC_HAS_PROCESS(traffic_generator);//-----------------------------------------------------------------------------//traffic_generator::traffic_generator            // @todo keep me, lose other constructor( sc_core::sc_module_name name                  // instance name, const unsigned int    ID                      // initiator ID, sc_dt::uint64         base_address_1          // first base address, sc_dt::uint64         base_address_2          // second base address, unsigned int          active_txn_count        // Max number of active transactions ): sc_module           ( name              )     /// instance name, m_ID                ( ID                )     /// initiator ID, m_base_address_1    ( base_address_1    )     /// first base address, m_base_address_2    ( base_address_2    )     /// second base address, m_active_txn_count  ( active_txn_count  )     /// Max number of active transactions , m_check_all         ( true              ){   SC_THREAD(traffic_generator_thread);}/// SystemC thread for generation of GP trafficvoidtraffic_generator::traffic_generator_thread   ( void){  std::ostringstream  msg;                      ///< log message    msg.str ("");  msg << "Initiator: " << m_ID << " Starting Traffic";  REPORT_INFO(filename, __FUNCTION__, msg.str());    tlm::tlm_generic_payload  *transaction_ptr;   ///< transaction pointer  unsigned char             *data_buffer_ptr;   ///< data buffer pointer    // build transaction pool   for (unsigned int i = 0; i < m_active_txn_count; i++ )  {    m_transaction_queue.enqueue ();  }    // outer loop of a simple memory test generate addresses  sc_dt::uint64 base_address;     for (unsigned int i = 0; i < 2; i++ )  {    base_address = i ? m_base_address_2 : m_base_address_1;     sc_dt::uint64 mem_address = base_address;     // write loop         for (unsigned int j = 0; j < 16; j++ )    {      if(!m_transaction_queue.is_empty())      {        transaction_ptr = m_transaction_queue.dequeue ();                data_buffer_ptr = transaction_ptr->get_data_ptr();        unsigned int w_data = (unsigned int)mem_address;                // invert data on second pass        if (i==1)        {          w_data = ~w_data;        }              // convert address of write data to an 32-bit value        *reinterpret_cast<unsigned int*>(data_buffer_ptr) = w_data;                transaction_ptr->set_command          ( tlm::TLM_WRITE_COMMAND       );        transaction_ptr->set_address          ( mem_address                  );        transaction_ptr->set_data_length      ( m_txn_data_size              );        transaction_ptr->set_streaming_width  ( m_txn_data_size              );        transaction_ptr->set_response_status  ( tlm::TLM_INCOMPLETE_RESPONSE );                #if (  defined ( USING_EXTENSION_OPTIONAL  ) )        // set the extension                extension_initiator_id  *extension_pointer;   // extension pointer        std::ostringstream       initiator_id;        // initiator ID string                initiator_id << "'Initiator ID: " << m_ID << "'";        extension_pointer                 = new extension_initiator_id;        extension_pointer->m_initiator_id = initiator_id.str();                // register the extension        transaction_ptr->set_extension ( extension_pointer );         #endif  /* USING_EXTENSION_OPTIONAL */                // increment memory address        mem_address += m_txn_data_size;                // send write request        request_out_port->write (transaction_ptr);      }            check_complete();       }        check_all_complete();        // read loop       mem_address = base_address;        for (unsigned int i = 0; i < 16; i++ )    {      if(!m_transaction_queue.is_empty())      {        transaction_ptr = m_transaction_queue.dequeue ();                                   transaction_ptr->set_command          ( tlm::TLM_READ_COMMAND        );        transaction_ptr->set_address          ( mem_address                  );        transaction_ptr->set_data_length      ( m_txn_data_size              );        transaction_ptr->set_streaming_width  ( m_txn_data_size              );        transaction_ptr->set_response_status  ( tlm::TLM_INCOMPLETE_RESPONSE );        #if (  defined ( USING_EXTENSION_OPTIONAL  ) )        // set the extension                extension_initiator_id  *extension_pointer;   // extension pointer        std::ostringstream       initiator_id;        // initiator ID string                initiator_id << "'Initiator ID: " << m_ID << "'";        extension_pointer                 = new extension_initiator_id;        extension_pointer->m_initiator_id = initiator_id.str();                // register the extension        transaction_ptr->set_extension ( extension_pointer );         #endif  /* USING_EXTENSION_OPTIONAL */                // increment memory address        mem_address += m_txn_data_size;                 // send write request        request_out_port->write (transaction_ptr);       }              check_complete();    } // end read loop       check_all_complete();  }  msg.str ("");  msg << "Traffic Generator : " << m_ID << endl   << "=========================================================" << endl   << "            ####  Traffic Generator Complete  #### ";  REPORT_INFO(filename, __FUNCTION__, msg.str());} // end traffic_generator_thread//-----------------------------------------------------------------------------//  Check Complete methodvoid traffic_generator::check_complete (void){  std::ostringstream        msg;     tlm::tlm_generic_payload  *transaction_ptr;      if (   m_transaction_queue.is_empty()       || m_check_all       || ( response_in_port->num_available() > 0 ) )  {    response_in_port->read(transaction_ptr);        if (transaction_ptr ->get_response_status() != tlm::TLM_OK_RESPONSE)    {      msg.str ("");      msg << m_ID << "Transaction ERROR";      REPORT_FATAL(filename, __FUNCTION__, msg.str());     }        if (  transaction_ptr->get_command() == tlm::TLM_READ_COMMAND)    {      unsigned int    expected_data   = (unsigned int)transaction_ptr->get_address();      unsigned char*  data_buffer_ptr = transaction_ptr->get_data_ptr();      unsigned int    read_data       = *reinterpret_cast<unsigned int*>(data_buffer_ptr);          //-----------------------------------------------------------------------------      // The address for the 揼p