Processing Element consume frequency

config_examples/256_12h.yaml

@@ -17,6 +17,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   WEST_FIRST

config_examples/256_16h.yaml

@@ -17,6 +17,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   WEST_FIRST

config_examples/256_16h_4channels.yaml

@@ -17,6 +17,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   WEST_FIRST

config_examples/256_4h.yaml

@@ -17,6 +17,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   WEST_FIRST

config_examples/256_4h_2channels.yaml

@@ -17,6 +17,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   WEST_FIRST

config_examples/256_8h.yaml

@@ -17,6 +17,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   WEST_FIRST

config_examples/article.yaml

@@ -17,6 +17,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 3
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   WEST_FIRST

config_examples/configWirelessCore2CoreBfly.yaml

@@ -23,6 +23,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   DELTA

config_examples/default_config.yaml

@@ -25,6 +25,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   DELTA

config_examples/default_configBaseline.yaml

@@ -20,6 +20,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   DELTA

config_examples/default_configBfly.yaml

@@ -20,6 +20,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   DELTA

config_examples/default_configMesh.yaml

@@ -25,6 +25,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   WEST_FIRST

config_examples/default_configMeshNoHUB.yaml

@@ -25,6 +25,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   DELTA

config_examples/default_configOmega.yaml

@@ -20,6 +20,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   WEST_FIRST

config_examples/multi_channel.yaml

@@ -17,6 +17,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 # Routing algorithms:
 #   XY
 #   WEST_FIRST

config_examples/testdelta.yaml

@@ -14,6 +14,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 routing_algorithm: DELTA
 routing_table_filename: ""
 

config_examples/testdelta_hops_1.yaml

@@ -20,6 +20,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 routing_algorithm: DELTA
 routing_table_filename: ""
 

config_examples/testdelta_hops_16.yaml

@@ -22,6 +22,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 routing_algorithm: DELTA
 routing_table_filename: ""
 

config_examples/testdelta_hops_2.yaml

@@ -22,6 +22,14 @@ r2h_link_length: 2.0
 r2r_link_length: 1.0
 n_virtual_channels: 1
 
+# pe input buffer size
+pe_rx_buffer_size: 1
+# how often does PE process a batch of flits (eg. 4 = once
+# every four cycles)
+processing_frequency: 1
+# how many flits are processed in a batch
+processing_size: 1
+
 routing_algorithm: DELTA
 routing_table_filename: ""
 

src/ConfigurationManager.cpp

@@ -87,6 +87,9 @@ void loadConfiguration() {
     GlobalParams::detailed = readParam<bool>(config, "detailed");
     GlobalParams::dyad_threshold = readParam<double>(config, "dyad_threshold");
     GlobalParams::max_volume_to_be_drained = readParam<unsigned int>(config, "max_volume_to_be_drained");
+    GlobalParams::processing_frequency = readParam<int>(config, "processing_frequency");
+    GlobalParams::pe_rx_buffer_size = readParam<int>(config, "pe_rx_buffer_size");
+    GlobalParams::processing_size = readParam<int>(config, "processing_size");
     //GlobalParams::hotspots;
     GlobalParams::show_buffer_stats = readParam<bool>(config, "show_buffer_stats");
     GlobalParams::use_winoc = readParam<bool>(config, "use_winoc");
@@ -247,6 +250,9 @@ void showHelp(char selfname[])
          << "\t\t\t\tbeen delivered" << endl
          << "\t-asciimonitor\t\tShow status of the network while running (experimental)" << endl
          << "\t-sim N\t\t\tRun for the specified simulation time [cycles]" << endl
+         << "\t-pe_rx_buffer_size N\t\t\tSets PE internal receive buffer size (default 1)" << endl
+         << "\t-processing_frequency N\t\t\tSets the frequency at which PEs consume packet(s) (default 1 - every cycle)" << endl
+         << "\t-processing_size N\t\t\tSets how many flits does a PE consume at a time (default 1 - one flit)" << endl
          << endl
          << "If you find this program useful please don't forget to mention in your paper Maurizio Palesi <maurizio.palesi@unikore.it>" << endl
          <<	"If you find this program useless please feel free to complain with Davide Patti <davide.patti@dieei.unict.it>" << endl
@@ -486,6 +492,14 @@ void parseCmdLine(int arg_num, char *arg_vet[])
 		setBufferAntenna(atoi(arg_vet[++i]));
 	    else if (!strcmp(arg_vet[i], "-vc"))
 		GlobalParams::n_virtual_channels = (atoi(arg_vet[++i]));
+	    //-----------------------EXTRA------------------------/
+	    else if (!strcmp(arg_vet[i], "-pe_rx_buffer_size"))
+		GlobalParams::pe_rx_buffer_size = (atoi(arg_vet[++i]));
+	    else if (!strcmp(arg_vet[i], "-processing_frequency"))
+		GlobalParams::processing_frequency = (atoi(arg_vet[++i]));
+	    else if (!strcmp(arg_vet[i], "-processing_size"))
+		GlobalParams::processing_size = (atoi(arg_vet[++i]));
+	    //-----------------------EXTRA------------------------/
 	    else if (!strcmp(arg_vet[i], "-flit"))
 		GlobalParams::flit_size = atoi(arg_vet[++i]);
 	    else if (!strcmp(arg_vet[i], "-winoc")) 

src/GlobalParams.cpp

@@ -27,6 +27,9 @@ int GlobalParams::buffer_depth;
 int GlobalParams::flit_size;
 int GlobalParams::min_packet_size;
 int GlobalParams::max_packet_size;
+int GlobalParams::pe_rx_buffer_size;
+int GlobalParams::processing_frequency;
+int GlobalParams::processing_size;
 string GlobalParams::routing_algorithm;
 string GlobalParams::routing_table_filename;
 string GlobalParams::selection_strategy;

src/GlobalParams.h

@@ -152,6 +152,9 @@ struct GlobalParams {
     static int flit_size;
     static int min_packet_size;
     static int max_packet_size;
+    static int processing_frequency;
+    static int processing_size;
+    static int pe_rx_buffer_size;
     static string routing_algorithm;
     static string routing_table_filename;
     static string selection_strategy;