30#define FSYNC_FILENAME "./pg_test_fsync.out"
32#define XLOG_BLCKSZ_K (XLOG_BLCKSZ / 1024)
34#define LABEL_FORMAT " %-30s"
35#define NA_FORMAT "%21s\n"
37#define OPS_FORMAT gettext_noop("%13.3f ops/sec %6.0f usecs/op\n")
38#define USECS_SEC 1000000
44 alarm_triggered = false; \
45 alarm(secs_per_test); \
46 gettimeofday(&start_t, NULL); \
52 alarm_triggered = false; \
53 if (CreateThread(NULL, 0, process_alarm, NULL, 0, NULL) == \
54 INVALID_HANDLE_VALUE) \
55 pg_fatal("could not create thread for alarm"); \
56 gettimeofday(&start_t, NULL); \
62 gettimeofday(&stop_t, NULL); \
63 print_elapse(start_t, stop_t, ops); \
74static struct timeval start_t,
95#ifdef HAVE_FSYNC_WRITETHROUGH
100#define die(msg) pg_fatal("%s: %m", _(msg))
148 static struct option long_options[] = {
156 unsigned long optval;
161 if (strcmp(argv[1],
"--help") == 0 || strcmp(argv[1],
"-?") == 0)
166 if (strcmp(argv[1],
"--version") == 0 || strcmp(argv[1],
"-V") == 0)
168 puts(
"pg_test_fsync (PostgreSQL) " PG_VERSION);
174 long_options, &optindex)) != -1)
184 optval = strtoul(
optarg, &endptr, 10);
186 if (endptr ==
optarg || *endptr !=
'\0' ||
187 errno != 0 || optval != (
unsigned int) optval)
189 pg_log_error(
"invalid argument for option %s",
"--secs-per-test");
196 pg_fatal(
"%s must be in range %u..%u",
197 "--secs-per-test", 1, UINT_MAX);
209 pg_log_error(
"too many command-line arguments (first is \"%s\")",
216 "%u seconds per test\n",
220 printf(
_(
"O_DIRECT supported on this platform for open_datasync and open_sync.\n"));
221#elif defined(F_NOCACHE)
222 printf(
_(
"F_NOCACHE supported on this platform for open_datasync and open_sync.\n"));
224 printf(
_(
"Direct I/O is not supported on this platform.\n"));
249 die(
"could not open output file");
256 if (
fsync(tmpfile) != 0)
271 fd = open(path, flags,
mode);
273#if !defined(O_DIRECT) && defined(F_NOCACHE)
274 if (
fd >= 0 && fcntl(
fd, F_NOCACHE, 1) < 0)
276 int save_errno = errno;
293 bool fs_warning =
false;
295 if (writes_per_op == 1)
299 printf(
_(
"(in \"wal_sync_method\" preference order, except fdatasync is Linux's default)\n"));
318 for (writes = 0; writes < writes_per_op; writes++)
322 writes * XLOG_BLCKSZ) != XLOG_BLCKSZ)
339 die(
"could not open output file");
343 for (writes = 0; writes < writes_per_op; writes++)
347 writes * XLOG_BLCKSZ) != XLOG_BLCKSZ)
361 die(
"could not open output file");
365 for (writes = 0; writes < writes_per_op; writes++)
369 writes * XLOG_BLCKSZ) != XLOG_BLCKSZ)
371 if (
fsync(tmpfile) != 0)
383#ifdef HAVE_FSYNC_WRITETHROUGH
385 die(
"could not open output file");
389 for (writes = 0; writes < writes_per_op; writes++)
393 writes * XLOG_BLCKSZ) != XLOG_BLCKSZ)
421 for (writes = 0; writes < writes_per_op; writes++)
425 writes * XLOG_BLCKSZ) != XLOG_BLCKSZ)
444 printf(
_(
"* This file system and its mount options do not support direct\n"
445 " I/O, e.g. ext4 in journaled mode.\n"));
452 printf(
_(
"\nCompare open_sync with different write sizes:\n"));
453 printf(
_(
"(This is designed to compare the cost of writing 16kB in different write\n"
454 "open_sync sizes.)\n"));
486 for (writes = 0; writes < 16 / writes_size; writes++)
490 writes * writes_size * 1024) !=
514 printf(
_(
"\nTest if fsync on non-write file descriptor is honored:\n"));
515 printf(
_(
"(If the times are similar, fsync() can sync data written on a different\n"
529 die(
"could not open output file");
530 if (
write(tmpfile,
buf, XLOG_BLCKSZ) != XLOG_BLCKSZ)
532 if (
fsync(tmpfile) != 0)
541 die(
"could not open output file");
557 die(
"could not open output file");
558 if (
write(tmpfile,
buf, XLOG_BLCKSZ) != XLOG_BLCKSZ)
563 die(
"could not open output file");
564 if (
fsync(tmpfile) != 0)
585 die(
"could not open output file");
589 if (
pg_pwrite(tmpfile,
buf, XLOG_BLCKSZ, 0) != XLOG_BLCKSZ)
610#ifdef HAVE_FSYNC_WRITETHROUGH
615#if defined(F_FULLFSYNC)
616 return (fcntl(
fd, F_FULLFSYNC, 0) == -1) ? -1 : 0;
630 double total_time = (
stop_t.tv_sec - start_t.tv_sec) +
631 (
stop_t.tv_usec - start_t.tv_usec) * 0.000001;
632 double per_second = ops / total_time;
633 double avg_op_time_us = (total_time / ops) *
USECS_SEC;
#define TYPEALIGN(ALIGNVAL, LEN)
#define ngettext(s, p, n)
#define PG_TEXTDOMAIN(domain)
int fdatasync(int fildes)
void set_pglocale_pgservice(const char *argv0, const char *app)
int pg_fsync_writethrough(int fd)
char * pg_strdup(const char *in)
int getopt_long(int argc, char *const argv[], const char *optstring, const struct option *longopts, int *longindex)
#define required_argument
void pg_logging_init(const char *argv0)
#define pg_log_error(...)
#define pg_log_error_hint(...)
static PgChecksumMode mode
#define DEFAULT_XLOG_SEG_SIZE
PGDLLIMPORT char * optarg
int32 pg_prng_int32(pg_prng_state *state)
void pg_prng_seed(pg_prng_state *state, uint64 seed)
pg_prng_state pg_global_prng_state
static void test_file_descriptor_sync(void)
int main(int argc, char *argv[])
static char full_buf[DEFAULT_XLOG_SEG_SIZE]
static void prepare_buf(void)
static void print_elapse(struct timeval start_t, struct timeval stop_t, int ops)
static void test_open_syncs(void)
static void handle_args(int argc, char *argv[])
static int open_direct(const char *path, int flags, mode_t mode)
static void test_sync(int writes_per_op)
static void test_open(void)
static void test_non_sync(void)
static struct timeval start_t stop_t
static void test_open_sync(const char *msg, int writes_size)
static const char * progname
static void process_alarm(SIGNAL_ARGS)
static sig_atomic_t alarm_triggered
static unsigned int secs_per_test
static void signal_cleanup(SIGNAL_ARGS)
const char * get_progname(const char *argv0)
static int fd(const char *x, int i)