DAOS-16286 client: intercept fdatasync() (#14835)

Signed-off-by: Lei Huang <lei.huang@intel.com>

src/client/dfuse/pil4dfs/int_dfs.c

@@ -399,6 +399,8 @@ static int (*next_unlinkat)(int dirfd, const char *path, int flags);
 
 static int (*next_fsync)(int fd);
 
+static int (*next_fdatasync)(int fd);
+
 static int (*next_truncate)(const char *path, off_t length);
 
 static int (*next_ftruncate)(int fd, off_t length);
@@ -5309,6 +5311,28 @@ fsync(int fd)
 	return 0;
 }
 
+int
+fdatasync(int fd)
+{
+	int fd_directed;
+
+	if (next_fdatasync == NULL) {
+		next_fdatasync = dlsym(RTLD_NEXT, "fdatasync");
+		D_ASSERT(next_fdatasync != NULL);
+	}
+	if (!d_hook_enabled)
+		return next_fdatasync(fd);
+
+	fd_directed = d_get_fd_redirected(fd);
+	if (fd_directed < FD_FILE_BASE)
+		return next_fdatasync(fd);
+
+	if (fd < FD_DIR_BASE && d_compatible_mode)
+		return next_fdatasync(fd);
+
+	return 0;
+}
+
 int
 ftruncate(int fd, off_t length)
 {

src/tests/suite/dfuse_test.c

@@ -101,6 +101,10 @@ do_openat(void **state)
 	rc = write(fd, input_buf, sizeof(input_buf));
 	assert_return_code(rc, errno);
 
+	/* test fdatasync() */
+	rc = fdatasync(fd);
+	assert_return_code(rc, errno);
+
 	/* First fstat.  IL will forward this to the kernel so it can save ino for future calls */
 	rc = fstat(fd, &stbuf0);
 	assert_return_code(rc, errno);