summaryrefslogtreecommitdiff
path: root/src/intersim2
diff options
context:
space:
mode:
authorDongdong Li <[email protected]>2013-11-22 11:31:19 -0800
committerAndrew Boktor <[email protected]>2014-08-14 13:50:59 -0700
commit3f74773ce1ffe8ed5044a103d84459b56d4e9c20 (patch)
treef7265582ead4f320b890fa744ac6af093b9e27e0 /src/intersim2
parent24f29469c042761d8b8d185c374493fbde79aca4 (diff)
Update with Booksim2.0 from Stanford
- Warning fixed - Unused file deleted - Add support for node map configuration. Code Review: Issue 93001 [git-p4: depot-paths = "//depot/gpgpu_sim_research/fermi/distribution/": change = 17410]
Diffstat (limited to 'src/intersim2')
-rw-r--r--src/intersim2/Makefile1
-rw-r--r--src/intersim2/examples/mesh88_lat1
-rw-r--r--src/intersim2/examples/mesh88_lat_hotspot82
-rw-r--r--src/intersim2/flitchannel.cpp6
-rw-r--r--src/intersim2/flitchannel.hpp5
-rw-r--r--src/intersim2/interconnect_interface.cpp140
-rw-r--r--src/intersim2/intersim_config.cpp27
-rw-r--r--src/intersim2/main.cpp178
-rw-r--r--src/intersim2/networks/dragonfly.cpp10
-rw-r--r--src/intersim2/networks/kncube.cpp4
-rw-r--r--src/intersim2/routers/chaos_router.cpp10
-rw-r--r--src/intersim2/trafficmanager.cpp3918
12 files changed, 2163 insertions, 2219 deletions
diff --git a/src/intersim2/Makefile b/src/intersim2/Makefile
index a0a04e9..fd9fba8 100644
--- a/src/intersim2/Makefile
+++ b/src/intersim2/Makefile
@@ -173,4 +173,3 @@ y.tab.c y.tab.h: config.y
lex.yy.c: config.l
$(LEX) $<
-# DO NOT DELETE
diff --git a/src/intersim2/examples/mesh88_lat b/src/intersim2/examples/mesh88_lat
index 189104e..90d4305 100644
--- a/src/intersim2/examples/mesh88_lat
+++ b/src/intersim2/examples/mesh88_lat
@@ -65,5 +65,4 @@ packet_size = 20;
sim_type = latency;
injection_rate = 0.005;
-watch_packets = {1,1,1};
diff --git a/src/intersim2/examples/mesh88_lat_hotspot b/src/intersim2/examples/mesh88_lat_hotspot
deleted file mode 100644
index 45c2b3f..0000000
--- a/src/intersim2/examples/mesh88_lat_hotspot
+++ /dev/null
@@ -1,82 +0,0 @@
-// $Id: mesh88_lat 5487 2013-02-27 08:16:18Z qtedq $
-
-// Copyright (c) 2007-2012, Trustees of The Leland Stanford Junior University
-// All rights reserved.
-//
-// Redistribution and use in source and binary forms, with or without
-// modification, are permitted provided that the following conditions are met:
-//
-// Redistributions of source code must retain the above copyright notice, this
-// list of conditions and the following disclaimer.
-// Redistributions in binary form must reproduce the above copyright notice,
-// this list of conditions and the following disclaimer in the documentation
-// and/or other materials provided with the distribution.
-//
-// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
-// AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
-// IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
-// ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
-// LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-// CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-// SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
-// INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
-// CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
-// ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
-// POSSIBILITY OF SUCH DAMAGE.
-
-//8X8 mesh with 20 flits per packet under injection mode
-//injection rate here is packet per cycle, NOT flit per cycle
-
-// Topology
-
-topology = mesh;
-k = 8;
-n = 2;
-
-// Routing
-
-routing_function = dor;
-
-// Flow control
-
-num_vcs = 8;
-vc_buf_size = 8;
-
-wait_for_tail_credit = 0;
-
-// Router architecture
-
-vc_allocator = separable_input_first;
-sw_allocator = separable_input_first;
-alloc_iters = 1;
-
-credit_delay = 2;
-routing_delay = 0;
-vc_alloc_delay = 1;
-sw_alloc_delay = 1;
-speculative=1;
-
-input_speedup = 1;
-output_speedup = 1;
-internal_speedup = 1.0;
-
-// Traffic
-
-traffic = hotspot;
-packet_size ={{1,2,3,4},{10,20}};
-packet_size_rate={{1,1,1,1},{2,1}};
-// Simulation
-
-sim_type = latency;
-latency_thres = 100000.0;
-
-injection_rate = 0.1;
-
-
-classes=2;
-
-
-classes=2;
-injection_rate={0.01,0.01};
-packet_size={{1,5},{10,20}};
-packet_size_rate={{1,1},{2,1}};
diff --git a/src/intersim2/flitchannel.cpp b/src/intersim2/flitchannel.cpp
index 0515f5f..d10ad61 100644
--- a/src/intersim2/flitchannel.cpp
+++ b/src/intersim2/flitchannel.cpp
@@ -1,4 +1,4 @@
-// $Id: flitchannel.cpp 5188 2012-08-30 00:31:31Z dub $
+// $Id: flitchannel.cpp 5516 2013-10-06 02:14:48Z dub $
/*
Copyright (c) 2007-2012, Trustees of The Leland Stanford Junior University
@@ -43,11 +43,11 @@
// ----------------------------------------------------------------------
// $Author: jbalfour $
// $Date: 2007/06/27 23:10:17 $
-// $Id: flitchannel.cpp 5188 2012-08-30 00:31:31Z dub $
+// $Id: flitchannel.cpp 5516 2013-10-06 02:14:48Z dub $
// ----------------------------------------------------------------------
FlitChannel::FlitChannel(Module * parent, string const & name, int classes)
: Channel<Flit>(parent, name), _routerSource(NULL), _routerSourcePort(-1),
- _routerSink(NULL), _routerSinkPort(-1), _idle(0), _classes(classes) {
+ _routerSink(NULL), _routerSinkPort(-1), _idle(0) {
_active.resize(classes, 0);
}
diff --git a/src/intersim2/flitchannel.hpp b/src/intersim2/flitchannel.hpp
index 632ab10..5816e63 100644
--- a/src/intersim2/flitchannel.hpp
+++ b/src/intersim2/flitchannel.hpp
@@ -1,4 +1,4 @@
-// $Id: flitchannel.hpp 5188 2012-08-30 00:31:31Z dub $
+// $Id: flitchannel.hpp 5516 2013-10-06 02:14:48Z dub $
/*
Copyright (c) 2007-2012, Trustees of The Leland Stanford Junior University
@@ -40,7 +40,7 @@
// ----------------------------------------------------------------------
// $Author: jbalfour $
// $Date: 2007/06/27 23:10:17 $
-// $Id: flitchannel.hpp 5188 2012-08-30 00:31:31Z dub $
+// $Id: flitchannel.hpp 5516 2013-10-06 02:14:48Z dub $
// ----------------------------------------------------------------------
#include "channel.hpp"
@@ -94,7 +94,6 @@ private:
// Statistics for Activity Factors
vector<int> _active;
int _idle;
- int _classes;
};
#endif
diff --git a/src/intersim2/interconnect_interface.cpp b/src/intersim2/interconnect_interface.cpp
index 81f6c82..18a7083 100644
--- a/src/intersim2/interconnect_interface.cpp
+++ b/src/intersim2/interconnect_interface.cpp
@@ -30,6 +30,8 @@
#include <sstream>
#include <iomanip>
#include <cmath>
+#include <utility>
+#include <algorithm>
#include "interconnect_interface.hpp"
#include "routefunc.hpp"
@@ -52,13 +54,13 @@ InterconnectInterface* InterconnectInterface::New(const char* const config_file)
InterconnectInterface* icnt_interface = new InterconnectInterface();
icnt_interface->_icnt_config = new IntersimConfig();
icnt_interface->_icnt_config->ParseFile(config_file);
-
+
return icnt_interface;
}
InterconnectInterface::InterconnectInterface()
{
-
+
}
InterconnectInterface::~InterconnectInterface()
@@ -71,7 +73,7 @@ InterconnectInterface::~InterconnectInterface()
}
delete _net[i];
}
-
+
delete _traffic_manager;
_traffic_manager = NULL;
delete _icnt_config;
@@ -81,12 +83,12 @@ void InterconnectInterface::CreateInterconnect(unsigned n_shader, unsigned n_mem
{
_n_shader = n_shader;
_n_mem = n_mem;
-
+
InitializeRoutingMap(*_icnt_config);
-
+
gPrintActivity = (_icnt_config->GetInt("print_activity") > 0);
gTrace = (_icnt_config->GetInt("viewer_trace") > 0);
-
+
string watch_out_file = _icnt_config->GetStr( "watch_out" );
if(watch_out_file == "") {
gWatchOut = NULL;
@@ -95,10 +97,10 @@ void InterconnectInterface::CreateInterconnect(unsigned n_shader, unsigned n_mem
} else {
gWatchOut = new ofstream(watch_out_file.c_str());
}
-
+
_subnets = _icnt_config->GetInt("subnets");
assert(_subnets);
-
+
/*To include a new network, must register the network here
*add an else if statement with the name of the network
*/
@@ -108,19 +110,19 @@ void InterconnectInterface::CreateInterconnect(unsigned n_shader, unsigned n_mem
name << "network_" << i;
_net[i] = Network::New( *_icnt_config, name.str() );
}
-
+
assert(_icnt_config->GetStr("sim_type") == "gpgpusim");
_traffic_manager = static_cast<GPUTrafficManager*>(TrafficManager::New( *_icnt_config, _net )) ;
-
+
_flit_size = _icnt_config->GetInt( "flit_size" );
-
+
// Config for interface buffers
if (_icnt_config->GetInt("ejection_buffer_size")) {
_ejection_buffer_capacity = _icnt_config->GetInt( "ejection_buffer_size" ) ;
} else {
_ejection_buffer_capacity = _icnt_config->GetInt( "vc_buf_size" );
}
-
+
_boundary_buffer_capacity = _icnt_config->GetInt( "boundary_buffer_size" ) ;
assert(_boundary_buffer_capacity);
if (_icnt_config->GetInt("input_buffer_size")) {
@@ -129,7 +131,7 @@ void InterconnectInterface::CreateInterconnect(unsigned n_shader, unsigned n_mem
_input_buffer_capacity = 9;
}
_vcs = _icnt_config->GetInt("num_vcs");
-
+
_CreateBuffer();
_CreateNodeMap(_n_shader, _n_mem, _traffic_manager->_nodes, _icnt_config->GetInt("use_map"));
}
@@ -148,11 +150,11 @@ void InterconnectInterface::Push(unsigned input_deviceID, unsigned output_device
int output_icntID = _node_map[output_deviceID];
int input_icntID = _node_map[input_deviceID];
-
+
#if 0
cout<<"Call interconnect push input: "<<input<<" output: "<<output<<endl;
#endif
-
+
//TODO: move to _IssuePacket
//TODO: create a Inject and wrap _IssuePacket and _GeneratePacket
unsigned int n_flits = size / _flit_size + ((size % _flit_size)? 1:0);
@@ -166,11 +168,11 @@ void InterconnectInterface::Push(unsigned input_deviceID, unsigned output_device
subnet = 1;
}
}
-
+
//TODO: Remove mem_fetch to reduce dependency
Flit::FlitType packet_type;
mem_fetch* mf = static_cast<mem_fetch*>(data);
-
+
switch (mf->get_type()) {
case READ_REQUEST: packet_type = Flit::READ_REQUEST ;break;
case WRITE_REQUEST: packet_type = Flit::WRITE_REQUEST ;break;
@@ -178,10 +180,10 @@ void InterconnectInterface::Push(unsigned input_deviceID, unsigned output_device
case WRITE_ACK: packet_type = Flit::WRITE_REPLY ;break;
default: assert (0);
}
-
+
//TODO: _include_queuing ?
_traffic_manager->_GeneratePacket( input_icntID, -1, 0 /*class*/, _traffic_manager->_time, subnet, n_flits, packet_type, data, output_icntID);
-
+
#if DOUB
cout <<"Traffic[" << subnet << "] (mapped) sending form "<< input_icntID << " to " << output_icntID << endl;
#endif
@@ -194,14 +196,14 @@ void* InterconnectInterface::Pop(unsigned deviceID)
#if DEBUG
cout<<"Call interconnect POP " << output<<endl;
#endif
-
+
void* data = NULL;
-
+
// 0-_n_shader-1 indicates reply(network 1), otherwise request(network 0)
int subnet = 0;
if (deviceID < _n_shader)
subnet = 1;
-
+
int turn = _round_robin_turn[subnet][icntID];
for (int vc=0;(vc<_vcs) && (data==NULL);vc++) {
if (_boundary_buffer[subnet][icntID][turn].HasPacket()) {
@@ -213,9 +215,9 @@ void* InterconnectInterface::Pop(unsigned deviceID)
if (data) {
_round_robin_turn[subnet][icntID] = turn;
}
-
+
return data;
-
+
}
void InterconnectInterface::Advance()
@@ -253,9 +255,9 @@ bool InterconnectInterface::HasBuffer(unsigned deviceID, unsigned int size) cons
bool has_buffer = false;
unsigned int n_flits = size / _flit_size + ((size % _flit_size)? 1:0);
int icntID = _node_map.find(deviceID)->second;
-
+
has_buffer = _traffic_manager->_input_queue[0][icntID][0].size() +n_flits <= _input_buffer_capacity;
-
+
if ((_subnets>1) && deviceID >= _n_shader) // deviceID is memory node
has_buffer = _traffic_manager->_input_queue[1][icntID][0].size() +n_flits <= _input_buffer_capacity;
@@ -279,7 +281,7 @@ void InterconnectInterface::DisplayOverallStats() const
_traffic_manager->_drain_time = _traffic_manager->_time;
// hack: also _total_sims equals to number of kernel calls
_traffic_manager->_total_sims += 1;
-
+
_traffic_manager->_UpdateOverallStats();
_traffic_manager->DisplayOverallStats();
if(_traffic_manager->_print_csv_results) {
@@ -291,12 +293,12 @@ void InterconnectInterface::DisplayState(FILE *fp) const
{
fprintf(fp, "GPGPU-Sim uArch: ICNT:Display State: Under implementation\n");
// fprintf(fp,"GPGPU-Sim uArch: interconnect busy state\n");
-
+
// for (unsigned i=0; i<net_c;i++) {
// if (traffic[i]->_measured_in_flight)
// fprintf(fp," Network %u has %u _measured_in_flight\n", i, traffic[i]->_measured_in_flight );
// }
-//
+//
// for (unsigned i=0 ;i<(_n_shader+_n_mem);i++ ) {
// if( !traffic[0]->_partial_packets[i] [0].empty() )
// fprintf(fp," Network 0 has nonempty _partial_packets[%u][0]\n", i);
@@ -316,16 +318,16 @@ void InterconnectInterface::Transfer2BoundaryBuffer(int subnet, int output)
Flit* flit;
int vc;
for (vc=0; vc<_vcs;vc++) {
-
+
if ( !_ejection_buffer[subnet][output][vc].empty() && _boundary_buffer[subnet][output][vc].Size() < _boundary_buffer_capacity ) {
flit = _ejection_buffer[subnet][output][vc].front();
assert(flit);
-
+
_ejection_buffer[subnet][output][vc].pop();
_boundary_buffer[subnet][output][vc].PushFlitData( flit->data, flit->tail);
-
+
_ejected_flit_queue[subnet][output].push(flit); //indicate this flit is already popped from ejection buffer and ready for credit return
-
+
if ( flit->head ) {
assert (flit->dest == output);
}
@@ -363,18 +365,18 @@ Flit* InterconnectInterface::GetEjectedFlit(int subnet, int node)
void InterconnectInterface::_CreateBuffer()
{
unsigned nodes = _n_shader + _n_mem;
-
+
_boundary_buffer.resize(_subnets);
_ejection_buffer.resize(_subnets);
_round_robin_turn.resize(_subnets);
_ejected_flit_queue.resize(_subnets);
-
+
for (int subnet = 0; subnet < _subnets; ++subnet) {
_ejection_buffer[subnet].resize(nodes);
_boundary_buffer[subnet].resize(nodes);
_round_robin_turn[subnet].resize(nodes);
_ejected_flit_queue[subnet].resize(nodes);
-
+
for (unsigned node=0;node < nodes;++node){
_ejection_buffer[subnet][node].resize(_vcs);
_boundary_buffer[subnet][node].resize(_vcs);
@@ -385,38 +387,59 @@ void InterconnectInterface::_CreateBuffer()
void InterconnectInterface::_CreateNodeMap(unsigned n_shader, unsigned n_mem, unsigned n_node, int use_map)
{
if (use_map) {
- map<unsigned, vector<unsigned> > preset_memory_map;
-
- // good for 8 shaders and 8 memory cores
+ // The (<SM, Memory>, Memory Location Vector) map
+ map<pair<unsigned,unsigned>, vector<unsigned> > preset_memory_map;
+
+ // preset memory and shader map, optimized for mesh
+ // good for 8 SMs and 8 memory ports, the map is as follows:
+ // +--+--+--+--+
+ // |C0|M0|C1|M1|
+ // +--+--+--+--+
+ // |M2|C2|M3|C3|
+ // +--+--+--+--+
+ // |C4|M4|C5|M5|
+ // +--+--+--+--+
+ // |M6|C6|M7|C7|
+ // +--+--+--+--+
{
unsigned memory_node[] = {1, 3, 4, 6, 9, 11, 12, 14};
- preset_memory_map[16] = vector<unsigned>(memory_node, memory_node+8);
+ preset_memory_map[make_pair(8,8)] = vector<unsigned>(memory_node, memory_node+8);
}
-
- // good for 28 shaders and 8 memory cores
+
+ // good for 28 SMs and 8 memory ports
{
unsigned memory_node[] = {3, 7, 10, 12, 23, 25, 28, 32};
- preset_memory_map[36] = vector<unsigned>(memory_node, memory_node+8);
+ preset_memory_map[make_pair(28,8)] = vector<unsigned>(memory_node, memory_node+8);
}
-
- // good for 56 shaders and 8 memory cores
+
+ // good for 56 SMs and 8 memory cores
{
unsigned memory_node[] = {3, 15, 17, 29, 36, 47, 49, 61};
- preset_memory_map[64] = vector<unsigned>(memory_node, memory_node+sizeof(memory_node)/sizeof(unsigned));
+ preset_memory_map[make_pair(56,8)] = vector<unsigned>(memory_node, memory_node+sizeof(memory_node)/sizeof(unsigned));
}
-
- // good for 110 shaders and 11 memory cores
+
+ // good for 110 SMs and 11 memory cores
{
unsigned memory_node[] = {12, 20, 25, 28, 57, 60, 63, 92, 95,100,108};
- preset_memory_map[121] = vector<unsigned>(memory_node, memory_node+sizeof(memory_node)/sizeof(unsigned));
+ preset_memory_map[make_pair(110, 11)] = vector<unsigned>(memory_node, memory_node+sizeof(memory_node)/sizeof(unsigned));
}
-
- const vector<unsigned> &memory_node = preset_memory_map[n_node];
+ const vector<int> config_memory_node(_icnt_config->GetIntArray("memory_node_map"));
+ if (!config_memory_node.empty()) {
+ if (config_memory_node.size() != _n_mem) {
+ cerr << "Number of memory nodes in memory_node_map should equal to memory ports" << endl;
+ assert( config_memory_node.size() == _n_mem);
+ }
+ vector<unsigned> t_memory_node(config_memory_node.size());
+ copy(config_memory_node.begin(), config_memory_node.end(), t_memory_node.begin());
+ preset_memory_map[make_pair(_n_shader, _n_mem)] = t_memory_node;
+ }
+
+ const vector<unsigned> &memory_node = preset_memory_map[make_pair(_n_shader, _n_mem)];
if (memory_node.empty()) {
cerr<<"ERROR!!! NO MAPPING IMPLEMENTED YET FOR THIS CONFIG"<<endl;
assert(0);
}
-
+
// create node map
unsigned next_node = 0;
unsigned memory_node_index = 0;
@@ -436,7 +459,7 @@ void InterconnectInterface::_CreateNodeMap(unsigned n_shader, unsigned n_mem, un
_node_map[i]=i;
}
}
-
+
for (unsigned i = 0; i < n_node ; i++) {
for (unsigned j = 0; j< n_node ; j++) {
if ( _node_map[j] == i ) {
@@ -445,10 +468,10 @@ void InterconnectInterface::_CreateNodeMap(unsigned n_shader, unsigned n_mem, un
}
}
}
-
- //FIXME: should compatible with non-squre number
+
+ //FIXME: should compatible with non-square number
_DisplayMap((int) sqrt(n_node), n_node);
-
+
}
void InterconnectInterface::_DisplayMap(int dim,int count)
@@ -462,7 +485,7 @@ void InterconnectInterface::_DisplayMap(int dim,int count)
cout << endl << "GPGPU-Sim uArch: ";
}
cout << endl;
-
+
cout << "GPGPU-Sim uArch: interconnect node reverse map (icntID to shaderID+MemID)" << endl;
cout << "GPGPU-Sim uArch: Memory nodes start from ID: " << _n_shader << endl;
cout << "GPGPU-Sim uArch: ";
@@ -503,7 +526,7 @@ void* InterconnectInterface::_BoundaryBufferItem::TopPacket() const
assert(temp_d == _buffer.front()); //all flits must belong to the same packet
}
return data;
-
+
}
void InterconnectInterface::_BoundaryBufferItem::PushFlitData(void* data,bool is_tail)
@@ -514,4 +537,3 @@ void InterconnectInterface::_BoundaryBufferItem::PushFlitData(void* data,bool is
_packet_n++;
}
}
-
diff --git a/src/intersim2/intersim_config.cpp b/src/intersim2/intersim_config.cpp
index 742fe9a..502419f 100644
--- a/src/intersim2/intersim_config.cpp
+++ b/src/intersim2/intersim_config.cpp
@@ -33,22 +33,27 @@ IntersimConfig::IntersimConfig()
_int_map["perfect_icnt"] = 0; // if set overrides fixed_lat_per_hop setting
_int_map["fixed_lat_per_hop"] = 0; // if set icnt is NOT simulated instead packets are sent into destination based on a fixed_lat_per_hop
- _int_map["network_count"] = 2; // number of independent interconnection networks (if it is set to 2 then 2 identical networks are created: sh2mem and mem2shd )
-
- _int_map["output_extra_latency"] = 0;
-
+
_int_map["use_map"] = 1;
-
+ // config SMs and memory nodes map
+ AddStrField("memory_node_map", "");
+
_int_map["flit_size"] = 32;
- //stats
- _int_map["enable_link_stats"] = 0; // show output link and VC utilization stats
+ _int_map["input_buffer_size"] = 0;
+ _int_map["ejection_buffer_size"] = 0; // if left zero the simulator will use the vc_buf_size instead
+ _int_map["boundary_buffer_size"] = 16;
+
+
+ // FIXME: obsolete, unsupport configs
+ _int_map["output_extra_latency"] = 0;
+ _int_map["network_count"] = 2; // number of independent interconnection networks (if it is set to 2 then 2 identical networks are created: sh2mem and mem2shd )
+ _int_map["enable_link_stats"] = 0; // show output link and VC utilization stats
+
+ //stats
_int_map["MATLAB_OUTPUT"] = 0; // output data in MATLAB friendly format
_int_map["DISPLAY_LAT_DIST"] = 0; // distribution of packet latencies
_int_map["DISPLAY_HOP_DIST"] = 0; // distribution of hop counts
_int_map["DISPLAY_PAIR_LATENCY"] = 0; // avg. latency for each s-d pair
-
- _int_map["input_buffer_size"] = 0;
- _int_map["ejection_buffer_size"] = 0; // if left zero the simulator will use the vc_buf_size instead
- _int_map["boundary_buffer_size"] = 16;
+
} \ No newline at end of file
diff --git a/src/intersim2/main.cpp b/src/intersim2/main.cpp
index 9b43fff..1e92250 100644
--- a/src/intersim2/main.cpp
+++ b/src/intersim2/main.cpp
@@ -3,19 +3,19 @@
/*
Copyright (c) 2007-2012, Trustees of The Leland Stanford Junior University
All rights reserved.
-
+
Redistribution and use in source and binary forms, with or without
modification, are permitted provided that the following conditions are met:
-
- Redistributions of source code must retain the above copyright notice, this
+
+ Redistributions of source code must retain the above copyright notice, this
list of conditions and the following disclaimer.
Redistributions in binary form must reproduce the above copyright notice, this
list of conditions and the following disclaimer in the documentation and/or
other materials provided with the distribution.
-
+
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
- WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
@@ -23,7 +23,7 @@
ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- */
+*/
/*main.cpp
*
@@ -55,6 +55,8 @@
#include "power_module.hpp"
#include "interconnect_interface.hpp"
+
+
///////////////////////////////////////////////////////////////////////////////
//Global declarations
//////////////////////
@@ -114,58 +116,58 @@ ostream * gWatchOut;
bool Simulate( BookSimConfig const & config )
{
- vector<Network *> net;
-
- int subnets = config.GetInt("subnets");
- /*To include a new network, must register the network here
- *add an else if statement with the name of the network
- */
- net.resize(subnets);
- for (int i = 0; i < subnets; ++i) {
- ostringstream name;
- name << "network_" << i;
- net[i] = Network::New( config, name.str() );
- }
-
- /*tcc and characterize are legacy
- *not sure how to use them
- */
-
- assert(trafficManager == NULL);
- trafficManager = TrafficManager::New( config, net ) ;
-
- /*Start the simulation run
- */
-
- double total_time; /* Amount of time we've run */
- struct timeval start_time, end_time; /* Time before/after user code */
- total_time = 0.0;
- gettimeofday(&start_time, NULL);
-
- bool result = trafficManager->Run() ;
-
-
- gettimeofday(&end_time, NULL);
- total_time = ((double)(end_time.tv_sec) + (double)(end_time.tv_usec)/1000000.0)
- - ((double)(start_time.tv_sec) + (double)(start_time.tv_usec)/1000000.0);
-
- cout<<"Total run time "<<total_time<<endl;
-
- for (int i=0; i<subnets; ++i) {
-
- ///Power analysis
- if(config.GetInt("sim_power") > 0){
- Power_Module pnet(net[i], config);
- pnet.run();
- }
-
- delete net[i];
+ vector<Network *> net;
+
+ int subnets = config.GetInt("subnets");
+ /*To include a new network, must register the network here
+ *add an else if statement with the name of the network
+ */
+ net.resize(subnets);
+ for (int i = 0; i < subnets; ++i) {
+ ostringstream name;
+ name << "network_" << i;
+ net[i] = Network::New( config, name.str() );
+ }
+
+ /*tcc and characterize are legacy
+ *not sure how to use them
+ */
+
+ assert(trafficManager == NULL);
+ trafficManager = TrafficManager::New( config, net ) ;
+
+ /*Start the simulation run
+ */
+
+ double total_time; /* Amount of time we've run */
+ struct timeval start_time, end_time; /* Time before/after user code */
+ total_time = 0.0;
+ gettimeofday(&start_time, NULL);
+
+ bool result = trafficManager->Run() ;
+
+
+ gettimeofday(&end_time, NULL);
+ total_time = ((double)(end_time.tv_sec) + (double)(end_time.tv_usec)/1000000.0)
+ - ((double)(start_time.tv_sec) + (double)(start_time.tv_usec)/1000000.0);
+
+ cout<<"Total run time "<<total_time<<endl;
+
+ for (int i=0; i<subnets; ++i) {
+
+ ///Power analysis
+ if(config.GetInt("sim_power") > 0){
+ Power_Module pnet(net[i], config);
+ pnet.run();
}
-
- delete trafficManager;
- trafficManager = NULL;
-
- return result;
+
+ delete net[i];
+ }
+
+ delete trafficManager;
+ trafficManager = NULL;
+
+ return result;
}
#ifdef CREATE_LIBRARY
@@ -173,37 +175,37 @@ bool Simulate( BookSimConfig const & config )
#else
int main( int argc, char **argv )
{
-
- BookSimConfig config;
-
-
- if ( !ParseArgs( &config, argc, argv ) ) {
- cerr << "Usage: " << argv[0] << " configfile... [param=value...]" << endl;
- return 0;
- }
-
-
- /*initialize routing, traffic, injection functions
- */
- InitializeRoutingMap( config );
-
- gPrintActivity = (config.GetInt("print_activity") > 0);
- gTrace = (config.GetInt("viewer_trace") > 0);
-
- string watch_out_file = config.GetStr( "watch_out" );
- if(watch_out_file == "") {
- gWatchOut = NULL;
- } else if(watch_out_file == "-") {
- gWatchOut = &cout;
- } else {
- gWatchOut = new ofstream(watch_out_file.c_str());
- }
-
-
- /*configure and run the simulator
- */
- bool result = Simulate( config );
- return result ? -1 : 0;
+
+ BookSimConfig config;
+
+
+ if ( !ParseArgs( &config, argc, argv ) ) {
+ cerr << "Usage: " << argv[0] << " configfile... [param=value...]" << endl;
+ return 0;
+ }
+
+
+ /*initialize routing, traffic, injection functions
+ */
+ InitializeRoutingMap( config );
+
+ gPrintActivity = (config.GetInt("print_activity") > 0);
+ gTrace = (config.GetInt("viewer_trace") > 0);
+
+ string watch_out_file = config.GetStr( "watch_out" );
+ if(watch_out_file == "") {
+ gWatchOut = NULL;
+ } else if(watch_out_file == "-") {
+ gWatchOut = &cout;
+ } else {
+ gWatchOut = new ofstream(watch_out_file.c_str());
+ }
+
+
+ /*configure and run the simulator
+ */
+ bool result = Simulate( config );
+ return result ? -1 : 0;
}
#endif
diff --git a/src/intersim2/networks/dragonfly.cpp b/src/intersim2/networks/dragonfly.cpp
index b539cc6..01a2281 100644
--- a/src/intersim2/networks/dragonfly.cpp
+++ b/src/intersim2/networks/dragonfly.cpp
@@ -217,12 +217,12 @@ void DragonFlyNew::_ComputeSize( const Configuration &config )
void DragonFlyNew::_BuildNet( const Configuration &config )
{
- int _output;
- int _input;
+ int _output=-1;
+ int _input=-1;
+ int _dim_ID=-1;
+ int _num_ports_per_switch=-1;
+ int _dim_size=-1;
int c;
- int _dim_ID;
- int _num_ports_per_switch;
- int _dim_size;
ostringstream router_name;
diff --git a/src/intersim2/networks/kncube.cpp b/src/intersim2/networks/kncube.cpp
index 6915f22..03e13e7 100644
--- a/src/intersim2/networks/kncube.cpp
+++ b/src/intersim2/networks/kncube.cpp
@@ -1,4 +1,4 @@
-// $Id: kncube.cpp 5188 2012-08-30 00:31:31Z dub $
+// $Id: kncube.cpp 5516 2013-10-06 02:14:48Z dub $
/*
Copyright (c) 2007-2012, Trustees of The Leland Stanford Junior University
@@ -239,7 +239,7 @@ void KNCube::InsertRandomFaults( const Configuration &config )
num_fails = config.GetInt( "link_failures" );
- if ( num_fails ) {
+ if ( _size && num_fails ) {
prev_seed = RandomIntLong( );
RandomSeed( config.GetInt( "fail_seed" ) );
diff --git a/src/intersim2/routers/chaos_router.cpp b/src/intersim2/routers/chaos_router.cpp
index 10c6277..b2bed93 100644
--- a/src/intersim2/routers/chaos_router.cpp
+++ b/src/intersim2/routers/chaos_router.cpp
@@ -1,4 +1,4 @@
-// $Id: chaos_router.cpp 5188 2012-08-30 00:31:31Z dub $
+// $Id: chaos_router.cpp 5516 2013-10-06 02:14:48Z dub $
/*
Copyright (c) 2007-2012, Trustees of The Leland Stanford Junior University
@@ -589,13 +589,13 @@ void ChaosRouter::_OutputAdvance( )
for ( int m = 0; m < _multi_queue_size; ++m ) {
if ( _multi_match[m] != -1 ) {
- if ( !_multi_queue[m].empty( ) ) {
- f = _multi_queue[m].front( );
- _multi_queue[m].pop( );
- } else {
+ if ( _multi_queue[m].empty( ) ) {
cout << "State = " << _multi_state[m] << endl;
Error( "Multi queue empty, but matched!" );
}
+ assert( !_multi_queue[m].empty( ) );
+ f = _multi_queue[m].front( );
+ _multi_queue[m].pop( );
_crossbar_pipe->Write( f, _multi_match[m] );
diff --git a/src/intersim2/trafficmanager.cpp b/src/intersim2/trafficmanager.cpp
index 7b2289c..8a015bb 100644
--- a/src/intersim2/trafficmanager.cpp
+++ b/src/intersim2/trafficmanager.cpp
@@ -43,2245 +43,2245 @@
TrafficManager * TrafficManager::New(Configuration const & config,
vector<Network *> const & net)
{
- TrafficManager * result = NULL;
- string sim_type = config.GetStr("sim_type");
- if((sim_type == "latency") || (sim_type == "throughput")) {
- result = new TrafficManager(config, net);
- } else if(sim_type == "batch") {
- result = new BatchTrafficManager(config, net);
+ TrafficManager * result = NULL;
+ string sim_type = config.GetStr("sim_type");
+ if((sim_type == "latency") || (sim_type == "throughput")) {
+ result = new TrafficManager(config, net);
+ } else if(sim_type == "batch") {
+ result = new BatchTrafficManager(config, net);
} else if(sim_type == "gpgpusim") {
result = new GPUTrafficManager(config, net);
}
else {
- cerr << "Unknown simulation type: " << sim_type << endl;
- }
- return result;
+ cerr << "Unknown simulation type: " << sim_type << endl;
+ }
+ return result;
}
TrafficManager::TrafficManager( const Configuration &config, const vector<Network *> & net )
-: Module( 0, "traffic_manager" ), _net(net), _empty_network(false), _deadlock_timer(0), _reset_time(0), _drain_time(-1), _cur_id(0), _cur_pid(0), _time(0)
+ : Module( 0, "traffic_manager" ), _net(net), _empty_network(false), _deadlock_timer(0), _reset_time(0), _drain_time(-1), _cur_id(0), _cur_pid(0), _time(0)
{
-
- _nodes = _net[0]->NumNodes( );
- _routers = _net[0]->NumRouters( );
-
- _vcs = config.GetInt("num_vcs");
- _subnets = config.GetInt("subnets");
-
- _subnet.resize(Flit::NUM_FLIT_TYPES);
- _subnet[Flit::READ_REQUEST] = config.GetInt("read_request_subnet");
- _subnet[Flit::READ_REPLY] = config.GetInt("read_reply_subnet");
- _subnet[Flit::WRITE_REQUEST] = config.GetInt("write_request_subnet");
- _subnet[Flit::WRITE_REPLY] = config.GetInt("write_reply_subnet");
-
- // ============ Message priorities ============
-
- string priority = config.GetStr( "priority" );
-
- if ( priority == "class" ) {
- _pri_type = class_based;
- } else if ( priority == "age" ) {
- _pri_type = age_based;
- } else if ( priority == "network_age" ) {
- _pri_type = network_age_based;
- } else if ( priority == "local_age" ) {
- _pri_type = local_age_based;
- } else if ( priority == "queue_length" ) {
- _pri_type = queue_length_based;
- } else if ( priority == "hop_count" ) {
- _pri_type = hop_count_based;
- } else if ( priority == "sequence" ) {
- _pri_type = sequence_based;
- } else if ( priority == "none" ) {
- _pri_type = none;
- } else {
- Error( "Unkown priority value: " + priority );
- }
-
- // ============ Routing ============
-
- string rf = config.GetStr("routing_function") + "_" + config.GetStr("topology");
- map<string, tRoutingFunction>::const_iterator rf_iter = gRoutingFunctionMap.find(rf);
- if(rf_iter == gRoutingFunctionMap.end()) {
- Error("Invalid routing function: " + rf);
- }
- _rf = rf_iter->second;
-
- _lookahead_routing = !config.GetInt("routing_delay");
- _noq = config.GetInt("noq");
- if(_noq) {
- if(!_lookahead_routing) {
- Error("NOQ requires lookahead routing to be enabled.");
+
+ _nodes = _net[0]->NumNodes( );
+ _routers = _net[0]->NumRouters( );
+
+ _vcs = config.GetInt("num_vcs");
+ _subnets = config.GetInt("subnets");
+
+ _subnet.resize(Flit::NUM_FLIT_TYPES);
+ _subnet[Flit::READ_REQUEST] = config.GetInt("read_request_subnet");
+ _subnet[Flit::READ_REPLY] = config.GetInt("read_reply_subnet");
+ _subnet[Flit::WRITE_REQUEST] = config.GetInt("write_request_subnet");
+ _subnet[Flit::WRITE_REPLY] = config.GetInt("write_reply_subnet");
+
+ // ============ Message priorities ============
+
+ string priority = config.GetStr( "priority" );
+
+ if ( priority == "class" ) {
+ _pri_type = class_based;
+ } else if ( priority == "age" ) {
+ _pri_type = age_based;
+ } else if ( priority == "network_age" ) {
+ _pri_type = network_age_based;
+ } else if ( priority == "local_age" ) {
+ _pri_type = local_age_based;
+ } else if ( priority == "queue_length" ) {
+ _pri_type = queue_length_based;
+ } else if ( priority == "hop_count" ) {
+ _pri_type = hop_count_based;
+ } else if ( priority == "sequence" ) {
+ _pri_type = sequence_based;
+ } else if ( priority == "none" ) {
+ _pri_type = none;
+ } else {
+ Error( "Unkown priority value: " + priority );
}
- }
-
- // ============ Traffic ============
-
- _classes = config.GetInt("classes");
-
- _use_read_write = config.GetIntArray("use_read_write");
- if(_use_read_write.empty()) {
- _use_read_write.push_back(config.GetInt("use_read_write"));
- }
- _use_read_write.resize(_classes, _use_read_write.back());
-
- _write_fraction = config.GetFloatArray("write_fraction");
- if(_write_fraction.empty()) {
- _write_fraction.push_back(config.GetFloat("write_fraction"));
- }
- _write_fraction.resize(_classes, _write_fraction.back());
-
- _read_request_size = config.GetIntArray("read_request_size");
- if(_read_request_size.empty()) {
- _read_request_size.push_back(config.GetInt("read_request_size"));
- }
- _read_request_size.resize(_classes, _read_request_size.back());
-
- _read_reply_size = config.GetIntArray("read_reply_size");
- if(_read_reply_size.empty()) {
- _read_reply_size.push_back(config.GetInt("read_reply_size"));
- }
- _read_reply_size.resize(_classes, _read_reply_size.back());
-
- _write_request_size = config.GetIntArray("write_request_size");
- if(_write_request_size.empty()) {
- _write_request_size.push_back(config.GetInt("write_request_size"));
- }
- _write_request_size.resize(_classes, _write_request_size.back());
-
- _write_reply_size = config.GetIntArray("write_reply_size");
- if(_write_reply_size.empty()) {
- _write_reply_size.push_back(config.GetInt("write_reply_size"));
- }
- _write_reply_size.resize(_classes, _write_reply_size.back());
-
- string packet_size_str = config.GetStr("packet_size");
- if(packet_size_str.empty()) {
- _packet_size.push_back(vector<int>(1, config.GetInt("packet_size")));
- } else {
- vector<string> packet_size_strings = tokenize_str(packet_size_str);
- for(size_t i = 0; i < packet_size_strings.size(); ++i) {
- _packet_size.push_back(tokenize_int(packet_size_strings[i]));
+
+ // ============ Routing ============
+
+ string rf = config.GetStr("routing_function") + "_" + config.GetStr("topology");
+ map<string, tRoutingFunction>::const_iterator rf_iter = gRoutingFunctionMap.find(rf);
+ if(rf_iter == gRoutingFunctionMap.end()) {
+ Error("Invalid routing function: " + rf);
}
- }
- _packet_size.resize(_classes, _packet_size.back());
+ _rf = rf_iter->second;
- string packet_size_rate_str = config.GetStr("packet_size_rate");
- if(packet_size_rate_str.empty()) {
- int rate = config.GetInt("packet_size_rate");
- assert(rate >= 0);
- for(int c = 0; c < _classes; ++c) {
- int size = _packet_size[c].size();
- _packet_size_rate.push_back(vector<int>(size, rate));
- _packet_size_max_val.push_back(size * rate - 1);
+ _lookahead_routing = !config.GetInt("routing_delay");
+ _noq = config.GetInt("noq");
+ if(_noq) {
+ if(!_lookahead_routing) {
+ Error("NOQ requires lookahead routing to be enabled.");
+ }
}
- } else {
- vector<string> packet_size_rate_strings = tokenize_str(packet_size_rate_str);
- packet_size_rate_strings.resize(_classes, packet_size_rate_strings.back());
- for(int c = 0; c < _classes; ++c) {
- vector<int> rates = tokenize_int(packet_size_rate_strings[c]);
- rates.resize(_packet_size[c].size(), rates.back());
- _packet_size_rate.push_back(rates);
- int size = rates.size();
- int max_val = -1;
- for(int i = 0; i < size; ++i) {
- int rate = rates[i];
+
+ // ============ Traffic ============
+
+ _classes = config.GetInt("classes");
+
+ _use_read_write = config.GetIntArray("use_read_write");
+ if(_use_read_write.empty()) {
+ _use_read_write.push_back(config.GetInt("use_read_write"));
+ }
+ _use_read_write.resize(_classes, _use_read_write.back());
+
+ _write_fraction = config.GetFloatArray("write_fraction");
+ if(_write_fraction.empty()) {
+ _write_fraction.push_back(config.GetFloat("write_fraction"));
+ }
+ _write_fraction.resize(_classes, _write_fraction.back());
+
+ _read_request_size = config.GetIntArray("read_request_size");
+ if(_read_request_size.empty()) {
+ _read_request_size.push_back(config.GetInt("read_request_size"));
+ }
+ _read_request_size.resize(_classes, _read_request_size.back());
+
+ _read_reply_size = config.GetIntArray("read_reply_size");
+ if(_read_reply_size.empty()) {
+ _read_reply_size.push_back(config.GetInt("read_reply_size"));
+ }
+ _read_reply_size.resize(_classes, _read_reply_size.back());
+
+ _write_request_size = config.GetIntArray("write_request_size");
+ if(_write_request_size.empty()) {
+ _write_request_size.push_back(config.GetInt("write_request_size"));
+ }
+ _write_request_size.resize(_classes, _write_request_size.back());
+
+ _write_reply_size = config.GetIntArray("write_reply_size");
+ if(_write_reply_size.empty()) {
+ _write_reply_size.push_back(config.GetInt("write_reply_size"));
+ }
+ _write_reply_size.resize(_classes, _write_reply_size.back());
+
+ string packet_size_str = config.GetStr("packet_size");
+ if(packet_size_str.empty()) {
+ _packet_size.push_back(vector<int>(1, config.GetInt("packet_size")));
+ } else {
+ vector<string> packet_size_strings = tokenize_str(packet_size_str);
+ for(size_t i = 0; i < packet_size_strings.size(); ++i) {
+ _packet_size.push_back(tokenize_int(packet_size_strings[i]));
+ }
+ }
+ _packet_size.resize(_classes, _packet_size.back());
+
+ string packet_size_rate_str = config.GetStr("packet_size_rate");
+ if(packet_size_rate_str.empty()) {
+ int rate = config.GetInt("packet_size_rate");
assert(rate >= 0);
- max_val += rate;
- }
- _packet_size_max_val.push_back(max_val);
+ for(int c = 0; c < _classes; ++c) {
+ int size = _packet_size[c].size();
+ _packet_size_rate.push_back(vector<int>(size, rate));
+ _packet_size_max_val.push_back(size * rate - 1);
+ }
+ } else {
+ vector<string> packet_size_rate_strings = tokenize_str(packet_size_rate_str);
+ packet_size_rate_strings.resize(_classes, packet_size_rate_strings.back());
+ for(int c = 0; c < _classes; ++c) {
+ vector<int> rates = tokenize_int(packet_size_rate_strings[c]);
+ rates.resize(_packet_size[c].size(), rates.back());
+ _packet_size_rate.push_back(rates);
+ int size = rates.size();
+ int max_val = -1;
+ for(int i = 0; i < size; ++i) {
+ int rate = rates[i];
+ assert(rate >= 0);
+ max_val += rate;
+ }
+ _packet_size_max_val.push_back(max_val);
+ }
}
- }
- for(int c = 0; c < _classes; ++c) {
- if(_use_read_write[c]) {
- _packet_size[c] =
- vector<int>(1, (_read_request_size[c] + _read_reply_size[c] +
- _write_request_size[c] + _write_reply_size[c]) / 2);
- _packet_size_rate[c] = vector<int>(1, 1);
- _packet_size_max_val[c] = 0;
+ for(int c = 0; c < _classes; ++c) {
+ if(_use_read_write[c]) {
+ _packet_size[c] =
+ vector<int>(1, (_read_request_size[c] + _read_reply_size[c] +
+ _write_request_size[c] + _write_reply_size[c]) / 2);
+ _packet_size_rate[c] = vector<int>(1, 1);
+ _packet_size_max_val[c] = 0;
+ }
}
- }
-
- _load = config.GetFloatArray("injection_rate");
- if(_load.empty()) {
- _load.push_back(config.GetFloat("injection_rate"));
- }
- _load.resize(_classes, _load.back());
-
- if(config.GetInt("injection_rate_uses_flits")) {
- for(int c = 0; c < _classes; ++c)
- _load[c] /= _GetAveragePacketSize(c);
- }
-
- _traffic = config.GetStrArray("traffic");
- _traffic.resize(_classes, _traffic.back());
-
- _traffic_pattern.resize(_classes);
-
- _class_priority = config.GetIntArray("class_priority");
- if(_class_priority.empty()) {
- _class_priority.push_back(config.GetInt("class_priority"));
- }
- _class_priority.resize(_classes, _class_priority.back());
-
- vector<string> injection_process = config.GetStrArray("injection_process");
- injection_process.resize(_classes, injection_process.back());
-
- _injection_process.resize(_classes);
-
- for(int c = 0; c < _classes; ++c) {
- _traffic_pattern[c] = TrafficPattern::New(_traffic[c], _nodes, &config);
- _injection_process[c] = InjectionProcess::New(injection_process[c], _nodes, _load[c], &config);
- }
-
- // ============ Injection VC states ============
-
- _buf_states.resize(_nodes);
- _last_vc.resize(_nodes);
- _last_class.resize(_nodes);
-
- for ( int source = 0; source < _nodes; ++source ) {
- _buf_states[source].resize(_subnets);
- _last_class[source].resize(_subnets, 0);
- _last_vc[source].resize(_subnets);
- for ( int subnet = 0; subnet < _subnets; ++subnet ) {
- ostringstream tmp_name;
- tmp_name << "terminal_buf_state_" << source << "_" << subnet;
- BufferState * bs = new BufferState( config, this, tmp_name.str( ) );
- int vc_alloc_delay = config.GetInt("vc_alloc_delay");
- int sw_alloc_delay = config.GetInt("sw_alloc_delay");
- int router_latency = config.GetInt("routing_delay") + (config.GetInt("speculative") ? max(vc_alloc_delay, sw_alloc_delay) : (vc_alloc_delay + sw_alloc_delay));
- int min_latency = 1 + _net[subnet]->GetInject(source)->GetLatency() + router_latency + _net[subnet]->GetInjectCred(source)->GetLatency();
- bs->SetMinLatency(min_latency);
- _buf_states[source][subnet] = bs;
- _last_vc[source][subnet].resize(_classes, -1);
+
+ _load = config.GetFloatArray("injection_rate");
+ if(_load.empty()) {
+ _load.push_back(config.GetFloat("injection_rate"));
}
- }
-
+ _load.resize(_classes, _load.back());
+
+ if(config.GetInt("injection_rate_uses_flits")) {
+ for(int c = 0; c < _classes; ++c)
+ _load[c] /= _GetAveragePacketSize(c);
+ }
+
+ _traffic = config.GetStrArray("traffic");
+ _traffic.resize(_classes, _traffic.back());
+
+ _traffic_pattern.resize(_classes);
+
+ _class_priority = config.GetIntArray("class_priority");
+ if(_class_priority.empty()) {
+ _class_priority.push_back(config.GetInt("class_priority"));
+ }
+ _class_priority.resize(_classes, _class_priority.back());
+
+ vector<string> injection_process = config.GetStrArray("injection_process");
+ injection_process.resize(_classes, injection_process.back());
+
+ _injection_process.resize(_classes);
+
+ for(int c = 0; c < _classes; ++c) {
+ _traffic_pattern[c] = TrafficPattern::New(_traffic[c], _nodes, &config);
+ _injection_process[c] = InjectionProcess::New(injection_process[c], _nodes, _load[c], &config);
+ }
+
+ // ============ Injection VC states ============
+
+ _buf_states.resize(_nodes);
+ _last_vc.resize(_nodes);
+ _last_class.resize(_nodes);
+
+ for ( int source = 0; source < _nodes; ++source ) {
+ _buf_states[source].resize(_subnets);
+ _last_class[source].resize(_subnets, 0);
+ _last_vc[source].resize(_subnets);
+ for ( int subnet = 0; subnet < _subnets; ++subnet ) {
+ ostringstream tmp_name;
+ tmp_name << "terminal_buf_state_" << source << "_" << subnet;
+ BufferState * bs = new BufferState( config, this, tmp_name.str( ) );
+ int vc_alloc_delay = config.GetInt("vc_alloc_delay");
+ int sw_alloc_delay = config.GetInt("sw_alloc_delay");
+ int router_latency = config.GetInt("routing_delay") + (config.GetInt("speculative") ? max(vc_alloc_delay, sw_alloc_delay) : (vc_alloc_delay + sw_alloc_delay));
+ int min_latency = 1 + _net[subnet]->GetInject(source)->GetLatency() + router_latency + _net[subnet]->GetInjectCred(source)->GetLatency();
+ bs->SetMinLatency(min_latency);
+ _buf_states[source][subnet] = bs;
+ _last_vc[source][subnet].resize(_classes, -1);
+ }
+ }
+
#ifdef TRACK_FLOWS
- _outstanding_credits.resize(_classes);
- for(int c = 0; c < _classes; ++c) {
- _outstanding_credits[c].resize(_subnets, vector<int>(_nodes, 0));
- }
- _outstanding_classes.resize(_nodes);
- for(int n = 0; n < _nodes; ++n) {
- _outstanding_classes[n].resize(_subnets, vector<queue<int> >(_vcs));
- }
+ _outstanding_credits.resize(_classes);
+ for(int c = 0; c < _classes; ++c) {
+ _outstanding_credits[c].resize(_subnets, vector<int>(_nodes, 0));
+ }
+ _outstanding_classes.resize(_nodes);
+ for(int n = 0; n < _nodes; ++n) {
+ _outstanding_classes[n].resize(_subnets, vector<queue<int> >(_vcs));
+ }
#endif
+
+ // ============ Injection queues ============
+
+ _qtime.resize(_nodes);
+ _qdrained.resize(_nodes);
+ _partial_packets.resize(_nodes);
+
+ for ( int s = 0; s < _nodes; ++s ) {
+ _qtime[s].resize(_classes);
+ _qdrained[s].resize(_classes);
+ _partial_packets[s].resize(_classes);
+ }
+
+ _total_in_flight_flits.resize(_classes);
+ _measured_in_flight_flits.resize(_classes);
+ _retired_packets.resize(_classes);
+
+ _packet_seq_no.resize(_nodes);
+ _repliesPending.resize(_nodes);
+ _requestsOutstanding.resize(_nodes);
+
+ _hold_switch_for_packet = config.GetInt("hold_switch_for_packet");
+
+ // ============ Simulation parameters ============
+
+ _total_sims = config.GetInt( "sim_count" );
+
+ _router.resize(_subnets);
+ for (int i=0; i < _subnets; ++i) {
+ _router[i] = _net[i]->GetRouters();
+ }
+
+ //seed the network
+ RandomSeed(config.GetInt("seed"));
+
+ _measure_latency = (config.GetStr("sim_type") == "latency");
+
+ _sample_period = config.GetInt( "sample_period" );
+ _max_samples = config.GetInt( "max_samples" );
+ _warmup_periods = config.GetInt( "warmup_periods" );
+
+ _measure_stats = config.GetIntArray( "measure_stats" );
+ if(_measure_stats.empty()) {
+ _measure_stats.push_back(config.GetInt("measure_stats"));
+ }
+ _measure_stats.resize(_classes, _measure_stats.back());
+ _pair_stats = (config.GetInt("pair_stats")==1);
+
+ _latency_thres = config.GetFloatArray( "latency_thres" );
+ if(_latency_thres.empty()) {
+ _latency_thres.push_back(config.GetFloat("latency_thres"));
+ }
+ _latency_thres.resize(_classes, _latency_thres.back());
+
+ _warmup_threshold = config.GetFloatArray( "warmup_thres" );
+ if(_warmup_threshold.empty()) {
+ _warmup_threshold.push_back(config.GetFloat("warmup_thres"));
+ }
+ _warmup_threshold.resize(_classes, _warmup_threshold.back());
+
+ _acc_warmup_threshold = config.GetFloatArray( "acc_warmup_thres" );
+ if(_acc_warmup_threshold.empty()) {
+ _acc_warmup_threshold.push_back(config.GetFloat("acc_warmup_thres"));
+ }
+ _acc_warmup_threshold.resize(_classes, _acc_warmup_threshold.back());
+
+ _stopping_threshold = config.GetFloatArray( "stopping_thres" );
+ if(_stopping_threshold.empty()) {
+ _stopping_threshold.push_back(config.GetFloat("stopping_thres"));
+ }
+ _stopping_threshold.resize(_classes, _stopping_threshold.back());
+
+ _acc_stopping_threshold = config.GetFloatArray( "acc_stopping_thres" );
+ if(_acc_stopping_threshold.empty()) {
+ _acc_stopping_threshold.push_back(config.GetFloat("acc_stopping_thres"));
+ }
+ _acc_stopping_threshold.resize(_classes, _acc_stopping_threshold.back());
+
+ _include_queuing = config.GetInt( "include_queuing" );
+
+ _print_csv_results = config.GetInt( "print_csv_results" );
+ _deadlock_warn_timeout = config.GetInt( "deadlock_warn_timeout" );
+
+ string watch_file = config.GetStr( "watch_file" );
+ if((watch_file != "") && (watch_file != "-")) {
+ _LoadWatchList(watch_file);
+ }
+
+ vector<int> watch_flits = config.GetIntArray("watch_flits");
+ for(size_t i = 0; i < watch_flits.size(); ++i) {
+ _flits_to_watch.insert(watch_flits[i]);
+ }
- // ============ Injection queues ============
-
- _qtime.resize(_nodes);
- _qdrained.resize(_nodes);
- _partial_packets.resize(_nodes);
-
- for ( int s = 0; s < _nodes; ++s ) {
- _qtime[s].resize(_classes);
- _qdrained[s].resize(_classes);
- _partial_packets[s].resize(_classes);
- }
-
- _total_in_flight_flits.resize(_classes);
- _measured_in_flight_flits.resize(_classes);
- _retired_packets.resize(_classes);
-
- _packet_seq_no.resize(_nodes);
- _repliesPending.resize(_nodes);
- _requestsOutstanding.resize(_nodes);
-
- _hold_switch_for_packet = config.GetInt("hold_switch_for_packet");
-
- // ============ Simulation parameters ============
-
- _total_sims = config.GetInt( "sim_count" );
-
- _router.resize(_subnets);
- for (int i=0; i < _subnets; ++i) {
- _router[i] = _net[i]->GetRouters();
- }
-
- //seed the network
- RandomSeed(config.GetInt("seed"));
-
- _measure_latency = (config.GetStr("sim_type") == "latency");
-
- _sample_period = config.GetInt( "sample_period" );
- _max_samples = config.GetInt( "max_samples" );
- _warmup_periods = config.GetInt( "warmup_periods" );
-
- _measure_stats = config.GetIntArray( "measure_stats" );
- if(_measure_stats.empty()) {
- _measure_stats.push_back(config.GetInt("measure_stats"));
- }
- _measure_stats.resize(_classes, _measure_stats.back());
- _pair_stats = (config.GetInt("pair_stats")==1);
-
- _latency_thres = config.GetFloatArray( "latency_thres" );
- if(_latency_thres.empty()) {
- _latency_thres.push_back(config.GetFloat("latency_thres"));
- }
- _latency_thres.resize(_classes, _latency_thres.back());
-
- _warmup_threshold = config.GetFloatArray( "warmup_thres" );
- if(_warmup_threshold.empty()) {
- _warmup_threshold.push_back(config.GetFloat("warmup_thres"));
- }
- _warmup_threshold.resize(_classes, _warmup_threshold.back());
-
- _acc_warmup_threshold = config.GetFloatArray( "acc_warmup_thres" );
- if(_acc_warmup_threshold.empty()) {
- _acc_warmup_threshold.push_back(config.GetFloat("acc_warmup_thres"));
- }
- _acc_warmup_threshold.resize(_classes, _acc_warmup_threshold.back());
-
- _stopping_threshold = config.GetFloatArray( "stopping_thres" );
- if(_stopping_threshold.empty()) {
- _stopping_threshold.push_back(config.GetFloat("stopping_thres"));
- }
- _stopping_threshold.resize(_classes, _stopping_threshold.back());
-
- _acc_stopping_threshold = config.GetFloatArray( "acc_stopping_thres" );
- if(_acc_stopping_threshold.empty()) {
- _acc_stopping_threshold.push_back(config.GetFloat("acc_stopping_thres"));
- }
- _acc_stopping_threshold.resize(_classes, _acc_stopping_threshold.back());
-
- _include_queuing = config.GetInt( "include_queuing" );
-
- _print_csv_results = config.GetInt( "print_csv_results" );
- _deadlock_warn_timeout = config.GetInt( "deadlock_warn_timeout" );
-
- string watch_file = config.GetStr( "watch_file" );
- if((watch_file != "") && (watch_file != "-")) {
- _LoadWatchList(watch_file);
- }
-
- vector<int> watch_flits = config.GetIntArray("watch_flits");
- for(size_t i = 0; i < watch_flits.size(); ++i) {
- _flits_to_watch.insert(watch_flits[i]);
- }
-
- vector<int> watch_packets = config.GetIntArray("watch_packets");
- for(size_t i = 0; i < watch_packets.size(); ++i) {
- _packets_to_watch.insert(watch_packets[i]);
- }
-
- string stats_out_file = config.GetStr( "stats_out" );
- if(stats_out_file == "") {
- _stats_out = NULL;
- } else if(stats_out_file == "-") {
- _stats_out = &cout;
- } else {
- _stats_out = new ofstream(stats_out_file.c_str());
- config.WriteMatlabFile(_stats_out);
- }
+ vector<int> watch_packets = config.GetIntArray("watch_packets");
+ for(size_t i = 0; i < watch_packets.size(); ++i) {
+ _packets_to_watch.insert(watch_packets[i]);
+ }
+
+ string stats_out_file = config.GetStr( "stats_out" );
+ if(stats_out_file == "") {
+ _stats_out = NULL;
+ } else if(stats_out_file == "-") {
+ _stats_out = &cout;
+ } else {
+ _stats_out = new ofstream(stats_out_file.c_str());
+ config.WriteMatlabFile(_stats_out);
+ }
#ifdef TRACK_FLOWS
- _injected_flits.resize(_classes, vector<int>(_nodes, 0));
- _ejected_flits.resize(_classes, vector<int>(_nodes, 0));
- string injected_flits_out_file = config.GetStr( "injected_flits_out" );
- if(injected_flits_out_file == "") {
- _injected_flits_out = NULL;
- } else {
- _injected_flits_out = new ofstream(injected_flits_out_file.c_str());
- }
- string received_flits_out_file = config.GetStr( "received_flits_out" );
- if(received_flits_out_file == "") {
- _received_flits_out = NULL;
- } else {
- _received_flits_out = new ofstream(received_flits_out_file.c_str());
- }
- string stored_flits_out_file = config.GetStr( "stored_flits_out" );
- if(stored_flits_out_file == "") {
- _stored_flits_out = NULL;
- } else {
- _stored_flits_out = new ofstream(stored_flits_out_file.c_str());
- }
- string sent_flits_out_file = config.GetStr( "sent_flits_out" );
- if(sent_flits_out_file == "") {
- _sent_flits_out = NULL;
- } else {
- _sent_flits_out = new ofstream(sent_flits_out_file.c_str());
- }
- string outstanding_credits_out_file = config.GetStr( "outstanding_credits_out" );
- if(outstanding_credits_out_file == "") {
- _outstanding_credits_out = NULL;
- } else {
- _outstanding_credits_out = new ofstream(outstanding_credits_out_file.c_str());
- }
- string ejected_flits_out_file = config.GetStr( "ejected_flits_out" );
- if(ejected_flits_out_file == "") {
- _ejected_flits_out = NULL;
- } else {
- _ejected_flits_out = new ofstream(ejected_flits_out_file.c_str());
- }
- string active_packets_out_file = config.GetStr( "active_packets_out" );
- if(active_packets_out_file == "") {
- _active_packets_out = NULL;
- } else {
- _active_packets_out = new ofstream(active_packets_out_file.c_str());
- }
+ _injected_flits.resize(_classes, vector<int>(_nodes, 0));
+ _ejected_flits.resize(_classes, vector<int>(_nodes, 0));
+ string injected_flits_out_file = config.GetStr( "injected_flits_out" );
+ if(injected_flits_out_file == "") {
+ _injected_flits_out = NULL;
+ } else {
+ _injected_flits_out = new ofstream(injected_flits_out_file.c_str());
+ }
+ string received_flits_out_file = config.GetStr( "received_flits_out" );
+ if(received_flits_out_file == "") {
+ _received_flits_out = NULL;
+ } else {
+ _received_flits_out = new ofstream(received_flits_out_file.c_str());
+ }
+ string stored_flits_out_file = config.GetStr( "stored_flits_out" );
+ if(stored_flits_out_file == "") {
+ _stored_flits_out = NULL;
+ } else {
+ _stored_flits_out = new ofstream(stored_flits_out_file.c_str());
+ }
+ string sent_flits_out_file = config.GetStr( "sent_flits_out" );
+ if(sent_flits_out_file == "") {
+ _sent_flits_out = NULL;
+ } else {
+ _sent_flits_out = new ofstream(sent_flits_out_file.c_str());
+ }
+ string outstanding_credits_out_file = config.GetStr( "outstanding_credits_out" );
+ if(outstanding_credits_out_file == "") {
+ _outstanding_credits_out = NULL;
+ } else {
+ _outstanding_credits_out = new ofstream(outstanding_credits_out_file.c_str());
+ }
+ string ejected_flits_out_file = config.GetStr( "ejected_flits_out" );
+ if(ejected_flits_out_file == "") {
+ _ejected_flits_out = NULL;
+ } else {
+ _ejected_flits_out = new ofstream(ejected_flits_out_file.c_str());
+ }
+ string active_packets_out_file = config.GetStr( "active_packets_out" );
+ if(active_packets_out_file == "") {
+ _active_packets_out = NULL;
+ } else {
+ _active_packets_out = new ofstream(active_packets_out_file.c_str());
+ }
#endif
-
+
#ifdef TRACK_CREDITS
- string used_credits_out_file = config.GetStr( "used_credits_out" );
- if(used_credits_out_file == "") {
- _used_credits_out = NULL;
- } else {
- _used_credits_out = new ofstream(used_credits_out_file.c_str());
- }
- string free_credits_out_file = config.GetStr( "free_credits_out" );
- if(free_credits_out_file == "") {
- _free_credits_out = NULL;
- } else {
- _free_credits_out = new ofstream(free_credits_out_file.c_str());
- }
- string max_credits_out_file = config.GetStr( "max_credits_out" );
- if(max_credits_out_file == "") {
- _max_credits_out = NULL;
- } else {
- _max_credits_out = new ofstream(max_credits_out_file.c_str());
- }
+ string used_credits_out_file = config.GetStr( "used_credits_out" );
+ if(used_credits_out_file == "") {
+ _used_credits_out = NULL;
+ } else {
+ _used_credits_out = new ofstream(used_credits_out_file.c_str());
+ }
+ string free_credits_out_file = config.GetStr( "free_credits_out" );
+ if(free_credits_out_file == "") {
+ _free_credits_out = NULL;
+ } else {
+ _free_credits_out = new ofstream(free_credits_out_file.c_str());
+ }
+ string max_credits_out_file = config.GetStr( "max_credits_out" );
+ if(max_credits_out_file == "") {
+ _max_credits_out = NULL;
+ } else {
+ _max_credits_out = new ofstream(max_credits_out_file.c_str());
+ }
#endif
+
+ // ============ Statistics ============
+
+ _plat_stats.resize(_classes);
+ _overall_min_plat.resize(_classes, 0.0);
+ _overall_avg_plat.resize(_classes, 0.0);
+ _overall_max_plat.resize(_classes, 0.0);
+
+ _nlat_stats.resize(_classes);
+ _overall_min_nlat.resize(_classes, 0.0);
+ _overall_avg_nlat.resize(_classes, 0.0);
+ _overall_max_nlat.resize(_classes, 0.0);
+
+ _flat_stats.resize(_classes);
+ _overall_min_flat.resize(_classes, 0.0);
+ _overall_avg_flat.resize(_classes, 0.0);
+ _overall_max_flat.resize(_classes, 0.0);
+
+ _frag_stats.resize(_classes);
+ _overall_min_frag.resize(_classes, 0.0);
+ _overall_avg_frag.resize(_classes, 0.0);
+ _overall_max_frag.resize(_classes, 0.0);
+
+ if(_pair_stats){
+ _pair_plat.resize(_classes);
+ _pair_nlat.resize(_classes);
+ _pair_flat.resize(_classes);
+ }
- // ============ Statistics ============
-
- _plat_stats.resize(_classes);
- _overall_min_plat.resize(_classes, 0.0);
- _overall_avg_plat.resize(_classes, 0.0);
- _overall_max_plat.resize(_classes, 0.0);
-
- _nlat_stats.resize(_classes);
- _overall_min_nlat.resize(_classes, 0.0);
- _overall_avg_nlat.resize(_classes, 0.0);
- _overall_max_nlat.resize(_classes, 0.0);
-
- _flat_stats.resize(_classes);
- _overall_min_flat.resize(_classes, 0.0);
- _overall_avg_flat.resize(_classes, 0.0);
- _overall_max_flat.resize(_classes, 0.0);
-
- _frag_stats.resize(_classes);
- _overall_min_frag.resize(_classes, 0.0);
- _overall_avg_frag.resize(_classes, 0.0);
- _overall_max_frag.resize(_classes, 0.0);
-
- if(_pair_stats){
- _pair_plat.resize(_classes);
- _pair_nlat.resize(_classes);
- _pair_flat.resize(_classes);
- }
-
- _hop_stats.resize(_classes);
- _overall_hop_stats.resize(_classes, 0.0);
-
- _sent_packets.resize(_classes);
- _overall_min_sent_packets.resize(_classes, 0.0);
- _overall_avg_sent_packets.resize(_classes, 0.0);
- _overall_max_sent_packets.resize(_classes, 0.0);
- _accepted_packets.resize(_classes);
- _overall_min_accepted_packets.resize(_classes, 0.0);
- _overall_avg_accepted_packets.resize(_classes, 0.0);
- _overall_max_accepted_packets.resize(_classes, 0.0);
-
- _sent_flits.resize(_classes);
- _overall_min_sent.resize(_classes, 0.0);
- _overall_avg_sent.resize(_classes, 0.0);
- _overall_max_sent.resize(_classes, 0.0);
- _accepted_flits.resize(_classes);
- _overall_min_accepted.resize(_classes, 0.0);
- _overall_avg_accepted.resize(_classes, 0.0);
- _overall_max_accepted.resize(_classes, 0.0);
+ _hop_stats.resize(_classes);
+ _overall_hop_stats.resize(_classes, 0.0);
+ _sent_packets.resize(_classes);
+ _overall_min_sent_packets.resize(_classes, 0.0);
+ _overall_avg_sent_packets.resize(_classes, 0.0);
+ _overall_max_sent_packets.resize(_classes, 0.0);
+ _accepted_packets.resize(_classes);
+ _overall_min_accepted_packets.resize(_classes, 0.0);
+ _overall_avg_accepted_packets.resize(_classes, 0.0);
+ _overall_max_accepted_packets.resize(_classes, 0.0);
+
+ _sent_flits.resize(_classes);
+ _overall_min_sent.resize(_classes, 0.0);
+ _overall_avg_sent.resize(_classes, 0.0);
+ _overall_max_sent.resize(_classes, 0.0);
+ _accepted_flits.resize(_classes);
+ _overall_min_accepted.resize(_classes, 0.0);
+ _overall_avg_accepted.resize(_classes, 0.0);
+ _overall_max_accepted.resize(_classes, 0.0);
+
#ifdef TRACK_STALLS
- _buffer_busy_stalls.resize(_classes);
- _buffer_conflict_stalls.resize(_classes);
- _buffer_full_stalls.resize(_classes);
- _buffer_reserved_stalls.resize(_classes);
- _crossbar_conflict_stalls.resize(_classes);
- _overall_buffer_busy_stalls.resize(_classes, 0);
- _overall_buffer_conflict_stalls.resize(_classes, 0);
- _overall_buffer_full_stalls.resize(_classes, 0);
- _overall_buffer_reserved_stalls.resize(_classes, 0);
- _overall_crossbar_conflict_stalls.resize(_classes, 0);
+ _buffer_busy_stalls.resize(_classes);
+ _buffer_conflict_stalls.resize(_classes);
+ _buffer_full_stalls.resize(_classes);
+ _buffer_reserved_stalls.resize(_classes);
+ _crossbar_conflict_stalls.resize(_classes);
+ _overall_buffer_busy_stalls.resize(_classes, 0);
+ _overall_buffer_conflict_stalls.resize(_classes, 0);
+ _overall_buffer_full_stalls.resize(_classes, 0);
+ _overall_buffer_reserved_stalls.resize(_classes, 0);
+ _overall_crossbar_conflict_stalls.resize(_classes, 0);
#endif
-
- for ( int c = 0; c < _classes; ++c ) {
- ostringstream tmp_name;
-
- tmp_name << "plat_stat_" << c;
- _plat_stats[c] = new Stats( this, tmp_name.str( ), 1.0, 1000 );
- _stats[tmp_name.str()] = _plat_stats[c];
- tmp_name.str("");
-
- tmp_name << "nlat_stat_" << c;
- _nlat_stats[c] = new Stats( this, tmp_name.str( ), 1.0, 1000 );
- _stats[tmp_name.str()] = _nlat_stats[c];
- tmp_name.str("");
-
- tmp_name << "flat_stat_" << c;
- _flat_stats[c] = new Stats( this, tmp_name.str( ), 1.0, 1000 );
- _stats[tmp_name.str()] = _flat_stats[c];
- tmp_name.str("");
-
- tmp_name << "frag_stat_" << c;
- _frag_stats[c] = new Stats( this, tmp_name.str( ), 1.0, 100 );
- _stats[tmp_name.str()] = _frag_stats[c];
- tmp_name.str("");
-
- tmp_name << "hop_stat_" << c;
- _hop_stats[c] = new Stats( this, tmp_name.str( ), 1.0, 20 );
- _stats[tmp_name.str()] = _hop_stats[c];
- tmp_name.str("");
-
- if(_pair_stats){
- _pair_plat[c].resize(_nodes*_nodes);
- _pair_nlat[c].resize(_nodes*_nodes);
- _pair_flat[c].resize(_nodes*_nodes);
- }
-
- _sent_packets[c].resize(_nodes, 0);
- _accepted_packets[c].resize(_nodes, 0);
- _sent_flits[c].resize(_nodes, 0);
- _accepted_flits[c].resize(_nodes, 0);
-
+
+ for ( int c = 0; c < _classes; ++c ) {
+ ostringstream tmp_name;
+
+ tmp_name << "plat_stat_" << c;
+ _plat_stats[c] = new Stats( this, tmp_name.str( ), 1.0, 1000 );
+ _stats[tmp_name.str()] = _plat_stats[c];
+ tmp_name.str("");
+
+ tmp_name << "nlat_stat_" << c;
+ _nlat_stats[c] = new Stats( this, tmp_name.str( ), 1.0, 1000 );
+ _stats[tmp_name.str()] = _nlat_stats[c];
+ tmp_name.str("");
+
+ tmp_name << "flat_stat_" << c;
+ _flat_stats[c] = new Stats( this, tmp_name.str( ), 1.0, 1000 );
+ _stats[tmp_name.str()] = _flat_stats[c];
+ tmp_name.str("");
+
+ tmp_name << "frag_stat_" << c;
+ _frag_stats[c] = new Stats( this, tmp_name.str( ), 1.0, 100 );
+ _stats[tmp_name.str()] = _frag_stats[c];
+ tmp_name.str("");
+
+ tmp_name << "hop_stat_" << c;
+ _hop_stats[c] = new Stats( this, tmp_name.str( ), 1.0, 20 );
+ _stats[tmp_name.str()] = _hop_stats[c];
+ tmp_name.str("");
+
+ if(_pair_stats){
+ _pair_plat[c].resize(_nodes*_nodes);
+ _pair_nlat[c].resize(_nodes*_nodes);
+ _pair_flat[c].resize(_nodes*_nodes);
+ }
+
+ _sent_packets[c].resize(_nodes, 0);
+ _accepted_packets[c].resize(_nodes, 0);
+ _sent_flits[c].resize(_nodes, 0);
+ _accepted_flits[c].resize(_nodes, 0);
+
#ifdef TRACK_STALLS
- _buffer_busy_stalls[c].resize(_subnets*_routers, 0);
- _buffer_conflict_stalls[c].resize(_subnets*_routers, 0);
- _buffer_full_stalls[c].resize(_subnets*_routers, 0);
- _buffer_reserved_stalls[c].resize(_subnets*_routers, 0);
- _crossbar_conflict_stalls[c].resize(_subnets*_routers, 0);
+ _buffer_busy_stalls[c].resize(_subnets*_routers, 0);
+ _buffer_conflict_stalls[c].resize(_subnets*_routers, 0);
+ _buffer_full_stalls[c].resize(_subnets*_routers, 0);
+ _buffer_reserved_stalls[c].resize(_subnets*_routers, 0);
+ _crossbar_conflict_stalls[c].resize(_subnets*_routers, 0);
#endif
- if(_pair_stats){
- for ( int i = 0; i < _nodes; ++i ) {
- for ( int j = 0; j < _nodes; ++j ) {
- tmp_name << "pair_plat_stat_" << c << "_" << i << "_" << j;
- _pair_plat[c][i*_nodes+j] = new Stats( this, tmp_name.str( ), 1.0, 250 );
- _stats[tmp_name.str()] = _pair_plat[c][i*_nodes+j];
- tmp_name.str("");
-
- tmp_name << "pair_nlat_stat_" << c << "_" << i << "_" << j;
- _pair_nlat[c][i*_nodes+j] = new Stats( this, tmp_name.str( ), 1.0, 250 );
- _stats[tmp_name.str()] = _pair_nlat[c][i*_nodes+j];
- tmp_name.str("");
-
- tmp_name << "pair_flat_stat_" << c << "_" << i << "_" << j;
- _pair_flat[c][i*_nodes+j] = new Stats( this, tmp_name.str( ), 1.0, 250 );
- _stats[tmp_name.str()] = _pair_flat[c][i*_nodes+j];
- tmp_name.str("");
+ if(_pair_stats){
+ for ( int i = 0; i < _nodes; ++i ) {
+ for ( int j = 0; j < _nodes; ++j ) {
+ tmp_name << "pair_plat_stat_" << c << "_" << i << "_" << j;
+ _pair_plat[c][i*_nodes+j] = new Stats( this, tmp_name.str( ), 1.0, 250 );
+ _stats[tmp_name.str()] = _pair_plat[c][i*_nodes+j];
+ tmp_name.str("");
+
+ tmp_name << "pair_nlat_stat_" << c << "_" << i << "_" << j;
+ _pair_nlat[c][i*_nodes+j] = new Stats( this, tmp_name.str( ), 1.0, 250 );
+ _stats[tmp_name.str()] = _pair_nlat[c][i*_nodes+j];
+ tmp_name.str("");
+
+ tmp_name << "pair_flat_stat_" << c << "_" << i << "_" << j;
+ _pair_flat[c][i*_nodes+j] = new Stats( this, tmp_name.str( ), 1.0, 250 );
+ _stats[tmp_name.str()] = _pair_flat[c][i*_nodes+j];
+ tmp_name.str("");
+ }
+ }
}
- }
}
- }
-
- _slowest_flit.resize(_classes, -1);
- _slowest_packet.resize(_classes, -1);
-
-
-
+
+ _slowest_flit.resize(_classes, -1);
+ _slowest_packet.resize(_classes, -1);
+
+
+
}
TrafficManager::~TrafficManager( )
{
-
- for ( int source = 0; source < _nodes; ++source ) {
- for ( int subnet = 0; subnet < _subnets; ++subnet ) {
- delete _buf_states[source][subnet];
+
+ for ( int source = 0; source < _nodes; ++source ) {
+ for ( int subnet = 0; subnet < _subnets; ++subnet ) {
+ delete _buf_states[source][subnet];
+ }
}
- }
- for ( int c = 0; c < _classes; ++c ) {
- delete _plat_stats[c];
- delete _nlat_stats[c];
- delete _flat_stats[c];
- delete _frag_stats[c];
- delete _hop_stats[c];
-
- delete _traffic_pattern[c];
- delete _injection_process[c];
- if(_pair_stats){
- for ( int i = 0; i < _nodes; ++i ) {
- for ( int j = 0; j < _nodes; ++j ) {
- delete _pair_plat[c][i*_nodes+j];
- delete _pair_nlat[c][i*_nodes+j];
- delete _pair_flat[c][i*_nodes+j];
+ for ( int c = 0; c < _classes; ++c ) {
+ delete _plat_stats[c];
+ delete _nlat_stats[c];
+ delete _flat_stats[c];
+ delete _frag_stats[c];
+ delete _hop_stats[c];
+
+ delete _traffic_pattern[c];
+ delete _injection_process[c];
+ if(_pair_stats){
+ for ( int i = 0; i < _nodes; ++i ) {
+ for ( int j = 0; j < _nodes; ++j ) {
+ delete _pair_plat[c][i*_nodes+j];
+ delete _pair_nlat[c][i*_nodes+j];
+ delete _pair_flat[c][i*_nodes+j];
+ }
+ }
}
- }
}
- }
-
- if(gWatchOut && (gWatchOut != &cout)) delete gWatchOut;
- if(_stats_out && (_stats_out != &cout)) delete _stats_out;
+ if(gWatchOut && (gWatchOut != &cout)) delete gWatchOut;
+ if(_stats_out && (_stats_out != &cout)) delete _stats_out;
+
#ifdef TRACK_FLOWS
- if(_injected_flits_out) delete _injected_flits_out;
- if(_received_flits_out) delete _received_flits_out;
- if(_stored_flits_out) delete _stored_flits_out;
- if(_sent_flits_out) delete _sent_flits_out;
- if(_outstanding_credits_out) delete _outstanding_credits_out;
- if(_ejected_flits_out) delete _ejected_flits_out;
- if(_active_packets_out) delete _active_packets_out;
+ if(_injected_flits_out) delete _injected_flits_out;
+ if(_received_flits_out) delete _received_flits_out;
+ if(_stored_flits_out) delete _stored_flits_out;
+ if(_sent_flits_out) delete _sent_flits_out;
+ if(_outstanding_credits_out) delete _outstanding_credits_out;
+ if(_ejected_flits_out) delete _ejected_flits_out;
+ if(_active_packets_out) delete _active_packets_out;
#endif
-
+
#ifdef TRACK_CREDITS
- if(_used_credits_out) delete _used_credits_out;
- if(_free_credits_out) delete _free_credits_out;
- if(_max_credits_out) delete _max_credits_out;
+ if(_used_credits_out) delete _used_credits_out;
+ if(_free_credits_out) delete _free_credits_out;
+ if(_max_credits_out) delete _max_credits_out;
#endif
-
- PacketReplyInfo::FreeAll();
- Flit::FreeAll();
- Credit::FreeAll();
+
+ PacketReplyInfo::FreeAll();
+ Flit::FreeAll();
+ Credit::FreeAll();
}
void TrafficManager::_RetireFlit( Flit *f, int dest )
{
- _deadlock_timer = 0;
-
- assert(_total_in_flight_flits[f->cl].count(f->id) > 0);
- _total_in_flight_flits[f->cl].erase(f->id);
-
- if(f->record) {
- assert(_measured_in_flight_flits[f->cl].count(f->id) > 0);
- _measured_in_flight_flits[f->cl].erase(f->id);
- }
-
- if ( f->watch ) {
- *gWatchOut << GetSimTime() << " | "
- << "node" << dest << " | "
- << "Retiring flit " << f->id
- << " (packet " << f->pid
- << ", src = " << f->src
- << ", dest = " << f->dest
- << ", hops = " << f->hops
- << ", flat = " << f->atime - f->itime
- << ")." << endl;
- }
-
- if ( f->head && ( f->dest != dest ) ) {
- ostringstream err;
- err << "Flit " << f->id << " arrived at incorrect output " << dest;
- Error( err.str( ) );
- }
-
- if((_slowest_flit[f->cl] < 0) ||
- (_flat_stats[f->cl]->Max() < (f->atime - f->itime)))
- _slowest_flit[f->cl] = f->id;
- _flat_stats[f->cl]->AddSample( f->atime - f->itime);
- if(_pair_stats){
- _pair_flat[f->cl][f->src*_nodes+dest]->AddSample( f->atime - f->itime );
- }
+ _deadlock_timer = 0;
+
+ assert(_total_in_flight_flits[f->cl].count(f->id) > 0);
+ _total_in_flight_flits[f->cl].erase(f->id);
- if ( f->tail ) {
- Flit * head;
- if(f->head) {
- head = f;
- } else {
- map<int, Flit *>::iterator iter = _retired_packets[f->cl].find(f->pid);
- assert(iter != _retired_packets[f->cl].end());
- head = iter->second;
- _retired_packets[f->cl].erase(iter);
- assert(head->head);
- assert(f->pid == head->pid);
+ if(f->record) {
+ assert(_measured_in_flight_flits[f->cl].count(f->id) > 0);
+ _measured_in_flight_flits[f->cl].erase(f->id);
}
- if ( f->watch ) {
- *gWatchOut << GetSimTime() << " | "
- << "node" << dest << " | "
- << "Retiring packet " << f->pid
- << " (plat = " << f->atime - head->ctime
- << ", nlat = " << f->atime - head->itime
- << ", frag = " << (f->atime - head->atime) - (f->id - head->id) // NB: In the spirit of solving problems using ugly hacks, we compute the packet length by taking advantage of the fact that the IDs of flits within a packet are contiguous.
- << ", src = " << head->src
- << ", dest = " << head->dest
- << ")." << endl;
+
+ if ( f->watch ) {
+ *gWatchOut << GetSimTime() << " | "
+ << "node" << dest << " | "
+ << "Retiring flit " << f->id
+ << " (packet " << f->pid
+ << ", src = " << f->src
+ << ", dest = " << f->dest
+ << ", hops = " << f->hops
+ << ", flat = " << f->atime - f->itime
+ << ")." << endl;
}
-
- //code the source of request, look carefully, its tricky ;)
- if (f->type == Flit::READ_REQUEST || f->type == Flit::WRITE_REQUEST) {
- PacketReplyInfo* rinfo = PacketReplyInfo::New();
- rinfo->source = f->src;
- rinfo->time = f->atime;
- rinfo->record = f->record;
- rinfo->type = f->type;
- _repliesPending[dest].push_back(rinfo);
- } else {
- if(f->type == Flit::READ_REPLY || f->type == Flit::WRITE_REPLY ){
- _requestsOutstanding[dest]--;
- } else if(f->type == Flit::ANY_TYPE) {
- _requestsOutstanding[f->src]--;
- }
-
+
+ if ( f->head && ( f->dest != dest ) ) {
+ ostringstream err;
+ err << "Flit " << f->id << " arrived at incorrect output " << dest;
+ Error( err.str( ) );
+ }
+
+ if((_slowest_flit[f->cl] < 0) ||
+ (_flat_stats[f->cl]->Max() < (f->atime - f->itime)))
+ _slowest_flit[f->cl] = f->id;
+ _flat_stats[f->cl]->AddSample( f->atime - f->itime);
+ if(_pair_stats){
+ _pair_flat[f->cl][f->src*_nodes+dest]->AddSample( f->atime - f->itime );
}
-
- // Only record statistics once per packet (at tail)
- // and based on the simulation state
- if ( ( _sim_state == warming_up ) || f->record ) {
- _hop_stats[f->cl]->AddSample( f->hops );
+ if ( f->tail ) {
+ Flit * head;
+ if(f->head) {
+ head = f;
+ } else {
+ map<int, Flit *>::iterator iter = _retired_packets[f->cl].find(f->pid);
+ assert(iter != _retired_packets[f->cl].end());
+ head = iter->second;
+ _retired_packets[f->cl].erase(iter);
+ assert(head->head);
+ assert(f->pid == head->pid);
+ }
+ if ( f->watch ) {
+ *gWatchOut << GetSimTime() << " | "
+ << "node" << dest << " | "
+ << "Retiring packet " << f->pid
+ << " (plat = " << f->atime - head->ctime
+ << ", nlat = " << f->atime - head->itime
+ << ", frag = " << (f->atime - head->atime) - (f->id - head->id) // NB: In the spirit of solving problems using ugly hacks, we compute the packet length by taking advantage of the fact that the IDs of flits within a packet are contiguous.
+ << ", src = " << head->src
+ << ", dest = " << head->dest
+ << ")." << endl;
+ }
+
+ //code the source of request, look carefully, its tricky ;)
+ if (f->type == Flit::READ_REQUEST || f->type == Flit::WRITE_REQUEST) {
+ PacketReplyInfo* rinfo = PacketReplyInfo::New();
+ rinfo->source = f->src;
+ rinfo->time = f->atime;
+ rinfo->record = f->record;
+ rinfo->type = f->type;
+ _repliesPending[dest].push_back(rinfo);
+ } else {
+ if(f->type == Flit::READ_REPLY || f->type == Flit::WRITE_REPLY ){
+ _requestsOutstanding[dest]--;
+ } else if(f->type == Flit::ANY_TYPE) {
+ _requestsOutstanding[f->src]--;
+ }
- if((_slowest_packet[f->cl] < 0) ||
- (_plat_stats[f->cl]->Max() < (f->atime - head->itime)))
- _slowest_packet[f->cl] = f->pid;
- _plat_stats[f->cl]->AddSample( f->atime - head->ctime);
- _nlat_stats[f->cl]->AddSample( f->atime - head->itime);
- _frag_stats[f->cl]->AddSample( (f->atime - head->atime) - (f->id - head->id) );
+ }
+
+ // Only record statistics once per packet (at tail)
+ // and based on the simulation state
+ if ( ( _sim_state == warming_up ) || f->record ) {
- if(_pair_stats){
- _pair_plat[f->cl][f->src*_nodes+dest]->AddSample( f->atime - head->ctime );
- _pair_nlat[f->cl][f->src*_nodes+dest]->AddSample( f->atime - head->itime );
- }
- }
+ _hop_stats[f->cl]->AddSample( f->hops );
+
+ if((_slowest_packet[f->cl] < 0) ||
+ (_plat_stats[f->cl]->Max() < (f->atime - head->itime)))
+ _slowest_packet[f->cl] = f->pid;
+ _plat_stats[f->cl]->AddSample( f->atime - head->ctime);
+ _nlat_stats[f->cl]->AddSample( f->atime - head->itime);
+ _frag_stats[f->cl]->AddSample( (f->atime - head->atime) - (f->id - head->id) );
+
+ if(_pair_stats){
+ _pair_plat[f->cl][f->src*_nodes+dest]->AddSample( f->atime - head->ctime );
+ _pair_nlat[f->cl][f->src*_nodes+dest]->AddSample( f->atime - head->itime );
+ }
+ }
- if(f != head) {
- head->Free();
- }
+ if(f != head) {
+ head->Free();
+ }
- }
+ }
- if(f->head && !f->tail) {
- _retired_packets[f->cl].insert(make_pair(f->pid, f));
- } else {
- f->Free();
- }
+ if(f->head && !f->tail) {
+ _retired_packets[f->cl].insert(make_pair(f->pid, f));
+ } else {
+ f->Free();
+ }
}
int TrafficManager::_IssuePacket( int source, int cl )
{
- int result = 0;
- if(_use_read_write[cl]){ //use read and write
- //check queue for waiting replies.
- //check to make sure it is on time yet
- if (!_repliesPending[source].empty()) {
- if(_repliesPending[source].front()->time <= _time) {
- result = -1;
- }
- } else {
+ int result = 0;
+ if(_use_read_write[cl]){ //use read and write
+ //check queue for waiting replies.
+ //check to make sure it is on time yet
+ if (!_repliesPending[source].empty()) {
+ if(_repliesPending[source].front()->time <= _time) {
+ result = -1;
+ }
+ } else {
- //produce a packet
- if(_injection_process[cl]->test(source)) {
-
- //coin toss to determine request type.
- result = (RandomFloat() < _write_fraction[cl]) ? 2 : 1;
-
+ //produce a packet
+ if(_injection_process[cl]->test(source)) {
+
+ //coin toss to determine request type.
+ result = (RandomFloat() < _write_fraction[cl]) ? 2 : 1;
+
+ _requestsOutstanding[source]++;
+ }
+ }
+ } else { //normal mode
+ result = _injection_process[cl]->test(source) ? 1 : 0;
_requestsOutstanding[source]++;
- }
+ }
+ if(result != 0) {
+ _packet_seq_no[source]++;
}
- } else { //normal mode
- result = _injection_process[cl]->test(source) ? 1 : 0;
- _requestsOutstanding[source]++;
- }
- if(result != 0) {
- _packet_seq_no[source]++;
- }
- return result;
+ return result;
}
-void TrafficManager::_GeneratePacket( int source, int stype,
- int cl, int time )
+void TrafficManager::_GeneratePacket( int source, int stype,
+ int cl, int time )
{
- assert(stype!=0);
-
- Flit::FlitType packet_type = Flit::ANY_TYPE;
- int size = _GetNextPacketSize(cl); //input size
- int pid = _cur_pid++;
- assert(_cur_pid);
- int packet_destination = _traffic_pattern[cl]->dest(source);
- bool record = false;
- bool watch = gWatchOut && (_packets_to_watch.count(pid) > 0);
- if(_use_read_write[cl]){
- if(stype > 0) {
- if (stype == 1) {
- packet_type = Flit::READ_REQUEST;
- size = _read_request_size[cl];
- } else if (stype == 2) {
- packet_type = Flit::WRITE_REQUEST;
- size = _write_request_size[cl];
- } else {
- ostringstream err;
- err << "Invalid packet type: " << packet_type;
- Error( err.str( ) );
- }
- } else {
- PacketReplyInfo* rinfo = _repliesPending[source].front();
- if (rinfo->type == Flit::READ_REQUEST) {//read reply
- size = _read_reply_size[cl];
- packet_type = Flit::READ_REPLY;
- } else if(rinfo->type == Flit::WRITE_REQUEST) { //write reply
- size = _write_reply_size[cl];
- packet_type = Flit::WRITE_REPLY;
- } else {
+ assert(stype!=0);
+
+ Flit::FlitType packet_type = Flit::ANY_TYPE;
+ int size = _GetNextPacketSize(cl); //input size
+ int pid = _cur_pid++;
+ assert(_cur_pid);
+ int packet_destination = _traffic_pattern[cl]->dest(source);
+ bool record = false;
+ bool watch = gWatchOut && (_packets_to_watch.count(pid) > 0);
+ if(_use_read_write[cl]){
+ if(stype > 0) {
+ if (stype == 1) {
+ packet_type = Flit::READ_REQUEST;
+ size = _read_request_size[cl];
+ } else if (stype == 2) {
+ packet_type = Flit::WRITE_REQUEST;
+ size = _write_request_size[cl];
+ } else {
+ ostringstream err;
+ err << "Invalid packet type: " << packet_type;
+ Error( err.str( ) );
+ }
+ } else {
+ PacketReplyInfo* rinfo = _repliesPending[source].front();
+ if (rinfo->type == Flit::READ_REQUEST) {//read reply
+ size = _read_reply_size[cl];
+ packet_type = Flit::READ_REPLY;
+ } else if(rinfo->type == Flit::WRITE_REQUEST) { //write reply
+ size = _write_reply_size[cl];
+ packet_type = Flit::WRITE_REPLY;
+ } else {
+ ostringstream err;
+ err << "Invalid packet type: " << rinfo->type;
+ Error( err.str( ) );
+ }
+ packet_destination = rinfo->source;
+ time = rinfo->time;
+ record = rinfo->record;
+ _repliesPending[source].pop_front();
+ rinfo->Free();
+ }
+ }
+
+ if ((packet_destination <0) || (packet_destination >= _nodes)) {
ostringstream err;
- err << "Invalid packet type: " << rinfo->type;
+ err << "Incorrect packet destination " << packet_destination
+ << " for stype " << packet_type;
Error( err.str( ) );
- }
- packet_destination = rinfo->source;
- time = rinfo->time;
- record = rinfo->record;
- _repliesPending[source].pop_front();
- rinfo->Free();
}
- }
-
- if ((packet_destination <0) || (packet_destination >= _nodes)) {
- ostringstream err;
- err << "Incorrect packet destination " << packet_destination
- << " for stype " << packet_type;
- Error( err.str( ) );
- }
-
- if ( ( _sim_state == running ) ||
- ( ( _sim_state == draining ) && ( time < _drain_time ) ) ) {
- record = _measure_stats[cl];
- }
-
- int subnetwork = ((packet_type == Flit::ANY_TYPE) ?
- RandomInt(_subnets-1) :
- _subnet[packet_type]);
-
- if ( watch ) {
- *gWatchOut << GetSimTime() << " | "
- << "node" << source << " | "
- << "Enqueuing packet " << pid
- << " at time " << time
- << "." << endl;
- }
-
- for ( int i = 0; i < size; ++i ) {
- Flit * f = Flit::New();
- f->id = _cur_id++;
- assert(_cur_id);
- f->pid = pid;
- f->watch = watch | (gWatchOut && (_flits_to_watch.count(f->id) > 0));
- f->subnetwork = subnetwork;
- f->src = source;
- f->ctime = time;
- f->record = record;
- f->cl = cl;
-
- _total_in_flight_flits[f->cl].insert(make_pair(f->id, f));
- if(record) {
- _measured_in_flight_flits[f->cl].insert(make_pair(f->id, f));
- }
-
- if(gTrace){
- cout<<"New Flit "<<f->src<<endl;
- }
- f->type = packet_type;
-
- if ( i == 0 ) { // Head flit
- f->head = true;
- //packets are only generated to nodes smaller or equal to limit
- f->dest = packet_destination;
- } else {
- f->head = false;
- f->dest = -1;
- }
- switch( _pri_type ) {
- case class_based:
- f->pri = _class_priority[cl];
- assert(f->pri >= 0);
- break;
- case age_based:
- f->pri = numeric_limits<int>::max() - time;
- assert(f->pri >= 0);
- break;
- case sequence_based:
- f->pri = numeric_limits<int>::max() - _packet_seq_no[source];
- assert(f->pri >= 0);
- break;
- default:
- f->pri = 0;
+
+ if ( ( _sim_state == running ) ||
+ ( ( _sim_state == draining ) && ( time < _drain_time ) ) ) {
+ record = _measure_stats[cl];
}
- if ( i == ( size - 1 ) ) { // Tail flit
- f->tail = true;
- } else {
- f->tail = false;
+
+ int subnetwork = ((packet_type == Flit::ANY_TYPE) ?
+ RandomInt(_subnets-1) :
+ _subnet[packet_type]);
+
+ if ( watch ) {
+ *gWatchOut << GetSimTime() << " | "
+ << "node" << source << " | "
+ << "Enqueuing packet " << pid
+ << " at time " << time
+ << "." << endl;
}
+
+ for ( int i = 0; i < size; ++i ) {
+ Flit * f = Flit::New();
+ f->id = _cur_id++;
+ assert(_cur_id);
+ f->pid = pid;
+ f->watch = watch | (gWatchOut && (_flits_to_watch.count(f->id) > 0));
+ f->subnetwork = subnetwork;
+ f->src = source;
+ f->ctime = time;
+ f->record = record;
+ f->cl = cl;
+
+ _total_in_flight_flits[f->cl].insert(make_pair(f->id, f));
+ if(record) {
+ _measured_in_flight_flits[f->cl].insert(make_pair(f->id, f));
+ }
- f->vc = -1;
+ if(gTrace){
+ cout<<"New Flit "<<f->src<<endl;
+ }
+ f->type = packet_type;
+
+ if ( i == 0 ) { // Head flit
+ f->head = true;
+ //packets are only generated to nodes smaller or equal to limit
+ f->dest = packet_destination;
+ } else {
+ f->head = false;
+ f->dest = -1;
+ }
+ switch( _pri_type ) {
+ case class_based:
+ f->pri = _class_priority[cl];
+ assert(f->pri >= 0);
+ break;
+ case age_based:
+ f->pri = numeric_limits<int>::max() - time;
+ assert(f->pri >= 0);
+ break;
+ case sequence_based:
+ f->pri = numeric_limits<int>::max() - _packet_seq_no[source];
+ assert(f->pri >= 0);
+ break;
+ default:
+ f->pri = 0;
+ }
+ if ( i == ( size - 1 ) ) { // Tail flit
+ f->tail = true;
+ } else {
+ f->tail = false;
+ }
- if ( f->watch ) {
- *gWatchOut << GetSimTime() << " | "
- << "node" << source << " | "
- << "Enqueuing flit " << f->id
- << " (packet " << f->pid
- << ") at time " << time
- << "." << endl;
+ f->vc = -1;
+
+ if ( f->watch ) {
+ *gWatchOut << GetSimTime() << " | "
+ << "node" << source << " | "
+ << "Enqueuing flit " << f->id
+ << " (packet " << f->pid
+ << ") at time " << time
+ << "." << endl;
+ }
+
+ _partial_packets[source][cl].push_back( f );
}
-
- _partial_packets[source][cl].push_back( f );
- }
}
void TrafficManager::_Inject(){
-
- for ( int input = 0; input < _nodes; ++input ) {
- for ( int c = 0; c < _classes; ++c ) {
- // Potentially generate packets for any (input,class)
- // that is currently empty
- if ( _partial_packets[input][c].empty() ) {
- bool generated = false;
- while( !generated && ( _qtime[input][c] <= _time ) ) {
- int stype = _IssuePacket( input, c );
-
- if ( stype != 0 ) { //generate a packet
- _GeneratePacket( input, stype, c,
- _include_queuing==1 ?
- _qtime[input][c] : _time );
- generated = true;
- }
- // only advance time if this is not a reply packet
- if(!_use_read_write[c] || (stype >= 0)){
- ++_qtime[input][c];
- }
- }
-
- if ( ( _sim_state == draining ) &&
- ( _qtime[input][c] > _drain_time ) ) {
- _qdrained[input][c] = true;
+
+ for ( int input = 0; input < _nodes; ++input ) {
+ for ( int c = 0; c < _classes; ++c ) {
+ // Potentially generate packets for any (input,class)
+ // that is currently empty
+ if ( _partial_packets[input][c].empty() ) {
+ bool generated = false;
+ while( !generated && ( _qtime[input][c] <= _time ) ) {
+ int stype = _IssuePacket( input, c );
+
+ if ( stype != 0 ) { //generate a packet
+ _GeneratePacket( input, stype, c,
+ _include_queuing==1 ?
+ _qtime[input][c] : _time );
+ generated = true;
+ }
+ // only advance time if this is not a reply packet
+ if(!_use_read_write[c] || (stype >= 0)){
+ ++_qtime[input][c];
+ }
+ }
+
+ if ( ( _sim_state == draining ) &&
+ ( _qtime[input][c] > _drain_time ) ) {
+ _qdrained[input][c] = true;
+ }
+ }
}
- }
}
- }
}
void TrafficManager::_Step( )
{
- bool flits_in_flight = false;
- for(int c = 0; c < _classes; ++c) {
- flits_in_flight |= !_total_in_flight_flits[c].empty();
- }
- if(flits_in_flight && (_deadlock_timer++ >= _deadlock_warn_timeout)){
- _deadlock_timer = 0;
- cout << "WARNING: Possible network deadlock.\n";
- }
-
- vector<map<int, Flit *> > flits(_subnets);
+ bool flits_in_flight = false;
+ for(int c = 0; c < _classes; ++c) {
+ flits_in_flight |= !_total_in_flight_flits[c].empty();
+ }
+ if(flits_in_flight && (_deadlock_timer++ >= _deadlock_warn_timeout)){
+ _deadlock_timer = 0;
+ cout << "WARNING: Possible network deadlock.\n";
+ }
+
+ vector<map<int, Flit *> > flits(_subnets);
- for ( int subnet = 0; subnet < _subnets; ++subnet ) {
- for ( int n = 0; n < _nodes; ++n ) {
- Flit * const f = _net[subnet]->ReadFlit( n );
- if ( f ) {
- if(f->watch) {
- *gWatchOut << GetSimTime() << " | "
- << "node" << n << " | "
- << "Ejecting flit " << f->id
- << " (packet " << f->pid << ")"
- << " from VC " << f->vc
- << "." << endl;
- }
- flits[subnet].insert(make_pair(n, f));
- if((_sim_state == warming_up) || (_sim_state == running)) {
- ++_accepted_flits[f->cl][n];
- if(f->tail) {
- ++_accepted_packets[f->cl][n];
- }
- }
- }
-
- Credit * const c = _net[subnet]->ReadCredit( n );
- if ( c ) {
+ for ( int subnet = 0; subnet < _subnets; ++subnet ) {
+ for ( int n = 0; n < _nodes; ++n ) {
+ Flit * const f = _net[subnet]->ReadFlit( n );
+ if ( f ) {
+ if(f->watch) {
+ *gWatchOut << GetSimTime() << " | "
+ << "node" << n << " | "
+ << "Ejecting flit " << f->id
+ << " (packet " << f->pid << ")"
+ << " from VC " << f->vc
+ << "." << endl;
+ }
+ flits[subnet].insert(make_pair(n, f));
+ if((_sim_state == warming_up) || (_sim_state == running)) {
+ ++_accepted_flits[f->cl][n];
+ if(f->tail) {
+ ++_accepted_packets[f->cl][n];
+ }
+ }
+ }
+
+ Credit * const c = _net[subnet]->ReadCredit( n );
+ if ( c ) {
#ifdef TRACK_FLOWS
- for(set<int>::const_iterator iter = c->vc.begin(); iter != c->vc.end(); ++iter) {
- int const vc = *iter;
- assert(!_outstanding_classes[n][subnet][vc].empty());
- int cl = _outstanding_classes[n][subnet][vc].front();
- _outstanding_classes[n][subnet][vc].pop();
- assert(_outstanding_credits[cl][subnet][n] > 0);
- --_outstanding_credits[cl][subnet][n];
- }
+ for(set<int>::const_iterator iter = c->vc.begin(); iter != c->vc.end(); ++iter) {
+ int const vc = *iter;
+ assert(!_outstanding_classes[n][subnet][vc].empty());
+ int cl = _outstanding_classes[n][subnet][vc].front();
+ _outstanding_classes[n][subnet][vc].pop();
+ assert(_outstanding_credits[cl][subnet][n] > 0);
+ --_outstanding_credits[cl][subnet][n];
+ }
#endif
- _buf_states[n][subnet]->ProcessCredit(c);
- c->Free();
- }
+ _buf_states[n][subnet]->ProcessCredit(c);
+ c->Free();
+ }
+ }
+ _net[subnet]->ReadInputs( );
}
- _net[subnet]->ReadInputs( );
- }
- if ( !_empty_network ) {
- _Inject();
- }
-
- for(int subnet = 0; subnet < _subnets; ++subnet) {
-
- for(int n = 0; n < _nodes; ++n) {
-
- Flit * f = NULL;
-
- BufferState * const dest_buf = _buf_states[n][subnet];
-
- int const last_class = _last_class[n][subnet];
-
- int class_limit = _classes;
-
- if(_hold_switch_for_packet) {
- list<Flit *> const & pp = _partial_packets[n][last_class];
- if(!pp.empty() && !pp.front()->head &&
- !dest_buf->IsFullFor(pp.front()->vc)) {
- f = pp.front();
- assert(f->vc == _last_vc[n][subnet][last_class]);
-
- // if we're holding the connection, we don't need to check that class
- // again in the for loop
- --class_limit;
- }
- }
-
- for(int i = 1; i <= class_limit; ++i) {
-
- int const c = (last_class + i) % _classes;
-
- list<Flit *> const & pp = _partial_packets[n][c];
-
- if(pp.empty()) {
- continue;
- }
-
- Flit * const cf = pp.front();
- assert(cf);
- assert(cf->cl == c);
-
- if(cf->subnetwork != subnet) {
- continue;
- }
-
- if(f && (f->pri >= cf->pri)) {
- continue;
- }
-
- if(cf->head && cf->vc == -1) { // Find first available VC
-
- OutputSet route_set;
- _rf(NULL, cf, -1, &route_set, true);
- set<OutputSet::sSetElement> const & os = route_set.GetSet();
- assert(os.size() == 1);
- OutputSet::sSetElement const & se = *os.begin();
- assert(se.output_port == -1);
- int vc_start = se.vc_start;
- int vc_end = se.vc_end;
- int vc_count = vc_end - vc_start + 1;
- if(_noq) {
- assert(_lookahead_routing);
- const FlitChannel * inject = _net[subnet]->GetInject(n);
- const Router * router = inject->GetSink();
- assert(router);
- int in_channel = inject->GetSinkPort();
-
- // NOTE: Because the lookahead is not for injection, but for the
- // first hop, we have to temporarily set cf's VC to be non-negative
- // in order to avoid seting of an assertion in the routing function.
- cf->vc = vc_start;
- _rf(router, cf, in_channel, &cf->la_route_set, false);
- cf->vc = -1;
-
- if(cf->watch) {
- *gWatchOut << GetSimTime() << " | "
- << "node" << n << " | "
- << "Generating lookahead routing info for flit " << cf->id
- << " (NOQ)." << endl;
+ if ( !_empty_network ) {
+ _Inject();
+ }
+
+ for(int subnet = 0; subnet < _subnets; ++subnet) {
+
+ for(int n = 0; n < _nodes; ++n) {
+
+ Flit * f = NULL;
+
+ BufferState * const dest_buf = _buf_states[n][subnet];
+
+ int const last_class = _last_class[n][subnet];
+
+ int class_limit = _classes;
+
+ if(_hold_switch_for_packet) {
+ list<Flit *> const & pp = _partial_packets[n][last_class];
+ if(!pp.empty() && !pp.front()->head &&
+ !dest_buf->IsFullFor(pp.front()->vc)) {
+ f = pp.front();
+ assert(f->vc == _last_vc[n][subnet][last_class]);
+
+ // if we're holding the connection, we don't need to check that class
+ // again in the for loop
+ --class_limit;
+ }
}
- set<OutputSet::sSetElement> const sl = cf->la_route_set.GetSet();
- assert(sl.size() == 1);
- int next_output = sl.begin()->output_port;
- vc_count /= router->NumOutputs();
- vc_start += next_output * vc_count;
- vc_end = vc_start + vc_count - 1;
- assert(vc_start >= se.vc_start && vc_start <= se.vc_end);
- assert(vc_end >= se.vc_start && vc_end <= se.vc_end);
- assert(vc_start <= vc_end);
- }
- if(cf->watch) {
- *gWatchOut << GetSimTime() << " | " << FullName() << " | "
- << "Finding output VC for flit " << cf->id
- << ":" << endl;
- }
- for(int i = 1; i <= vc_count; ++i) {
- int const lvc = _last_vc[n][subnet][c];
- int const vc =
- (lvc < vc_start || lvc > vc_end) ?
- vc_start :
- (vc_start + (lvc - vc_start + i) % vc_count);
- assert((vc >= vc_start) && (vc <= vc_end));
- if(!dest_buf->IsAvailableFor(vc)) {
- if(cf->watch) {
- *gWatchOut << GetSimTime() << " | " << FullName() << " | "
- << " Output VC " << vc << " is busy." << endl;
- }
- } else {
- if(dest_buf->IsFullFor(vc)) {
- if(cf->watch) {
- *gWatchOut << GetSimTime() << " | " << FullName() << " | "
- << " Output VC " << vc << " is full." << endl;
+
+ for(int i = 1; i <= class_limit; ++i) {
+
+ int const c = (last_class + i) % _classes;
+
+ list<Flit *> const & pp = _partial_packets[n][c];
+
+ if(pp.empty()) {
+ continue;
}
- } else {
- if(cf->watch) {
- *gWatchOut << GetSimTime() << " | " << FullName() << " | "
- << " Selected output VC " << vc << "." << endl;
+
+ Flit * const cf = pp.front();
+ assert(cf);
+ assert(cf->cl == c);
+
+ if(cf->subnetwork != subnet) {
+ continue;
+ }
+
+ if(f && (f->pri >= cf->pri)) {
+ continue;
+ }
+
+ if(cf->head && cf->vc == -1) { // Find first available VC
+
+ OutputSet route_set;
+ _rf(NULL, cf, -1, &route_set, true);
+ set<OutputSet::sSetElement> const & os = route_set.GetSet();
+ assert(os.size() == 1);
+ OutputSet::sSetElement const & se = *os.begin();
+ assert(se.output_port == -1);
+ int vc_start = se.vc_start;
+ int vc_end = se.vc_end;
+ int vc_count = vc_end - vc_start + 1;
+ if(_noq) {
+ assert(_lookahead_routing);
+ const FlitChannel * inject = _net[subnet]->GetInject(n);
+ const Router * router = inject->GetSink();
+ assert(router);
+ int in_channel = inject->GetSinkPort();
+
+ // NOTE: Because the lookahead is not for injection, but for the
+ // first hop, we have to temporarily set cf's VC to be non-negative
+ // in order to avoid seting of an assertion in the routing function.
+ cf->vc = vc_start;
+ _rf(router, cf, in_channel, &cf->la_route_set, false);
+ cf->vc = -1;
+
+ if(cf->watch) {
+ *gWatchOut << GetSimTime() << " | "
+ << "node" << n << " | "
+ << "Generating lookahead routing info for flit " << cf->id
+ << " (NOQ)." << endl;
+ }
+ set<OutputSet::sSetElement> const sl = cf->la_route_set.GetSet();
+ assert(sl.size() == 1);
+ int next_output = sl.begin()->output_port;
+ vc_count /= router->NumOutputs();
+ vc_start += next_output * vc_count;
+ vc_end = vc_start + vc_count - 1;
+ assert(vc_start >= se.vc_start && vc_start <= se.vc_end);
+ assert(vc_end >= se.vc_start && vc_end <= se.vc_end);
+ assert(vc_start <= vc_end);
+ }
+ if(cf->watch) {
+ *gWatchOut << GetSimTime() << " | " << FullName() << " | "
+ << "Finding output VC for flit " << cf->id
+ << ":" << endl;
+ }
+ for(int i = 1; i <= vc_count; ++i) {
+ int const lvc = _last_vc[n][subnet][c];
+ int const vc =
+ (lvc < vc_start || lvc > vc_end) ?
+ vc_start :
+ (vc_start + (lvc - vc_start + i) % vc_count);
+ assert((vc >= vc_start) && (vc <= vc_end));
+ if(!dest_buf->IsAvailableFor(vc)) {
+ if(cf->watch) {
+ *gWatchOut << GetSimTime() << " | " << FullName() << " | "
+ << " Output VC " << vc << " is busy." << endl;
+ }
+ } else {
+ if(dest_buf->IsFullFor(vc)) {
+ if(cf->watch) {
+ *gWatchOut << GetSimTime() << " | " << FullName() << " | "
+ << " Output VC " << vc << " is full." << endl;
+ }
+ } else {
+ if(cf->watch) {
+ *gWatchOut << GetSimTime() << " | " << FullName() << " | "
+ << " Selected output VC " << vc << "." << endl;
+ }
+ cf->vc = vc;
+ break;
+ }
+ }
+ }
+ }
+
+ if(cf->vc == -1) {
+ if(cf->watch) {
+ *gWatchOut << GetSimTime() << " | " << FullName() << " | "
+ << "No output VC found for flit " << cf->id
+ << "." << endl;
+ }
+ } else {
+ if(dest_buf->IsFullFor(cf->vc)) {
+ if(cf->watch) {
+ *gWatchOut << GetSimTime() << " | " << FullName() << " | "
+ << "Selected output VC " << cf->vc
+ << " is full for flit " << cf->id
+ << "." << endl;
+ }
+ } else {
+ f = cf;
+ }
}
- cf->vc = vc;
- break;
- }
- }
- }
- }
-
- if(cf->vc == -1) {
- if(cf->watch) {
- *gWatchOut << GetSimTime() << " | " << FullName() << " | "
- << "No output VC found for flit " << cf->id
- << "." << endl;
- }
- } else {
- if(dest_buf->IsFullFor(cf->vc)) {
- if(cf->watch) {
- *gWatchOut << GetSimTime() << " | " << FullName() << " | "
- << "Selected output VC " << cf->vc
- << " is full for flit " << cf->id
- << "." << endl;
- }
- } else {
- f = cf;
- }
- }
- }
-
- if(f) {
-
- assert(f->subnetwork == subnet);
-
- int const c = f->cl;
-
- if(f->head) {
-
- if (_lookahead_routing) {
- if(!_noq) {
- const FlitChannel * inject = _net[subnet]->GetInject(n);
- const Router * router = inject->GetSink();
- assert(router);
- int in_channel = inject->GetSinkPort();
- _rf(router, f, in_channel, &f->la_route_set, false);
- if(f->watch) {
- *gWatchOut << GetSimTime() << " | "
- << "node" << n << " | "
- << "Generating lookahead routing info for flit " << f->id
- << "." << endl;
- }
- } else if(f->watch) {
- *gWatchOut << GetSimTime() << " | "
- << "node" << n << " | "
- << "Already generated lookahead routing info for flit " << f->id
- << " (NOQ)." << endl;
}
- } else {
- f->la_route_set.Clear();
- }
-
- dest_buf->TakeBuffer(f->vc);
- _last_vc[n][subnet][c] = f->vc;
- }
-
- _last_class[n][subnet] = c;
-
- _partial_packets[n][c].pop_front();
-
+
+ if(f) {
+
+ assert(f->subnetwork == subnet);
+
+ int const c = f->cl;
+
+ if(f->head) {
+
+ if (_lookahead_routing) {
+ if(!_noq) {
+ const FlitChannel * inject = _net[subnet]->GetInject(n);
+ const Router * router = inject->GetSink();
+ assert(router);
+ int in_channel = inject->GetSinkPort();
+ _rf(router, f, in_channel, &f->la_route_set, false);
+ if(f->watch) {
+ *gWatchOut << GetSimTime() << " | "
+ << "node" << n << " | "
+ << "Generating lookahead routing info for flit " << f->id
+ << "." << endl;
+ }
+ } else if(f->watch) {
+ *gWatchOut << GetSimTime() << " | "
+ << "node" << n << " | "
+ << "Already generated lookahead routing info for flit " << f->id
+ << " (NOQ)." << endl;
+ }
+ } else {
+ f->la_route_set.Clear();
+ }
+
+ dest_buf->TakeBuffer(f->vc);
+ _last_vc[n][subnet][c] = f->vc;
+ }
+
+ _last_class[n][subnet] = c;
+
+ _partial_packets[n][c].pop_front();
+
#ifdef TRACK_FLOWS
- ++_outstanding_credits[c][subnet][n];
- _outstanding_classes[n][subnet][f->vc].push(c);
+ ++_outstanding_credits[c][subnet][n];
+ _outstanding_classes[n][subnet][f->vc].push(c);
#endif
-
- dest_buf->SendingFlit(f);
-
- if(_pri_type == network_age_based) {
- f->pri = numeric_limits<int>::max() - _time;
- assert(f->pri >= 0);
- }
-
- if(f->watch) {
- *gWatchOut << GetSimTime() << " | "
- << "node" << n << " | "
- << "Injecting flit " << f->id
- << " into subnet " << subnet
- << " at time " << _time
- << " with priority " << f->pri
- << "." << endl;
- }
- f->itime = _time;
-
- // Pass VC "back"
- if(!_partial_packets[n][c].empty() && !f->tail) {
- Flit * const nf = _partial_packets[n][c].front();
- nf->vc = f->vc;
- }
-
- if((_sim_state == warming_up) || (_sim_state == running)) {
- ++_sent_flits[c][n];
- if(f->head) {
- ++_sent_packets[c][n];
- }
- }
-
+
+ dest_buf->SendingFlit(f);
+
+ if(_pri_type == network_age_based) {
+ f->pri = numeric_limits<int>::max() - _time;
+ assert(f->pri >= 0);
+ }
+
+ if(f->watch) {
+ *gWatchOut << GetSimTime() << " | "
+ << "node" << n << " | "
+ << "Injecting flit " << f->id
+ << " into subnet " << subnet
+ << " at time " << _time
+ << " with priority " << f->pri
+ << "." << endl;
+ }
+ f->itime = _time;
+
+ // Pass VC "back"
+ if(!_partial_packets[n][c].empty() && !f->tail) {
+ Flit * const nf = _partial_packets[n][c].front();
+ nf->vc = f->vc;
+ }
+
+ if((_sim_state == warming_up) || (_sim_state == running)) {
+ ++_sent_flits[c][n];
+ if(f->head) {
+ ++_sent_packets[c][n];
+ }
+ }
+
#ifdef TRACK_FLOWS
- ++_injected_flits[c][n];
+ ++_injected_flits[c][n];
#endif
-
- _net[subnet]->WriteFlit(f, n);
-
- }
- }
- }
-
- for(int subnet = 0; subnet < _subnets; ++subnet) {
- for(int n = 0; n < _nodes; ++n) {
- map<int, Flit *>::const_iterator iter = flits[subnet].find(n);
- if(iter != flits[subnet].end()) {
- Flit * const f = iter->second;
-
- f->atime = _time;
- if(f->watch) {
- *gWatchOut << GetSimTime() << " | "
- << "node" << n << " | "
- << "Injecting credit for VC " << f->vc
- << " into subnet " << subnet
- << "." << endl;
+
+ _net[subnet]->WriteFlit(f, n);
+
+ }
}
- Credit * const c = Credit::New();
- c->vc.insert(f->vc);
- _net[subnet]->WriteCredit(c, n);
-
+ }
+
+ for(int subnet = 0; subnet < _subnets; ++subnet) {
+ for(int n = 0; n < _nodes; ++n) {
+ map<int, Flit *>::const_iterator iter = flits[subnet].find(n);
+ if(iter != flits[subnet].end()) {
+ Flit * const f = iter->second;
+
+ f->atime = _time;
+ if(f->watch) {
+ *gWatchOut << GetSimTime() << " | "
+ << "node" << n << " | "
+ << "Injecting credit for VC " << f->vc
+ << " into subnet " << subnet
+ << "." << endl;
+ }
+ Credit * const c = Credit::New();
+ c->vc.insert(f->vc);
+ _net[subnet]->WriteCredit(c, n);
+
#ifdef TRACK_FLOWS
- ++_ejected_flits[f->cl][n];
+ ++_ejected_flits[f->cl][n];
#endif
-
- _RetireFlit(f, n);
- }
+
+ _RetireFlit(f, n);
+ }
+ }
+ flits[subnet].clear();
+ _net[subnet]->Evaluate( );
+ _net[subnet]->WriteOutputs( );
+ }
+
+ ++_time;
+ assert(_time);
+ if(gTrace){
+ cout<<"TIME "<<_time<<endl;
}
- flits[subnet].clear();
- _net[subnet]->Evaluate( );
- _net[subnet]->WriteOutputs( );
- }
-
- ++_time;
- assert(_time);
- if(gTrace){
- cout<<"TIME "<<_time<<endl;
- }
-
-}
+}
+
bool TrafficManager::_PacketsOutstanding( ) const
{
- for ( int c = 0; c < _classes; ++c ) {
- if ( _measure_stats[c] ) {
- if ( _measured_in_flight_flits[c].empty() ) {
-
- for ( int s = 0; s < _nodes; ++s ) {
- if ( !_qdrained[s][c] ) {
+ for ( int c = 0; c < _classes; ++c ) {
+ if ( _measure_stats[c] ) {
+ if ( _measured_in_flight_flits[c].empty() ) {
+
+ for ( int s = 0; s < _nodes; ++s ) {
+ if ( !_qdrained[s][c] ) {
#ifdef DEBUG_DRAIN
- cout << "waiting on queue " << s << " class " << c;
- cout << ", time = " << _time << " qtime = " << _qtime[s][c] << endl;
+ cout << "waiting on queue " << s << " class " << c;
+ cout << ", time = " << _time << " qtime = " << _qtime[s][c] << endl;
#endif
- return true;
- }
- }
- } else {
+ return true;
+ }
+ }
+ } else {
#ifdef DEBUG_DRAIN
- cout << "in flight = " << _measured_in_flight_flits[c].size() << endl;
+ cout << "in flight = " << _measured_in_flight_flits[c].size() << endl;
#endif
- return true;
- }
+ return true;
+ }
+ }
}
- }
- return false;
+ return false;
}
void TrafficManager::_ClearStats( )
{
- _slowest_flit.assign(_classes, -1);
- _slowest_packet.assign(_classes, -1);
-
- for ( int c = 0; c < _classes; ++c ) {
-
- _plat_stats[c]->Clear( );
- _nlat_stats[c]->Clear( );
- _flat_stats[c]->Clear( );
-
- _frag_stats[c]->Clear( );
-
- _sent_packets[c].assign(_nodes, 0);
- _accepted_packets[c].assign(_nodes, 0);
- _sent_flits[c].assign(_nodes, 0);
- _accepted_flits[c].assign(_nodes, 0);
-
+ _slowest_flit.assign(_classes, -1);
+ _slowest_packet.assign(_classes, -1);
+
+ for ( int c = 0; c < _classes; ++c ) {
+
+ _plat_stats[c]->Clear( );
+ _nlat_stats[c]->Clear( );
+ _flat_stats[c]->Clear( );
+
+ _frag_stats[c]->Clear( );
+
+ _sent_packets[c].assign(_nodes, 0);
+ _accepted_packets[c].assign(_nodes, 0);
+ _sent_flits[c].assign(_nodes, 0);
+ _accepted_flits[c].assign(_nodes, 0);
+
#ifdef TRACK_STALLS
- _buffer_busy_stalls[c].assign(_subnets*_routers, 0);
- _buffer_conflict_stalls[c].assign(_subnets*_routers, 0);
- _buffer_full_stalls[c].assign(_subnets*_routers, 0);
- _buffer_reserved_stalls[c].assign(_subnets*_routers, 0);
- _crossbar_conflict_stalls[c].assign(_subnets*_routers, 0);
+ _buffer_busy_stalls[c].assign(_subnets*_routers, 0);
+ _buffer_conflict_stalls[c].assign(_subnets*_routers, 0);
+ _buffer_full_stalls[c].assign(_subnets*_routers, 0);
+ _buffer_reserved_stalls[c].assign(_subnets*_routers, 0);
+ _crossbar_conflict_stalls[c].assign(_subnets*_routers, 0);
#endif
- if(_pair_stats){
- for ( int i = 0; i < _nodes; ++i ) {
- for ( int j = 0; j < _nodes; ++j ) {
- _pair_plat[c][i*_nodes+j]->Clear( );
- _pair_nlat[c][i*_nodes+j]->Clear( );
- _pair_flat[c][i*_nodes+j]->Clear( );
+ if(_pair_stats){
+ for ( int i = 0; i < _nodes; ++i ) {
+ for ( int j = 0; j < _nodes; ++j ) {
+ _pair_plat[c][i*_nodes+j]->Clear( );
+ _pair_nlat[c][i*_nodes+j]->Clear( );
+ _pair_flat[c][i*_nodes+j]->Clear( );
+ }
+ }
}
- }
+ _hop_stats[c]->Clear();
+
}
- _hop_stats[c]->Clear();
-
- }
-
- _reset_time = _time;
+
+ _reset_time = _time;
}
-void TrafficManager::_ComputeStats( const vector<int> & stats, int *sum, int *min, int *max, int *min_pos, int *max_pos ) const
+void TrafficManager::_ComputeStats( const vector<int> & stats, int *sum, int *min, int *max, int *min_pos, int *max_pos ) const
{
- int const count = stats.size();
- assert(count > 0);
-
- if(min_pos) {
- *min_pos = 0;
- }
- if(max_pos) {
- *max_pos = 0;
- }
-
- if(min) {
- *min = stats[0];
- }
- if(max) {
- *max = stats[0];
- }
-
- *sum = stats[0];
-
- for ( int i = 1; i < count; ++i ) {
- int curr = stats[i];
- if ( min && ( curr < *min ) ) {
- *min = curr;
- if ( min_pos ) {
- *min_pos = i;
- }
+ int const count = stats.size();
+ assert(count > 0);
+
+ if(min_pos) {
+ *min_pos = 0;
}
- if ( max && ( curr > *max ) ) {
- *max = curr;
- if ( max_pos ) {
- *max_pos = i;
- }
+ if(max_pos) {
+ *max_pos = 0;
+ }
+
+ if(min) {
+ *min = stats[0];
+ }
+ if(max) {
+ *max = stats[0];
+ }
+
+ *sum = stats[0];
+
+ for ( int i = 1; i < count; ++i ) {
+ int curr = stats[i];
+ if ( min && ( curr < *min ) ) {
+ *min = curr;
+ if ( min_pos ) {
+ *min_pos = i;
+ }
+ }
+ if ( max && ( curr > *max ) ) {
+ *max = curr;
+ if ( max_pos ) {
+ *max_pos = i;
+ }
+ }
+ *sum += curr;
}
- *sum += curr;
- }
}
-void TrafficManager::_DisplayRemaining( ostream & os ) const
+void TrafficManager::_DisplayRemaining( ostream & os ) const
{
- for(int c = 0; c < _classes; ++c) {
-
- map<int, Flit *>::const_iterator iter;
- int i;
+ for(int c = 0; c < _classes; ++c) {
+
+ map<int, Flit *>::const_iterator iter;
+ int i;
+
+ os << "Class " << c << ":" << endl;
+
+ os << "Remaining flits: ";
+ for ( iter = _total_in_flight_flits[c].begin( ), i = 0;
+ ( iter != _total_in_flight_flits[c].end( ) ) && ( i < 10 );
+ iter++, i++ ) {
+ os << iter->first << " ";
+ }
+ if(_total_in_flight_flits[c].size() > 10)
+ os << "[...] ";
- os << "Class " << c << ":" << endl;
+ os << "(" << _total_in_flight_flits[c].size() << " flits)" << endl;
- os << "Remaining flits: ";
- for ( iter = _total_in_flight_flits[c].begin( ), i = 0;
- ( iter != _total_in_flight_flits[c].end( ) ) && ( i < 10 );
- iter++, i++ ) {
- os << iter->first << " ";
- }
- if(_total_in_flight_flits[c].size() > 10)
- os << "[...] ";
+ os << "Measured flits: ";
+ for ( iter = _measured_in_flight_flits[c].begin( ), i = 0;
+ ( iter != _measured_in_flight_flits[c].end( ) ) && ( i < 10 );
+ iter++, i++ ) {
+ os << iter->first << " ";
+ }
+ if(_measured_in_flight_flits[c].size() > 10)
+ os << "[...] ";
- os << "(" << _total_in_flight_flits[c].size() << " flits)" << endl;
+ os << "(" << _measured_in_flight_flits[c].size() << " flits)" << endl;
- os << "Measured flits: ";
- for ( iter = _measured_in_flight_flits[c].begin( ), i = 0;
- ( iter != _measured_in_flight_flits[c].end( ) ) && ( i < 10 );
- iter++, i++ ) {
- os << iter->first << " ";
}
- if(_measured_in_flight_flits[c].size() > 10)
- os << "[...] ";
-
- os << "(" << _measured_in_flight_flits[c].size() << " flits)" << endl;
-
- }
}
bool TrafficManager::_SingleSim( )
{
- int converged = 0;
+ int converged = 0;
- //once warmed up, we require 3 converging runs to end the simulation
- vector<double> prev_latency(_classes, 0.0);
- vector<double> prev_accepted(_classes, 0.0);
- bool clear_last = false;
- int total_phases = 0;
- while( ( total_phases < _max_samples ) &&
- ( ( _sim_state != running ) ||
- ( converged < 3 ) ) ) {
-
- if ( clear_last || (( ( _sim_state == warming_up ) && ( ( total_phases % 2 ) == 0 ) )) ) {
+ //once warmed up, we require 3 converging runs to end the simulation
+ vector<double> prev_latency(_classes, 0.0);
+ vector<double> prev_accepted(_classes, 0.0);
+ bool clear_last = false;
+ int total_phases = 0;
+ while( ( total_phases < _max_samples ) &&
+ ( ( _sim_state != running ) ||
+ ( converged < 3 ) ) ) {
+
+ if ( clear_last || (( ( _sim_state == warming_up ) && ( ( total_phases % 2 ) == 0 ) )) ) {
clear_last = false;
_ClearStats( );
- }
-
-
- for ( int iter = 0; iter < _sample_period; ++iter )
+ }
+
+
+ for ( int iter = 0; iter < _sample_period; ++iter )
_Step( );
-
- //cout << _sim_state << endl;
-
- UpdateStats();
- DisplayStats();
-
- int lat_exc_class = -1;
- int lat_chg_exc_class = -1;
- int acc_chg_exc_class = -1;
-
- for(int c = 0; c < _classes; ++c) {
-
+
+ //cout << _sim_state << endl;
+
+ UpdateStats();
+ DisplayStats();
+
+ int lat_exc_class = -1;
+ int lat_chg_exc_class = -1;
+ int acc_chg_exc_class = -1;
+
+ for(int c = 0; c < _classes; ++c) {
+
if(_measure_stats[c] == 0) {
- continue;
+ continue;
}
-
+
double cur_latency = _plat_stats[c]->Average( );
-
+
int total_accepted_count;
_ComputeStats( _accepted_flits[c], &total_accepted_count );
double total_accepted_rate = (double)total_accepted_count / (double)(_time - _reset_time);
double cur_accepted = total_accepted_rate / (double)_nodes;
-
+
double latency_change = fabs((cur_latency - prev_latency[c]) / cur_latency);
prev_latency[c] = cur_latency;
-
+
double accepted_change = fabs((cur_accepted - prev_accepted[c]) / cur_accepted);
prev_accepted[c] = cur_accepted;
-
+
double latency = (double)_plat_stats[c]->Sum();
double count = (double)_plat_stats[c]->NumSamples();
-
+
map<int, Flit *>::const_iterator iter;
- for(iter = _total_in_flight_flits[c].begin();
- iter != _total_in_flight_flits[c].end();
+ for(iter = _total_in_flight_flits[c].begin();
+ iter != _total_in_flight_flits[c].end();
iter++) {
- latency += (double)(_time - iter->second->ctime);
- count++;
+ latency += (double)(_time - iter->second->ctime);
+ count++;
}
-
+
if((lat_exc_class < 0) &&
(_latency_thres[c] >= 0.0) &&
((latency / count) > _latency_thres[c])) {
- lat_exc_class = c;
+ lat_exc_class = c;
}
-
+
cout << "latency change = " << latency_change << endl;
if(lat_chg_exc_class < 0) {
- if((_sim_state == warming_up) &&
- (_warmup_threshold[c] >= 0.0) &&
- (latency_change > _warmup_threshold[c])) {
- lat_chg_exc_class = c;
- } else if((_sim_state == running) &&
- (_stopping_threshold[c] >= 0.0) &&
- (latency_change > _stopping_threshold[c])) {
- lat_chg_exc_class = c;
- }
+ if((_sim_state == warming_up) &&
+ (_warmup_threshold[c] >= 0.0) &&
+ (latency_change > _warmup_threshold[c])) {
+ lat_chg_exc_class = c;
+ } else if((_sim_state == running) &&
+ (_stopping_threshold[c] >= 0.0) &&
+ (latency_change > _stopping_threshold[c])) {
+ lat_chg_exc_class = c;
+ }
}
-
+
cout << "throughput change = " << accepted_change << endl;
if(acc_chg_exc_class < 0) {
- if((_sim_state == warming_up) &&
- (_acc_warmup_threshold[c] >= 0.0) &&
- (accepted_change > _acc_warmup_threshold[c])) {
- acc_chg_exc_class = c;
- } else if((_sim_state == running) &&
- (_acc_stopping_threshold[c] >= 0.0) &&
- (accepted_change > _acc_stopping_threshold[c])) {
- acc_chg_exc_class = c;
- }
+ if((_sim_state == warming_up) &&
+ (_acc_warmup_threshold[c] >= 0.0) &&
+ (accepted_change > _acc_warmup_threshold[c])) {
+ acc_chg_exc_class = c;
+ } else if((_sim_state == running) &&
+ (_acc_stopping_threshold[c] >= 0.0) &&
+ (accepted_change > _acc_stopping_threshold[c])) {
+ acc_chg_exc_class = c;
+ }
}
-
- }
-
- // Fail safe for latency mode, throughput will ust continue
- if ( _measure_latency && ( lat_exc_class >= 0 ) ) {
-
+
+ }
+
+ // Fail safe for latency mode, throughput will ust continue
+ if ( _measure_latency && ( lat_exc_class >= 0 ) ) {
+
cout << "Average latency for class " << lat_exc_class << " exceeded " << _latency_thres[lat_exc_class] << " cycles. Aborting simulation." << endl;
- converged = 0;
+ converged = 0;
_sim_state = draining;
_drain_time = _time;
if(_stats_out) {
- WriteStats(*_stats_out);
+ WriteStats(*_stats_out);
}
break;
-
- }
-
- if ( _sim_state == warming_up ) {
- if ( ( _warmup_periods > 0 ) ?
- ( total_phases + 1 >= _warmup_periods ) :
- ( ( !_measure_latency || ( lat_chg_exc_class < 0 ) ) &&
- ( acc_chg_exc_class < 0 ) ) ) {
- cout << "Warmed up ..." << "Time used is " << _time << " cycles" <<endl;
- clear_last = true;
- _sim_state = running;
- }
- } else if(_sim_state == running) {
+
+ }
+
+ if ( _sim_state == warming_up ) {
+ if ( ( _warmup_periods > 0 ) ?
+ ( total_phases + 1 >= _warmup_periods ) :
+ ( ( !_measure_latency || ( lat_chg_exc_class < 0 ) ) &&
+ ( acc_chg_exc_class < 0 ) ) ) {
+ cout << "Warmed up ..." << "Time used is " << _time << " cycles" <<endl;
+ clear_last = true;
+ _sim_state = running;
+ }
+ } else if(_sim_state == running) {
if ( ( !_measure_latency || ( lat_chg_exc_class < 0 ) ) &&
- ( acc_chg_exc_class < 0 ) ) {
- ++converged;
+ ( acc_chg_exc_class < 0 ) ) {
+ ++converged;
} else {
- converged = 0;
+ converged = 0;
}
- }
- ++total_phases;
}
+ ++total_phases;
+ }
- if ( _sim_state == running ) {
- ++converged;
-
- _sim_state = draining;
- _drain_time = _time;
+ if ( _sim_state == running ) {
+ ++converged;
- if ( _measure_latency ) {
- cout << "Draining all recorded packets ..." << endl;
- int empty_steps = 0;
- while( _PacketsOutstanding( ) ) {
- _Step( );
-
- ++empty_steps;
-
- if ( empty_steps % 1000 == 0 ) {
-
- int lat_exc_class = -1;
-
- for(int c = 0; c < _classes; c++) {
-
- double threshold = _latency_thres[c];
-
- if(threshold < 0.0) {
- continue;
- }
-
- double acc_latency = _plat_stats[c]->Sum();
- double acc_count = (double)_plat_stats[c]->NumSamples();
-
- map<int, Flit *>::const_iterator iter;
- for(iter = _total_in_flight_flits[c].begin();
- iter != _total_in_flight_flits[c].end();
- iter++) {
- acc_latency += (double)(_time - iter->second->ctime);
- acc_count++;
- }
-
- if((acc_latency / acc_count) > threshold) {
- lat_exc_class = c;
- break;
- }
- }
-
- if(lat_exc_class >= 0) {
- cout << "Average latency for class " << lat_exc_class << " exceeded " << _latency_thres[lat_exc_class] << " cycles. Aborting simulation." << endl;
- converged = 0;
- _sim_state = warming_up;
- if(_stats_out) {
- WriteStats(*_stats_out);
+ _sim_state = draining;
+ _drain_time = _time;
+
+ if ( _measure_latency ) {
+ cout << "Draining all recorded packets ..." << endl;
+ int empty_steps = 0;
+ while( _PacketsOutstanding( ) ) {
+ _Step( );
+
+ ++empty_steps;
+
+ if ( empty_steps % 1000 == 0 ) {
+
+ int lat_exc_class = -1;
+
+ for(int c = 0; c < _classes; c++) {
+
+ double threshold = _latency_thres[c];
+
+ if(threshold < 0.0) {
+ continue;
+ }
+
+ double acc_latency = _plat_stats[c]->Sum();
+ double acc_count = (double)_plat_stats[c]->NumSamples();
+
+ map<int, Flit *>::const_iterator iter;
+ for(iter = _total_in_flight_flits[c].begin();
+ iter != _total_in_flight_flits[c].end();
+ iter++) {
+ acc_latency += (double)(_time - iter->second->ctime);
+ acc_count++;
+ }
+
+ if((acc_latency / acc_count) > threshold) {
+ lat_exc_class = c;
+ break;
+ }
+ }
+
+ if(lat_exc_class >= 0) {
+ cout << "Average latency for class " << lat_exc_class << " exceeded " << _latency_thres[lat_exc_class] << " cycles. Aborting simulation." << endl;
+ converged = 0;
+ _sim_state = warming_up;
+ if(_stats_out) {
+ WriteStats(*_stats_out);
+ }
+ break;
+ }
+
+ _DisplayRemaining( );
+
+ }
}
- break;
- }
-
- _DisplayRemaining( );
-
}
- }
+ } else {
+ cout << "Too many sample periods needed to converge" << endl;
}
- } else {
- cout << "Too many sample periods needed to converge" << endl;
- }
- return ( converged > 0 );
+ return ( converged > 0 );
}
bool TrafficManager::Run( )
{
- for ( int sim = 0; sim < _total_sims; ++sim ) {
-
- _time = 0;
-
- //remove any pending request from the previous simulations
- _requestsOutstanding.assign(_nodes, 0);
- for (int i=0;i<_nodes;i++) {
- while(!_repliesPending[i].empty()) {
- _repliesPending[i].front()->Free();
- _repliesPending[i].pop_front();
- }
- }
-
- //reset queuetime for all sources
- for ( int s = 0; s < _nodes; ++s ) {
- _qtime[s].assign(_classes, 0);
- _qdrained[s].assign(_classes, false);
- }
-
- // warm-up ...
- // reset stats, all packets after warmup_time marked
- // converge
- // draing, wait until all packets finish
- _sim_state = warming_up;
-
- _ClearStats( );
-
- for(int c = 0; c < _classes; ++c) {
- _traffic_pattern[c]->reset();
- _injection_process[c]->reset();
- }
-
- if ( !_SingleSim( ) ) {
- cout << "Simulation unstable, ending ..." << endl;
- return false;
- }
-
- // Empty any remaining packets
- cout << "Draining remaining packets ..." << endl;
- _empty_network = true;
- int empty_steps = 0;
-
- bool packets_left = false;
- for(int c = 0; c < _classes; ++c) {
- packets_left |= !_total_in_flight_flits[c].empty();
- }
-
- while( packets_left ) {
- _Step( );
-
- ++empty_steps;
-
- if ( empty_steps % 1000 == 0 ) {
- _DisplayRemaining( );
- }
+ for ( int sim = 0; sim < _total_sims; ++sim ) {
+
+ _time = 0;
+
+ //remove any pending request from the previous simulations
+ _requestsOutstanding.assign(_nodes, 0);
+ for (int i=0;i<_nodes;i++) {
+ while(!_repliesPending[i].empty()) {
+ _repliesPending[i].front()->Free();
+ _repliesPending[i].pop_front();
+ }
+ }
+
+ //reset queuetime for all sources
+ for ( int s = 0; s < _nodes; ++s ) {
+ _qtime[s].assign(_classes, 0);
+ _qdrained[s].assign(_classes, false);
+ }
+
+ // warm-up ...
+ // reset stats, all packets after warmup_time marked
+ // converge
+ // draing, wait until all packets finish
+ _sim_state = warming_up;
+
+ _ClearStats( );
+
+ for(int c = 0; c < _classes; ++c) {
+ _traffic_pattern[c]->reset();
+ _injection_process[c]->reset();
+ }
+
+ if ( !_SingleSim( ) ) {
+ cout << "Simulation unstable, ending ..." << endl;
+ return false;
+ }
+
+ // Empty any remaining packets
+ cout << "Draining remaining packets ..." << endl;
+ _empty_network = true;
+ int empty_steps = 0;
+
+ bool packets_left = false;
+ for(int c = 0; c < _classes; ++c) {
+ packets_left |= !_total_in_flight_flits[c].empty();
+ }
+
+ while( packets_left ) {
+ _Step( );
+
+ ++empty_steps;
+
+ if ( empty_steps % 1000 == 0 ) {
+ _DisplayRemaining( );
+ }
- packets_left = false;
- for(int c = 0; c < _classes; ++c) {
- packets_left |= !_total_in_flight_flits[c].empty();
- }
- }
- //wait until all the credits are drained as well
- while(Credit::OutStanding()!=0){
- _Step();
- }
- _empty_network = false;
-
- //for the love of god don't ever say "Time taken" anywhere else
- //the power script depend on it
- cout << "Time taken is " << _time << " cycles" <<endl;
-
- if(_stats_out) {
- WriteStats(*_stats_out);
+ packets_left = false;
+ for(int c = 0; c < _classes; ++c) {
+ packets_left |= !_total_in_flight_flits[c].empty();
+ }
+ }
+ //wait until all the credits are drained as well
+ while(Credit::OutStanding()!=0){
+ _Step();
+ }
+ _empty_network = false;
+
+ //for the love of god don't ever say "Time taken" anywhere else
+ //the power script depend on it
+ cout << "Time taken is " << _time << " cycles" <<endl;
+
+ if(_stats_out) {
+ WriteStats(*_stats_out);
+ }
+ _UpdateOverallStats();
}
- _UpdateOverallStats();
- }
- DisplayOverallStats();
- if(_print_csv_results) {
- DisplayOverallStatsCSV();
- }
+ DisplayOverallStats();
+ if(_print_csv_results) {
+ DisplayOverallStatsCSV();
+ }
- return true;
+ return true;
}
void TrafficManager::_UpdateOverallStats() {
- for ( int c = 0; c < _classes; ++c ) {
-
- if(_measure_stats[c] == 0) {
- continue;
- }
-
- _overall_min_plat[c] += _plat_stats[c]->Min();
- _overall_avg_plat[c] += _plat_stats[c]->Average();
- _overall_max_plat[c] += _plat_stats[c]->Max();
- _overall_min_nlat[c] += _nlat_stats[c]->Min();
- _overall_avg_nlat[c] += _nlat_stats[c]->Average();
- _overall_max_nlat[c] += _nlat_stats[c]->Max();
- _overall_min_flat[c] += _flat_stats[c]->Min();
- _overall_avg_flat[c] += _flat_stats[c]->Average();
- _overall_max_flat[c] += _flat_stats[c]->Max();
-
- _overall_min_frag[c] += _frag_stats[c]->Min();
- _overall_avg_frag[c] += _frag_stats[c]->Average();
- _overall_max_frag[c] += _frag_stats[c]->Max();
+ for ( int c = 0; c < _classes; ++c ) {
- _overall_hop_stats[c] += _hop_stats[c]->Average();
+ if(_measure_stats[c] == 0) {
+ continue;
+ }
- int count_min, count_sum, count_max;
- double rate_min, rate_sum, rate_max;
- double rate_avg;
- double time_delta = (double)(_drain_time - _reset_time);
- _ComputeStats( _sent_flits[c], &count_sum, &count_min, &count_max );
- rate_min = (double)count_min / time_delta;
- rate_sum = (double)count_sum / time_delta;
- rate_max = (double)count_max / time_delta;
- rate_avg = rate_sum / (double)_nodes;
- _overall_min_sent[c] += rate_min;
- _overall_avg_sent[c] += rate_avg;
- _overall_max_sent[c] += rate_max;
- _ComputeStats( _sent_packets[c], &count_sum, &count_min, &count_max );
- rate_min = (double)count_min / time_delta;
- rate_sum = (double)count_sum / time_delta;
- rate_max = (double)count_max / time_delta;
- rate_avg = rate_sum / (double)_nodes;
- _overall_min_sent_packets[c] += rate_min;
- _overall_avg_sent_packets[c] += rate_avg;
- _overall_max_sent_packets[c] += rate_max;
- _ComputeStats( _accepted_flits[c], &count_sum, &count_min, &count_max );
- rate_min = (double)count_min / time_delta;
- rate_sum = (double)count_sum / time_delta;
- rate_max = (double)count_max / time_delta;
- rate_avg = rate_sum / (double)_nodes;
- _overall_min_accepted[c] += rate_min;
- _overall_avg_accepted[c] += rate_avg;
- _overall_max_accepted[c] += rate_max;
- _ComputeStats( _accepted_packets[c], &count_sum, &count_min, &count_max );
- rate_min = (double)count_min / time_delta;
- rate_sum = (double)count_sum / time_delta;
- rate_max = (double)count_max / time_delta;
- rate_avg = rate_sum / (double)_nodes;
- _overall_min_accepted_packets[c] += rate_min;
- _overall_avg_accepted_packets[c] += rate_avg;
- _overall_max_accepted_packets[c] += rate_max;
+ _overall_min_plat[c] += _plat_stats[c]->Min();
+ _overall_avg_plat[c] += _plat_stats[c]->Average();
+ _overall_max_plat[c] += _plat_stats[c]->Max();
+ _overall_min_nlat[c] += _nlat_stats[c]->Min();
+ _overall_avg_nlat[c] += _nlat_stats[c]->Average();
+ _overall_max_nlat[c] += _nlat_stats[c]->Max();
+ _overall_min_flat[c] += _flat_stats[c]->Min();
+ _overall_avg_flat[c] += _flat_stats[c]->Average();
+ _overall_max_flat[c] += _flat_stats[c]->Max();
+ _overall_min_frag[c] += _frag_stats[c]->Min();
+ _overall_avg_frag[c] += _frag_stats[c]->Average();
+ _overall_max_frag[c] += _frag_stats[c]->Max();
+
+ _overall_hop_stats[c] += _hop_stats[c]->Average();
+
+ int count_min, count_sum, count_max;
+ double rate_min, rate_sum, rate_max;
+ double rate_avg;
+ double time_delta = (double)(_drain_time - _reset_time);
+ _ComputeStats( _sent_flits[c], &count_sum, &count_min, &count_max );
+ rate_min = (double)count_min / time_delta;
+ rate_sum = (double)count_sum / time_delta;
+ rate_max = (double)count_max / time_delta;
+ rate_avg = rate_sum / (double)_nodes;
+ _overall_min_sent[c] += rate_min;
+ _overall_avg_sent[c] += rate_avg;
+ _overall_max_sent[c] += rate_max;
+ _ComputeStats( _sent_packets[c], &count_sum, &count_min, &count_max );
+ rate_min = (double)count_min / time_delta;
+ rate_sum = (double)count_sum / time_delta;
+ rate_max = (double)count_max / time_delta;
+ rate_avg = rate_sum / (double)_nodes;
+ _overall_min_sent_packets[c] += rate_min;
+ _overall_avg_sent_packets[c] += rate_avg;
+ _overall_max_sent_packets[c] += rate_max;
+ _ComputeStats( _accepted_flits[c], &count_sum, &count_min, &count_max );
+ rate_min = (double)count_min / time_delta;
+ rate_sum = (double)count_sum / time_delta;
+ rate_max = (double)count_max / time_delta;
+ rate_avg = rate_sum / (double)_nodes;
+ _overall_min_accepted[c] += rate_min;
+ _overall_avg_accepted[c] += rate_avg;
+ _overall_max_accepted[c] += rate_max;
+ _ComputeStats( _accepted_packets[c], &count_sum, &count_min, &count_max );
+ rate_min = (double)count_min / time_delta;
+ rate_sum = (double)count_sum / time_delta;
+ rate_max = (double)count_max / time_delta;
+ rate_avg = rate_sum / (double)_nodes;
+ _overall_min_accepted_packets[c] += rate_min;
+ _overall_avg_accepted_packets[c] += rate_avg;
+ _overall_max_accepted_packets[c] += rate_max;
+
#ifdef TRACK_STALLS
- _ComputeStats(_buffer_busy_stalls[c], &count_sum);
- rate_sum = (double)count_sum / time_delta;
- rate_avg = rate_sum / (double)(_subnets*_routers);
- _overall_buffer_busy_stalls[c] += rate_avg;
- _ComputeStats(_buffer_conflict_stalls[c], &count_sum);
- rate_sum = (double)count_sum / time_delta;
- rate_avg = rate_sum / (double)(_subnets*_routers);
- _overall_buffer_conflict_stalls[c] += rate_avg;
- _ComputeStats(_buffer_full_stalls[c], &count_sum);
- rate_sum = (double)count_sum / time_delta;
- rate_avg = rate_sum / (double)(_subnets*_routers);
- _overall_buffer_full_stalls[c] += rate_avg;
- _ComputeStats(_buffer_reserved_stalls[c], &count_sum);
- rate_sum = (double)count_sum / time_delta;
- rate_avg = rate_sum / (double)(_subnets*_routers);
- _overall_buffer_reserved_stalls[c] += rate_avg;
- _ComputeStats(_crossbar_conflict_stalls[c], &count_sum);
- rate_sum = (double)count_sum / time_delta;
- rate_avg = rate_sum / (double)(_subnets*_routers);
- _overall_crossbar_conflict_stalls[c] += rate_avg;
+ _ComputeStats(_buffer_busy_stalls[c], &count_sum);
+ rate_sum = (double)count_sum / time_delta;
+ rate_avg = rate_sum / (double)(_subnets*_routers);
+ _overall_buffer_busy_stalls[c] += rate_avg;
+ _ComputeStats(_buffer_conflict_stalls[c], &count_sum);
+ rate_sum = (double)count_sum / time_delta;
+ rate_avg = rate_sum / (double)(_subnets*_routers);
+ _overall_buffer_conflict_stalls[c] += rate_avg;
+ _ComputeStats(_buffer_full_stalls[c], &count_sum);
+ rate_sum = (double)count_sum / time_delta;
+ rate_avg = rate_sum / (double)(_subnets*_routers);
+ _overall_buffer_full_stalls[c] += rate_avg;
+ _ComputeStats(_buffer_reserved_stalls[c], &count_sum);
+ rate_sum = (double)count_sum / time_delta;
+ rate_avg = rate_sum / (double)(_subnets*_routers);
+ _overall_buffer_reserved_stalls[c] += rate_avg;
+ _ComputeStats(_crossbar_conflict_stalls[c], &count_sum);
+ rate_sum = (double)count_sum / time_delta;
+ rate_avg = rate_sum / (double)(_subnets*_routers);
+ _overall_crossbar_conflict_stalls[c] += rate_avg;
#endif
-
- }
+
+ }
}
void TrafficManager::WriteStats(ostream & os) const {
- os << "%=================================" << endl;
-
- for(int c = 0; c < _classes; ++c) {
+ os << "%=================================" << endl;
+
+ for(int c = 0; c < _classes; ++c) {
- if(_measure_stats[c] == 0) {
- continue;
- }
+ if(_measure_stats[c] == 0) {
+ continue;
+ }
- //c+1 due to matlab array starting at 1
- os << "plat(" << c+1 << ") = " << _plat_stats[c]->Average() << ";" << endl
- << "plat_hist(" << c+1 << ",:) = " << *_plat_stats[c] << ";" << endl
- << "nlat(" << c+1 << ") = " << _nlat_stats[c]->Average() << ";" << endl
- << "nlat_hist(" << c+1 << ",:) = " << *_nlat_stats[c] << ";" << endl
- << "flat(" << c+1 << ") = " << _flat_stats[c]->Average() << ";" << endl
- << "flat_hist(" << c+1 << ",:) = " << *_flat_stats[c] << ";" << endl
- << "frag_hist(" << c+1 << ",:) = " << *_frag_stats[c] << ";" << endl
- << "hops(" << c+1 << ",:) = " << *_hop_stats[c] << ";" << endl;
- if(_pair_stats){
- os<< "pair_sent(" << c+1 << ",:) = [ ";
- for(int i = 0; i < _nodes; ++i) {
- for(int j = 0; j < _nodes; ++j) {
- os << _pair_plat[c][i*_nodes+j]->NumSamples() << " ";
+ //c+1 due to matlab array starting at 1
+ os << "plat(" << c+1 << ") = " << _plat_stats[c]->Average() << ";" << endl
+ << "plat_hist(" << c+1 << ",:) = " << *_plat_stats[c] << ";" << endl
+ << "nlat(" << c+1 << ") = " << _nlat_stats[c]->Average() << ";" << endl
+ << "nlat_hist(" << c+1 << ",:) = " << *_nlat_stats[c] << ";" << endl
+ << "flat(" << c+1 << ") = " << _flat_stats[c]->Average() << ";" << endl
+ << "flat_hist(" << c+1 << ",:) = " << *_flat_stats[c] << ";" << endl
+ << "frag_hist(" << c+1 << ",:) = " << *_frag_stats[c] << ";" << endl
+ << "hops(" << c+1 << ",:) = " << *_hop_stats[c] << ";" << endl;
+ if(_pair_stats){
+ os<< "pair_sent(" << c+1 << ",:) = [ ";
+ for(int i = 0; i < _nodes; ++i) {
+ for(int j = 0; j < _nodes; ++j) {
+ os << _pair_plat[c][i*_nodes+j]->NumSamples() << " ";
+ }
+ }
+ os << "];" << endl
+ << "pair_plat(" << c+1 << ",:) = [ ";
+ for(int i = 0; i < _nodes; ++i) {
+ for(int j = 0; j < _nodes; ++j) {
+ os << _pair_plat[c][i*_nodes+j]->Average( ) << " ";
+ }
+ }
+ os << "];" << endl
+ << "pair_nlat(" << c+1 << ",:) = [ ";
+ for(int i = 0; i < _nodes; ++i) {
+ for(int j = 0; j < _nodes; ++j) {
+ os << _pair_nlat[c][i*_nodes+j]->Average( ) << " ";
+ }
+ }
+ os << "];" << endl
+ << "pair_flat(" << c+1 << ",:) = [ ";
+ for(int i = 0; i < _nodes; ++i) {
+ for(int j = 0; j < _nodes; ++j) {
+ os << _pair_flat[c][i*_nodes+j]->Average( ) << " ";
+ }
+ }
}
- }
- os << "];" << endl
- << "pair_plat(" << c+1 << ",:) = [ ";
- for(int i = 0; i < _nodes; ++i) {
- for(int j = 0; j < _nodes; ++j) {
- os << _pair_plat[c][i*_nodes+j]->Average( ) << " ";
+
+ double time_delta = (double)(_drain_time - _reset_time);
+
+ os << "];" << endl
+ << "sent_packets(" << c+1 << ",:) = [ ";
+ for ( int d = 0; d < _nodes; ++d ) {
+ os << (double)_sent_packets[c][d] / time_delta << " ";
}
- }
- os << "];" << endl
- << "pair_nlat(" << c+1 << ",:) = [ ";
- for(int i = 0; i < _nodes; ++i) {
- for(int j = 0; j < _nodes; ++j) {
- os << _pair_nlat[c][i*_nodes+j]->Average( ) << " ";
+ os << "];" << endl
+ << "accepted_packets(" << c+1 << ",:) = [ ";
+ for ( int d = 0; d < _nodes; ++d ) {
+ os << (double)_accepted_packets[c][d] / time_delta << " ";
}
- }
- os << "];" << endl
- << "pair_flat(" << c+1 << ",:) = [ ";
- for(int i = 0; i < _nodes; ++i) {
- for(int j = 0; j < _nodes; ++j) {
- os << _pair_flat[c][i*_nodes+j]->Average( ) << " ";
+ os << "];" << endl
+ << "sent_flits(" << c+1 << ",:) = [ ";
+ for ( int d = 0; d < _nodes; ++d ) {
+ os << (double)_sent_flits[c][d] / time_delta << " ";
}
- }
- }
-
- double time_delta = (double)(_drain_time - _reset_time);
-
- os << "];" << endl
- << "sent_packets(" << c+1 << ",:) = [ ";
- for ( int d = 0; d < _nodes; ++d ) {
- os << (double)_sent_packets[c][d] / time_delta << " ";
- }
- os << "];" << endl
- << "accepted_packets(" << c+1 << ",:) = [ ";
- for ( int d = 0; d < _nodes; ++d ) {
- os << (double)_accepted_packets[c][d] / time_delta << " ";
- }
- os << "];" << endl
- << "sent_flits(" << c+1 << ",:) = [ ";
- for ( int d = 0; d < _nodes; ++d ) {
- os << (double)_sent_flits[c][d] / time_delta << " ";
- }
- os << "];" << endl
- << "accepted_flits(" << c+1 << ",:) = [ ";
- for ( int d = 0; d < _nodes; ++d ) {
- os << (double)_accepted_flits[c][d] / time_delta << " ";
- }
- os << "];" << endl
- << "sent_packet_size(" << c+1 << ",:) = [ ";
- for ( int d = 0; d < _nodes; ++d ) {
- os << (double)_sent_flits[c][d] / (double)_sent_packets[c][d] << " ";
- }
- os << "];" << endl
- << "accepted_packet_size(" << c+1 << ",:) = [ ";
- for ( int d = 0; d < _nodes; ++d ) {
- os << (double)_accepted_flits[c][d] / (double)_accepted_packets[c][d] << " ";
- }
- os << "];" << endl;
+ os << "];" << endl
+ << "accepted_flits(" << c+1 << ",:) = [ ";
+ for ( int d = 0; d < _nodes; ++d ) {
+ os << (double)_accepted_flits[c][d] / time_delta << " ";
+ }
+ os << "];" << endl
+ << "sent_packet_size(" << c+1 << ",:) = [ ";
+ for ( int d = 0; d < _nodes; ++d ) {
+ os << (double)_sent_flits[c][d] / (double)_sent_packets[c][d] << " ";
+ }
+ os << "];" << endl
+ << "accepted_packet_size(" << c+1 << ",:) = [ ";
+ for ( int d = 0; d < _nodes; ++d ) {
+ os << (double)_accepted_flits[c][d] / (double)_accepted_packets[c][d] << " ";
+ }
+ os << "];" << endl;
#ifdef TRACK_STALLS
- os << "buffer_busy_stalls(" << c+1 << ",:) = [ ";
- for ( int d = 0; d < _subnets*_routers; ++d ) {
- os << (double)_buffer_busy_stalls[c][d] / time_delta << " ";
- }
- os << "];" << endl
- << "buffer_conflict_stalls(" << c+1 << ",:) = [ ";
- for ( int d = 0; d < _subnets*_routers; ++d ) {
- os << (double)_buffer_conflict_stalls[c][d] / time_delta << " ";
- }
- os << "];" << endl
- << "buffer_full_stalls(" << c+1 << ",:) = [ ";
- for ( int d = 0; d < _subnets*_routers; ++d ) {
- os << (double)_buffer_full_stalls[c][d] / time_delta << " ";
- }
- os << "];" << endl
- << "buffer_reserved_stalls(" << c+1 << ",:) = [ ";
- for ( int d = 0; d < _subnets*_routers; ++d ) {
- os << (double)_buffer_reserved_stalls[c][d] / time_delta << " ";
- }
- os << "];" << endl
- << "crossbar_conflict_stalls(" << c+1 << ",:) = [ ";
- for ( int d = 0; d < _subnets*_routers; ++d ) {
- os << (double)_crossbar_conflict_stalls[c][d] / time_delta << " ";
- }
- os << "];" << endl;
+ os << "buffer_busy_stalls(" << c+1 << ",:) = [ ";
+ for ( int d = 0; d < _subnets*_routers; ++d ) {
+ os << (double)_buffer_busy_stalls[c][d] / time_delta << " ";
+ }
+ os << "];" << endl
+ << "buffer_conflict_stalls(" << c+1 << ",:) = [ ";
+ for ( int d = 0; d < _subnets*_routers; ++d ) {
+ os << (double)_buffer_conflict_stalls[c][d] / time_delta << " ";
+ }
+ os << "];" << endl
+ << "buffer_full_stalls(" << c+1 << ",:) = [ ";
+ for ( int d = 0; d < _subnets*_routers; ++d ) {
+ os << (double)_buffer_full_stalls[c][d] / time_delta << " ";
+ }
+ os << "];" << endl
+ << "buffer_reserved_stalls(" << c+1 << ",:) = [ ";
+ for ( int d = 0; d < _subnets*_routers; ++d ) {
+ os << (double)_buffer_reserved_stalls[c][d] / time_delta << " ";
+ }
+ os << "];" << endl
+ << "crossbar_conflict_stalls(" << c+1 << ",:) = [ ";
+ for ( int d = 0; d < _subnets*_routers; ++d ) {
+ os << (double)_crossbar_conflict_stalls[c][d] / time_delta << " ";
+ }
+ os << "];" << endl;
#endif
- }
+ }
}
void TrafficManager::UpdateStats() {
#if defined(TRACK_FLOWS) || defined(TRACK_STALLS)
- for(int c = 0; c < _classes; ++c) {
+ for(int c = 0; c < _classes; ++c) {
#ifdef TRACK_FLOWS
- {
- char trail_char = (c == _classes - 1) ? '\n' : ',';
- if(_injected_flits_out) *_injected_flits_out << _injected_flits[c] << trail_char;
- _injected_flits[c].assign(_nodes, 0);
- if(_ejected_flits_out) *_ejected_flits_out << _ejected_flits[c] << trail_char;
- _ejected_flits[c].assign(_nodes, 0);
- }
+ {
+ char trail_char = (c == _classes - 1) ? '\n' : ',';
+ if(_injected_flits_out) *_injected_flits_out << _injected_flits[c] << trail_char;
+ _injected_flits[c].assign(_nodes, 0);
+ if(_ejected_flits_out) *_ejected_flits_out << _ejected_flits[c] << trail_char;
+ _ejected_flits[c].assign(_nodes, 0);
+ }
#endif
- for(int subnet = 0; subnet < _subnets; ++subnet) {
+ for(int subnet = 0; subnet < _subnets; ++subnet) {
#ifdef TRACK_FLOWS
- if(_outstanding_credits_out) *_outstanding_credits_out << _outstanding_credits[c][subnet] << ',';
- if(_stored_flits_out) *_stored_flits_out << vector<int>(_nodes, 0) << ',';
+ if(_outstanding_credits_out) *_outstanding_credits_out << _outstanding_credits[c][subnet] << ',';
+ if(_stored_flits_out) *_stored_flits_out << vector<int>(_nodes, 0) << ',';
#endif
- for(int router = 0; router < _routers; ++router) {
- Router * const r = _router[subnet][router];
+ for(int router = 0; router < _routers; ++router) {
+ Router * const r = _router[subnet][router];
#ifdef TRACK_FLOWS
- char trail_char =
- ((router == _routers - 1) && (subnet == _subnets - 1) && (c == _classes - 1)) ? '\n' : ',';
- if(_received_flits_out) *_received_flits_out << r->GetReceivedFlits(c) << trail_char;
- if(_stored_flits_out) *_stored_flits_out << r->GetStoredFlits(c) << trail_char;
- if(_sent_flits_out) *_sent_flits_out << r->GetSentFlits(c) << trail_char;
- if(_outstanding_credits_out) *_outstanding_credits_out << r->GetOutstandingCredits(c) << trail_char;
- if(_active_packets_out) *_active_packets_out << r->GetActivePackets(c) << trail_char;
- r->ResetFlowStats(c);
+ char trail_char =
+ ((router == _routers - 1) && (subnet == _subnets - 1) && (c == _classes - 1)) ? '\n' : ',';
+ if(_received_flits_out) *_received_flits_out << r->GetReceivedFlits(c) << trail_char;
+ if(_stored_flits_out) *_stored_flits_out << r->GetStoredFlits(c) << trail_char;
+ if(_sent_flits_out) *_sent_flits_out << r->GetSentFlits(c) << trail_char;
+ if(_outstanding_credits_out) *_outstanding_credits_out << r->GetOutstandingCredits(c) << trail_char;
+ if(_active_packets_out) *_active_packets_out << r->GetActivePackets(c) << trail_char;
+ r->ResetFlowStats(c);
#endif
#ifdef TRACK_STALLS
- _buffer_busy_stalls[c][subnet*_routers+router] += r->GetBufferBusyStalls(c);
- _buffer_conflict_stalls[c][subnet*_routers+router] += r->GetBufferConflictStalls(c);
- _buffer_full_stalls[c][subnet*_routers+router] += r->GetBufferFullStalls(c);
- _buffer_reserved_stalls[c][subnet*_routers+router] += r->GetBufferReservedStalls(c);
- _crossbar_conflict_stalls[c][subnet*_routers+router] += r->GetCrossbarConflictStalls(c);
- r->ResetStallStats(c);
+ _buffer_busy_stalls[c][subnet*_routers+router] += r->GetBufferBusyStalls(c);
+ _buffer_conflict_stalls[c][subnet*_routers+router] += r->GetBufferConflictStalls(c);
+ _buffer_full_stalls[c][subnet*_routers+router] += r->GetBufferFullStalls(c);
+ _buffer_reserved_stalls[c][subnet*_routers+router] += r->GetBufferReservedStalls(c);
+ _crossbar_conflict_stalls[c][subnet*_routers+router] += r->GetCrossbarConflictStalls(c);
+ r->ResetStallStats(c);
#endif
- }
+ }
+ }
}
- }
#ifdef TRACK_FLOWS
- if(_injected_flits_out) *_injected_flits_out << flush;
- if(_received_flits_out) *_received_flits_out << flush;
- if(_stored_flits_out) *_stored_flits_out << flush;
- if(_sent_flits_out) *_sent_flits_out << flush;
- if(_outstanding_credits_out) *_outstanding_credits_out << flush;
- if(_ejected_flits_out) *_ejected_flits_out << flush;
- if(_active_packets_out) *_active_packets_out << flush;
+ if(_injected_flits_out) *_injected_flits_out << flush;
+ if(_received_flits_out) *_received_flits_out << flush;
+ if(_stored_flits_out) *_stored_flits_out << flush;
+ if(_sent_flits_out) *_sent_flits_out << flush;
+ if(_outstanding_credits_out) *_outstanding_credits_out << flush;
+ if(_ejected_flits_out) *_ejected_flits_out << flush;
+ if(_active_packets_out) *_active_packets_out << flush;
#endif
#endif
-
+
#ifdef TRACK_CREDITS
- for(int s = 0; s < _subnets; ++s) {
- for(int n = 0; n < _nodes; ++n) {
- BufferState const * const bs = _buf_states[n][s];
- for(int v = 0; v < _vcs; ++v) {
- if(_used_credits_out) *_used_credits_out << bs->OccupancyFor(v) << ',';
- if(_free_credits_out) *_free_credits_out << bs->AvailableFor(v) << ',';
- if(_max_credits_out) *_max_credits_out << bs->LimitFor(v) << ',';
- }
- }
- for(int r = 0; r < _routers; ++r) {
- Router const * const rtr = _router[s][r];
- char trail_char =
- ((r == _routers - 1) && (s == _subnets - 1)) ? '\n' : ',';
- if(_used_credits_out) *_used_credits_out << rtr->UsedCredits() << trail_char;
- if(_free_credits_out) *_free_credits_out << rtr->FreeCredits() << trail_char;
- if(_max_credits_out) *_max_credits_out << rtr->MaxCredits() << trail_char;
+ for(int s = 0; s < _subnets; ++s) {
+ for(int n = 0; n < _nodes; ++n) {
+ BufferState const * const bs = _buf_states[n][s];
+ for(int v = 0; v < _vcs; ++v) {
+ if(_used_credits_out) *_used_credits_out << bs->OccupancyFor(v) << ',';
+ if(_free_credits_out) *_free_credits_out << bs->AvailableFor(v) << ',';
+ if(_max_credits_out) *_max_credits_out << bs->LimitFor(v) << ',';
+ }
+ }
+ for(int r = 0; r < _routers; ++r) {
+ Router const * const rtr = _router[s][r];
+ char trail_char =
+ ((r == _routers - 1) && (s == _subnets - 1)) ? '\n' : ',';
+ if(_used_credits_out) *_used_credits_out << rtr->UsedCredits() << trail_char;
+ if(_free_credits_out) *_free_credits_out << rtr->FreeCredits() << trail_char;
+ if(_max_credits_out) *_max_credits_out << rtr->MaxCredits() << trail_char;
+ }
}
- }
- if(_used_credits_out) *_used_credits_out << flush;
- if(_free_credits_out) *_free_credits_out << flush;
- if(_max_credits_out) *_max_credits_out << flush;
+ if(_used_credits_out) *_used_credits_out << flush;
+ if(_free_credits_out) *_free_credits_out << flush;
+ if(_max_credits_out) *_max_credits_out << flush;
#endif
-
+
}
void TrafficManager::DisplayStats(ostream & os) const {
- for(int c = 0; c < _classes; ++c) {
-
- if(_measure_stats[c] == 0) {
- continue;
- }
+ for(int c = 0; c < _classes; ++c) {
- cout << "Class " << c << ":" << endl;
+ if(_measure_stats[c] == 0) {
+ continue;
+ }
- cout
- << "Packet latency average = " << _plat_stats[c]->Average() << endl
- << "\tminimum = " << _plat_stats[c]->Min() << endl
- << "\tmaximum = " << _plat_stats[c]->Max() << endl
- << "Network latency average = " << _nlat_stats[c]->Average() << endl
- << "\tminimum = " << _nlat_stats[c]->Min() << endl
- << "\tmaximum = " << _nlat_stats[c]->Max() << endl
- << "Slowest packet = " << _slowest_packet[c] << endl
- << "Flit latency average = " << _flat_stats[c]->Average() << endl
- << "\tminimum = " << _flat_stats[c]->Min() << endl
- << "\tmaximum = " << _flat_stats[c]->Max() << endl
- << "Slowest flit = " << _slowest_flit[c] << endl
- << "Fragmentation average = " << _frag_stats[c]->Average() << endl
- << "\tminimum = " << _frag_stats[c]->Min() << endl
- << "\tmaximum = " << _frag_stats[c]->Max() << endl;
+ cout << "Class " << c << ":" << endl;
- int count_sum, count_min, count_max;
- double rate_sum, rate_min, rate_max;
- double rate_avg;
- int sent_packets, sent_flits, accepted_packets, accepted_flits;
- int min_pos, max_pos;
- double time_delta = (double)(_time - _reset_time);
- _ComputeStats(_sent_packets[c], &count_sum, &count_min, &count_max, &min_pos, &max_pos);
- rate_sum = (double)count_sum / time_delta;
- rate_min = (double)count_min / time_delta;
- rate_max = (double)count_max / time_delta;
- rate_avg = rate_sum / (double)_nodes;
- sent_packets = count_sum;
- cout << "Injected packet rate average = " << rate_avg << endl
- << "\tminimum = " << rate_min
- << " (at node " << min_pos << ")" << endl
- << "\tmaximum = " << rate_max
- << " (at node " << max_pos << ")" << endl;
- _ComputeStats(_accepted_packets[c], &count_sum, &count_min, &count_max, &min_pos, &max_pos);
- rate_sum = (double)count_sum / time_delta;
- rate_min = (double)count_min / time_delta;
- rate_max = (double)count_max / time_delta;
- rate_avg = rate_sum / (double)_nodes;
- accepted_packets = count_sum;
- cout << "Accepted packet rate average = " << rate_avg << endl
- << "\tminimum = " << rate_min
- << " (at node " << min_pos << ")" << endl
- << "\tmaximum = " << rate_max
- << " (at node " << max_pos << ")" << endl;
- _ComputeStats(_sent_flits[c], &count_sum, &count_min, &count_max, &min_pos, &max_pos);
- rate_sum = (double)count_sum / time_delta;
- rate_min = (double)count_min / time_delta;
- rate_max = (double)count_max / time_delta;
- rate_avg = rate_sum / (double)_nodes;
- sent_flits = count_sum;
- cout << "Injected flit rate average = " << rate_avg << endl
- << "\tminimum = " << rate_min
- << " (at node " << min_pos << ")" << endl
- << "\tmaximum = " << rate_max
- << " (at node " << max_pos << ")" << endl;
- _ComputeStats(_accepted_flits[c], &count_sum, &count_min, &count_max, &min_pos, &max_pos);
- rate_sum = (double)count_sum / time_delta;
- rate_min = (double)count_min / time_delta;
- rate_max = (double)count_max / time_delta;
- rate_avg = rate_sum / (double)_nodes;
- accepted_flits = count_sum;
- cout << "Accepted flit rate average= " << rate_avg << endl
- << "\tminimum = " << rate_min
- << " (at node " << min_pos << ")" << endl
- << "\tmaximum = " << rate_max
- << " (at node " << max_pos << ")" << endl;
+ cout
+ << "Packet latency average = " << _plat_stats[c]->Average() << endl
+ << "\tminimum = " << _plat_stats[c]->Min() << endl
+ << "\tmaximum = " << _plat_stats[c]->Max() << endl
+ << "Network latency average = " << _nlat_stats[c]->Average() << endl
+ << "\tminimum = " << _nlat_stats[c]->Min() << endl
+ << "\tmaximum = " << _nlat_stats[c]->Max() << endl
+ << "Slowest packet = " << _slowest_packet[c] << endl
+ << "Flit latency average = " << _flat_stats[c]->Average() << endl
+ << "\tminimum = " << _flat_stats[c]->Min() << endl
+ << "\tmaximum = " << _flat_stats[c]->Max() << endl
+ << "Slowest flit = " << _slowest_flit[c] << endl
+ << "Fragmentation average = " << _frag_stats[c]->Average() << endl
+ << "\tminimum = " << _frag_stats[c]->Min() << endl
+ << "\tmaximum = " << _frag_stats[c]->Max() << endl;
- cout << "Injected packet length average = " << (double)sent_flits / (double)sent_packets << endl
- << "Accepted packet length average = " << (double)accepted_flits / (double)accepted_packets << endl;
+ int count_sum, count_min, count_max;
+ double rate_sum, rate_min, rate_max;
+ double rate_avg;
+ int sent_packets, sent_flits, accepted_packets, accepted_flits;
+ int min_pos, max_pos;
+ double time_delta = (double)(_time - _reset_time);
+ _ComputeStats(_sent_packets[c], &count_sum, &count_min, &count_max, &min_pos, &max_pos);
+ rate_sum = (double)count_sum / time_delta;
+ rate_min = (double)count_min / time_delta;
+ rate_max = (double)count_max / time_delta;
+ rate_avg = rate_sum / (double)_nodes;
+ sent_packets = count_sum;
+ cout << "Injected packet rate average = " << rate_avg << endl
+ << "\tminimum = " << rate_min
+ << " (at node " << min_pos << ")" << endl
+ << "\tmaximum = " << rate_max
+ << " (at node " << max_pos << ")" << endl;
+ _ComputeStats(_accepted_packets[c], &count_sum, &count_min, &count_max, &min_pos, &max_pos);
+ rate_sum = (double)count_sum / time_delta;
+ rate_min = (double)count_min / time_delta;
+ rate_max = (double)count_max / time_delta;
+ rate_avg = rate_sum / (double)_nodes;
+ accepted_packets = count_sum;
+ cout << "Accepted packet rate average = " << rate_avg << endl
+ << "\tminimum = " << rate_min
+ << " (at node " << min_pos << ")" << endl
+ << "\tmaximum = " << rate_max
+ << " (at node " << max_pos << ")" << endl;
+ _ComputeStats(_sent_flits[c], &count_sum, &count_min, &count_max, &min_pos, &max_pos);
+ rate_sum = (double)count_sum / time_delta;
+ rate_min = (double)count_min / time_delta;
+ rate_max = (double)count_max / time_delta;
+ rate_avg = rate_sum / (double)_nodes;
+ sent_flits = count_sum;
+ cout << "Injected flit rate average = " << rate_avg << endl
+ << "\tminimum = " << rate_min
+ << " (at node " << min_pos << ")" << endl
+ << "\tmaximum = " << rate_max
+ << " (at node " << max_pos << ")" << endl;
+ _ComputeStats(_accepted_flits[c], &count_sum, &count_min, &count_max, &min_pos, &max_pos);
+ rate_sum = (double)count_sum / time_delta;
+ rate_min = (double)count_min / time_delta;
+ rate_max = (double)count_max / time_delta;
+ rate_avg = rate_sum / (double)_nodes;
+ accepted_flits = count_sum;
+ cout << "Accepted flit rate average= " << rate_avg << endl
+ << "\tminimum = " << rate_min
+ << " (at node " << min_pos << ")" << endl
+ << "\tmaximum = " << rate_max
+ << " (at node " << max_pos << ")" << endl;
- cout << "Total in-flight flits = " << _total_in_flight_flits[c].size()
- << " (" << _measured_in_flight_flits[c].size() << " measured)"
- << endl;
+ cout << "Injected packet length average = " << (double)sent_flits / (double)sent_packets << endl
+ << "Accepted packet length average = " << (double)accepted_flits / (double)accepted_packets << endl;
+
+ cout << "Total in-flight flits = " << _total_in_flight_flits[c].size()
+ << " (" << _measured_in_flight_flits[c].size() << " measured)"
+ << endl;
#ifdef TRACK_STALLS
- _ComputeStats(_buffer_busy_stalls[c], &count_sum);
- rate_sum = (double)count_sum / time_delta;
- rate_avg = rate_sum / (double)(_subnets*_routers);
- os << "Buffer busy stall rate = " << rate_avg << endl;
- _ComputeStats(_buffer_conflict_stalls[c], &count_sum);
- rate_sum = (double)count_sum / time_delta;
- rate_avg = rate_sum / (double)(_subnets*_routers);
- os << "Buffer conflict stall rate = " << rate_avg << endl;
- _ComputeStats(_buffer_full_stalls[c], &count_sum);
- rate_sum = (double)count_sum / time_delta;
- rate_avg = rate_sum / (double)(_subnets*_routers);
- os << "Buffer full stall rate = " << rate_avg << endl;
- _ComputeStats(_buffer_reserved_stalls[c], &count_sum);
- rate_sum = (double)count_sum / time_delta;
- rate_avg = rate_sum / (double)(_subnets*_routers);
- os << "Buffer reserved stall rate = " << rate_avg << endl;
- _ComputeStats(_crossbar_conflict_stalls[c], &count_sum);
- rate_sum = (double)count_sum / time_delta;
- rate_avg = rate_sum / (double)(_subnets*_routers);
- os << "Crossbar conflict stall rate = " << rate_avg << endl;
+ _ComputeStats(_buffer_busy_stalls[c], &count_sum);
+ rate_sum = (double)count_sum / time_delta;
+ rate_avg = rate_sum / (double)(_subnets*_routers);
+ os << "Buffer busy stall rate = " << rate_avg << endl;
+ _ComputeStats(_buffer_conflict_stalls[c], &count_sum);
+ rate_sum = (double)count_sum / time_delta;
+ rate_avg = rate_sum / (double)(_subnets*_routers);
+ os << "Buffer conflict stall rate = " << rate_avg << endl;
+ _ComputeStats(_buffer_full_stalls[c], &count_sum);
+ rate_sum = (double)count_sum / time_delta;
+ rate_avg = rate_sum / (double)(_subnets*_routers);
+ os << "Buffer full stall rate = " << rate_avg << endl;
+ _ComputeStats(_buffer_reserved_stalls[c], &count_sum);
+ rate_sum = (double)count_sum / time_delta;
+ rate_avg = rate_sum / (double)(_subnets*_routers);
+ os << "Buffer reserved stall rate = " << rate_avg << endl;
+ _ComputeStats(_crossbar_conflict_stalls[c], &count_sum);
+ rate_sum = (double)count_sum / time_delta;
+ rate_avg = rate_sum / (double)(_subnets*_routers);
+ os << "Crossbar conflict stall rate = " << rate_avg << endl;
#endif
- }
+ }
}
void TrafficManager::DisplayOverallStats( ostream & os ) const {
-
- os << "====== Overall Traffic Statistics ======" << endl;
- for ( int c = 0; c < _classes; ++c ) {
-
- if(_measure_stats[c] == 0) {
- continue;
- }
-
- os << "====== Traffic class " << c << " ======" << endl;
-
- os << "Packet latency average = " << _overall_avg_plat[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tminimum = " << _overall_min_plat[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tmaximum = " << _overall_max_plat[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
-
- os << "Network latency average = " << _overall_avg_nlat[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tminimum = " << _overall_min_nlat[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tmaximum = " << _overall_max_nlat[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
-
- os << "Flit latency average = " << _overall_avg_flat[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tminimum = " << _overall_min_flat[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tmaximum = " << _overall_max_flat[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
-
- os << "Fragmentation average = " << _overall_avg_frag[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tminimum = " << _overall_min_frag[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tmaximum = " << _overall_max_frag[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
-
- os << "Injected packet rate average = " << _overall_avg_sent_packets[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tminimum = " << _overall_min_sent_packets[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tmaximum = " << _overall_max_sent_packets[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
-
- os << "Accepted packet rate average = " << _overall_avg_accepted_packets[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tminimum = " << _overall_min_accepted_packets[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tmaximum = " << _overall_max_accepted_packets[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
+
+ os << "====== Overall Traffic Statistics ======" << endl;
+ for ( int c = 0; c < _classes; ++c ) {
+
+ if(_measure_stats[c] == 0) {
+ continue;
+ }
+
+ os << "====== Traffic class " << c << " ======" << endl;
- os << "Injected flit rate average = " << _overall_avg_sent[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tminimum = " << _overall_min_sent[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tmaximum = " << _overall_max_sent[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
+ os << "Packet latency average = " << _overall_avg_plat[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tminimum = " << _overall_min_plat[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tmaximum = " << _overall_max_plat[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+
+ os << "Network latency average = " << _overall_avg_nlat[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tminimum = " << _overall_min_nlat[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tmaximum = " << _overall_max_nlat[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+
+ os << "Flit latency average = " << _overall_avg_flat[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tminimum = " << _overall_min_flat[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tmaximum = " << _overall_max_flat[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+
+ os << "Fragmentation average = " << _overall_avg_frag[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tminimum = " << _overall_min_frag[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tmaximum = " << _overall_max_frag[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+
+ os << "Injected packet rate average = " << _overall_avg_sent_packets[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tminimum = " << _overall_min_sent_packets[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tmaximum = " << _overall_max_sent_packets[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
- os << "Accepted flit rate average = " << _overall_avg_accepted[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tminimum = " << _overall_min_accepted[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
- os << "\tmaximum = " << _overall_max_accepted[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
+ os << "Accepted packet rate average = " << _overall_avg_accepted_packets[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tminimum = " << _overall_min_accepted_packets[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tmaximum = " << _overall_max_accepted_packets[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+
+ os << "Injected flit rate average = " << _overall_avg_sent[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tminimum = " << _overall_min_sent[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tmaximum = " << _overall_max_sent[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
- os << "Injected packet size average = " << _overall_avg_sent[c] / _overall_avg_sent_packets[c]
- << " (" << _total_sims << " samples)" << endl;
+ os << "Accepted flit rate average = " << _overall_avg_accepted[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tminimum = " << _overall_min_accepted[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
+ os << "\tmaximum = " << _overall_max_accepted[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
- os << "Accepted packet size average = " << _overall_avg_accepted[c] / _overall_avg_accepted_packets[c]
- << " (" << _total_sims << " samples)" << endl;
+ os << "Injected packet size average = " << _overall_avg_sent[c] / _overall_avg_sent_packets[c]
+ << " (" << _total_sims << " samples)" << endl;
+
+ os << "Accepted packet size average = " << _overall_avg_accepted[c] / _overall_avg_accepted_packets[c]
+ << " (" << _total_sims << " samples)" << endl;
- os << "Hops average = " << _overall_hop_stats[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
+ os << "Hops average = " << _overall_hop_stats[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
#ifdef TRACK_STALLS
- os << "Buffer busy stall rate = " << (double)_overall_buffer_busy_stalls[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl
- << "Buffer conflict stall rate = " << (double)_overall_buffer_conflict_stalls[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl
- << "Buffer full stall rate = " << (double)_overall_buffer_full_stalls[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl
- << "Buffer reserved stall rate = " << (double)_overall_buffer_reserved_stalls[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl
- << "Crossbar conflict stall rate = " << (double)_overall_crossbar_conflict_stalls[c] / (double)_total_sims
- << " (" << _total_sims << " samples)" << endl;
+ os << "Buffer busy stall rate = " << (double)_overall_buffer_busy_stalls[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl
+ << "Buffer conflict stall rate = " << (double)_overall_buffer_conflict_stalls[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl
+ << "Buffer full stall rate = " << (double)_overall_buffer_full_stalls[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl
+ << "Buffer reserved stall rate = " << (double)_overall_buffer_reserved_stalls[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl
+ << "Crossbar conflict stall rate = " << (double)_overall_crossbar_conflict_stalls[c] / (double)_total_sims
+ << " (" << _total_sims << " samples)" << endl;
#endif
- }
+ }
}
string TrafficManager::_OverallStatsCSV(int c) const
{
- ostringstream os;
- os << _traffic[c]
- << ',' << _use_read_write[c]
- << ',' << _load[c]
- << ',' << _overall_min_plat[c] / (double)_total_sims
- << ',' << _overall_avg_plat[c] / (double)_total_sims
- << ',' << _overall_max_plat[c] / (double)_total_sims
- << ',' << _overall_min_nlat[c] / (double)_total_sims
- << ',' << _overall_avg_nlat[c] / (double)_total_sims
- << ',' << _overall_max_nlat[c] / (double)_total_sims
- << ',' << _overall_min_flat[c] / (double)_total_sims
- << ',' << _overall_avg_flat[c] / (double)_total_sims
- << ',' << _overall_max_flat[c] / (double)_total_sims
- << ',' << _overall_min_frag[c] / (double)_total_sims
- << ',' << _overall_avg_frag[c] / (double)_total_sims
- << ',' << _overall_max_frag[c] / (double)_total_sims
- << ',' << _overall_min_sent_packets[c] / (double)_total_sims
- << ',' << _overall_avg_sent_packets[c] / (double)_total_sims
- << ',' << _overall_max_sent_packets[c] / (double)_total_sims
- << ',' << _overall_min_accepted_packets[c] / (double)_total_sims
- << ',' << _overall_avg_accepted_packets[c] / (double)_total_sims
- << ',' << _overall_max_accepted_packets[c] / (double)_total_sims
- << ',' << _overall_min_sent[c] / (double)_total_sims
- << ',' << _overall_avg_sent[c] / (double)_total_sims
- << ',' << _overall_max_sent[c] / (double)_total_sims
- << ',' << _overall_min_accepted[c] / (double)_total_sims
- << ',' << _overall_avg_accepted[c] / (double)_total_sims
- << ',' << _overall_max_accepted[c] / (double)_total_sims
- << ',' << _overall_avg_sent[c] / _overall_avg_sent_packets[c]
- << ',' << _overall_avg_accepted[c] / _overall_avg_accepted_packets[c]
- << ',' << _overall_hop_stats[c] / (double)_total_sims;
-
+ ostringstream os;
+ os << _traffic[c]
+ << ',' << _use_read_write[c]
+ << ',' << _load[c]
+ << ',' << _overall_min_plat[c] / (double)_total_sims
+ << ',' << _overall_avg_plat[c] / (double)_total_sims
+ << ',' << _overall_max_plat[c] / (double)_total_sims
+ << ',' << _overall_min_nlat[c] / (double)_total_sims
+ << ',' << _overall_avg_nlat[c] / (double)_total_sims
+ << ',' << _overall_max_nlat[c] / (double)_total_sims
+ << ',' << _overall_min_flat[c] / (double)_total_sims
+ << ',' << _overall_avg_flat[c] / (double)_total_sims
+ << ',' << _overall_max_flat[c] / (double)_total_sims
+ << ',' << _overall_min_frag[c] / (double)_total_sims
+ << ',' << _overall_avg_frag[c] / (double)_total_sims
+ << ',' << _overall_max_frag[c] / (double)_total_sims
+ << ',' << _overall_min_sent_packets[c] / (double)_total_sims
+ << ',' << _overall_avg_sent_packets[c] / (double)_total_sims
+ << ',' << _overall_max_sent_packets[c] / (double)_total_sims
+ << ',' << _overall_min_accepted_packets[c] / (double)_total_sims
+ << ',' << _overall_avg_accepted_packets[c] / (double)_total_sims
+ << ',' << _overall_max_accepted_packets[c] / (double)_total_sims
+ << ',' << _overall_min_sent[c] / (double)_total_sims
+ << ',' << _overall_avg_sent[c] / (double)_total_sims
+ << ',' << _overall_max_sent[c] / (double)_total_sims
+ << ',' << _overall_min_accepted[c] / (double)_total_sims
+ << ',' << _overall_avg_accepted[c] / (double)_total_sims
+ << ',' << _overall_max_accepted[c] / (double)_total_sims
+ << ',' << _overall_avg_sent[c] / _overall_avg_sent_packets[c]
+ << ',' << _overall_avg_accepted[c] / _overall_avg_accepted_packets[c]
+ << ',' << _overall_hop_stats[c] / (double)_total_sims;
+
#ifdef TRACK_STALLS
- os << ',' << (double)_overall_buffer_busy_stalls[c] / (double)_total_sims
- << ',' << (double)_overall_buffer_conflict_stalls[c] / (double)_total_sims
- << ',' << (double)_overall_buffer_full_stalls[c] / (double)_total_sims
- << ',' << (double)_overall_buffer_reserved_stalls[c] / (double)_total_sims
- << ',' << (double)_overall_crossbar_conflict_stalls[c] / (double)_total_sims;
+ os << ',' << (double)_overall_buffer_busy_stalls[c] / (double)_total_sims
+ << ',' << (double)_overall_buffer_conflict_stalls[c] / (double)_total_sims
+ << ',' << (double)_overall_buffer_full_stalls[c] / (double)_total_sims
+ << ',' << (double)_overall_buffer_reserved_stalls[c] / (double)_total_sims
+ << ',' << (double)_overall_crossbar_conflict_stalls[c] / (double)_total_sims;
#endif
-
- return os.str();
+
+ return os.str();
}
void TrafficManager::DisplayOverallStatsCSV(ostream & os) const {
- for(int c = 0; c < _classes; ++c) {
- os << "results:" << c << ',' << _OverallStatsCSV() << endl;
- }
+ for(int c = 0; c < _classes; ++c) {
+ os << "results:" << c << ',' << _OverallStatsCSV() << endl;
+ }
}
//read the watchlist
void TrafficManager::_LoadWatchList(const string & filename){
- ifstream watch_list;
- watch_list.open(filename.c_str());
+ ifstream watch_list;
+ watch_list.open(filename.c_str());
- string line;
- if(watch_list.is_open()) {
- while(!watch_list.eof()) {
- getline(watch_list, line);
- if(line != "") {
- if(line[0] == 'p') {
- _packets_to_watch.insert(atoi(line.c_str()+1));
- } else {
- _flits_to_watch.insert(atoi(line.c_str()));
+ string line;
+ if(watch_list.is_open()) {
+ while(!watch_list.eof()) {
+ getline(watch_list, line);
+ if(line != "") {
+ if(line[0] == 'p') {
+ _packets_to_watch.insert(atoi(line.c_str()+1));
+ } else {
+ _flits_to_watch.insert(atoi(line.c_str()));
+ }
+ }
}
- }
- }
- } else {
- Error("Unable to open flit watch file: " + filename);
- }
+ } else {
+ Error("Unable to open flit watch file: " + filename);
+ }
}
int TrafficManager::_GetNextPacketSize(int cl) const
{
- assert(cl >= 0 && cl < _classes);
-
- vector<int> const & psize = _packet_size[cl];
- int sizes = psize.size();
-
- if(sizes == 1) {
- return psize[0];
- }
-
- vector<int> const & prate = _packet_size_rate[cl];
- int max_val = _packet_size_max_val[cl];
-
- int pct = RandomInt(max_val);
-
- for(int i = 0; i < (sizes - 1); ++i) {
- int const limit = prate[i];
- if(limit > pct) {
- return psize[i];
- } else {
- pct -= limit;
+ assert(cl >= 0 && cl < _classes);
+
+ vector<int> const & psize = _packet_size[cl];
+ int sizes = psize.size();
+
+ if(sizes == 1) {
+ return psize[0];
}
- }
- assert(prate.back() > pct);
- return psize.back();
+
+ vector<int> const & prate = _packet_size_rate[cl];
+ int max_val = _packet_size_max_val[cl];
+
+ int pct = RandomInt(max_val);
+
+ for(int i = 0; i < (sizes - 1); ++i) {
+ int const limit = prate[i];
+ if(limit > pct) {
+ return psize[i];
+ } else {
+ pct -= limit;
+ }
+ }
+ assert(prate.back() > pct);
+ return psize.back();
}
double TrafficManager::_GetAveragePacketSize(int cl) const
{
- vector<int> const & psize = _packet_size[cl];
- int sizes = psize.size();
- if(sizes == 1) {
- return (double)psize[0];
- }
- vector<int> const & prate = _packet_size_rate[cl];
- int sum = 0;
- for(int i = 0; i < sizes; ++i) {
- sum += psize[i] * prate[i];
- }
- return (double)sum / (double)(_packet_size_max_val[cl] + 1);
+ vector<int> const & psize = _packet_size[cl];
+ int sizes = psize.size();
+ if(sizes == 1) {
+ return (double)psize[0];
+ }
+ vector<int> const & prate = _packet_size_rate[cl];
+ int sum = 0;
+ for(int i = 0; i < sizes; ++i) {
+ sum += psize[i] * prate[i];
+ }
+ return (double)sum / (double)(_packet_size_max_val[cl] + 1);
}
generated by cgit v1.3 (git 2.53.0) at 2026-07-10 23:25:55 +0000