@@ -1790,15 +1790,16 @@ afsync_f(int opno, long r)
struct iocb iocb;
struct iocb *iocbs[] = { &iocb };
struct io_event event;
+ DIR *dir;
init_pathname(&f);
- if (!get_fname(FT_REGFILE, r, &f, NULL, NULL, &v)) {
+ if (!get_fname(FT_REGFILE | FT_DIRm, r, &f, NULL, NULL, &v)) {
if (v)
printf("%d/%d: afsync - no filename\n", procid, opno);
free_pathname(&f);
return;
}
- fd = open_path(&f, O_WRONLY | O_DIRECT);
+ fd = open_file_or_dir(&f, O_WRONLY | O_DIRECT, &dir);
e = fd < 0 ? errno : 0;
check_cwd();
if (fd < 0) {
@@ -1815,7 +1816,7 @@ afsync_f(int opno, long r)
printf("%d/%d: afsync - io_submit %s %d\n",
procid, opno, f.path, e);
free_pathname(&f);
- close(fd);
+ close_file_or_dir(fd, dir);
return;
}
if ((e = io_getevents(io_ctx, 1, 1, &event, NULL)) != 1) {
@@ -1823,7 +1824,7 @@ afsync_f(int opno, long r)
printf("%d/%d: afsync - io_getevents failed %d\n",
procid, opno, e);
free_pathname(&f);
- close(fd);
+ close_file_or_dir(fd, dir);
return;
}
@@ -1831,7 +1832,7 @@ afsync_f(int opno, long r)
if (v)
printf("%d/%d: afsync %s %d\n", procid, opno, f.path, e);
free_pathname(&f);
- close(fd);
+ close_file_or_dir(fd, dir);
#endif
}