XDMA: dma_from/to_device: do NOT mark partial completion as failure. the bw is...

XDMA: dma_from/to_device: do NOT mark partial completion as failure. the bw is not calculated in the case of underflow (partial completion).

XDMA/linux-kernel/tools/dma_from_device.c

@@ -170,6 +170,7 @@ static int test_dma(char *devname, uint64_t addr, uint64_t aperture,
 	long total_time = 0;
 	float result;
 	float avg_time = 0;
+	int underflow = 0;
 
 	if (fpga_fd < 0) {
                 fprintf(stderr, "unable to open device %s, %d.\n",
@@ -210,29 +211,34 @@ static int test_dma(char *devname, uint64_t addr, uint64_t aperture,
 			char *buf = buffer;
 
 			for (j = 0; j < apt_loop; j++, len -= aperture, buf += aperture) {
-				/* lseek & read data from AXI MM into buffer using SGDMA */
+				uint64_t bytes = (len > aperture) ? aperture : len,
 				rc = read_to_buffer(devname, fpga_fd, buf,
-									(len > aperture) ? aperture : len,
-									addr);
+						bytes, addr);
 				if (rc < 0)
 					goto out;
+
+				if (!underflow && rc < bytes)
+					underflow = 1;
 			}
 		} else {
-			/* lseek & read data from AXI MM into buffer using SGDMA */
 			rc = read_to_buffer(devname, fpga_fd, buffer, size, addr);
 			if (rc < 0)
 				goto out;
+
+			if (!underflow && rc < size)
+				underflow = 1;
 		}
 		clock_gettime(CLOCK_MONOTONIC, &ts_end);
 
+
 		/* subtract the start time from the end time */
 		timespec_sub(&ts_end, &ts_start);
 		total_time += ts_end.tv_nsec;
 		/* a bit less accurate but side-effects are accounted for */
 		if (verbose)
 		fprintf(stdout,
-			"#%lu: CLOCK_MONOTONIC %ld.%09ld sec. read %ld bytes\n",
-			i, ts_end.tv_sec, ts_end.tv_nsec, size);
+			"#%lu: CLOCK_MONOTONIC %ld.%09ld sec. read %ld/%ld bytes\n",
+			i, ts_end.tv_sec, ts_end.tv_nsec, rc, size);
 
 		/* file argument given? */
 		if ((out_fd >= 0) & (no_write == 0)) {
@@ -242,14 +248,17 @@ static int test_dma(char *devname, uint64_t addr, uint64_t aperture,
 				goto out;
 		}
 	}
+
+	if (!underflow) {
 		avg_time = (float)total_time/(float)count;
 		result = ((float)size)*1000/avg_time;
 		if (verbose)
 			printf("** Avg time device %s, total time %ld nsec, avg_time = %f, size = %lu, BW = %f \n",
 				devname, total_time, avg_time, size, result);
-	printf("** Average BW = %lu, %f\n", size, result);
-	rc = 0;
+		printf("%s ** Average BW = %lu, %f\n", devname, size, result);
+	}
 
+	rc = 0;
 out:
 	close(fpga_fd);
 	if (out_fd >= 0)

XDMA/linux-kernel/tools/dma_to_device.c

@@ -183,6 +183,7 @@ static int test_dma(char *devname, uint64_t addr, uint64_t aperture,
 	long total_time = 0;
 	float result;
 	float avg_time = 0;
+	int underflow = 0;
 
 	if (fpga_fd < 0) {
 		fprintf(stderr, "unable to open device %s, %d.\n",
@@ -243,17 +244,23 @@ static int test_dma(char *devname, uint64_t addr, uint64_t aperture,
 
 			for (j = 0; j < apt_loop; j++, len -= aperture,
 					buf += aperture) {
+				uint64_t bytes = (len > aperture) ? aperture : len,
 				rc = write_from_buffer(devname, fpga_fd, buf,
-					(len > aperture) ? aperture : len,
-					addr);
+							bytes, addr);
 				if (rc < 0)
 					goto out;
+
+				if (!underflow && rc < bytes)
+					underflow = 1;
 			}
 		} else {
 			rc = write_from_buffer(devname, fpga_fd, buffer, size,
 				      	 	addr);
 			if (rc < 0)
 				goto out;
+
+			if (!underflow && rc < size)
+				underflow = 1;
 		}
 
 		rc = clock_gettime(CLOCK_MONOTONIC, &ts_end);
@@ -273,13 +280,15 @@ static int test_dma(char *devname, uint64_t addr, uint64_t aperture,
 				goto out;
 		}
 	}
+
+	if (!underflow) {
 		avg_time = (float)total_time/(float)count;
 		result = ((float)size)*1000/avg_time;
 		if (verbose)
 			printf("** Avg time device %s, total time %ld nsec, avg_time = %f, size = %lu, BW = %f \n",
 			devname, total_time, avg_time, size, result);
-
-	printf("** Average BW = %lu, %f\n",size, result);
+		printf("%s ** Average BW = %lu, %f\n", devname, size, result);
+	}
 	rc = 0;
 
 out:

XDMA/linux-kernel/tools/dma_utils.c

@@ -66,23 +66,28 @@ ssize_t read_to_buffer(char *fname, int fd, char *buffer, uint64_t size,
 
 		/* read data from file into memory buffer */
 		rc = read(fd, buf, bytes);
-		if (rc != bytes) {
-			fprintf(stderr, "%s, R off 0x%lx, 0x%lx != 0x%lx.\n",
-				fname, count, rc, bytes);
+		if (rc < 0) {
+			fprintf(stderr, "%s, read 0x%lx @ 0x%lx failed %d.\n",
+				fname, bytes, offset, rc);
 			perror("read file");
 			return -EIO;
 		}
 
-		count += bytes;
+		count += rc;
+		if (rc != bytes) {
+			fprintf(stderr, "%s, read underflow 0x%lx/0x%lx, off 0x%lx.\n",
+				fname, rc, bytes, offset);
+			break;
+		}
+
 		buf += bytes;
 		offset += bytes;
 	}	 
 
-	if (count != size) {
-		fprintf(stderr, "%s, R failed 0x%lx != 0x%lx.\n",
+	if (count != size)
+		fprintf(stderr, "%s, read underflow 0x%lx != 0x%lx.\n",
 			fname, count, size);
-		return -EIO;
-	}
+
 	return count;
 }
 
@@ -112,23 +117,27 @@ ssize_t write_from_buffer(char *fname, int fd, char *buffer, uint64_t size,
 
 		/* write data to file from memory buffer */
 		rc = write(fd, buf, bytes);
-		if (rc != bytes) {
-			fprintf(stderr, "%s, W off 0x%lx, 0x%lx != 0x%lx.\n",
-				fname, offset, rc, bytes);
+		if (rc < 0) {
+			fprintf(stderr, "%s, write 0x%lx @ 0x%lx failed %d.\n",
+				fname, bytes, offset, rc);
 			perror("write file");
 			return -EIO;
 		}
 
-		count += bytes;
+		count += rc;
+		if (rc != bytes) {
+			fprintf(stderr, "%s, write underflow 0x%lx/0x%lx, off 0x%lx.\n",
+				fname, rc, bytes, offset);
+			break;
+		}
 		buf += bytes;
 		offset += bytes;
 	}	 
 
-	if (count != size) {
-		fprintf(stderr, "%s, R failed 0x%lx != 0x%lx.\n",
+	if (count != size)
+		fprintf(stderr, "%s, write underflow 0x%lx != 0x%lx.\n",
 			fname, count, size);
-		return -EIO;
-	}
+
 	return count;
 }
 

XDMA/linux-kernel/xdma/version.h

@@ -22,7 +22,7 @@
 
 #define DRV_MOD_MAJOR		2020
 #define DRV_MOD_MINOR		1
-#define DRV_MOD_PATCHLEVEL	06
+#define DRV_MOD_PATCHLEVEL	07
 
 #define DRV_MODULE_VERSION      \
 	__stringify(DRV_MOD_MAJOR) "." \