Skip to content
Snippets Groups Projects
Commit 22a83474 authored by Peter W. Draper's avatar Peter W. Draper
Browse files

Add scaling option

parent 2e8cbf16
No related branches found
No related tags found
1 merge request!8Draft: RDMA version with wrapped infinity calls
...@@ -35,6 +35,9 @@ int myrank = -1; ...@@ -35,6 +35,9 @@ int myrank = -1;
/* Are we verbose. */ /* Are we verbose. */
static int verbose = 0; static int verbose = 0;
/* Scale to apply to the size of the messages we send. */
static float messagescale = 1.0;
/* Attempt to keep original injection time differences. */ /* Attempt to keep original injection time differences. */
static int usetics = 1; static int usetics = 1;
...@@ -388,6 +391,9 @@ static void pick_logs(void) { ...@@ -388,6 +391,9 @@ static void pick_logs(void) {
reqs_queue[nr_reqs] = log; reqs_queue[nr_reqs] = log;
nr_reqs++; nr_reqs++;
/* Scale size. */
log->size *= messagescale;
} else { } else {
error("task type '%d' is not a known send or recv task", log->type); error("task type '%d' is not a known send or recv task", log->type);
} }
...@@ -437,7 +443,7 @@ int main(int argc, char *argv[]) { ...@@ -437,7 +443,7 @@ int main(int argc, char *argv[]) {
/* Handle the command-line, we expect a mpiuse data file to read and various /* Handle the command-line, we expect a mpiuse data file to read and various
* options. */ * options. */
int opt; int opt;
while ((opt = getopt(argc, argv, "vfd")) != -1) { while ((opt = getopt(argc, argv, "vfds:")) != -1) {
switch (opt) { switch (opt) {
case 'd': case 'd':
datacheck = 1; datacheck = 1;
...@@ -445,6 +451,9 @@ int main(int argc, char *argv[]) { ...@@ -445,6 +451,9 @@ int main(int argc, char *argv[]) {
case 'f': case 'f':
usetics = 0; usetics = 0;
break; break;
case 's':
messagescale = atof(optarg);
break;
case 'v': case 'v':
verbose = 1; verbose = 1;
break; break;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment