Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit46117e4

Browse files
committed
Have test_fsync honor -f filename argument.
1 parent698ee9c commit46117e4

File tree

1 file changed

+17
-17
lines changed

1 file changed

+17
-17
lines changed

‎src/tools/fsync/test_fsync.c

Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ main(int argc, char *argv[])
5858
for (i=0;i<WAL_FILE_SIZE;i++)
5959
strout[i]='a';
6060

61-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR |O_CREAT,S_IRUSR |S_IWUSR))==-1)
61+
if ((tmpfile=open(filename,O_RDWR |O_CREAT,S_IRUSR |S_IWUSR))==-1)
6262
die("can't open /var/tmp/test_fsync.out");
6363
write(tmpfile,strout,WAL_FILE_SIZE);
6464
fsync(tmpfile);/* fsync so later fsync's don't have to do it */
@@ -69,7 +69,7 @@ main(int argc, char *argv[])
6969
gettimeofday(&start_t,NULL);
7070
for (i=0;i<loops;i++)
7171
{
72-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR))==-1)
72+
if ((tmpfile=open(filename,O_RDWR))==-1)
7373
die("can't open /var/tmp/test_fsync.out");
7474
write(tmpfile,strout,8192);
7575
close(tmpfile);
@@ -86,12 +86,12 @@ main(int argc, char *argv[])
8686
gettimeofday(&start_t,NULL);
8787
for (i=0;i<loops;i++)
8888
{
89-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR))==-1)
89+
if ((tmpfile=open(filename,O_RDWR))==-1)
9090
die("can't open /var/tmp/test_fsync.out");
9191
write(tmpfile,strout,8192);
9292
fsync(tmpfile);
9393
close(tmpfile);
94-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR))==-1)
94+
if ((tmpfile=open(filename,O_RDWR))==-1)
9595
die("can't open /var/tmp/test_fsync.out");
9696
/* do nothing but the open/close the tests are consistent. */
9797
close(tmpfile);
@@ -105,12 +105,12 @@ main(int argc, char *argv[])
105105
gettimeofday(&start_t,NULL);
106106
for (i=0;i<loops;i++)
107107
{
108-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR))==-1)
108+
if ((tmpfile=open(filename,O_RDWR))==-1)
109109
die("can't open /var/tmp/test_fsync.out");
110110
write(tmpfile,strout,8192);
111111
close(tmpfile);
112112
/* reopen file */
113-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR))==-1)
113+
if ((tmpfile=open(filename,O_RDWR))==-1)
114114
die("can't open /var/tmp/test_fsync.out");
115115
fsync(tmpfile);
116116
close(tmpfile);
@@ -123,7 +123,7 @@ main(int argc, char *argv[])
123123
printf("\nCompare one o_sync write to two:\n");
124124

125125
/* 16k o_sync write */
126-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR |OPEN_SYNC_FLAG))==-1)
126+
if ((tmpfile=open(filename,O_RDWR |OPEN_SYNC_FLAG))==-1)
127127
die("can't open /var/tmp/test_fsync.out");
128128
gettimeofday(&start_t,NULL);
129129
for (i=0;i<loops;i++)
@@ -135,7 +135,7 @@ main(int argc, char *argv[])
135135
printf("\n");
136136

137137
/* 2*8k o_sync writes */
138-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR |OPEN_SYNC_FLAG))==-1)
138+
if ((tmpfile=open(filename,O_RDWR |OPEN_SYNC_FLAG))==-1)
139139
die("can't open /var/tmp/test_fsync.out");
140140
gettimeofday(&start_t,NULL);
141141
for (i=0;i<loops;i++)
@@ -153,7 +153,7 @@ main(int argc, char *argv[])
153153

154154
#ifdefOPEN_DATASYNC_FLAG
155155
/* open_dsync, write */
156-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR |O_DSYNC))==-1)
156+
if ((tmpfile=open(filename,O_RDWR |O_DSYNC))==-1)
157157
die("can't open /var/tmp/test_fsync.out");
158158
gettimeofday(&start_t,NULL);
159159
for (i=0;i<loops;i++)
@@ -168,7 +168,7 @@ main(int argc, char *argv[])
168168
printf("\n");
169169

170170
/* open_fsync, write */
171-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR |OPEN_SYNC_FLAG))==-1)
171+
if ((tmpfile=open(filename,O_RDWR |OPEN_SYNC_FLAG))==-1)
172172
die("can't open /var/tmp/test_fsync.out");
173173
gettimeofday(&start_t,NULL);
174174
for (i=0;i<loops;i++)
@@ -181,7 +181,7 @@ main(int argc, char *argv[])
181181

182182
#ifdefHAVE_FDATASYNC
183183
/* write, fdatasync */
184-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR))==-1)
184+
if ((tmpfile=open(filename,O_RDWR))==-1)
185185
die("can't open /var/tmp/test_fsync.out");
186186
gettimeofday(&start_t,NULL);
187187
for (i=0;i<loops;i++)
@@ -199,7 +199,7 @@ main(int argc, char *argv[])
199199
printf("\n");
200200

201201
/* write, fsync, close */
202-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR))==-1)
202+
if ((tmpfile=open(filename,O_RDWR))==-1)
203203
die("can't open /var/tmp/test_fsync.out");
204204
gettimeofday(&start_t,NULL);
205205
for (i=0;i<loops;i++)
@@ -217,7 +217,7 @@ main(int argc, char *argv[])
217217

218218
#ifdefOPEN_DATASYNC_FLAG
219219
/* open_dsync, write */
220-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR |O_DSYNC))==-1)
220+
if ((tmpfile=open(filename,O_RDWR |O_DSYNC))==-1)
221221
die("can't open /var/tmp/test_fsync.out");
222222
gettimeofday(&start_t,NULL);
223223
for (i=0;i<loops;i++)
@@ -235,7 +235,7 @@ main(int argc, char *argv[])
235235
printf("\n");
236236

237237
/* open_fsync, write */
238-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR |OPEN_SYNC_FLAG))==-1)
238+
if ((tmpfile=open(filename,O_RDWR |OPEN_SYNC_FLAG))==-1)
239239
die("can't open /var/tmp/test_fsync.out");
240240
gettimeofday(&start_t,NULL);
241241
for (i=0;i<loops;i++)
@@ -251,7 +251,7 @@ main(int argc, char *argv[])
251251

252252
#ifdefHAVE_FDATASYNC
253253
/* write, fdatasync */
254-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR))==-1)
254+
if ((tmpfile=open(filename,O_RDWR))==-1)
255255
die("can't open /var/tmp/test_fsync.out");
256256
gettimeofday(&start_t,NULL);
257257
for (i=0;i<loops;i++)
@@ -270,7 +270,7 @@ main(int argc, char *argv[])
270270
printf("\n");
271271

272272
/* write, fsync, close */
273-
if ((tmpfile=open(FSYNC_FILENAME,O_RDWR))==-1)
273+
if ((tmpfile=open(filename,O_RDWR))==-1)
274274
die("can't open /var/tmp/test_fsync.out");
275275
gettimeofday(&start_t,NULL);
276276
for (i=0;i<loops;i++)
@@ -285,7 +285,7 @@ main(int argc, char *argv[])
285285
print_elapse(start_t,elapse_t);
286286
printf("\n");
287287

288-
unlink(FSYNC_FILENAME);
288+
unlink(filename);
289289

290290
return0;
291291
}

0 commit comments

Comments
 (0)

[8]ページ先頭

©2009-2025 Movatter.jp