From 9cd5909f5a88a01e646a76973875464ad94686ee Mon Sep 17 00:00:00 2001 From: jpekkila Date: Thu, 9 Apr 2020 20:28:04 +0300 Subject: [PATCH] BWtest calculates now aggregate bandwidths per process instead of assuming that all neighbor communication can be done in parallel (Within a node one can have parallel P2P connections to all neighbors and we have an insane total bandwidth, but this is not the case with network, we seem to have only one bidirectional socket) --- samples/bwtest/main.c | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/samples/bwtest/main.c b/samples/bwtest/main.c index fb9de90..ada1721 100644 --- a/samples/bwtest/main.c +++ b/samples/bwtest/main.c @@ -384,9 +384,9 @@ main(void) measurebw("Bidirectional bandwidth, twoway (Host)", // 2 * BLOCK_SIZE, sendrecv_twoway, src, dst); measurebw("Bidirectional bandwidth, async multiple (Host)", // - 2 * BLOCK_SIZE, sendrecv_nonblocking_multiple, src, dst); - measurebw("Bidirectional bandwidth, async multiple parallel (Host)", // - 2 * BLOCK_SIZE, sendrecv_nonblocking_multiple_parallel, src, dst); + 2 * (nprocs-1) * BLOCK_SIZE, sendrecv_nonblocking_multiple, src, dst); + //measurebw("Bidirectional bandwidth, async multiple parallel (Host)", // + // 2 * (nprocs-1) * BLOCK_SIZE, sendrecv_nonblocking_multiple_parallel, src, dst); freeHost(src); freeHost(dst); @@ -404,11 +404,11 @@ main(void) measurebw("Bidirectional bandwidth, twoway (Device)", // 2 * BLOCK_SIZE, sendrecv_twoway, src, dst); measurebw("Bidirectional bandwidth, async multiple (Device)", // - 2 * BLOCK_SIZE, sendrecv_nonblocking_multiple, src, dst); - measurebw("Bidirectional bandwidth, async multiple parallel (Device)", // - 2 * BLOCK_SIZE, sendrecv_nonblocking_multiple_parallel, src, dst); + 2 * (nprocs-1) *BLOCK_SIZE, sendrecv_nonblocking_multiple, src, dst); + //measurebw("Bidirectional bandwidth, async multiple parallel (Device)", // + // 2 * (nprocs-1) *BLOCK_SIZE, sendrecv_nonblocking_multiple_parallel, src, dst); measurebw("Bidirectional bandwidth, async multiple (Device, rt pinning)", // - 2 * BLOCK_SIZE, sendrecv_nonblocking_multiple_rt_pinning, src, dst); + 2 * (nprocs-1) *BLOCK_SIZE, sendrecv_nonblocking_multiple_rt_pinning, src, dst); freeDevice(src); freeDevice(dst); @@ -426,7 +426,7 @@ main(void) measurebw("Bidirectional bandwidth, twoway (Device, pinned)", // 2 * BLOCK_SIZE, sendrecv_twoway, src, dst); measurebw("Bidirectional bandwidth, async multiple (Device, pinned)", // - 2 * BLOCK_SIZE, sendrecv_nonblocking_multiple, src, dst); + 2 * (nprocs-1) *BLOCK_SIZE, sendrecv_nonblocking_multiple, src, dst); freeDevice(src); freeDevice(dst);