Skip to content

P
Postgres FD Implementation
Commit b2906c5b authored by Bruce Momjian's avatar Bruce Momjian
Browse files
Options

Add fsync tests: 

	Compare fsync before and after write's close:
	Compare one o_sync write to two:
	Compare file sync methods with one 8k write:
	Compare file sync methods with 2 8k writes:
parent 5ddecd1e
Show whitespace changes
Inline Side-by-side
Showing with 144 additions and 49 deletions
src/tools/fsync/test_fsync.c
View file @ b2906c5b
...@@ -6,6 +6,7 @@ ...@@ -6,6 +6,7 @@
#include "../../include/pg_config.h" #include "../../include/pg_config.h"
#include <sys/types.h> #include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h> #include <fcntl.h>
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
...@@ -29,121 +30,214 @@ ...@@ -29,121 +30,214 @@
void die(char *str); void die(char *str);
void print_elapse(struct timeval start_t, struct timeval elapse_t); void print_elapse(struct timeval start_t, struct timeval elapse_t);
int main(int argc, char *argv[]) int
main(int argc, char *argv[])
{ {
struct timeval start_t; struct timeval start_t;
struct timeval elapse_t; struct timeval elapse_t;
int tmpfile; int tmpfile,
char *strout = "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"; i;
char *strout = (char *) malloc(65536);
for (i = 0; i < 65536; i++)
strout[i] = 'a';
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | O_CREAT, S_IRUSR | S_IWUSR)) == -1)
die("can't open /var/tmp/test_fsync.out");
write(tmpfile, strout, 65536);
fsync(tmpfile); /* fsync so later fsync's don't have to do
* it */
close(tmpfile);
printf("Simple write timing:\n"); printf("Simple write timing:\n");
/* write only */ /* write only */
gettimeofday(&start_t, NULL); gettimeofday(&start_t, NULL);
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | O_CREAT, 0600)) == -1) if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR)) == -1)
die("can't open /var/tmp/test_fsync.out"); die("can't open /var/tmp/test_fsync.out");
write(tmpfile, &strout, 200); write(tmpfile, strout, 8192);
close(tmpfile); close(tmpfile);
gettimeofday(&elapse_t, NULL); gettimeofday(&elapse_t, NULL);
unlink("/var/tmp/test_fsync.out"); printf("\twrite ");
printf("write ");
print_elapse(start_t, elapse_t); print_elapse(start_t, elapse_t);
printf("\n\n"); printf("\n\n");
printf("Compare fsync before and after write's close:\n"); printf("Compare fsync before and after write's close:\n");
/* write, fsync, close */ /* write, fsync, close */
gettimeofday(&start_t, NULL); gettimeofday(&start_t, NULL);
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | O_CREAT, 0600)) == -1) if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR)) == -1)
die("can't open /var/tmp/test_fsync.out"); die("can't open /var/tmp/test_fsync.out");
write(tmpfile, &strout, 200); write(tmpfile, strout, 8192);
fsync(tmpfile); fsync(tmpfile);
close(tmpfile); close(tmpfile);
gettimeofday(&elapse_t, NULL); gettimeofday(&elapse_t, NULL);
unlink("/var/tmp/test_fsync.out"); printf("\twrite, fsync, close ");
printf("write, fsync, close ");
print_elapse(start_t, elapse_t); print_elapse(start_t, elapse_t);
printf("\n"); printf("\n");
/* write, close, fsync */ /* write, close, fsync */
gettimeofday(&start_t, NULL); gettimeofday(&start_t, NULL);
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | O_CREAT, 0600)) == -1) if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR)) == -1)
die("can't open /var/tmp/test_fsync.out"); die("can't open /var/tmp/test_fsync.out");
write(tmpfile, &strout, 200); write(tmpfile, strout, 8192);
close(tmpfile); close(tmpfile);
/* reopen file */ /* reopen file */
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | O_CREAT, 0600)) == -1) if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR)) == -1)
die("can't open /var/tmp/test_fsync.out"); die("can't open /var/tmp/test_fsync.out");
fsync(tmpfile); fsync(tmpfile);
close(tmpfile); close(tmpfile);
gettimeofday(&elapse_t, NULL); gettimeofday(&elapse_t, NULL);
unlink("/var/tmp/test_fsync.out"); printf("\twrite, close, fsync ");
printf("write, close, fsync "); print_elapse(start_t, elapse_t);
printf("\n");
printf("\nCompare one o_sync write to two:\n");
/* 16k o_sync write */
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | OPEN_SYNC_FLAG)) == -1)
die("can't open /var/tmp/test_fsync.out");
gettimeofday(&start_t, NULL);
write(tmpfile, strout, 16384);
gettimeofday(&elapse_t, NULL);
close(tmpfile);
printf("\tone 16k o_sync write ");
print_elapse(start_t, elapse_t);
printf("\n");
/* 2*8k o_sync writes */
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | OPEN_SYNC_FLAG)) == -1)
die("can't open /var/tmp/test_fsync.out");
gettimeofday(&start_t, NULL);
write(tmpfile, strout, 8192);
write(tmpfile, strout, 8192);
gettimeofday(&elapse_t, NULL);
close(tmpfile);
printf("\ttwo 8k o_sync writes ");
print_elapse(start_t, elapse_t); print_elapse(start_t, elapse_t);
printf("\n"); printf("\n");
printf("\nTest file sync methods:\n"); printf("\nCompare file sync methods with one 8k write:\n");
#ifdef OPEN_DATASYNC_FLAG #ifdef OPEN_DATASYNC_FLAG
/* open_dsync, write */ /* open_dsync, write */
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | O_DSYNC)) == -1)
die("can't open /var/tmp/test_fsync.out");
gettimeofday(&start_t, NULL); gettimeofday(&start_t, NULL);
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | O_CREAT | O_DSYNC, 0600)) == -1) write(tmpfile, strout, 8192);
gettimeofday(&elapse_t, NULL);
close(tmpfile);
printf("\topen o_dsync, write ");
print_elapse(start_t, elapse_t);
#else
printf("\t(o_dsync unavailable) ");
#endif
printf("\n");
/* open_fsync, write */
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | OPEN_SYNC_FLAG)) == -1)
die("can't open /var/tmp/test_fsync.out"); die("can't open /var/tmp/test_fsync.out");
write(tmpfile, &strout, 200); gettimeofday(&start_t, NULL);
write(tmpfile, strout, 8192);
gettimeofday(&elapse_t, NULL);
close(tmpfile); close(tmpfile);
printf("\topen o_sync, write ");
print_elapse(start_t, elapse_t);
printf("\n");
#ifdef HAVE_FDATASYNC
/* write, fdatasync */
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR)) == -1)
die("can't open /var/tmp/test_fsync.out");
gettimeofday(&start_t, NULL);
write(tmpfile, strout, 8192);
fdatasync(tmpfile);
gettimeofday(&elapse_t, NULL); gettimeofday(&elapse_t, NULL);
unlink("/var/tmp/test_fsync.out"); close(tmpfile);
printf("open o_dsync, write "); printf("\twrite, fdatasync ");
print_elapse(start_t, elapse_t); print_elapse(start_t, elapse_t);
#else #else
printf("o_dsync unavailable "); printf("\t(fdatasync unavailable)");
#endif #endif
printf("\n"); printf("\n");
/* open_fsync, write */ /* write, fsync, close */
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR)) == -1)
die("can't open /var/tmp/test_fsync.out");
gettimeofday(&start_t, NULL); gettimeofday(&start_t, NULL);
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | O_CREAT | OPEN_SYNC_FLAG, 0600)) == -1) write(tmpfile, strout, 8192);
fsync(tmpfile);
gettimeofday(&elapse_t, NULL);
close(tmpfile);
printf("\twrite, fsync, ");
print_elapse(start_t, elapse_t);
printf("\n");
printf("\nCompare file sync methods with 2 8k writes:\n");
#ifdef OPEN_DATASYNC_FLAG
/* open_dsync, write */
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | O_DSYNC)) == -1)
die("can't open /var/tmp/test_fsync.out"); die("can't open /var/tmp/test_fsync.out");
write(tmpfile, &strout, 200); gettimeofday(&start_t, NULL);
write(tmpfile, strout, 8192);
write(tmpfile, strout, 8192);
gettimeofday(&elapse_t, NULL);
close(tmpfile); close(tmpfile);
printf("\topen o_dsync, write ");
print_elapse(start_t, elapse_t);
#else
printf("\t(o_dsync unavailable) ");
#endif
printf("\n");
/* open_fsync, write */
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | OPEN_SYNC_FLAG)) == -1)
die("can't open /var/tmp/test_fsync.out");
gettimeofday(&start_t, NULL);
write(tmpfile, strout, 8192);
write(tmpfile, strout, 8192);
gettimeofday(&elapse_t, NULL); gettimeofday(&elapse_t, NULL);
unlink("/var/tmp/test_fsync.out"); close(tmpfile);
printf("open o_fsync, write "); printf("\topen o_sync, write ");
print_elapse(start_t, elapse_t); print_elapse(start_t, elapse_t);
printf("\n"); printf("\n");
#ifdef HAVE_FDATASYNC #ifdef HAVE_FDATASYNC
/* write, fdatasync */ /* write, fdatasync */
gettimeofday(&start_t, NULL); if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR)) == -1)
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | O_CREAT, 0600)) == -1)
die("can't open /var/tmp/test_fsync.out"); die("can't open /var/tmp/test_fsync.out");
write(tmpfile, &strout, 200); gettimeofday(&start_t, NULL);
write(tmpfile, strout, 8192);
write(tmpfile, strout, 8192);
fdatasync(tmpfile); fdatasync(tmpfile);
close(tmpfile);
gettimeofday(&elapse_t, NULL); gettimeofday(&elapse_t, NULL);
unlink("/var/tmp/test_fsync.out"); close(tmpfile);
printf("write, fdatasync "); printf("\twrite, fdatasync ");
print_elapse(start_t, elapse_t); print_elapse(start_t, elapse_t);
#else #else
printf("fdatasync unavailable "); printf("\t(fdatasync unavailable)");
#endif #endif
printf("\n"); printf("\n");
/* write, fsync, close */ /* write, fsync, close */
gettimeofday(&start_t, NULL); if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR)) == -1)
if ((tmpfile = open("/var/tmp/test_fsync.out", O_RDWR | O_CREAT, 0600)) == -1)
die("can't open /var/tmp/test_fsync.out"); die("can't open /var/tmp/test_fsync.out");
write(tmpfile, &strout, 200); gettimeofday(&start_t, NULL);
write(tmpfile, strout, 8192);
write(tmpfile, strout, 8192);
fsync(tmpfile); fsync(tmpfile);
close(tmpfile);
gettimeofday(&elapse_t, NULL); gettimeofday(&elapse_t, NULL);
unlink("/var/tmp/test_fsync.out"); close(tmpfile);
printf("write, fsync, "); printf("\twrite, fsync, ");
print_elapse(start_t, elapse_t); print_elapse(start_t, elapse_t);
printf("\n"); printf("\n");
unlink("/var/tmp/test_fsync.out");
return 0; return 0;
} }
void print_elapse(struct timeval start_t, struct timeval elapse_t) void
print_elapse(struct timeval start_t, struct timeval elapse_t)
{ {
if (elapse_t.tv_usec < start_t.tv_usec) if (elapse_t.tv_usec < start_t.tv_usec)
{ {
...@@ -155,7 +249,8 @@ void print_elapse(struct timeval start_t, struct timeval elapse_t) ...@@ -155,7 +249,8 @@ void print_elapse(struct timeval start_t, struct timeval elapse_t)
(long) (elapse_t.tv_usec - start_t.tv_usec)); (long) (elapse_t.tv_usec - start_t.tv_usec));
} }
void die(char *str) void
die(char *str)
{ {
fprintf(stderr, "%s", str); fprintf(stderr, "%s", str);
exit(1); exit(1);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment