From 5118d0eeb284d442fb96379b977c2837e9a06e8e Mon Sep 17 00:00:00 2001
From: Dustin Richmond <drichmond@eng.ucsd.edu>
Date: Tue, 9 Feb 2016 10:06:31 -0800
Subject: [PATCH] Adding the applications we use to test before release

---
 c_c++/linux/x64/test_apps/Makefile         |  27 ++
 c_c++/linux/x64/test_apps/testutil.c       | 509 +++++++++++++++++++++
 c_c++/linux/x64/test_apps/testutil.c_multi | 160 +++++++
 c_c++/linux/x64/test_apps/testutil.sh      |  22 +
 c_c++/linux/x64/test_apps/timer.h          |   8 +
 5 files changed, 726 insertions(+)
 create mode 100644 c_c++/linux/x64/test_apps/Makefile
 create mode 100644 c_c++/linux/x64/test_apps/testutil.c
 create mode 100644 c_c++/linux/x64/test_apps/testutil.c_multi
 create mode 100755 c_c++/linux/x64/test_apps/testutil.sh
 create mode 100644 c_c++/linux/x64/test_apps/timer.h

diff --git a/c_c++/linux/x64/test_apps/Makefile b/c_c++/linux/x64/test_apps/Makefile
new file mode 100644
index 0000000..c326bcf
--- /dev/null
+++ b/c_c++/linux/x64/test_apps/Makefile
@@ -0,0 +1,27 @@
+program_NAME := testutil
+program_C_SRCS := $(wildcard *.c)
+program_CXX_SRCS := $(wildcard *.cpp)
+program_C_OBJS := ${program_C_SRCS:.c=.o}
+program_CXX_OBJS := ${program_CXX_SRCS:.cpp=.o}
+program_OBJS := $(program_C_OBJS) $(program_CXX_OBJS)
+program_INCLUDE_DIRS :=
+program_LIBRARY_DIRS :=
+program_LIBRARIES := riffa
+CPPFLAGS += -g
+
+CPPFLAGS += $(foreach includedir,$(program_INCLUDE_DIRS),-I$(includedir))
+LDFLAGS += $(foreach librarydir,$(program_LIBRARY_DIRS),-L$(librarydir))
+LDFLAGS += $(foreach library,$(program_LIBRARIES),-l$(library))
+
+.PHONY: all clean distclean
+
+all: $(program_NAME)
+
+$(program_NAME): $(program_OBJS)
+	$(CC) $(CPPFLAGS) $(program_OBJS) -o $(program_NAME) $(LDFLAGS)
+
+clean:
+	@- $(RM) $(program_NAME)
+	@- $(RM) $(program_OBJS)
+
+distclean: clean
diff --git a/c_c++/linux/x64/test_apps/testutil.c b/c_c++/linux/x64/test_apps/testutil.c
new file mode 100644
index 0000000..9f347a7
--- /dev/null
+++ b/c_c++/linux/x64/test_apps/testutil.c
@@ -0,0 +1,509 @@
+#include <stdlib.h>
+#include <stdio.h>
+#include "timer.h"
+#include "riffa.h"
+#define NUM_TESTS 100
+
+int main(int argc, char** argv) {
+	fpga_t * fpga;
+	fpga_info_list info;
+	int option;
+	int i;
+	int id;
+	int chnl;
+	size_t numWords;
+	int sent;
+	int recvd;
+	int failure = 0;
+	unsigned int * sendBuffer;
+	unsigned int * recvBuffer;
+	int err;
+	GET_TIME_INIT(3);
+
+	if (argc < 2) {
+		printf("Usage: %s <option>\n", argv[0]);
+		return -1;
+	}
+
+	option = atoi(argv[1]);
+
+	if (option == 0) {
+		// List FPGA info
+		// Populate the fpga_info_list struct
+		if (fpga_list(&info) != 0) {
+			printf("Error populating fpga_info_list\n");
+			return -1;
+		}
+		printf("Number of devices: %d\n", info.num_fpgas);
+		for (i = 0; i < info.num_fpgas; i++) {
+			printf("%d: id:%d\n", i, info.id[i]);
+			printf("%d: num_chnls:%d\n", i, info.num_chnls[i]);
+			printf("%d: name:%s\n", i, info.name[i]);
+			printf("%d: vendor id:%04X\n", i, info.vendor_id[i]);
+			printf("%d: device id:%04X\n", i, info.device_id[i]);
+		}
+	}
+	else if (option == 1) { // Reset FPGA
+		if (argc < 3) {
+			printf("Usage: %s %d <fpga id>\n", argv[0], option);
+			return -1;
+		}
+
+		id = atoi(argv[2]);
+
+		// Get the device with id
+		fpga = fpga_open(id);
+		if (fpga == NULL) {
+			printf("Could not get FPGA %d\n", id);
+			return -1;
+		}
+
+		// Reset
+		fpga_reset(fpga);
+
+		// Done with device
+		fpga_close(fpga);
+	}
+	else if (option == 2) { // Send data, receive data
+		if (argc < 5) {
+			printf("Usage: %s %d <fpga id> <chnl> <num words to transfer>\n", argv[0], option);
+			return -1;
+		}
+
+		size_t maxWords, minWords;
+		id = atoi(argv[2]);
+		chnl = atoi(argv[3]);
+		minWords = 4; // Must be at least 4 for the channel tester app
+		maxWords = atoi(argv[4]);
+		printf("Running bandwidth test from %zu up to %zu words\n", minWords, maxWords);
+
+		// Get the device with id
+		fpga = fpga_open(id);
+		if (fpga == NULL) {
+			printf("Could not get FPGA %d\n", id);
+			return -1;
+		}
+
+		// Malloc the arrays
+		sendBuffer = (unsigned int *)malloc(maxWords*4);
+		if (sendBuffer == NULL) {
+			printf("Could not malloc memory for sendBuffer\n");
+			fpga_close(fpga);
+			return -1;
+		}
+		recvBuffer = (unsigned int *)malloc(maxWords*4 + 4);
+		recvBuffer +=1;
+		if (recvBuffer == NULL) {
+			printf("Could not malloc memory for recvBuffer\n");
+			free(sendBuffer);
+			fpga_close(fpga);
+			return -1;
+		}
+
+		int numWords;
+		for (numWords = minWords; numWords <= maxWords; numWords = numWords*2) {
+			int j;
+			for (j = 0; j < NUM_TESTS + 1; ++j) {
+				// Initialize the data
+				for (i = 0; i < numWords; i++) {
+					sendBuffer[i] = i+1;
+					recvBuffer[i] = 0;
+				}
+
+				GET_TIME_VAL(0);
+
+				// Send the data
+				sent = fpga_send(fpga, chnl, sendBuffer, numWords, 0, 1, 25000);
+				printf("Test %d: words sent: %d\n", j, sent);
+
+				GET_TIME_VAL(1);
+
+				if (sent != 0) {
+					// Recv the data
+					recvd = fpga_recv(fpga, chnl, recvBuffer, numWords, 25000);
+					printf("Test %d: words recv: %d\n", j, recvd);
+				}
+
+				GET_TIME_VAL(2);
+
+				// Check the data
+				if (recvd != 0) {
+					for (i = 4; i < recvd; i++) {
+						if (recvBuffer[i] != sendBuffer[i]) {
+							printf("recvBuffer[%d]: %d, expected %d\n", i, recvBuffer[i], sendBuffer[i]);
+							return;
+						}
+					}
+
+					if (j > 0)
+						printf("send bw: %f\n",
+							sent*4.0/1000/1000/((TIME_VAL_TO_MS(1) - TIME_VAL_TO_MS(0))/1000.0)); //,
+
+					if (j > 0)
+						printf("recv bw: %f\n",
+							recvd*4.0/1000/1000/((TIME_VAL_TO_MS(2) - TIME_VAL_TO_MS(1))/1000.0)); //,
+				}
+			}
+		}
+		// Done with device
+	        fpga_close(fpga);
+	}
+	else if (option == 3) { // Send data, receive data
+		if (argc < 5) {
+			printf("Usage: %s %d <fpga id> <chnl> <num words to transfer>\n", argv[0], option);
+			return -1;
+		}
+
+		size_t maxWords, minWords;
+		id = atoi(argv[2]);
+		chnl = atoi(argv[3]);
+		minWords = 4; // Must be at least 4 for the channel tester app
+		maxWords = atoi(argv[4]);
+		printf("Running receive offset test from %zu up to %zu words\n", minWords, maxWords);
+
+		// Get the device with id
+		fpga = fpga_open(id);
+		if (fpga == NULL) {
+			printf("Could not get FPGA %d\n", id);
+			return -1;
+		}
+
+		// Malloc the arrays (page aligned) 
+		printf("Asked for %zu bytes\n",((maxWords*sizeof(unsigned int)*2 + 4096)/4096)*4096 + 4096);
+		err = posix_memalign((void **)&sendBuffer, 4096, ((maxWords*sizeof(unsigned int)*2 + 4096)/4096)*4096 + 4096);
+		if (sendBuffer == NULL) {
+			printf("Could not malloc memory for sendBuffer\n");
+			fpga_close(fpga);
+			return -1;
+		}
+		err = posix_memalign((void **)&recvBuffer, 4096, ((maxWords*sizeof(unsigned int)*2 + 4096)/4096)*4096 + 4096);
+
+		recvBuffer = (unsigned int *)malloc(((maxWords*sizeof(unsigned int)*2 + 4096)/4096)*4096 + 4096);
+		if (recvBuffer == NULL) {
+			printf("Could not malloc memory for recvBuffer\n");
+			free(sendBuffer);
+			fpga_close(fpga);
+			return -1;
+		}
+
+		int numWords;
+		for (numWords = minWords; numWords <= maxWords; numWords = numWords*2) {
+			int j;
+			for (j = 0; j < 4096/sizeof(unsigned int); j++) {
+				int rxOffset = j;
+				// Initialize the data
+				for (i = 0; i < numWords; i++) {
+					sendBuffer[i+ rxOffset] = i+1;
+					recvBuffer[i] = 0;
+				}
+
+				GET_TIME_VAL(0);
+
+				// Send the data
+				sent = fpga_send(fpga, chnl, &sendBuffer[rxOffset], numWords, 0, 1, 25000);
+				printf("Test %d: words sent from address %p: %d\n", j, &sendBuffer[rxOffset], sent);
+
+				GET_TIME_VAL(1);
+
+				if (sent != 0) {
+					// Recv the data
+					recvd = fpga_recv(fpga, chnl, recvBuffer, numWords, 25000);
+					printf("Test %d: words recv: %d\n", j, recvd);
+				}
+
+				GET_TIME_VAL(2);
+
+				// Check the data
+				if (recvd != 0) {
+					for (i = 4; i < recvd; i++) {
+						if (recvBuffer[i] != sendBuffer[i + rxOffset]) {
+							printf("recvBuffer[%d]: %d, expected %d\n", i, recvBuffer[i], sendBuffer[i + rxOffset]);
+							failure = 1;
+						}
+					}
+
+
+					if (j > 0)
+						printf("send bw: %f\n",
+							sent*4.0/1000/1000/((TIME_VAL_TO_MS(1) - TIME_VAL_TO_MS(0))/1000.0)); //,
+
+					if (j > 0)
+						printf("recv bw: %f\n",
+							recvd*4.0/1000/1000/((TIME_VAL_TO_MS(2) - TIME_VAL_TO_MS(1))/1000.0)); //,
+					if(failure) 
+						return;
+				}
+			}
+		}
+		// Done with device
+	        fpga_close(fpga);
+	}	
+	else if (option == 4) { // Send data, receive data
+		if (argc < 5) {
+			printf("Usage: %s %d <fpga id> <chnl> <num words to transfer>\n", argv[0], option);
+			return -1;
+		}
+
+		size_t maxWords, minWords;
+		id = atoi(argv[2]);
+		chnl = atoi(argv[3]);
+		minWords = 4; // Must be at least 4 for the channel tester app
+		maxWords = atoi(argv[4]);
+		printf("Running tx offset test from %zu up to %zu words\n", minWords, maxWords);
+
+		// Get the device with id
+		fpga = fpga_open(id);
+		if (fpga == NULL) {
+			printf("Could not get FPGA %d\n", id);
+			return -1;
+		}
+
+		// Malloc the arrays (page aligned) 
+		printf("Asked for %zu bytes\n",((maxWords*sizeof(unsigned int)*2 + 4096)/4096)*4096 + 4096);
+
+		err = posix_memalign((void **)&sendBuffer, 4096, ((maxWords*sizeof(unsigned int)*2 + 4096)/4096)*4096 + 4096);
+		if (err) {
+			printf("Could not malloc memory for sendBuffer\n");
+			fpga_close(fpga);
+			return -1;
+		}
+		err = posix_memalign((void **)&recvBuffer, 4096, ((maxWords*sizeof(unsigned int)*2 + 4096)/4096)*4096 + 4096);
+
+		if (err) {
+			printf("Could not malloc memory for recvBuffer\n");
+			free(sendBuffer);
+			fpga_close(fpga);
+			return -1;
+		}
+
+		int numWords;
+		for (numWords = minWords; numWords <= maxWords; numWords = numWords*2) {
+			int j;
+			for (j = 0; j < 4096/sizeof(unsigned int); ++j) {
+				int txOffset = j;
+				// Initialize the data
+				for (i = 0; i < numWords; i++) {
+					sendBuffer[i] = i+1;
+					recvBuffer[i + txOffset] = 0;
+				}
+
+				GET_TIME_VAL(0);
+
+				// Send the data
+				sent = fpga_send(fpga, chnl, sendBuffer, numWords, 0, 1, 25000);
+				printf("Test %d: words sent: %d (Address %p) \n", j, sent, sendBuffer);
+
+				GET_TIME_VAL(1);
+
+				if (sent != 0) {
+					// Recv the data
+					recvd = fpga_recv(fpga, chnl, &recvBuffer[txOffset], numWords, 25000);
+					printf("Test %d: words recv: %d (Address %p) \n", j, recvd, &recvBuffer[txOffset]);
+				}
+
+				GET_TIME_VAL(2);
+
+				// Check the data
+				if (recvd != 0) {
+					for (i = 4; i < recvd; i++) {
+						if (recvBuffer[i + txOffset] != sendBuffer[i]) {
+							printf("recvBuffer[%d]: %d, expected %d\n", i, recvBuffer[i + txOffset], sendBuffer[i]);
+							failure = 1;
+						}
+					}
+
+					if (j > 0)
+						printf("send bw: %f\n",
+							sent*4.0/1000/1000/((TIME_VAL_TO_MS(1) - TIME_VAL_TO_MS(0))/1000.0)); //,
+
+					if (j > 0)
+						printf("recv bw: %f\n",
+							recvd*4.0/1000/1000/((TIME_VAL_TO_MS(2) - TIME_VAL_TO_MS(1))/1000.0)); //,
+					if(failure) 
+						return;
+
+				}
+			}
+		}
+		// Done with device
+	        fpga_close(fpga);
+	}
+	else if (option == 5) { // Send data, receive data
+		if (argc < 7) {
+			printf("Usage: %s %d <fpga id> <chnl> <offset> <num words to transfer> <number of iterations>\n", argv[0], option);
+			return -1;
+		}
+		size_t offset;
+		size_t numWords;
+		unsigned int numIter;
+		id = atoi(argv[2]);
+		chnl = atoi(argv[3]);
+		offset = atoi(argv[4]) % (4096 / sizeof(unsigned int));
+		if(numWords < 4) {
+			printf("Must transfer at least 4 words %d\n", id);
+			return -1;
+		}
+		numWords = atoi(argv[5]);
+		numIter = atoi(argv[6]);
+		printf("Running single test with %zu words, from host-page offset %zu \n", numWords, offset);
+
+		// Get the device with id
+		fpga = fpga_open(id);
+		if (fpga == NULL) {
+			printf("Could not get FPGA %d\n", id);
+			return -1;
+		}
+
+		// Malloc the arrays (page aligned) 
+		printf("Asked for %zu bytes\n",((numWords*sizeof(unsigned int) + 4096)/4096)*4096 + 4096);
+		err = posix_memalign((void **)&sendBuffer, 4096, ((numWords*sizeof(unsigned int)*2 + 4096)/4096)*4096 + 4096);
+		if (err) {
+			printf("Could not malloc memory for sendBuffer\n");
+			fpga_close(fpga);
+			return -1;
+		}
+
+		err = posix_memalign((void **)&recvBuffer, 4096, ((numWords*sizeof(unsigned int)*2 + 4096)/4096)*4096 + 4096);
+		if (err) {
+			printf("Could not malloc memory for recvBuffer\n");
+			free(sendBuffer);
+			fpga_close(fpga);
+			return -1;
+		}
+
+		int j;
+		for (j = 0; j < numIter; ++j) {
+			for (i = 0; i < numWords; i++) {
+				sendBuffer[i + offset] = i+1;
+				recvBuffer[i] = 0;
+			}
+
+			GET_TIME_VAL(0);
+
+			// Send the data
+			sent = fpga_send(fpga, chnl, &sendBuffer[offset], numWords, 0, 1, 25000);
+			printf("words sent: %d\n", sent);
+
+			GET_TIME_VAL(1);
+
+			if (sent != 0) {
+				// Recv the data
+				recvd = fpga_recv(fpga, chnl, recvBuffer, numWords, 25000);
+				printf("words recv: %d\n", recvd);
+			}
+
+			GET_TIME_VAL(2);
+
+			// Check the data
+			if (recvd != 0) {
+				for (i = 4; i < recvd; i++) {
+					if (recvBuffer[i] != sendBuffer[i + offset]) {
+						printf("recvBuffer[%d]: %d, expected %d\n", i, recvBuffer[i], sendBuffer[i + offset]);
+						failure = 1;
+					}
+				}
+
+				printf("send bw: %f\n",
+					sent*4.0/1000/1000/((TIME_VAL_TO_MS(1) - TIME_VAL_TO_MS(0))/1000.0)); //,
+
+				printf("recv bw: %f\n",
+					recvd*4.0/1000/1000/((TIME_VAL_TO_MS(2) - TIME_VAL_TO_MS(1))/1000.0)); //,
+				if(failure) 
+					return;
+
+			}
+		}
+		// Done with device
+	        fpga_close(fpga);
+	}
+	else if (option == 6) { // Send data, receive data
+		if (argc < 7) {
+			printf("Usage: %s %d <fpga id> <chnl> <offset> <num words to transfer> <number of iterations>\n", argv[0], option);
+			return -1;
+		}
+		size_t offset;
+		size_t numWords;
+		unsigned int numIter;
+
+		id = atoi(argv[2]);
+		chnl = atoi(argv[3]);
+		offset = atoi(argv[4]) % (4096 / sizeof(unsigned int));
+		if(numWords < 4) {
+			printf("Must transfer at least 4 words %d\n", id);
+			return -1;
+		}
+		numWords = atoi(argv[5]);
+		numIter = atoi(argv[6]);
+		printf("Running single test with %zu words, to host-page offset %zu \n", numWords, offset);
+
+		// Get the device with id
+		fpga = fpga_open(id);
+		if (fpga == NULL) {
+			printf("Could not get FPGA %d\n", id);
+			return -1;
+		}
+
+		// Malloc the arrays (page aligned) 
+		printf("Asked for %zu bytes\n",((numWords*sizeof(unsigned int) + 4096)/4096)*4096 + 4096);
+		err = posix_memalign((void **)&sendBuffer, 4096, ((numWords*sizeof(unsigned int)*2 + 4096)/4096)*4096 + 4096);
+		if (err) {
+			printf("Could not malloc memory for sendBuffer\n");
+			fpga_close(fpga);
+			return -1;
+		}
+
+		err = posix_memalign((void **)&recvBuffer, 4096, ((numWords*sizeof(unsigned int)*2 + 4096)/4096)*4096 + 4096);
+		if (err) {
+			printf("Could not malloc memory for recvBuffer\n");
+			free(sendBuffer);
+			fpga_close(fpga);
+			return -1;
+		}
+
+		int j;
+		for (j = 0; j < numIter; ++j) {
+			for (i = 0; i < numWords; i++) {
+				sendBuffer[i] = i+1;
+				recvBuffer[i + offset] = 0;
+			}
+
+			GET_TIME_VAL(0);
+
+			// Send the data
+			sent = fpga_send(fpga, chnl, sendBuffer, numWords, 0, 1, 25000);
+			printf("test %d: words sent: %d\n", j, sent);
+
+			GET_TIME_VAL(1);
+
+			if (sent != 0) {
+				// Recv the data
+				recvd = fpga_recv(fpga, chnl, &recvBuffer[offset], numWords, 25000);
+				printf("test %d: words recv: %d (Address %p %p)\n", j, recvd, &recvBuffer[offset], &recvBuffer[offset+numWords]);
+			}
+
+			GET_TIME_VAL(2);
+
+			// Check the data
+			if (recvd != 0) {
+				for (i = 4; i < recvd; i++) {
+					if (recvBuffer[i + offset] != sendBuffer[i]) {
+						printf("recvBuffer[%d]: %d, expected %d\n", i, recvBuffer[i + offset], sendBuffer[i]);
+						failure = 1;
+					}
+				}
+
+				printf("send bw: %f\n",
+					sent*4.0/1000/1000/((TIME_VAL_TO_MS(1) - TIME_VAL_TO_MS(0))/1000.0)); //,
+
+				printf("recv bw: %f\n",
+					recvd*4.0/1000/1000/((TIME_VAL_TO_MS(2) - TIME_VAL_TO_MS(1))/1000.0)); //,
+				if(failure) 
+					return;
+
+			}
+		}
+		// Done with device
+	        fpga_close(fpga);
+	}
+	return 0;
+}
diff --git a/c_c++/linux/x64/test_apps/testutil.c_multi b/c_c++/linux/x64/test_apps/testutil.c_multi
new file mode 100644
index 0000000..190d7d8
--- /dev/null
+++ b/c_c++/linux/x64/test_apps/testutil.c_multi
@@ -0,0 +1,160 @@
+#include <stdlib.h>
+#include <stdio.h>
+#include "timer.h"
+#include "riffa.h"
+
+int main(int argc, char** argv) {
+	fpga_t * fpga;
+	fpga_info_list info;
+	int option;
+	int i;
+	int id;
+	int chnl;
+	size_t numWords;
+	int sent;
+	int recvd;
+	unsigned int * sendBuffer;
+	unsigned int * recvBuffer;
+	GET_TIME_INIT(3);
+
+	if (argc < 2) {
+		printf("Usage: %s <option>\n", argv[0]);
+		return -1;
+	}
+
+	option = atoi(argv[1]);
+
+	if (option == 0) {	// List FPGA info
+		// Populate the fpga_info_list struct
+		if (fpga_list(&info) != 0) {
+			printf("Error populating fpga_info_list\n");
+			return -1;
+		}
+		printf("Number of devices: %d\n", info.num_fpgas);
+		for (i = 0; i < info.num_fpgas; i++) {
+			printf("%d: id:%d\n", i, info.id[i]);
+			printf("%d: num_chnls:%d\n", i, info.num_chnls[i]);
+			printf("%d: name:%s\n", i, info.name[i]);
+			printf("%d: vendor id:%04X\n", i, info.vendor_id[i]);
+			printf("%d: device id:%04X\n", i, info.device_id[i]);
+		}
+	}
+	else if (option == 1) { // Reset FPGA
+		if (argc < 3) {
+			printf("Usage: %s %d <fpga id>\n", argv[0], option);
+			return -1;
+		}
+
+		id = atoi(argv[2]);
+
+		// Get the device with id
+		fpga = fpga_open(id);
+		if (fpga == NULL) {
+			printf("Could not get FPGA %d\n", id);
+			return -1;
+	    }
+
+		// Reset
+		fpga_reset(fpga);
+
+		// Done with device
+        fpga_close(fpga);
+	}
+	else if (option == 2) { // Send data, receive data
+		if (argc < 5) {
+			printf("Usage: %s %d <fpga id> <chnl> <num words to transfer>\n", argv[0], option);
+			return -1;
+		}
+
+		size_t maxWords;
+		id = atoi(argv[2]);
+		chnl = atoi(argv[3]);
+		maxWords = atoi(argv[4]);
+
+		// Get the device with id
+		fpga = fpga_open(id);
+		if (fpga == NULL) {
+			printf("Could not get FPGA %d\n", id);
+			return -1;
+	    }
+
+		// Malloc the arrays
+//		sendBuffer = (unsigned int *)malloc(2147483648l);
+		sendBuffer = (unsigned int *)malloc(maxWords*4);
+		if (sendBuffer == NULL) {
+			printf("Could not malloc memory for sendBuffer\n");
+			fpga_close(fpga);
+			return -1;
+	    }
+		recvBuffer = (unsigned int *)malloc(maxWords*4);
+		if (recvBuffer == NULL) {
+			printf("Could not malloc memory for recvBuffer\n");
+			free(sendBuffer);
+			fpga_close(fpga);
+			return -1;
+	    }
+
+
+		int numWords;
+		for (numWords = 256; numWords <= maxWords; numWords = numWords*2) {
+		
+
+		int j;
+		for (j = 0; j < 101; ++j) {
+		// Initialize the data
+		for (i = 0; i < numWords; i++) {
+			sendBuffer[i] = i+1;
+			recvBuffer[i] = 0;
+		}
+
+		GET_TIME_VAL(0);
+
+		// Send the data
+		sent = fpga_send(fpga, chnl, sendBuffer, numWords, 0, 1, 25000);
+		printf("words sent: %d\n", sent);
+
+		GET_TIME_VAL(1);
+
+		if (sent != 0) {
+			// Recv the data
+			recvd = fpga_recv(fpga, chnl, recvBuffer, numWords, 25000);
+			printf("words recv: %d\n", recvd);
+		}
+
+		GET_TIME_VAL(2);
+
+		// Display some data
+//		for (i = 0; i < 20; i++) {
+//			printf("recvBuffer[%d]: %d\n", i, recvBuffer[i]);
+//		}
+
+		// Check the data
+		if (recvd != 0) {
+			for (i = 4; i < recvd; i++) {
+				if (recvBuffer[i] != sendBuffer[i]) {
+					printf("recvBuffer[%d]: %d, expected %d\n", i, recvBuffer[i], sendBuffer[i]);
+					return;
+				}
+			}
+
+			if (j > 0)
+			printf("send bw: %f\n",
+				sent*4.0/1000/1000/((TIME_VAL_TO_MS(1) - TIME_VAL_TO_MS(0))/1000.0)); //,
+//				(TIME_VAL_TO_MS(1) - TIME_VAL_TO_MS(0)) );
+
+			if (j > 0)
+			printf("recv bw: %f\n",
+				recvd*4.0/1000/1000/((TIME_VAL_TO_MS(2) - TIME_VAL_TO_MS(1))/1000.0)); //,
+//				(TIME_VAL_TO_MS(2) - TIME_VAL_TO_MS(1)) );
+		}
+		}
+		}
+
+		// Done with device
+	        fpga_close(fpga);
+
+
+	}
+
+	return 0;
+}
diff --git a/c_c++/linux/x64/test_apps/testutil.sh b/c_c++/linux/x64/test_apps/testutil.sh
new file mode 100755
index 0000000..2c27985
--- /dev/null
+++ b/c_c++/linux/x64/test_apps/testutil.sh
@@ -0,0 +1,22 @@
+#!/bin/bash
+
+PATH=$PATH:~/Research/repositories/git/riffa/c_c++/linux/x64/test_apps/
+RESULT_PATH=~/results 
+
+if [ "$#" -lt 2 ]; then 
+    echo "usage: $0 <fpga id> <board name>"
+    exit
+fi
+
+
+# Run full bandwidth test
+testutil 2 $1 0 536970912 | tee $RESULT_PATH/$2_bw.txt
+
+# Run RX Sweep Test
+testutil 3 $1 0 2048 | tee $RESULT_PATH/$2_rx.txt
+
+# Run TX Sweep Test
+testutil 4 $1 0 2048 | tee $RESULT_PATH/$2_tx.txt
+
+
+
diff --git a/c_c++/linux/x64/test_apps/timer.h b/c_c++/linux/x64/test_apps/timer.h
new file mode 100644
index 0000000..623ad66
--- /dev/null
+++ b/c_c++/linux/x64/test_apps/timer.h
@@ -0,0 +1,8 @@
+#include <sys/time.h>
+
+#define GET_TIME_INIT(num) struct timeval _timers[num]
+
+#define GET_TIME_VAL(num) gettimeofday(&_timers[num], NULL)
+
+#define TIME_VAL_TO_MS(num) (((double)_timers[num].tv_sec*1000.0) + ((double)_timers[num].tv_usec/1000.0))
+