From 8b46154738f1ed78c00096bb757a8be800d8b244 Mon Sep 17 00:00:00 2001
From: Bruce Momjian <bruce@momjian.us>
Date: Mon, 21 Sep 2009 20:20:56 +0000
Subject: [PATCH] fsync test files

Prevent creation of 16GB files during fsync testing; only create 16MB
files;  backpatch to 8.4.X.
---
 src/tools/fsync/test_fsync.c | 26 ++++++++++++++++++++++++++
 1 file changed, 26 insertions(+)

diff --git a/src/tools/fsync/test_fsync.c b/src/tools/fsync/test_fsync.c
index 10fd9964c0..3c99682f5a 100644
--- a/src/tools/fsync/test_fsync.c
+++ b/src/tools/fsync/test_fsync.c
@@ -149,8 +149,12 @@ main(int argc, char *argv[])
 		die("Cannot open output file.");
 	gettimeofday(&start_t, NULL);
 	for (i = 0; i < loops; i++)
+	{
 		if (write(tmpfile, buf, WRITE_SIZE) != WRITE_SIZE)
 			die("write failed");
+		if (lseek(tmpfile, 0, SEEK_SET) == -1)
+			die("seek failed");
+	}
 	gettimeofday(&elapse_t, NULL);
 	close(tmpfile);
 	printf("\tone 16k o_sync write   ");
@@ -167,6 +171,8 @@ main(int argc, char *argv[])
 			die("write failed");
 		if (write(tmpfile, buf, WRITE_SIZE / 2) != WRITE_SIZE / 2)
 			die("write failed");
+		if (lseek(tmpfile, 0, SEEK_SET) == -1)
+			die("seek failed");
 	}
 	gettimeofday(&elapse_t, NULL);
 	close(tmpfile);
@@ -188,8 +194,12 @@ main(int argc, char *argv[])
 		die("Cannot open output file.");
 	gettimeofday(&start_t, NULL);
 	for (i = 0; i < loops; i++)
+	{
 		if (write(tmpfile, buf, WRITE_SIZE / 2) != WRITE_SIZE / 2)
 			die("write failed");
+		if (lseek(tmpfile, 0, SEEK_SET) == -1)
+			die("seek failed");
+	}
 	gettimeofday(&elapse_t, NULL);
 	close(tmpfile);
 	printf("\topen o_dsync, write    ");
@@ -205,8 +215,12 @@ main(int argc, char *argv[])
 		die("Cannot open output file.");
 	gettimeofday(&start_t, NULL);
 	for (i = 0; i < loops; i++)
+	{
 		if (write(tmpfile, buf, WRITE_SIZE / 2) != WRITE_SIZE / 2)
 			die("write failed");
+		if (lseek(tmpfile, 0, SEEK_SET) == -1)
+			die("seek failed");
+	}
 	gettimeofday(&elapse_t, NULL);
 	close(tmpfile);
 	printf("\topen o_sync, write     ");
@@ -226,6 +240,8 @@ main(int argc, char *argv[])
 		if (write(tmpfile, buf, WRITE_SIZE / 2) != WRITE_SIZE / 2)
 			die("write failed");
 		fdatasync(tmpfile);
+		if (lseek(tmpfile, 0, SEEK_SET) == -1)
+			die("seek failed");
 	}
 	gettimeofday(&elapse_t, NULL);
 	close(tmpfile);
@@ -246,6 +262,8 @@ main(int argc, char *argv[])
 			die("write failed");
 		if (fsync(tmpfile) != 0)
 			die("fsync failed");
+		if (lseek(tmpfile, 0, SEEK_SET) == -1)
+			die("seek failed");
 	}
 	gettimeofday(&elapse_t, NULL);
 	close(tmpfile);
@@ -269,6 +287,8 @@ main(int argc, char *argv[])
 			die("write failed");
 		if (write(tmpfile, buf, WRITE_SIZE / 2) != WRITE_SIZE / 2)
 			die("write failed");
+		if (lseek(tmpfile, 0, SEEK_SET) == -1)
+			die("seek failed");
 	}
 	gettimeofday(&elapse_t, NULL);
 	close(tmpfile);
@@ -290,6 +310,8 @@ main(int argc, char *argv[])
 			die("write failed");
 		if (write(tmpfile, buf, WRITE_SIZE / 2) != WRITE_SIZE / 2)
 			die("write failed");
+		if (lseek(tmpfile, 0, SEEK_SET) == -1)
+			die("seek failed");
 	}
 	gettimeofday(&elapse_t, NULL);
 	close(tmpfile);
@@ -310,6 +332,8 @@ main(int argc, char *argv[])
 		if (write(tmpfile, buf, WRITE_SIZE / 2) != WRITE_SIZE / 2)
 			die("write failed");
 		fdatasync(tmpfile);
+		if (lseek(tmpfile, 0, SEEK_SET) == -1)
+			die("seek failed");
 	}
 	gettimeofday(&elapse_t, NULL);
 	close(tmpfile);
@@ -332,6 +356,8 @@ main(int argc, char *argv[])
 			die("write failed");
 		if (fsync(tmpfile) != 0)
 			die("fsync failed");
+		if (lseek(tmpfile, 0, SEEK_SET) == -1)
+			die("seek failed");
 	}
 	gettimeofday(&elapse_t, NULL);
 	close(tmpfile);
-- 
2.39.5