summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorTushar Krishna <tushar@ece.gatech.edu>2016-10-06 14:35:16 -0400
committerTushar Krishna <tushar@ece.gatech.edu>2016-10-06 14:35:16 -0400
commit0f68b50ff11a957a9c8d31b592c75e659f8a1023 (patch)
treeeba783cfce7f7922b359740721050ebda504357a /src
parentaca869bf2dba8cc7a7b06be223b84fa0376a59e9 (diff)
downloadgem5-0f68b50ff11a957a9c8d31b592c75e659f8a1023.tar.xz
ruby: rename networktest to garnet_synthetic_traffic.
networktest is essentially a collection of synthetic traffic patterns for the network. The protocol name and the tester having the same name led to multiple python configuration files with the same name, adding confusion. This patch renames networktest to garnet_synthetic_traffic, and also adds more synthetic traffic patterns.
Diffstat (limited to 'src')
-rw-r--r--src/cpu/testers/garnet_synthetic_traffic/GarnetSyntheticTraffic.cc (renamed from src/cpu/testers/networktest/networktest.cc)203
-rw-r--r--src/cpu/testers/garnet_synthetic_traffic/GarnetSyntheticTraffic.hh (renamed from src/cpu/testers/networktest/networktest.hh)61
-rw-r--r--src/cpu/testers/garnet_synthetic_traffic/GarnetSyntheticTraffic.py (renamed from src/cpu/testers/networktest/NetworkTest.py)29
-rw-r--r--src/cpu/testers/garnet_synthetic_traffic/SConscript (renamed from src/cpu/testers/networktest/SConscript)8
4 files changed, 201 insertions, 100 deletions
diff --git a/src/cpu/testers/networktest/networktest.cc b/src/cpu/testers/garnet_synthetic_traffic/GarnetSyntheticTraffic.cc
index 6ad26077c..f5a718697 100644
--- a/src/cpu/testers/networktest/networktest.cc
+++ b/src/cpu/testers/garnet_synthetic_traffic/GarnetSyntheticTraffic.cc
@@ -1,5 +1,5 @@
/*
- * Copyright (c) 2009 Advanced Micro Devices, Inc.
+ * Copyright (c) 2016 Georgia Institute of Technology
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
@@ -37,8 +37,8 @@
#include "base/misc.hh"
#include "base/random.hh"
#include "base/statistics.hh"
-#include "cpu/testers/networktest/networktest.hh"
-#include "debug/NetworkTest.hh"
+#include "cpu/testers/garnet_synthetic_traffic/GarnetSyntheticTraffic.hh"
+#include "debug/GarnetSyntheticTraffic.hh"
#include "mem/mem_object.hh"
#include "mem/packet.hh"
#include "mem/port.hh"
@@ -52,20 +52,20 @@ using namespace std;
int TESTER_NETWORK=0;
bool
-NetworkTest::CpuPort::recvTimingResp(PacketPtr pkt)
+GarnetSyntheticTraffic::CpuPort::recvTimingResp(PacketPtr pkt)
{
- networktest->completeRequest(pkt);
+ tester->completeRequest(pkt);
return true;
}
void
-NetworkTest::CpuPort::recvReqRetry()
+GarnetSyntheticTraffic::CpuPort::recvReqRetry()
{
- networktest->doRetry();
+ tester->doRetry();
}
void
-NetworkTest::sendPkt(PacketPtr pkt)
+GarnetSyntheticTraffic::sendPkt(PacketPtr pkt)
{
if (!cachePort.sendTimingReq(pkt)) {
retryPkt = pkt; // RubyPort will retry sending
@@ -73,34 +73,43 @@ NetworkTest::sendPkt(PacketPtr pkt)
numPacketsSent++;
}
-NetworkTest::NetworkTest(const Params *p)
+GarnetSyntheticTraffic::GarnetSyntheticTraffic(const Params *p)
: MemObject(p),
tickEvent(this),
- cachePort("network-test", this),
+ cachePort("GarnetSyntheticTraffic", this),
retryPkt(NULL),
size(p->memory_size),
blockSizeBits(p->block_offset),
- numMemories(p->num_memories),
+ numDestinations(p->num_dest),
simCycles(p->sim_cycles),
- fixedPkts(p->fixed_pkts),
- maxPackets(p->max_packets),
+ numPacketsMax(p->num_packets_max),
numPacketsSent(0),
+ singleSender(p->single_sender),
+ singleDest(p->single_dest),
trafficType(p->traffic_type),
injRate(p->inj_rate),
+ injVnet(p->inj_vnet),
precision(p->precision),
+ responseLimit(p->response_limit),
masterId(p->system->getMasterId(name()))
{
// set up counters
noResponseCycles = 0;
schedule(tickEvent, 0);
+ initTrafficType();
+ if (trafficStringToEnum.count(trafficType) == 0) {
+ fatal("Unknown Traffic Type: %s!\n", traffic);
+ }
+ traffic = trafficStringToEnum[trafficType];
+
id = TESTER_NETWORK++;
- DPRINTF(NetworkTest,"Config Created: Name = %s , and id = %d\n",
+ DPRINTF(GarnetSyntheticTraffic,"Config Created: Name = %s , and id = %d\n",
name(), id);
}
BaseMasterPort &
-NetworkTest::getMasterPort(const std::string &if_name, PortID idx)
+GarnetSyntheticTraffic::getMasterPort(const std::string &if_name, PortID idx)
{
if (if_name == "test")
return cachePort;
@@ -109,18 +118,19 @@ NetworkTest::getMasterPort(const std::string &if_name, PortID idx)
}
void
-NetworkTest::init()
+GarnetSyntheticTraffic::init()
{
numPacketsSent = 0;
}
void
-NetworkTest::completeRequest(PacketPtr pkt)
+GarnetSyntheticTraffic::completeRequest(PacketPtr pkt)
{
Request *req = pkt->req;
- DPRINTF(NetworkTest, "Completed injection of %s packet for address %x\n",
+ DPRINTF(GarnetSyntheticTraffic,
+ "Completed injection of %s packet for address %x\n",
pkt->isWrite() ? "write" : "read\n",
req->getPaddr());
@@ -132,34 +142,36 @@ NetworkTest::completeRequest(PacketPtr pkt)
void
-NetworkTest::tick()
+GarnetSyntheticTraffic::tick()
{
- if (++noResponseCycles >= 500000) {
- cerr << name() << ": deadlocked at cycle " << curTick() << endl;
- fatal("");
+ if (++noResponseCycles >= responseLimit) {
+ fatal("%s deadlocked at cycle %d\n", name(), curTick());
}
// make new request based on injection rate
// (injection rate's range depends on precision)
// - generate a random number between 0 and 10^precision
// - send pkt if this number is < injRate*(10^precision)
- bool send_this_cycle;
+ bool sendAllowedThisCycle;
double injRange = pow((double) 10, (double) precision);
unsigned trySending = random_mt.random<unsigned>(0, (int) injRange);
if (trySending < injRate*injRange)
- send_this_cycle = true;
+ sendAllowedThisCycle = true;
else
- send_this_cycle = false;
-
- // always generatePkt unless fixedPkts is enabled
- if (send_this_cycle) {
- if (fixedPkts) {
- if (numPacketsSent < maxPackets) {
- generatePkt();
- }
- } else {
+ sendAllowedThisCycle = false;
+
+ // always generatePkt unless fixedPkts or singleSender is enabled
+ if (sendAllowedThisCycle) {
+ bool senderEnable = true;
+
+ if (numPacketsMax >= 0 && numPacketsSent >= numPacketsMax)
+ senderEnable = false;
+
+ if (singleSender >= 0 && id != singleSender)
+ senderEnable = false;
+
+ if (senderEnable)
generatePkt();
- }
}
// Schedule wakeup
@@ -172,30 +184,64 @@ NetworkTest::tick()
}
void
-NetworkTest::generatePkt()
+GarnetSyntheticTraffic::generatePkt()
{
+ int num_destinations = numDestinations;
+ int radix = (int) sqrt(num_destinations);
unsigned destination = id;
- if (trafficType == 0) { // Uniform Random
- destination = random_mt.random<unsigned>(0, numMemories - 1);
- } else if (trafficType == 1) { // Tornado
- int networkDimension = (int) sqrt(numMemories);
- int my_x = id%networkDimension;
- int my_y = id/networkDimension;
-
- int dest_x = my_x + (int) ceil(networkDimension/2) - 1;
- dest_x = dest_x%networkDimension;
- int dest_y = my_y;
-
- destination = dest_y*networkDimension + dest_x;
- } else if (trafficType == 2) { // Bit Complement
- int networkDimension = (int) sqrt(numMemories);
- int my_x = id%networkDimension;
- int my_y = id/networkDimension;
-
- int dest_x = networkDimension - my_x - 1;
- int dest_y = networkDimension - my_y - 1;
-
- destination = dest_y*networkDimension + dest_x;
+ int dest_x = -1;
+ int dest_y = -1;
+ int source = id;
+ int src_x = id%radix;
+ int src_y = id/radix;
+
+ if (singleDest >= 0)
+ {
+ destination = singleDest;
+ } else if (traffic == UNIFORM_RANDOM_) {
+ destination = random_mt.random<unsigned>(0, num_destinations - 1);
+ } else if (traffic == BIT_COMPLEMENT_) {
+ dest_x = radix - src_x - 1;
+ dest_y = radix - src_y - 1;
+ destination = dest_y*radix + dest_x;
+ } else if (traffic == BIT_REVERSE_) {
+ unsigned int straight = source;
+ unsigned int reverse = source & 1; // LSB
+
+ int num_bits = (int) log2(num_destinations);
+
+ for (int i = 1; i < num_bits; i++)
+ {
+ reverse <<= 1;
+ straight >>= 1;
+ reverse |= (straight & 1); // LSB
+ }
+ destination = reverse;
+ } else if (traffic == BIT_ROTATION_) {
+ if (source%2 == 0)
+ destination = source/2;
+ else // (source%2 == 1)
+ destination = ((source/2) + (num_destinations/2));
+ } else if (traffic == NEIGHBOR_) {
+ dest_x = (src_x + 1) % radix;
+ dest_y = src_y;
+ destination = dest_y*radix + dest_x;
+ } else if (traffic == SHUFFLE_) {
+ if (source < num_destinations/2)
+ destination = source*2;
+ else
+ destination = (source*2 - num_destinations + 1);
+ } else if (traffic == TRANSPOSE_) {
+ dest_x = src_y;
+ dest_y = src_x;
+ destination = dest_y*radix + dest_x;
+ } else if (traffic == TORNADO_) {
+ dest_x = (src_x + (int) ceil(radix/2) - 1) % radix;
+ dest_y = src_y;
+ destination = dest_y*radix + dest_x;
+ }
+ else {
+ fatal("Unknown Traffic Type: %s!\n", traffic);
}
// The source of the packets is a cache.
@@ -207,7 +253,7 @@ NetworkTest::generatePkt()
// Modeling different coherence msg types over different msg classes.
//
- // networktest assumes the Network_test coherence protocol
+ // GarnetSyntheticTraffic assumes the Garnet_standalone coherence protocol
// which models three message classes/virtual networks.
// These are: request, forward, response.
// requests and forwards are "control" packets (typically 8 bytes),
@@ -234,18 +280,28 @@ NetworkTest::generatePkt()
Request *req = nullptr;
Request::Flags flags;
- unsigned randomReqType = random_mt.random(0, 2);
- if (randomReqType == 0) {
+ // Inject in specific Vnet
+ // Vnet 0 and 1 are for control packets (1-flit)
+ // Vnet 2 is for data packets (5-flit)
+ int injReqType = injVnet;
+
+ if (injReqType < 0 || injReqType > 2)
+ {
+ // randomly inject in any vnet
+ injReqType = random_mt.random(0, 2);
+ }
+
+ if (injReqType == 0) {
// generate packet for virtual network 0
requestType = MemCmd::ReadReq;
req = new Request(paddr, access_size, flags, masterId);
- } else if (randomReqType == 1) {
+ } else if (injReqType == 1) {
// generate packet for virtual network 1
requestType = MemCmd::ReadReq;
flags.set(Request::INST_FETCH);
req = new Request(0, 0x0, access_size, flags, masterId, 0x0, 0);
req->setPaddr(paddr);
- } else { // if (randomReqType == 2)
+ } else { // if (injReqType == 2)
// generate packet for virtual network 2
requestType = MemCmd::WriteReq;
req = new Request(paddr, access_size, flags, masterId);
@@ -256,7 +312,7 @@ NetworkTest::generatePkt()
//No need to do functional simulation
//We just do timing simulation of the network
- DPRINTF(NetworkTest,
+ DPRINTF(GarnetSyntheticTraffic,
"Generated packet with destination %d, embedded in address %x\n",
destination, req->getPaddr());
@@ -268,7 +324,20 @@ NetworkTest::generatePkt()
}
void
-NetworkTest::doRetry()
+GarnetSyntheticTraffic::initTrafficType()
+{
+ trafficStringToEnum["bit_complement"] = BIT_COMPLEMENT_;
+ trafficStringToEnum["bit_reverse"] = BIT_REVERSE_;
+ trafficStringToEnum["bit_rotation"] = BIT_ROTATION_;
+ trafficStringToEnum["neighbor"] = NEIGHBOR_;
+ trafficStringToEnum["shuffle"] = SHUFFLE_;
+ trafficStringToEnum["tornado"] = TORNADO_;
+ trafficStringToEnum["transpose"] = TRANSPOSE_;
+ trafficStringToEnum["uniform_random"] = UNIFORM_RANDOM_;
+}
+
+void
+GarnetSyntheticTraffic::doRetry()
{
if (cachePort.sendTimingReq(retryPkt)) {
retryPkt = NULL;
@@ -276,14 +345,14 @@ NetworkTest::doRetry()
}
void
-NetworkTest::printAddr(Addr a)
+GarnetSyntheticTraffic::printAddr(Addr a)
{
cachePort.printAddr(a);
}
-NetworkTest *
-NetworkTestParams::create()
+GarnetSyntheticTraffic *
+GarnetSyntheticTrafficParams::create()
{
- return new NetworkTest(this);
+ return new GarnetSyntheticTraffic(this);
}
diff --git a/src/cpu/testers/networktest/networktest.hh b/src/cpu/testers/garnet_synthetic_traffic/GarnetSyntheticTraffic.hh
index 572097a09..94eee44d7 100644
--- a/src/cpu/testers/networktest/networktest.hh
+++ b/src/cpu/testers/garnet_synthetic_traffic/GarnetSyntheticTraffic.hh
@@ -1,5 +1,5 @@
/*
- * Copyright (c) 2009 Advanced Micro Devices, Inc.
+ * Copyright (c) 2016 Georgia Institute of Technology
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
@@ -28,26 +28,36 @@
* Authors: Tushar Krishna
*/
-#ifndef __CPU_NETWORKTEST_NETWORKTEST_HH__
-#define __CPU_NETWORKTEST_NETWORKTEST_HH__
+#ifndef __CPU_GARNET_SYNTHETIC_TRAFFIC_HH__
+#define __CPU_GARNET_SYNTHETIC_TRAFFIC_HH__
#include <set>
#include "base/statistics.hh"
#include "mem/mem_object.hh"
#include "mem/port.hh"
-#include "params/NetworkTest.hh"
+#include "params/GarnetSyntheticTraffic.hh"
#include "sim/eventq.hh"
#include "sim/sim_exit.hh"
#include "sim/sim_object.hh"
#include "sim/stats.hh"
+enum TrafficType {BIT_COMPLEMENT_ = 0,
+ BIT_REVERSE_ = 1,
+ BIT_ROTATION_ = 2,
+ NEIGHBOR_ = 3,
+ SHUFFLE_ = 4,
+ TORNADO_ = 5,
+ TRANSPOSE_ = 6,
+ UNIFORM_RANDOM_ = 7,
+ NUM_TRAFFIC_PATTERNS_};
+
class Packet;
-class NetworkTest : public MemObject
+class GarnetSyntheticTraffic : public MemObject
{
public:
- typedef NetworkTestParams Params;
- NetworkTest(const Params *p);
+ typedef GarnetSyntheticTrafficParams Params;
+ GarnetSyntheticTraffic(const Params *p);
virtual void init();
@@ -67,24 +77,27 @@ class NetworkTest : public MemObject
class TickEvent : public Event
{
private:
- NetworkTest *cpu;
+ GarnetSyntheticTraffic *cpu;
public:
- TickEvent(NetworkTest *c) : Event(CPU_Tick_Pri), cpu(c) {}
+ TickEvent(GarnetSyntheticTraffic *c) : Event(CPU_Tick_Pri), cpu(c) {}
void process() { cpu->tick(); }
- virtual const char *description() const { return "NetworkTest tick"; }
+ virtual const char *description() const
+ {
+ return "GarnetSyntheticTraffic tick";
+ }
};
TickEvent tickEvent;
class CpuPort : public MasterPort
{
- NetworkTest *networktest;
+ GarnetSyntheticTraffic *tester;
public:
- CpuPort(const std::string &_name, NetworkTest *_networktest)
- : MasterPort(_name, _networktest), networktest(_networktest)
+ CpuPort(const std::string &_name, GarnetSyntheticTraffic *_tester)
+ : MasterPort(_name, _tester), tester(_tester)
{ }
protected:
@@ -96,11 +109,11 @@ class NetworkTest : public MemObject
CpuPort cachePort;
- class NetworkTestSenderState : public Packet::SenderState
+ class GarnetSyntheticTrafficSenderState : public Packet::SenderState
{
public:
/** Constructor. */
- NetworkTestSenderState(uint8_t *_data)
+ GarnetSyntheticTrafficSenderState(uint8_t *_data)
: data(_data)
{ }
@@ -112,33 +125,41 @@ class NetworkTest : public MemObject
unsigned size;
int id;
+ std::map<std::string, TrafficType> trafficStringToEnum;
+
unsigned blockSizeBits;
Tick noResponseCycles;
- int numMemories;
+ int numDestinations;
Tick simCycles;
- bool fixedPkts;
- int maxPackets;
+ int numPacketsMax;
int numPacketsSent;
+ int singleSender;
+ int singleDest;
- int trafficType;
+ std::string trafficType; // string
+ TrafficType traffic; // enum from string
double injRate;
+ int injVnet;
int precision;
+ const Cycles responseLimit;
+
MasterID masterId;
void completeRequest(PacketPtr pkt);
void generatePkt();
void sendPkt(PacketPtr pkt);
+ void initTrafficType();
void doRetry();
friend class MemCompleteEvent;
};
-#endif // __CPU_NETWORKTEST_NETWORKTEST_HH__
+#endif // __CPU_GARNET_SYNTHETIC_TRAFFIC_HH__
diff --git a/src/cpu/testers/networktest/NetworkTest.py b/src/cpu/testers/garnet_synthetic_traffic/GarnetSyntheticTraffic.py
index 25b2bb690..261e643c1 100644
--- a/src/cpu/testers/networktest/NetworkTest.py
+++ b/src/cpu/testers/garnet_synthetic_traffic/GarnetSyntheticTraffic.py
@@ -1,4 +1,4 @@
-# Copyright (c) 2009 Advanced Micro Devices, Inc.
+# Copyright (c) 2016 Georgia Institute of Technology
# All rights reserved.
#
# Redistribution and use in source and binary forms, with or without
@@ -30,17 +30,28 @@ from MemObject import MemObject
from m5.params import *
from m5.proxy import *
-class NetworkTest(MemObject):
- type = 'NetworkTest'
- cxx_header = "cpu/testers/networktest/networktest.hh"
+class GarnetSyntheticTraffic(MemObject):
+ type = 'GarnetSyntheticTraffic'
+ cxx_header = \
+ "cpu/testers/garnet_synthetic_traffic/GarnetSyntheticTraffic.hh"
block_offset = Param.Int(6, "block offset in bits")
- num_memories = Param.Int(1, "Num Memories")
+ num_dest = Param.Int(1, "Number of Destinations")
memory_size = Param.Int(65536, "memory size")
sim_cycles = Param.Int(1000, "Number of simulation cycles")
- fixed_pkts = Param.Bool(False, "Send fixed number of packets")
- max_packets = Param.Counter(0, "Number of packets to send when in fixed_pkts mode")
- traffic_type = Param.Counter(0, "Traffic type: uniform random, tornado, bit complement")
+ num_packets_max = Param.Int(-1, "Max number of packets to send. \
+ Default is to keep sending till simulation ends")
+ single_sender = Param.Int(-1, "Send only from this node. \
+ By default every node sends")
+ single_dest = Param.Int(-1, "Send only to this dest. \
+ Default depends on traffic_type")
+ traffic_type = Param.String("uniform_random", "Traffic type")
inj_rate = Param.Float(0.1, "Packet injection rate")
- precision = Param.Int(3, "Number of digits of precision after decimal point")
+ inj_vnet = Param.Int(-1, "Vnet to inject in. \
+ 0 and 1 are 1-flit, 2 is 5-flit. \
+ Default is to inject in all three vnets")
+ precision = Param.Int(3, "Number of digits of precision \
+ after decimal point")
+ response_limit = Param.Cycles(5000000, "Cycles before exiting \
+ due to lack of progress")
test = MasterPort("Port to the memory system to test")
system = Param.System(Parent.any, "System we belong to")
diff --git a/src/cpu/testers/networktest/SConscript b/src/cpu/testers/garnet_synthetic_traffic/SConscript
index 06ab0f2aa..f1624b05e 100644
--- a/src/cpu/testers/networktest/SConscript
+++ b/src/cpu/testers/garnet_synthetic_traffic/SConscript
@@ -1,6 +1,6 @@
# -*- mode:python -*-
-# Copyright (c) 2009 Advanced Micro Devices, Inc.
+# Copyright (c) 2016 Georgia Institute of Technology.
# All rights reserved.
#
# Redistribution and use in source and binary forms, with or without
@@ -30,8 +30,8 @@
Import('*')
-SimObject('NetworkTest.py')
+SimObject('GarnetSyntheticTraffic.py')
-Source('networktest.cc')
+Source('GarnetSyntheticTraffic.cc')
-DebugFlag('NetworkTest')
+DebugFlag('GarnetSyntheticTraffic')