+++ /dev/null
-Bottom: 6143dc261a8c3107f32a4bd74443fd381b89d52e
-Top: 070f92a593aea528dcae7a68d42159b016d77109
-Author: Sean Hefty <sean.hefty@intel.com>
-Date: 2012-05-17 11:38:24 -0700
-
-Refresh of rs-fulltest
-
----
-
-diff --git a/examples/rstream.c b/examples/rstream.c
-index 3e6d8d5..cb65911 100644
---- a/examples/rstream.c
-+++ b/examples/rstream.c
-@@ -52,22 +52,22 @@ struct test_size_param {
-
- static struct test_size_param test_size[] = {
- { 1 << 6, 0 },
-- { 1 << 7, 1 }, { 1 << 7 + 1 << 6, 1},
-- { 1 << 8, 1 }, { 1 << 8 + 1 << 7, 1},
-- { 1 << 9, 1 }, { 1 << 9 + 1 << 8, 1},
-- { 1 << 10, 1 }, { 1 << 10 + 1 << 9, 1},
-- { 1 << 11, 1 }, { 1 << 11 + 1 << 10, 1},
-- { 1 << 12, 0 }, { 1 << 12 + 1 << 11, 1},
-- { 1 << 13, 1 }, { 1 << 13 + 1 << 12, 1},
-- { 1 << 14, 1 }, { 1 << 14 + 1 << 13, 1},
-- { 1 << 15, 1 }, { 1 << 15 + 1 << 14, 1},
-- { 1 << 16, 0 }, { 1 << 16 + 1 << 15, 1},
-- { 1 << 17, 1 }, { 1 << 17 + 1 << 16, 1},
-- { 1 << 18, 1 }, { 1 << 18 + 1 << 17, 1},
-- { 1 << 19, 1 }, { 1 << 19 + 1 << 18, 1},
-- { 1 << 20, 0 }, { 1 << 20 + 1 << 19, 1},
-- { 1 << 21, 1 }, { 1 << 21 + 1 << 20, 1},
-- { 1 << 22, 1 }, { 1 << 22 + 1 << 21, 1},
-+ { 1 << 7, 1 }, { (1 << 7) + (1 << 6), 1},
-+ { 1 << 8, 1 }, { (1 << 8) + (1 << 7), 1},
-+ { 1 << 9, 1 }, { (1 << 9) + (1 << 8), 1},
-+ { 1 << 10, 1 }, { (1 << 10) + (1 << 9), 1},
-+ { 1 << 11, 1 }, { (1 << 11) + (1 << 10), 1},
-+ { 1 << 12, 0 }, { (1 << 12) + (1 << 11), 1},
-+ { 1 << 13, 1 }, { (1 << 13) + (1 << 12), 1},
-+ { 1 << 14, 1 }, { (1 << 14) + (1 << 13), 1},
-+ { 1 << 15, 1 }, { (1 << 15) + (1 << 14), 1},
-+ { 1 << 16, 0 }, { (1 << 16) + (1 << 15), 1},
-+ { 1 << 17, 1 }, { (1 << 17) + (1 << 16), 1},
-+ { 1 << 18, 1 }, { (1 << 18) + (1 << 17), 1},
-+ { 1 << 19, 1 }, { (1 << 19) + (1 << 18), 1},
-+ { 1 << 20, 0 }, { (1 << 20) + (1 << 19), 1},
-+ { 1 << 21, 1 }, { (1 << 21) + (1 << 20), 1},
-+ { 1 << 22, 1 }, { (1 << 22) + (1 << 21), 1},
- };
- #define TEST_CNT (sizeof test_size / sizeof test_size[0])
-
-@@ -106,14 +106,30 @@ static void *buf;
-
- static void size_str(char *str, long long size)
- {
-- if (size >= (1 << 30))
-- sprintf(str, "%lldg", size / (1 << 30));
-- else if (size >= (1 << 20))
-- sprintf(str, "%lldm", size / (1 << 20));
-- else if (size >= (1 << 10))
-- sprintf(str, "%lldk", size / (1 << 10));
-- else
-- sprintf(str, "%lld", size);
-+ long long base, fraction = 0;
-+ char mag;
-+
-+ if (size >= (1 << 30)) {
-+ base = 1 << 30;
-+ mag = 'g';
-+ } else if (size >= (1 << 20)) {
-+ base = 1 << 20;
-+ mag = 'm';
-+ } else if (size >= (1 << 10)) {
-+ base = 1 << 10;
-+ mag = 'k';
-+ } else {
-+ base = 1;
-+ mag = '\0';
-+ }
-+
-+ if (size / base < 10)
-+ fraction = (size % base) * 10 / base;
-+ if (fraction) {
-+ sprintf(str, "%lld.%lld%c", size / base, fraction, mag);
-+ } else {
-+ sprintf(str, "%lld%c", size / base, mag);
-+ }
- }
-
- static void cnt_str(char *str, long long cnt)
-@@ -491,13 +507,13 @@ static int run(void)
- printf("name \tbytes \txfers \titers \ttotal \ttime \tGb/sec \tusec/xfer\n");
- if (!custom) {
- for (i = 0; i < TEST_CNT; i++) {
-- if (test_size[i] > size_option)
-+ if (test_size[i].option > size_option)
- continue;
- init_latency_test(test_size[i].size);
- run_test(rs);
- }
- for (i = 0; i < TEST_CNT; i++) {
-- if (test_size[i] > size_option)
-+ if (test_size[i].option > size_option)
- continue;
- init_bandwidth_test(test_size[i].size);
- run_test(rs);
-@@ -574,7 +590,7 @@ int main(int argc, char **argv)
- transfer_count = atoi(optarg);
- break;
- case 'S':
-- if (strncasecmp("all", optarg, 3) {
-+ if (!strncasecmp("all", optarg, 3)) {
- size_option = 1;
- } else {
- custom = 1;
Bottom: 73ebe2ff1ff06d4ecc24c5fe35c8f54b8ad98f9f
-Top: 6143dc261a8c3107f32a4bd74443fd381b89d52e
+Top: 070f92a593aea528dcae7a68d42159b016d77109
Author: Sean Hefty <sean.hefty@intel.com>
Date: 2012-05-17 09:50:15 -0700
---
diff --git a/examples/rstream.c b/examples/rstream.c
-index ec9b4ff..3e6d8d5 100644
+index ec9b4ff..cb65911 100644
--- a/examples/rstream.c
+++ b/examples/rstream.c
@@ -45,11 +45,29 @@
+
+static struct test_size_param test_size[] = {
+ { 1 << 6, 0 },
-+ { 1 << 7, 1 }, { 1 << 7 + 1 << 6, 1},
-+ { 1 << 8, 1 }, { 1 << 8 + 1 << 7, 1},
-+ { 1 << 9, 1 }, { 1 << 9 + 1 << 8, 1},
-+ { 1 << 10, 1 }, { 1 << 10 + 1 << 9, 1},
-+ { 1 << 11, 1 }, { 1 << 11 + 1 << 10, 1},
-+ { 1 << 12, 0 }, { 1 << 12 + 1 << 11, 1},
-+ { 1 << 13, 1 }, { 1 << 13 + 1 << 12, 1},
-+ { 1 << 14, 1 }, { 1 << 14 + 1 << 13, 1},
-+ { 1 << 15, 1 }, { 1 << 15 + 1 << 14, 1},
-+ { 1 << 16, 0 }, { 1 << 16 + 1 << 15, 1},
-+ { 1 << 17, 1 }, { 1 << 17 + 1 << 16, 1},
-+ { 1 << 18, 1 }, { 1 << 18 + 1 << 17, 1},
-+ { 1 << 19, 1 }, { 1 << 19 + 1 << 18, 1},
-+ { 1 << 20, 0 }, { 1 << 20 + 1 << 19, 1},
-+ { 1 << 21, 1 }, { 1 << 21 + 1 << 20, 1},
-+ { 1 << 22, 1 }, { 1 << 22 + 1 << 21, 1},
++ { 1 << 7, 1 }, { (1 << 7) + (1 << 6), 1},
++ { 1 << 8, 1 }, { (1 << 8) + (1 << 7), 1},
++ { 1 << 9, 1 }, { (1 << 9) + (1 << 8), 1},
++ { 1 << 10, 1 }, { (1 << 10) + (1 << 9), 1},
++ { 1 << 11, 1 }, { (1 << 11) + (1 << 10), 1},
++ { 1 << 12, 0 }, { (1 << 12) + (1 << 11), 1},
++ { 1 << 13, 1 }, { (1 << 13) + (1 << 12), 1},
++ { 1 << 14, 1 }, { (1 << 14) + (1 << 13), 1},
++ { 1 << 15, 1 }, { (1 << 15) + (1 << 14), 1},
++ { 1 << 16, 0 }, { (1 << 16) + (1 << 15), 1},
++ { 1 << 17, 1 }, { (1 << 17) + (1 << 16), 1},
++ { 1 << 18, 1 }, { (1 << 18) + (1 << 17), 1},
++ { 1 << 19, 1 }, { (1 << 19) + (1 << 18), 1},
++ { 1 << 20, 0 }, { (1 << 20) + (1 << 19), 1},
++ { 1 << 21, 1 }, { (1 << 21) + (1 << 20), 1},
++ { 1 << 22, 1 }, { (1 << 22) + (1 << 21), 1},
};
#define TEST_CNT (sizeof test_size / sizeof test_size[0])
static int iterations = 1;
static int transfer_size = 1000;
static int transfer_count = 1000;
-@@ -457,7 +476,7 @@ static int run(void)
+@@ -87,14 +106,30 @@ static void *buf;
+
+ static void size_str(char *str, long long size)
+ {
+- if (size >= (1 << 30))
+- sprintf(str, "%lldg", size / (1 << 30));
+- else if (size >= (1 << 20))
+- sprintf(str, "%lldm", size / (1 << 20));
+- else if (size >= (1 << 10))
+- sprintf(str, "%lldk", size / (1 << 10));
+- else
+- sprintf(str, "%lld", size);
++ long long base, fraction = 0;
++ char mag;
++
++ if (size >= (1 << 30)) {
++ base = 1 << 30;
++ mag = 'g';
++ } else if (size >= (1 << 20)) {
++ base = 1 << 20;
++ mag = 'm';
++ } else if (size >= (1 << 10)) {
++ base = 1 << 10;
++ mag = 'k';
++ } else {
++ base = 1;
++ mag = '\0';
++ }
++
++ if (size / base < 10)
++ fraction = (size % base) * 10 / base;
++ if (fraction) {
++ sprintf(str, "%lld.%lld%c", size / base, fraction, mag);
++ } else {
++ sprintf(str, "%lld%c", size / base, mag);
++ }
+ }
+
+ static void cnt_str(char *str, long long cnt)
+@@ -457,7 +492,7 @@ static int run(void)
{
int i, rs, ret = 0;
if (!buf) {
perror("malloc");
return -1;
-@@ -472,11 +491,15 @@ static int run(void)
+@@ -472,11 +507,15 @@ static int run(void)
printf("name \tbytes \txfers \titers \ttotal \ttime \tGb/sec \tusec/xfer\n");
if (!custom) {
for (i = 0; i < TEST_CNT; i++) {
- init_latency_test(test_size[i]);
-+ if (test_size[i] > size_option)
++ if (test_size[i].option > size_option)
+ continue;
+ init_latency_test(test_size[i].size);
run_test(rs);
}
for (i = 0; i < TEST_CNT; i++) {
- init_bandwidth_test(test_size[i]);
-+ if (test_size[i] > size_option)
++ if (test_size[i].option > size_option)
+ continue;
+ init_bandwidth_test(test_size[i].size);
run_test(rs);
}
} else {
-@@ -551,8 +574,12 @@ int main(int argc, char **argv)
+@@ -551,8 +590,12 @@ int main(int argc, char **argv)
transfer_count = atoi(optarg);
break;
case 'S':
- custom = 1;
- transfer_size = atoi(optarg);
-+ if (strncasecmp("all", optarg, 3) {
++ if (!strncasecmp("all", optarg, 3)) {
+ size_option = 1;
+ } else {
+ custom = 1;
break;
case 'p':
port = optarg;
-@@ -567,7 +594,7 @@ int main(int argc, char **argv)
+@@ -567,7 +610,7 @@ int main(int argc, char **argv)
printf("\t[-b bind_address]\n");
printf("\t[-I iterations]\n");
printf("\t[-C transfer_count]\n");