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))
149 static struct option long_options[] = {
157 unsigned long optval;
162 if (strcmp(argv[1],
"--help") == 0 || strcmp(argv[1],
"-?") == 0)
167 if (strcmp(argv[1],
"--version") == 0 || strcmp(argv[1],
"-V") == 0)
169 puts(
"pg_test_fsync (PostgreSQL) " PG_VERSION);
175 long_options, &optindex)) != -1)
185 optval = strtoul(
optarg, &endptr, 10);
187 if (endptr ==
optarg || *endptr !=
'\0' ||
188 errno != 0 || optval != (
unsigned int) optval)
190 pg_log_error(
"invalid argument for option %s",
"--secs-per-test");
197 pg_fatal(
"%s must be in range %u..%u",
198 "--secs-per-test", 1, UINT_MAX);
210 pg_log_error(
"too many command-line arguments (first is \"%s\")",
217 "%u seconds per test\n",
221 printf(
_(
"O_DIRECT supported on this platform for open_datasync and open_sync.\n"));
222#elif defined(F_NOCACHE)
223 printf(
_(
"F_NOCACHE supported on this platform for open_datasync and open_sync.\n"));
225 printf(
_(
"Direct I/O is not supported on this platform.\n"));
250 die(
"could not open output file");
257 if (
fsync(tmpfile) != 0)
272 fd = open(path, flags,
mode);
274#if !defined(O_DIRECT) && defined(F_NOCACHE)
275 if (
fd >= 0 && fcntl(
fd, F_NOCACHE, 1) < 0)
277 int save_errno = errno;
294 bool fs_warning =
false;
296 if (writes_per_op == 1)
300 printf(
_(
"(in \"wal_sync_method\" preference order, except fdatasync is Linux's default)\n"));
319 for (writes = 0; writes < writes_per_op; writes++)
323 writes * XLOG_BLCKSZ) != XLOG_BLCKSZ)
340 die(
"could not open output file");
344 for (writes = 0; writes < writes_per_op; writes++)
348 writes * XLOG_BLCKSZ) != XLOG_BLCKSZ)
362 die(
"could not open output file");
366 for (writes = 0; writes < writes_per_op; writes++)
370 writes * XLOG_BLCKSZ) != XLOG_BLCKSZ)
372 if (
fsync(tmpfile) != 0)
384#ifdef HAVE_FSYNC_WRITETHROUGH
386 die(
"could not open output file");
390 for (writes = 0; writes < writes_per_op; writes++)
394 writes * XLOG_BLCKSZ) != XLOG_BLCKSZ)
422 for (writes = 0; writes < writes_per_op; writes++)
426 writes * XLOG_BLCKSZ) != XLOG_BLCKSZ)
445 printf(
_(
"* This file system and its mount options do not support direct\n"
446 " I/O, e.g. ext4 in journaled mode.\n"));
453 printf(
_(
"\nCompare open_sync with different write sizes:\n"));
454 printf(
_(
"(This is designed to compare the cost of writing 16kB in different write\n"
455 "open_sync sizes.)\n"));
487 for (writes = 0; writes < 16 / writes_size; writes++)
491 writes * writes_size * 1024) !=
515 printf(
_(
"\nTest if fsync on non-write file descriptor is honored:\n"));
516 printf(
_(
"(If the times are similar, fsync() can sync data written on a different\n"
530 die(
"could not open output file");
531 if (
write(tmpfile,
buf, XLOG_BLCKSZ) != XLOG_BLCKSZ)
533 if (
fsync(tmpfile) != 0)
542 die(
"could not open output file");
558 die(
"could not open output file");
559 if (
write(tmpfile,
buf, XLOG_BLCKSZ) != XLOG_BLCKSZ)
564 die(
"could not open output file");
565 if (
fsync(tmpfile) != 0)
586 die(
"could not open output file");
590 if (
pg_pwrite(tmpfile,
buf, XLOG_BLCKSZ, 0) != XLOG_BLCKSZ)
611#ifdef HAVE_FSYNC_WRITETHROUGH
616#if defined(F_FULLFSYNC)
617 return (fcntl(
fd, F_FULLFSYNC, 0) == -1) ? -1 : 0;
631 double total_time = (
stop_t.tv_sec - start_t.tv_sec) +
632 (
stop_t.tv_usec - start_t.tv_usec) * 0.000001;
633 double per_second = ops / total_time;
634 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
static void const char fflush(stdout)
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)
pqsigfunc pqsignal(int signo, pqsigfunc func)
const char * get_progname(const char *argv0)
static int fd(const char *x, int i)