11/*
2- * $PostgreSQL: pgsql/src/tools/fsync/test_fsync.c,v 1.30 2010/07/06 19:19:02 momjian Exp $
2+ * $PostgreSQL: pgsql/src/tools/fsync/test_fsync.c,v 1.31 2010/07/13 17:00:50 momjian Exp $
33 *
44 *
55 * test_fsync.c
@@ -80,7 +80,8 @@ main(int argc, char *argv[])
8080 * Simple write
8181 */
8282 printf ("Simple write:\n" );
83- /* write only */
83+ printf (LABEL_FORMAT , "8k write" );
84+ fflush (stdout );
8485 gettimeofday (& start_t , NULL );
8586 for (i = 0 ; i < loops ; i ++ )
8687 {
@@ -91,7 +92,6 @@ main(int argc, char *argv[])
9192 close (tmpfile );
9293 }
9394 gettimeofday (& stop_t , NULL );
94- printf (LABEL_FORMAT , "8k write" );
9595 print_elapse (start_t , stop_t );
9696
9797 /*
@@ -100,7 +100,8 @@ main(int argc, char *argv[])
100100 printf ("\nCompare file sync methods using one write:\n" );
101101
102102#ifdef OPEN_DATASYNC_FLAG
103- /* open_dsync, write */
103+ printf (LABEL_FORMAT , "open_datasync 8k write" );
104+ fflush (stdout );
104105 if ((tmpfile = open (filename , O_RDWR | O_DSYNC , 0 )) == -1 )
105106 die ("Cannot open output file." );
106107 gettimeofday (& start_t , NULL );
@@ -113,14 +114,14 @@ main(int argc, char *argv[])
113114 }
114115 gettimeofday (& stop_t , NULL );
115116 close (tmpfile );
116- printf (LABEL_FORMAT , "open_datasync 8k write" );
117117 print_elapse (start_t , stop_t );
118118#else
119- printf ("\t(open_datasync unavailable)\n" );
119+ printf ("\t(unavailable: open_datasync )\n" );
120120#endif
121121
122122#ifdef OPEN_SYNC_FLAG
123- /* open_fsync, write */
123+ printf (LABEL_FORMAT , "open_sync 8k write" );
124+ fflush (stdout );
124125 if ((tmpfile = open (filename , O_RDWR | OPEN_SYNC_FLAG , 0 )) == -1 )
125126 die ("Cannot open output file." );
126127 gettimeofday (& start_t , NULL );
@@ -133,14 +134,14 @@ main(int argc, char *argv[])
133134 }
134135 gettimeofday (& stop_t , NULL );
135136 close (tmpfile );
136- printf (LABEL_FORMAT , "open_sync 8k write" );
137137 print_elapse (start_t , stop_t );
138138#else
139- printf ("\t(open_sync unavailable)\n" );
139+ printf ("\t(unavailable: open_sync )\n" );
140140#endif
141141
142142#ifdef HAVE_FDATASYNC
143- /* write, fdatasync */
143+ printf (LABEL_FORMAT , "8k write, fdatasync" );
144+ fflush (stdout );
144145 if ((tmpfile = open (filename , O_RDWR , 0 )) == -1 )
145146 die ("Cannot open output file." );
146147 gettimeofday (& start_t , NULL );
@@ -154,13 +155,13 @@ main(int argc, char *argv[])
154155 }
155156 gettimeofday (& stop_t , NULL );
156157 close (tmpfile );
157- printf (LABEL_FORMAT , "8k write, fdatasync" );
158158 print_elapse (start_t , stop_t );
159159#else
160- printf ("\t(fdatasync unavailable)\n" );
160+ printf ("\t(unavailable: fdatasync )\n" );
161161#endif
162162
163- /* write, fsync, close */
163+ printf (LABEL_FORMAT , "8k write, fsync" );
164+ fflush (stdout );
164165 if ((tmpfile = open (filename , O_RDWR , 0 )) == -1 )
165166 die ("Cannot open output file." );
166167 gettimeofday (& start_t , NULL );
@@ -175,7 +176,6 @@ main(int argc, char *argv[])
175176 }
176177 gettimeofday (& stop_t , NULL );
177178 close (tmpfile );
178- printf (LABEL_FORMAT , "8k write, fsync" );
179179 print_elapse (start_t , stop_t );
180180
181181 /*
@@ -184,7 +184,8 @@ main(int argc, char *argv[])
184184 printf ("\nCompare file sync methods using two writes:\n" );
185185
186186#ifdef OPEN_DATASYNC_FLAG
187- /* open_dsync, write */
187+ printf (LABEL_FORMAT , "2 open_datasync 8k writes" );
188+ fflush (stdout );
188189 if ((tmpfile = open (filename , O_RDWR | O_DSYNC , 0 )) == -1 )
189190 die ("Cannot open output file." );
190191 gettimeofday (& start_t , NULL );
@@ -199,14 +200,14 @@ main(int argc, char *argv[])
199200 }
200201 gettimeofday (& stop_t , NULL );
201202 close (tmpfile );
202- printf (LABEL_FORMAT , "2 open_datasync 8k writes" );
203203 print_elapse (start_t , stop_t );
204204#else
205- printf ("\t(open_datasync unavailable)\n" );
205+ printf ("\t(unavailable: open_datasync )\n" );
206206#endif
207207
208208#ifdef OPEN_SYNC_FLAG
209- /* open_fsync, write */
209+ printf (LABEL_FORMAT , "2 open_sync 8k writes" );
210+ fflush (stdout );
210211 if ((tmpfile = open (filename , O_RDWR | OPEN_SYNC_FLAG , 0 )) == -1 )
211212 die ("Cannot open output file." );
212213 gettimeofday (& start_t , NULL );
@@ -221,12 +222,12 @@ main(int argc, char *argv[])
221222 }
222223 gettimeofday (& stop_t , NULL );
223224 close (tmpfile );
224- printf (LABEL_FORMAT , "2 open_sync 8k writes" );
225225 print_elapse (start_t , stop_t );
226226#endif
227227
228228#ifdef HAVE_FDATASYNC
229- /* write, fdatasync */
229+ printf (LABEL_FORMAT , "8k write, 8k write, fdatasync" );
230+ fflush (stdout );
230231 if ((tmpfile = open (filename , O_RDWR , 0 )) == -1 )
231232 die ("Cannot open output file." );
232233 gettimeofday (& start_t , NULL );
@@ -242,13 +243,13 @@ main(int argc, char *argv[])
242243 }
243244 gettimeofday (& stop_t , NULL );
244245 close (tmpfile );
245- printf (LABEL_FORMAT , "8k write, 8k write, fdatasync" );
246246 print_elapse (start_t , stop_t );
247247#else
248- printf ("\t(fdatasync unavailable)\n" );
248+ printf ("\t(unavailable: fdatasync )\n" );
249249#endif
250250
251- /* write, fsync, close */
251+ printf (LABEL_FORMAT , "8k write, 8k write, fsync" );
252+ fflush (stdout );
252253 if ((tmpfile = open (filename , O_RDWR , 0 )) == -1 )
253254 die ("Cannot open output file." );
254255 gettimeofday (& start_t , NULL );
@@ -265,7 +266,6 @@ main(int argc, char *argv[])
265266 }
266267 gettimeofday (& stop_t , NULL );
267268 close (tmpfile );
268- printf (LABEL_FORMAT , "8k write, 8k write, fsync" );
269269 print_elapse (start_t , stop_t );
270270
271271 /*
@@ -274,7 +274,8 @@ main(int argc, char *argv[])
274274 printf ("\nCompare open_sync with different sizes:\n" );
275275
276276#ifdef OPEN_SYNC_FLAG
277- /* 16k open_sync write */
277+ printf (LABEL_FORMAT , "open_sync 16k write" );
278+ fflush (stdout );
278279 if ((tmpfile = open (filename , O_RDWR | OPEN_SYNC_FLAG , 0 )) == -1 )
279280 die ("Cannot open output file." );
280281 gettimeofday (& start_t , NULL );
@@ -287,10 +288,10 @@ main(int argc, char *argv[])
287288 }
288289 gettimeofday (& stop_t , NULL );
289290 close (tmpfile );
290- printf (LABEL_FORMAT , "open_sync 16k write" );
291291 print_elapse (start_t , stop_t );
292292
293- /* Two 8k open_sync writes */
293+ printf (LABEL_FORMAT , "2 open_sync 8k writes" );
294+ fflush (stdout );
294295 if ((tmpfile = open (filename , O_RDWR | OPEN_SYNC_FLAG , 0 )) == -1 )
295296 die ("Cannot open output file." );
296297 gettimeofday (& start_t , NULL );
@@ -305,10 +306,9 @@ main(int argc, char *argv[])
305306 }
306307 gettimeofday (& stop_t , NULL );
307308 close (tmpfile );
308- printf (LABEL_FORMAT , "2 open_sync 8k writes" );
309309 print_elapse (start_t , stop_t );
310310#else
311- printf ("\t(open_sync unavailable)\n" );
311+ printf ("\t(unavailable: open_sync )\n" );
312312#endif
313313
314314 /*
@@ -318,7 +318,8 @@ main(int argc, char *argv[])
318318 printf ("(If the times are similar, fsync() can sync data written\n" );
319319 printf ("on a different descriptor.)\n" );
320320
321- /* write, fsync, close */
321+ printf (LABEL_FORMAT , "8k write, fsync, close" );
322+ fflush (stdout );
322323 gettimeofday (& start_t , NULL );
323324 for (i = 0 ; i < loops ; i ++ )
324325 {
@@ -335,10 +336,10 @@ main(int argc, char *argv[])
335336 close (tmpfile );
336337 }
337338 gettimeofday (& stop_t , NULL );
338- printf (LABEL_FORMAT , "8k write, fsync, close" );
339339 print_elapse (start_t , stop_t );
340340
341- /* write, close, fsync */
341+ printf (LABEL_FORMAT , "8k write, close, fsync" );
342+ fflush (stdout );
342343 gettimeofday (& start_t , NULL );
343344 for (i = 0 ; i < loops ; i ++ )
344345 {
@@ -355,7 +356,6 @@ main(int argc, char *argv[])
355356 close (tmpfile );
356357 }
357358 gettimeofday (& stop_t , NULL );
358- printf (LABEL_FORMAT , "8k write, close, fsync" );
359359 print_elapse (start_t , stop_t );
360360
361361 /* cleanup */
0 commit comments